一个基于隔壁傻b论坛开发的TG机器人 - 全球主机交流论坛

// =================================================================
// 配置信息 (必须填写)
// =================================================================
const TOKEN = ENV_BOT_TOKEN; // 从 @BotFather 获取
const WEBHOOK = '/endpoint';
const SECRET = ENV_BOT_SECRET; // 一个安全的随机字符串 (A-Z, a-z, 0-9, _ and -)
const ADMIN_UID = ENV_ADMIN_UID; // 您的 Telegram User ID
// =================================================================
// 核心功能 (无需修改)
// =================================================================
function apiUrl(methodName, params = null) {
let query = '';
if (params) {
query = '?' + new URLSearchParams(params).toString();
}
return `https://api.telegram.org/bot${TOKEN}/${methodName}${query}`;
}
function requestTelegram(methodName, body, params = null) {
return fetch(apiUrl(methodName, params), {
method: 'POST',
headers: {
'content-type': 'application/json'
},
body: JSON.stringify(body)
}).then(r => r.json());
}
function sendMessage(msg = {}) {
return requestTelegram('sendMessage', msg);
}
function copyMessage(msg = {}) {
return requestTelegram('copyMessage', msg);
}
function forwardMessage(msg) {
return requestTelegram('forwardMessage', msg);
}
addEventListener('fetch', event => {
const url = new URL(event.request.url);
if (url.pathname === WEBHOOK) {
event.respondWith(handleWebhook(event));
} else if (url.pathname === '/registerWebhook') {
event.respondWith(registerWebhook(event, url, WEBHOOK, SECRET));
} else if (url.pathname === '/unRegisterWebhook') {
event.respondWith(unRegisterWebhook(event));
} else {
event.respondWith(new Response('No handler for this request'));
}
});
async function handleWebhook(event) {
if (event.request.headers.get('X-Telegram-Bot-Api-Secret-Token') !== SECRET) {
return new Response('Unauthorized', { status: 403 });
}
const update = await event.request.json();
event.waitUntil(onUpdate(update));
return new Response('Ok');
}
async function onUpdate(update) {
if ('message' in update) {
await onMessage(update.message);
}
}
async function onMessage(message) {
const chatId = message.chat.id.toString();
// 如果来自管理员
if (chatId === ADMIN_UID) {
const reply = message.reply_to_message;
// 检查是否在回复转发消息
if (reply && (reply.forward_from || reply.forward_sender_name)) {
const guestChatId = await nfd.get('msg-map-' + reply.message_id);
if (guestChatId) {
return copyMessage({
chat_id: guestChatId,
from_chat_id: message.chat.id,
message_id: message.message_id,
});
} else {
return sendMessage({
chat_id: ADMIN_UID,
text: '⚠️ 未找到原用户映射，可能消息太旧或被清理了缓存。'
});
}
} else {
// 非合法回复
return sendMessage({
chat_id: ADMIN_UID,
text: '提示：请直接“回复由机器人转发的用户消息”来进行回复。'
});
}
} else {
// 访客发消息
return handleGuestMessage(message);
}
}
async function handleGuestMessage(message) {
const forwardReq = await forwardMessage({
chat_id: ADMIN_UID,
from_chat_id: message.chat.id,
message_id: message.message_id
});
if (forwardReq.ok && forwardReq.result && forwardReq.result.message_id) {
await nfd.put('msg-map-' + forwardReq.result.message_id, message.chat.id.toString());
} else {
await sendMessage({
chat_id: ADMIN_UID,
text: `❌ 转发消息失败：${JSON.stringify(forwardReq)}`
});
}
}
// =================================================================
// Webhook 设置工具 (无需修改)
// =================================================================
async function registerWebhook(event, requestUrl, suffix, secret) {
const webhookUrl = `${requestUrl.protocol}//${requestUrl.hostname}${suffix}`;
const r = await (await fetch(apiUrl('setWebhook', { url: webhookUrl, secret_token: secret }))).json();
return new Response('ok' in r && r.ok ? 'Ok' : JSON.stringify(r, null, 2));
}
async function unRegisterWebhook(event) {
const r = await (await fetch(apiUrl('setWebhook', { url: '' }))).json();
return new Response('ok' in r && r.ok ? 'Ok' : JSON.stringify(r, null, 2));
}

复制代码