Telegraf.js中接收Telegram Web App发送数据的实用指南

// 确保Telegram Web App脚本已加载
if (window.Telegram && window.Telegram.WebApp) {
    const dataToSend = {
        action: 'auth_complete',
        userId: '12345',
        token: 'some_secure_token'
    };

    // 将JavaScript对象序列化为JSON字符串
    const jsonStringData = JSON.stringify(dataToSend);

    // 发送数据到Telegram Bot
    window.Telegram.WebApp.sendData(jsonStringData);

    // 可选：发送数据后关闭Web App
    // window.Telegram.WebApp.close(); 
} else {
    console.error('Telegram WebApp object not found.');
}

{
  "message_id": 123,
  "from": { /* ... */ },
  "chat": { /* ... */ },
  "date": 1678888888,
  "web_app_data": {
    "data": "{\"action\":\"auth_complete\",\"userId\":\"12345\",\"token\":\"some_secure_token\"}"
  }
}

const { Telegraf } = require('telegraf');
const bot = new Telegraf(process.env.BOT_TOKEN);

// 定义你的Web App URL
const FRONT_URL = 'https://your-web-app-domain.com'; // 请替换为你的实际Web App URL

// Bot启动命令，用于打开Web App
bot.start(async (ctx) => {
    ctx.reply('欢迎使用Web App集成示例！点击下方按钮打开Web App。', {
        reply_markup: {
            inline_keyboard: [
                [{ text: '打开我的Web App', web_app: { url: FRONT_URL } }]
            ]
        }
    });
});

// 监听所有消息
bot.on('message', (ctx) => {
    // 检查消息是否包含web_app_data字段
    if (ctx.message && ctx.message.web_app_data) {
        const receivedDataString = ctx.message.web_app_data.data;
        console.log('从Web App接收到原始数据:', receivedDataString);

        try {
            // 尝试将接收到的JSON字符串解析为JavaScript对象
            const parsedData = JSON.parse(receivedDataString);
            console.log('解析后的Web App数据:', parsedData);

            // 根据解析后的数据执行业务逻辑
            if (parsedData.action === 'auth_complete') {
                ctx.reply(`认证成功！用户ID: ${parsedData.userId}`);
                // 在这里可以进行用户认证、数据库更新等操作
            } else {
                ctx.reply(`接收到未知Web App动作: ${parsedData.action}`);
            }
        } catch (e) {
            // 处理JSON解析失败的情况
            ctx.reply(`接收到非JSON格式的Web App数据: ${receivedDataString}`);
            console.error('解析Web App数据失败:', e);
        }
    } else {
        // 处理其他类型的普通消息
        // ctx.reply('收到一条普通消息。');
    }
});

// 启动Bot
bot.launch();

// 优雅关闭Bot
process.once('SIGINT', () => bot.stop('SIGINT'));
process.once('SIGTERM', () => bot.stop('SIGTERM'));