summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/limiter.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/server/api/limiter.ts')
-rw-r--r--packages/backend/src/server/api/limiter.ts77
1 files changed, 0 insertions, 77 deletions
diff --git a/packages/backend/src/server/api/limiter.ts b/packages/backend/src/server/api/limiter.ts
deleted file mode 100644
index 9a7751716e..0000000000
--- a/packages/backend/src/server/api/limiter.ts
+++ /dev/null
@@ -1,77 +0,0 @@
-import Limiter from 'ratelimiter';
-import { CacheableLocalUser, User } from '@/models/entities/user.js';
-import Logger from '@/services/logger.js';
-import { redisClient } from '../../db/redis.js';
-import { IEndpointMeta } from './endpoints.js';
-
-const logger = new Logger('limiter');
-
-export const limiter = (limitation: IEndpointMeta['limit'] & { key: NonNullable<string> }, actor: string) => new Promise<void>((ok, reject) => {
- if (process.env.NODE_ENV === 'test') ok();
-
- const hasShortTermLimit = typeof limitation.minInterval === 'number';
-
- const hasLongTermLimit =
- typeof limitation.duration === 'number' &&
- typeof limitation.max === 'number';
-
- if (hasShortTermLimit) {
- min();
- } else if (hasLongTermLimit) {
- max();
- } else {
- ok();
- }
-
- // Short-term limit
- function min(): void {
- const minIntervalLimiter = new Limiter({
- id: `${actor}:${limitation.key}:min`,
- duration: limitation.minInterval,
- max: 1,
- db: redisClient,
- });
-
- minIntervalLimiter.get((err, info) => {
- if (err) {
- return reject('ERR');
- }
-
- logger.debug(`${actor} ${limitation.key} min remaining: ${info.remaining}`);
-
- if (info.remaining === 0) {
- reject('BRIEF_REQUEST_INTERVAL');
- } else {
- if (hasLongTermLimit) {
- max();
- } else {
- ok();
- }
- }
- });
- }
-
- // Long term limit
- function max(): void {
- const limiter = new Limiter({
- id: `${actor}:${limitation.key}`,
- duration: limitation.duration,
- max: limitation.max,
- db: redisClient,
- });
-
- limiter.get((err, info) => {
- if (err) {
- return reject('ERR');
- }
-
- logger.debug(`${actor} ${limitation.key} max remaining: ${info.remaining}`);
-
- if (info.remaining === 0) {
- reject('RATE_LIMIT_EXCEEDED');
- } else {
- ok();
- }
- });
- }
-});