如何使用Telegraf.js接收Telegram Web App发送的数据

// 确保Telegram Web App SDK已加载并准备就绪
window.Telegram.WebApp.ready();

// 构造要发送的数据对象
const dataToSend = {
    action: 'user_auth',
    userId: 12345,
    username: 'john_doe',
    timestamp: Date.now()
};

// 将数据对象转换为JSON字符串并发送
try {
    window.Telegram.WebApp.sendData(JSON.stringify(dataToSend));
    // 数据发送成功后，可以选择关闭Web App
    // window.Telegram.WebApp.close();
    console.log('数据已成功发送至Bot。');
} catch (error) {
    console.error('发送数据失败:', error);
}

const { Telegraf } = require('telegraf');
require('dotenv').config(); // 如果使用 .env 文件管理 BOT_TOKEN

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

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

bot.start(async (ctx) => {
    await ctx.reply('欢迎使用我们的Web App！请点击下方按钮启动。', {
        reply_markup: {
            inline_keyboard: [
                [{ text: '启动我的Web App', web_app: { url: FRONT_URL } }]
            ]
        }
    });
});

bot.on('message', async (ctx) => {
    // 打印完整的消息对象，有助于调试
    console.log('接收到消息:', ctx.message);

    // 检查消息是否包含 web_app_data 字段
    if (ctx.message && ctx.message.web_app_data) {
        const webAppData = ctx.message.web_app_data;
        const receivedDataString = webAppData.data; // 这是前端sendData()发送的字符串

        console.log('接收到Web App数据字符串:', receivedDataString);

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

            // 根据解析出的数据执行相应的业务逻辑
            if (parsedData.action === 'user_auth') {
                await ctx.reply(
                    `成功接收到用户认证数据：用户ID ${parsedData.userId}，用户名 ${parsedData.username}。`
                );
                // 在这里可以进行用户认证、数据库更新、发送确认消息等操作
                // 例如：await authenticateUser(parsedData.userId, parsedData.username);
            } else {
                await ctx.reply(`接收到未知Web App数据动作: ${parsedData.action || '未指定'}`);
            }
        } catch (error) {
            console.error('解析Web App数据时发生错误:', error);
            await ctx.reply('接收到的Web App数据格式不正确，请检查。');
        }
    } else {
        // 如果不是Web App数据，则按常规消息处理
        await ctx.reply(`您发送了普通消息: "${ctx.message.text || '（无文本）'}"`);
    }
});

// 启动Bot
bot.launch();

// 优雅地停止Bot
process.once('SIGINT', () => bot.stop('SIGINT'));
process.once('SIGTERM', () => bot.stop('SIGTERM'));

const { Telegraf } = require('telegraf');
require('dotenv').config(); // 确保您已安装 dotenv 包并配置 .env 文件

// 替换为您的Bot Token
const bot = new Telegraf(process.env.BOT_TOKEN);

// 替换为您的Web App的实际URL
const FRONT_URL = 'https://your-web-app-domain.com'; // 例如：https://my-awesome-webapp.vercel.app

// Bot的启动命令处理
bot.start(async (ctx) => {
    await ctx.reply('欢迎使用我们的Web App！请点击下方按钮启动。', {
        reply_markup: {
            inline_keyboard: [
                [{ text: '启动我的Web App', web_app: { url: FRONT_URL } }]
            ]
        }
    });
});

// 监听所有消息事件，包括Web App发送的数据
bot.on('message', async (ctx) => {
    console.log('接收到消息:', ctx.message);

    // 检查消息中是否包含 web_app_data 字段
    if (ctx.message && ctx.message.web_app_data) {
        const webAppData = ctx.message.web_app_data;
        const receivedDataString = webAppData.data; // 这是前端sendData()发送的字符串

        console.log('接收到Web App数据字符串:', receivedDataString);

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

            // 根据解析出的数据执行相应的业务逻辑
            if (parsedData.action === 'user_auth') {
                await ctx.reply(
                    `? 认证成功！接收到用户数据：用户ID ${parsedData.userId}，用户名 ${parsedData.username}。`
                );
                // 在这里可以进行用户认证、数据库更新、发送确认消息等操作
                // 例如：await authenticateUser(parsedData.userId, parsedData.username);
            } else if (parsedData.action === 'submit_form') {
                await ctx.reply(`✅ 表单提交成功！数据：${JSON.stringify(parsedData.formData)}`);
            }
            else {
                await ctx.reply(`ℹ️ 接收到未知Web App数据动作: ${parsedData.action || '未指定'}`);
            }
        } catch (error) {
            console.error('解析Web App数据时发生错误:', error);
            await ctx.reply('⚠️ 接收到的Web App数据格式不正确，请检查。');
        }
    } else {
        // 处理普通消息
        await ctx.reply(`您发送了普通消息: "${ctx.message.text || '（无文本）'}"`);
    }
});

// 启动Bot
bot.launch();

console.log('Bot已启动...');

// 优雅地停止Bot
process.once('SIGINT', () => {
    bot.stop('SIGINT');
    console.log('Bot已停止 (SIGINT)');
});
process.once('SIGTERM', () => {
    bot.stop('SIGTERM');
    console.log('Bot已停止 (SIGTERM)');
});