Compare commits

..

3 Commits

Author SHA1 Message Date
Ceda EI 7ea30c8c71 Merge branch 'main' of https://gitlab.com/ceda_ei/Quadnite-Bot 2024-09-30 10:52:54 +05:30
Ceda EI cd374090f2 Merge branch 'feat/ratelimit' into 'main'
feat: add rate limiter middleware

See merge request ceda_ei/Quadnite-Bot!4
2024-09-30 05:22:36 +00:00
Sphericalkat 8274ab0980
feat: add rate limiter middleware
Signed-off-by: Sphericalkat <me@kat.bio>
2024-09-30 10:39:07 +05:30
4 changed files with 23 additions and 1 deletions

View File

@ -13,4 +13,6 @@ roleplay gifs. Once you have an instance of Ugoki (and optionally
- `export BOT_API_KEY="your-token-for-bot"` - `export BOT_API_KEY="your-token-for-bot"`
- `export FEEDBACK_ID="chat-id-where-feedback-is-forwarded-to"` - `export FEEDBACK_ID="chat-id-where-feedback-is-forwarded-to"`
- `export UGOKI_ROOT="https://root.of.ugoki.api/server/"` - `export UGOKI_ROOT="https://root.of.ugoki.api/server/"`
- `export RATE_TIMEFRAME=5000 # rate limit time interval in milliseconds`
- `export RATE_LIMIT=5 # number of requests allowed in the timeframe`
- `npm start` - `npm start`

10
bot.js
View File

@ -1,12 +1,20 @@
const { Telegraf } = require("telegraf"); const { Telegraf } = require("telegraf");
const { BOT_API_KEY, FEEDBACK_ID, UGOKI_ROOT } = process.env; const { BOT_API_KEY, FEEDBACK_ID, UGOKI_ROOT, RATE_TIMEFRAME, RATE_LIMIT } = process.env;
const fs = require("fs").promises; const fs = require("fs").promises;
const commands = require("./commands"); const commands = require("./commands");
const axios = require("axios"); const axios = require("axios");
const roleplay = require("./static/roleplay.json"); const roleplay = require("./static/roleplay.json");
const { limit } = require("@grammyjs/ratelimiter");
const bot = new Telegraf(BOT_API_KEY); const bot = new Telegraf(BOT_API_KEY);
bot.catch((err) => console.log(err)); bot.catch((err) => console.log(err));
bot.use(limit({
// default config: 5 messages per 5 seconds
timeFrame: RATE_TIMEFRAME ?? 5000,
limit: RATE_LIMIT ?? 5,
onLimitExceeded: (ctx, next) => ctx.reply('Too many requests!'),
}))
const data = [ const data = [
"questions", "questions",

11
package-lock.json generated
View File

@ -9,12 +9,18 @@
"version": "2.0.0", "version": "2.0.0",
"license": "GPL-3.0", "license": "GPL-3.0",
"dependencies": { "dependencies": {
"@grammyjs/ratelimiter": "^1.2.0",
"axios": "^0.21.0", "axios": "^0.21.0",
"fluent-ffmpeg": "^2.1.2", "fluent-ffmpeg": "^2.1.2",
"form-data": "^4.0.0", "form-data": "^4.0.0",
"telegraf": "^4.15.3" "telegraf": "^4.15.3"
} }
}, },
"node_modules/@grammyjs/ratelimiter": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/@grammyjs/ratelimiter/-/ratelimiter-1.2.0.tgz",
"integrity": "sha512-xBkH/ATJsuv5JgVYX9yQM9DNg75Qqjw+gh82lVsBn4j+d0DkxxC+kuy6WFoB96Cb6oifQfaBJL8CTikdYG4v0A=="
},
"node_modules/@telegraf/types": { "node_modules/@telegraf/types": {
"version": "6.9.1", "version": "6.9.1",
"resolved": "https://registry.npmjs.org/@telegraf/types/-/types-6.9.1.tgz", "resolved": "https://registry.npmjs.org/@telegraf/types/-/types-6.9.1.tgz",
@ -288,6 +294,11 @@
} }
}, },
"dependencies": { "dependencies": {
"@grammyjs/ratelimiter": {
"version": "1.2.0",
"resolved": "https://registry.npmjs.org/@grammyjs/ratelimiter/-/ratelimiter-1.2.0.tgz",
"integrity": "sha512-xBkH/ATJsuv5JgVYX9yQM9DNg75Qqjw+gh82lVsBn4j+d0DkxxC+kuy6WFoB96Cb6oifQfaBJL8CTikdYG4v0A=="
},
"@telegraf/types": { "@telegraf/types": {
"version": "6.9.1", "version": "6.9.1",
"resolved": "https://registry.npmjs.org/@telegraf/types/-/types-6.9.1.tgz", "resolved": "https://registry.npmjs.org/@telegraf/types/-/types-6.9.1.tgz",

View File

@ -22,6 +22,7 @@
}, },
"homepage": "https://gitlab.com/ceda_ei/Quadnite-Bot#readme", "homepage": "https://gitlab.com/ceda_ei/Quadnite-Bot#readme",
"dependencies": { "dependencies": {
"@grammyjs/ratelimiter": "^1.2.0",
"axios": "^0.21.0", "axios": "^0.21.0",
"fluent-ffmpeg": "^2.1.2", "fluent-ffmpeg": "^2.1.2",
"form-data": "^4.0.0", "form-data": "^4.0.0",