Method addRateLimiter

packages/server/src/utils/rateLimit.ts:94–126

(id: string, duration: number, limit: number, message: string)

    }

    public async addRateLimiter(id: string, duration: number, limit: number, message: string): Promise<void> {
        const release = await this.rateLimiterMutex.acquire()
        try {
            if (process.env.MODE === MODE.QUEUE) {
                this.rateLimiters.set(
                    id,
                    rateLimit({
                        windowMs: duration * 1000,
                        max: limit,
                        standardHeaders: true,
                        legacyHeaders: false,
                        message,
                        store: new RedisStore({
                            prefix: `rl:${id}`,
                            // @ts-expect-error - Known issue: the `call` function is not present in @types/ioredis
                            sendCommand: (...args: string[]) => this.redisClient.call(...args)
                        })
                    })
                )
            } else {
                this.rateLimiters.set(
                    id,
                    rateLimit({
                        windowMs: duration * 1000,
                        max: limit,
                        message
                    })
                )
            }
        } finally {
            release()
        }
    }

    public removeRateLimiter(id: string): void {
        this.rateLimiters.delete(id)