diff options
| author | Akihiko Odaki <nekomanma@pixiv.co.jp> | 2018-03-29 01:20:40 +0900 |
|---|---|---|
| committer | Akihiko Odaki <nekomanma@pixiv.co.jp> | 2018-03-29 01:54:41 +0900 |
| commit | 90f8fe7e538bb7e52d2558152a0390e693f39b11 (patch) | |
| tree | 0f830887053c8f352b1cd0c13ca715fd14c1f030 /src/api/limitter.ts | |
| parent | Implement remote account resolution (diff) | |
| download | misskey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.gz misskey-90f8fe7e538bb7e52d2558152a0390e693f39b11.tar.bz2 misskey-90f8fe7e538bb7e52d2558152a0390e693f39b11.zip | |
Introduce processor
Diffstat (limited to 'src/api/limitter.ts')
| -rw-r--r-- | src/api/limitter.ts | 83 |
1 files changed, 0 insertions, 83 deletions
diff --git a/src/api/limitter.ts b/src/api/limitter.ts deleted file mode 100644 index 9d2c42d335..0000000000 --- a/src/api/limitter.ts +++ /dev/null @@ -1,83 +0,0 @@ -import * as Limiter from 'ratelimiter'; -import * as debug from 'debug'; -import limiterDB from '../db/redis'; -import { Endpoint } from './endpoints'; -import { IAuthContext } from './authenticate'; -import getAcct from '../common/user/get-acct'; - -const log = debug('misskey:limitter'); - -export default (endpoint: Endpoint, ctx: IAuthContext) => new Promise((ok, reject) => { - const limitation = endpoint.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: `${ctx.user._id}:${key}:min`, - duration: limitation.minInterval, - max: 1, - db: limiterDB - }); - - minIntervalLimiter.get((err, info) => { - if (err) { - return reject('ERR'); - } - - log(`@${getAcct(ctx.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: `${ctx.user._id}:${key}`, - duration: limitation.duration, - max: limitation.max, - db: limiterDB - }); - - limiter.get((err, info) => { - if (err) { - return reject('ERR'); - } - - log(`@${getAcct(ctx.user)} ${endpoint.name} max remaining: ${info.remaining}`); - - if (info.remaining === 0) { - reject('RATE_LIMIT_EXCEEDED'); - } else { - ok(); - } - }); - } -}); |