summaryrefslogtreecommitdiff
path: root/src/server/api/limiter.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2021-11-12 02:02:25 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2021-11-12 02:02:25 +0900
commit0e4a111f81cceed275d9bec2695f6e401fb654d8 (patch)
tree40874799472fa07416f17b50a398ac33b7771905 /src/server/api/limiter.ts
parentupdate deps (diff)
downloadsharkey-0e4a111f81cceed275d9bec2695f6e401fb654d8.tar.gz
sharkey-0e4a111f81cceed275d9bec2695f6e401fb654d8.tar.bz2
sharkey-0e4a111f81cceed275d9bec2695f6e401fb654d8.zip
refactoring
Resolve #7779
Diffstat (limited to 'src/server/api/limiter.ts')
-rw-r--r--src/server/api/limiter.ts83
1 files changed, 0 insertions, 83 deletions
diff --git a/src/server/api/limiter.ts b/src/server/api/limiter.ts
deleted file mode 100644
index e677aad0b6..0000000000
--- a/src/server/api/limiter.ts
+++ /dev/null
@@ -1,83 +0,0 @@
-import * as Limiter from 'ratelimiter';
-import { redisClient } from '../../db/redis';
-import { IEndpoint } from './endpoints';
-import { getAcct } from '@/misc/acct';
-import { User } from '@/models/entities/user';
-import Logger from '@/services/logger';
-
-const logger = new Logger('limiter');
-
-export default (endpoint: IEndpoint, user: User) => new Promise<void>((ok, reject) => {
- const limitation = endpoint.meta.limit!;
-
- const key = limitation.hasOwnProperty('key')
- ? limitation.key
- : endpoint.name;
-
- const hasShortTermLimit =
- limitation.hasOwnProperty('minInterval');
-
- const hasLongTermLimit =
- limitation.hasOwnProperty('duration') &&
- limitation.hasOwnProperty('max');
-
- if (hasShortTermLimit) {
- min();
- } else if (hasLongTermLimit) {
- max();
- } else {
- ok();
- }
-
- // Short-term limit
- function min() {
- const minIntervalLimiter = new Limiter({
- id: `${user.id}:${key}:min`,
- duration: limitation.minInterval,
- max: 1,
- db: redisClient
- });
-
- minIntervalLimiter.get((err, info) => {
- if (err) {
- return reject('ERR');
- }
-
- logger.debug(`@${getAcct(user)} ${endpoint.name} min remaining: ${info.remaining}`);
-
- if (info.remaining === 0) {
- reject('BRIEF_REQUEST_INTERVAL');
- } else {
- if (hasLongTermLimit) {
- max();
- } else {
- ok();
- }
- }
- });
- }
-
- // Long term limit
- function max() {
- const limiter = new Limiter({
- id: `${user.id}:${key}`,
- duration: limitation.duration,
- max: limitation.max,
- db: redisClient
- });
-
- limiter.get((err, info) => {
- if (err) {
- return reject('ERR');
- }
-
- logger.debug(`@${getAcct(user)} ${endpoint.name} max remaining: ${info.remaining}`);
-
- if (info.remaining === 0) {
- reject('RATE_LIMIT_EXCEEDED');
- } else {
- ok();
- }
- });
- }
-});