mirror of https://github.com/Chocobozzz/PeerTube
60 lines
1.9 KiB
TypeScript
60 lines
1.9 KiB
TypeScript
import express from 'express'
|
|
import RateLimit, { Options as RateLimitHandlerOptions } from 'express-rate-limit'
|
|
import { UserRole, UserRoleType } from '@peertube/peertube-models'
|
|
import { CONFIG } from '@server/initializers/config.js'
|
|
import { RunnerModel } from '@server/models/runner/runner.js'
|
|
import { optionalAuthenticate } from './auth.js'
|
|
|
|
const whitelistRoles = new Set<UserRoleType>([ UserRole.ADMINISTRATOR, UserRole.MODERATOR ])
|
|
|
|
export function buildRateLimiter (options: {
|
|
windowMs: number
|
|
max: number
|
|
skipFailedRequests?: boolean
|
|
}) {
|
|
return RateLimit({
|
|
windowMs: options.windowMs,
|
|
max: options.max,
|
|
skipFailedRequests: options.skipFailedRequests,
|
|
|
|
handler: (req, res, next, options) => {
|
|
// Bypass rate limit for registered runners
|
|
if (req.body?.runnerToken) {
|
|
return RunnerModel.loadByToken(req.body.runnerToken)
|
|
.then(runner => {
|
|
if (runner) return next()
|
|
|
|
return sendRateLimited(res, options)
|
|
})
|
|
}
|
|
|
|
// Bypass rate limit for admins/moderators
|
|
return optionalAuthenticate(req, res, () => {
|
|
if (res.locals.authenticated === true && whitelistRoles.has(res.locals.oauth.token.User.role)) {
|
|
return next()
|
|
}
|
|
|
|
return sendRateLimited(res, options)
|
|
})
|
|
}
|
|
})
|
|
}
|
|
|
|
export const apiRateLimiter = buildRateLimiter({
|
|
windowMs: CONFIG.RATES_LIMIT.API.WINDOW_MS,
|
|
max: CONFIG.RATES_LIMIT.API.MAX
|
|
})
|
|
|
|
export const activityPubRateLimiter = buildRateLimiter({
|
|
windowMs: CONFIG.RATES_LIMIT.ACTIVITY_PUB.WINDOW_MS,
|
|
max: CONFIG.RATES_LIMIT.ACTIVITY_PUB.MAX
|
|
})
|
|
|
|
// ---------------------------------------------------------------------------
|
|
// Private
|
|
// ---------------------------------------------------------------------------
|
|
|
|
function sendRateLimited (res: express.Response, options: RateLimitHandlerOptions) {
|
|
return res.status(options.statusCode).send(options.message)
|
|
}
|