Quickstart: Telegram Bot

import { Telegraf } from 'telegraf';

const bot = new Telegraf(process.env.BOT_TOKEN!);

// Handle /analyze command
bot.command('analyze', async (ctx) => {
  const symbol = ctx.message.text.split(' ')[1] || 'BTC';
  const userId = ctx.from.id.toString();
  
  try {
    const result = await executeCommand('analyze', {
      args: { q: symbol },
      userId,
    });
    
    if (result.requiresPayment) {
      await ctx.reply(result.message, {
        reply_markup: {
          inline_keyboard: [
            [{
              text: 'Approve Payment',
              web_app: { url: result.paymentUrl }
            }]
          ]
        }
      });
    } else {
      await ctx.reply(`Analysis for ${symbol}:\n${JSON.stringify(result.result, null, 2)}`);
    }
  } catch (error) {
    await ctx.reply('Error processing command');
  }
});

bot.launch();

async function executeCommand(command: string, data: any) {
  const idempotencyKey = crypto.randomUUID();
  
  let response = await fetch(
    `https://x402tele.app/api/v1/bots/${BOT_ID}/commands/${command}`,
    {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'Authorization': `Bearer ${API_KEY}`,
        'Idempotency-Key': idempotencyKey,
      },
      body: JSON.stringify({
        args: data.args,
        user_id: `tg:${data.userId}`,
      }),
    }
  );

  if (response.status === 402) {
    const price = response.headers.get('X-402-Price');
    const currency = response.headers.get('X-402-Currency');
    const nonce = response.headers.get('X-402-Nonce');
    
    return {
      requiresPayment: true,
      paymentUrl: `https://x402tele.app/pay?nonce=${nonce}`,
      message: `This command costs ${price} ${currency}. Tap to approve.`,
    };
  }

  const result = await response.json();
  return {
    requiresPayment: false,
    result: result.result,
    receipt: result.receipt,
  };
}