nameless
/
eris
forked from pinks/eris
1
0
Fork 0
Code Pull Requests Activity

replace timeout logic with Grammy's timeout option

This commit is contained in:
pinks 2023-09-23 01:42:15 +02:00
parent 10b57926ed
commit cc854639d7
1 changed files with 6 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
bot/mod.ts
View File

@ -34,7 +34,12 @@ type WithRetryApi<T extends Grammy.RawApi> = {
type Api = Grammy.Api<WithRetryApi<Grammy.RawApi>>; type Api = Grammy.Api<WithRetryApi<Grammy.RawApi>>;
export const bot = new Grammy.Bot<Context, Api>(Deno.env.get("TG_BOT_TOKEN")!); export const bot = new Grammy.Bot<Context, Api>(
Deno.env.get("TG_BOT_TOKEN")!,
{
client: { timeoutSeconds: 30 },
},
);
bot.use(GrammyAutoQuote.autoQuote); bot.use(GrammyAutoQuote.autoQuote);
bot.use(GrammyParseMode.hydrateReply); bot.use(GrammyParseMode.hydrateReply);
@ -54,36 +59,6 @@ bot.use(Grammy.session<
bot.api.config.use(GrammyFiles.hydrateFiles(bot.token)); bot.api.config.use(GrammyFiles.hydrateFiles(bot.token));
// Automatically cancel requests after 30 seconds
bot.api.config.use(async (prev, method, payload, signal) => {
// don't time out getUpdates requests, they are long-polling
if (method === "getUpdates") return prev(method, payload, signal);
const controller = new AbortController();
let timedOut = false;
const timeout = setTimeout(() => {
timedOut = true;
// TODO: this sometimes throws with "can't abort a locked stream", why?
try {
controller.abort();
} catch (error) {
logger().error(`Error while cancelling on timeout: ${error}`);
}
}, 30 * 1000);
signal?.addEventListener("abort", () => {
controller.abort();
});
try {
return await prev(method, payload, controller.signal);
} finally {
clearTimeout(timeout);
if (timedOut) {
logger().warning(`${method} timed out`);
}
}
});
// Automatically retry bot requests if we get a "too many requests" or telegram internal error // Automatically retry bot requests if we get a "too many requests" or telegram internal error
bot.api.config.use(async (prev, method, payload, signal) => { bot.api.config.use(async (prev, method, payload, signal) => {
const maxAttempts = payload && ("maxAttempts" in payload) ? payload.maxAttempts ?? 3 : 3; const maxAttempts = payload && ("maxAttempts" in payload) ? payload.maxAttempts ?? 3 : 3;