mirror of
https://github.com/tiennm99/miti99bot.git
synced 2026-09-19 22:22:47 +00:00
tiennm99
fbef449247
Production showed: Request timed out after 10000 ms / status 500. grammY's webhookCallback defaults to 10s — fine for simple handlers but too tight for twentyq's Workers AI call (Gemma 4 26B cold-starts can easily exceed 10s). Raise to 25s, leaving 5s headroom under Cloudflare Workers' 30s wall-clock cap.
107 lines
3.0 KiB
JavaScript
107 lines
3.0 KiB
JavaScript
/**
|
|
* @file fetch entry point for the Cloudflare Worker.
|
|
*
|
|
* Routes:
|
|
* GET / — "miti99bot ok" health check (unauthenticated).
|
|
* POST /webhook — Telegram webhook. grammY validates the
|
|
* X-Telegram-Bot-Api-Secret-Token header against
|
|
* env.TELEGRAM_WEBHOOK_SECRET and replies 401 on mismatch.
|
|
* * — 404.
|
|
*
|
|
* There is NO admin HTTP surface. `setWebhook` + `setMyCommands` run at
|
|
* deploy time from `scripts/register.js`, not from the Worker.
|
|
*/
|
|
|
|
import { webhookCallback } from "grammy";
|
|
import { getBot, getRegistry } from "./bot.js";
|
|
import { dispatchScheduled } from "./modules/cron-dispatcher.js";
|
|
|
|
/** @type {ReturnType<typeof webhookCallback> | null} */
|
|
let cachedWebhookHandler = null;
|
|
|
|
/**
|
|
* @param {any} env
|
|
*/
|
|
async function getWebhookHandler(env) {
|
|
if (cachedWebhookHandler) return cachedWebhookHandler;
|
|
const bot = await getBot(env);
|
|
cachedWebhookHandler = webhookCallback(bot, "cloudflare-mod", {
|
|
secretToken: env.TELEGRAM_WEBHOOK_SECRET,
|
|
// Default is 10s — too short for LLM calls (Gemma 4 cold-start can exceed).
|
|
// Workers wall-clock limit is 30s; leave 5s headroom.
|
|
timeoutMilliseconds: 25000,
|
|
});
|
|
return cachedWebhookHandler;
|
|
}
|
|
|
|
export default {
|
|
/**
|
|
* Cloudflare Cron Trigger handler.
|
|
* Dispatches the scheduled event to all module cron handlers whose
|
|
* schedule matches event.cron.
|
|
*
|
|
* @param {any} event — ScheduledEvent ({ cron: string, scheduledTime: number })
|
|
* @param {any} env
|
|
* @param {{ waitUntil: (p: Promise<any>) => void }} ctx
|
|
*/
|
|
async scheduled(event, env, ctx) {
|
|
try {
|
|
const registry = await getRegistry(env);
|
|
dispatchScheduled(event, env, ctx, registry);
|
|
} catch (err) {
|
|
console.error("scheduled handler failed", err);
|
|
}
|
|
},
|
|
|
|
/**
|
|
* @param {Request} request
|
|
* @param {any} env
|
|
* @param {any} _ctx
|
|
*/
|
|
async fetch(request, env, _ctx) {
|
|
const start = Date.now();
|
|
const { pathname } = new URL(request.url);
|
|
const method = request.method;
|
|
|
|
const response = await route(request, env, pathname);
|
|
|
|
// Structured request log for Workers Observability dashboard.
|
|
console.log(
|
|
JSON.stringify({
|
|
msg: "req",
|
|
method,
|
|
path: pathname,
|
|
status: response.status,
|
|
ms: Date.now() - start,
|
|
}),
|
|
);
|
|
return response;
|
|
},
|
|
};
|
|
|
|
/**
|
|
* @param {Request} request
|
|
* @param {any} env
|
|
* @param {string} pathname
|
|
*/
|
|
async function route(request, env, pathname) {
|
|
if (request.method === "GET" && pathname === "/") {
|
|
return new Response("miti99bot ok", {
|
|
status: 200,
|
|
headers: { "content-type": "text/plain" },
|
|
});
|
|
}
|
|
|
|
if (request.method === "POST" && pathname === "/webhook") {
|
|
try {
|
|
const handler = await getWebhookHandler(env);
|
|
return await handler(request);
|
|
} catch (err) {
|
|
console.error("webhook handler failed", err);
|
|
return new Response("internal error", { status: 500 });
|
|
}
|
|
}
|
|
|
|
return new Response("not found", { status: 404 });
|
|
}
|