Code-MCP

import { Bot, Context, session, SessionFlavor } from 'grammy'; import { run } from '@grammyjs/runner'; // ============================================ // Types // ============================================ interface SessionData { step: 'idle' | 'waiting_for_name'; counter: number; } type MyContext = Context & SessionFlavor<SessionData>; // ============================================ // Setup // ============================================ const token = process.env.TELEGRAM_BOT_TOKEN; if (!token) throw new Error('TELEGRAM_BOT_TOKEN is missing'); const bot = new Bot<MyContext>(token); // ============================================ // Middleware // ============================================ // Session middleware bot.use(session({ initial: (): SessionData => ({ step: 'idle', counter: 0 }), })); // Logging middleware bot.use(async (ctx, next) => { const start = Date.now(); await next(); const ms = Date.now() - start; console.log(`Response time: ${ms}ms`); }); // ============================================ // Commands // ============================================ bot.command('start', async (ctx) => { await ctx.reply('Welcome! Use /help to see available commands.'); }); bot.command('help', async (ctx) => { await ctx.reply( 'Available commands:\n' + '/start - Start the bot\n' + '/count - Increment counter\n' + '/reset - Reset counter\n' + '/ask - Interactive conversation' ); }); bot.command('count', async (ctx) => { ctx.session.counter++; await ctx.reply(`Counter: ${ctx.session.counter}`); }); bot.command('reset', async (ctx) => { ctx.session.counter = 0; await ctx.reply('Counter reset to 0'); }); bot.command('ask', async (ctx) => { ctx.session.step = 'waiting_for_name'; await ctx.reply('What is your name?'); }); // ============================================ // Message Handler (Conversation logic) // ============================================ bot.on('message:text', async (ctx) => { const text = ctx.message.text; if (ctx.session.step === 'waiting_for_name') { await ctx.reply(`Nice to meet you, ${text}!`); ctx.session.step = 'idle'; return; } // Default response // await ctx.reply('I did not understand that. Try /help'); }); // ============================================ // Error Handling // ============================================ bot.catch((err) => { console.error(`Error while handling update ${err.ctx.update.update_id}:`); console.error(err.error); }); // ============================================ // Start // ============================================ // For Long Polling (Development) if (process.env.NODE_ENV !== 'production') { console.log('🤖 Bot started (Long Polling)'); run(bot); } // Export for Webhook (Production) export const webhookCallback = (req: any, res: any) => { // Adapter logic for your specific server (Express, Hono, etc.) // return webhookCallback(bot, 'express')(req, res); }; export { bot };