trading_bot_v4/lib/notifications/telegram.ts

/**
 * Telegram notification utilities
 * 
 * Sends direct notifications to Telegram bot without requiring n8n
 */

interface TelegramNotificationOptions {
  symbol: string
  direction: 'long' | 'short'
  entryPrice: number
  exitPrice: number
  positionSize: number
  realizedPnL: number
  exitReason: string
  holdTimeSeconds: number
  maxDrawdown?: number
  maxGain?: number
}

interface TelegramWithdrawalOptions {
  type: 'withdrawal'
  amount: number
  signature: string
  availableProfit: number
  totalWithdrawn: number
}

type TelegramOptions = TelegramNotificationOptions | TelegramWithdrawalOptions

/**
 * Send Telegram notification for position closure
 */
export async function sendPositionClosedNotification(options: TelegramNotificationOptions): Promise<void> {
  try {
    const token = process.env.TELEGRAM_BOT_TOKEN
    const chatId = process.env.TELEGRAM_CHAT_ID

    if (!token || !chatId) {
      console.log('⚠️ Telegram credentials not configured, skipping notification')
      return
    }

    const profitEmoji = options.realizedPnL >= 0 ? '💚' : '🔴'
    const exitReasonEmoji = getExitReasonEmoji(options.exitReason)
    const directionEmoji = options.direction === 'long' ? '📈' : '📉'
    
    const priceChange = ((options.exitPrice - options.entryPrice) / options.entryPrice * 100) * (options.direction === 'long' ? 1 : -1)
    const holdTime = formatHoldTime(options.holdTimeSeconds)

    const message = `${exitReasonEmoji} POSITION CLOSED

${directionEmoji} ${options.symbol} ${options.direction.toUpperCase()}

💰 P&L: $${options.realizedPnL.toFixed(2)} (${priceChange >= 0 ? '+' : ''}${priceChange.toFixed(2)}%)
📊 Size: $${options.positionSize.toFixed(2)}

📍 Entry: $${options.entryPrice.toFixed(2)}
🎯 Exit: $${options.exitPrice.toFixed(2)}

⏱ Hold Time: ${holdTime}
🔚 Exit: ${options.exitReason.toUpperCase()}
${options.maxGain ? `\n📈 Max Gain: +${options.maxGain.toFixed(2)}%` : ''}
${options.maxDrawdown ? `\n📉 Max Drawdown: -${options.maxDrawdown.toFixed(2)}%` : ''}`

    const url = `https://api.telegram.org/bot${token}/sendMessage`
    const response = await fetch(url, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        chat_id: chatId,
        text: message,
        parse_mode: 'HTML'
      })
    })

    if (!response.ok) {
      const errorData = await response.json()
      console.error('❌ Telegram notification failed:', errorData)
    } else {
      console.log('✅ Telegram notification sent')
    }
  } catch (error) {
    console.error('❌ Error sending Telegram notification:', error)
    // Don't throw - notification failure shouldn't break position closing
  }
}

/**
 * Get emoji for exit reason
 */
function getExitReasonEmoji(reason: string): string {
  const reasonUpper = reason.toUpperCase()
  
  if (reasonUpper.includes('TP1')) return '🎯'
  if (reasonUpper.includes('TP2')) return '🎯🎯'
  if (reasonUpper.includes('SL') || reasonUpper.includes('STOP')) return '🛑'
  if (reasonUpper.includes('MANUAL')) return '👤'
  if (reasonUpper.includes('EMERGENCY')) return '🚨'
  if (reasonUpper.includes('GHOST')) return '👻'
  
  return '✅'
}

/**
 * Format hold time in human-readable format
 */
function formatHoldTime(seconds: number): string {
  const hours = Math.floor(seconds / 3600)
  const minutes = Math.floor((seconds % 3600) / 60)
  const secs = seconds % 60

  if (hours > 0) {
    return `${hours}h ${minutes}m`
  } else if (minutes > 0) {
    return `${minutes}m ${secs}s`
  } else {
    return `${secs}s`
  }
}

/**
 * Send Telegram notification (supports both position closures and withdrawals)
 */
export async function sendTelegramNotification(options: TelegramOptions): Promise<void> {
  if ('type' in options && options.type === 'withdrawal') {
    return sendWithdrawalNotification(options)
  }
  return sendPositionClosedNotification(options as TelegramNotificationOptions)
}

/**
 * Send withdrawal notification
 */
async function sendWithdrawalNotification(options: TelegramWithdrawalOptions): Promise<void> {
  try {
    const token = process.env.TELEGRAM_BOT_TOKEN
    const chatId = process.env.TELEGRAM_CHAT_ID

    if (!token || !chatId) {
      console.log('⚠️ Telegram credentials not configured, skipping notification')
      return
    }

    const message = `💸 PROFIT WITHDRAWAL

💰 Amount: $${options.amount.toFixed(2)} USDC

📊 Available Profit: $${options.availableProfit.toFixed(2)}
📈 Total Withdrawn: $${options.totalWithdrawn.toFixed(2)}

🔗 Transaction: <a href="https://solscan.io/tx/${options.signature}">${options.signature.substring(0, 8)}...</a>

✅ Funds sent to your wallet`

    const url = `https://api.telegram.org/bot${token}/sendMessage`
    const response = await fetch(url, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        chat_id: chatId,
        text: message,
        parse_mode: 'HTML'
      })
    })

    if (!response.ok) {
      const errorData = await response.json()
      console.error('❌ Telegram notification failed:', errorData)
    } else {
      console.log('✅ Telegram withdrawal notification sent')
    }
  } catch (error) {
    console.error('❌ Error sending Telegram notification:', error)
  }
}