Rate limits
This is a guide that shows how to solve rate limit errors (Error code 429, Error: Too many requests: retry later) from Telegram Bot API.
Generally speaking, if you avoid broadcast-like behavior in your bot, there is no need to worry about rate limits. But it's better to use the auto-retry plugin just in case. if you reach these limits without broadcasting, then most likely something is wrong on your side.
How to Broadcast
For a start, we can solve rate-limit errors when broadcasting without using queues.
Let's use the auto-retry plugin which catches errors with the retry_after field (rate limit errors), waits for the specified time and repeats the API request.
Next, we need to make a loop and adjust the delay so that we are least likely to fall for a rate-limit error, and if we catch it, we will wait for the specified time (and the auto-retry plugin will repeat it)
// experimental API available since Node.js@16.14.0
import { scheduler } from "node:timers/promises";
import { Bot, TelegramError } from "gramio";
import { autoRetry } from "@gramio/auto-retry";
const bot = new Bot(process.env.BOT_TOKEN as string).extend(autoRetry());
const chatIds: number[] = [
/** some chat ids */
];
for (const chatId of chatIds) {
const result = await bot.api.sendMessage({
suppress: true,
chat_id: chatId,
text: "Hi!",
});
await scheduler.wait(
result instanceof TelegramError && result.payload?.retry_after
? result.payload.retry_after * 1000
: 1000
);
}With queue:
Persistent even when server restarts and ready to horizontal-scaling broadcasting sample.
Pre-requirements:
// TODO: more text about it
import { Worker } from "bullmq";
import { Bot, TelegramError } from "gramio";
import { Redis } from "ioredis";
import { initJobify } from "jobify";
const bot = new Bot(process.env.BOT_TOKEN as string);
const redis = new Redis({
maxRetriesPerRequest: null,
});
const defineJob = initJobify(redis);
const text = "Hello, world!";
const sendMailing = defineJob("send-mailing")
.input<{ chatId: number }>()
.options({
limiter: {
max: 20,
duration: 1000,
},
})
.action(async ({ data: { chatId } }) => {
const response = await bot.api.sendMessage({
chat_id: chatId,
suppress: true,
text,
});
if (response instanceof TelegramError) {
if (response.payload?.retry_after) {
await sendMailing.worker.rateLimit(
response.payload.retry_after * 1000
);
// use this only if you did not use auto-retry
// because it re-run this job again
throw Worker.RateLimitError();
} else throw response;
}
});
const chats: number[] = []; // pick chats from database
await sendMailing.addBulk(
chats.map((x) => ({
name: "mailing",
data: {
chatId: x,
},
}))
);