OpenCloud
/
PeerTube
mirror of https://github.com/Chocobozzz/PeerTube
1
0
Fork 0
Code Issues Releases Wiki Activity

feat(server): log rate limit exceeded

pull/6261/head
kontrollanten 2024-03-09 21:43:17 +01:00
parent bfdd4d10f3
commit 36b88bd00b
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/core/middlewares/rate-limiter.ts
View File

@ -4,6 +4,7 @@ import { UserRole, UserRoleType } from '@peertube/peertube-models'
import { CONFIG } from '@server/initializers/config.js' import { CONFIG } from '@server/initializers/config.js'
import { RunnerModel } from '@server/models/runner/runner.js' import { RunnerModel } from '@server/models/runner/runner.js'
import { optionalAuthenticate } from './auth.js' import { optionalAuthenticate } from './auth.js'
import { logger } from '@server/helpers/logger.js'
const whitelistRoles = new Set<UserRoleType>([ UserRole.ADMINISTRATOR, UserRole.MODERATOR ]) const whitelistRoles = new Set<UserRoleType>([ UserRole.ADMINISTRATOR, UserRole.MODERATOR ])
@ -24,7 +25,7 @@ export function buildRateLimiter (options: {
.then(runner => { .then(runner => {
if (runner) return next() if (runner) return next()
return sendRateLimited(res, options) return sendRateLimited(req, res, options)
}) })
} }
@ -34,7 +35,7 @@ export function buildRateLimiter (options: {
return next() return next()
} }
return sendRateLimited(res, options) return sendRateLimited(req, res, options)
}) })
} }
}) })
@ -54,6 +55,8 @@ export const activityPubRateLimiter = buildRateLimiter({
// Private // Private
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
function sendRateLimited (res: express.Response, options: RateLimitHandlerOptions) { function sendRateLimited (req: express.Request, res: express.Response, options: RateLimitHandlerOptions) {
logger.debug('Rate limit exceeded for route ' + req.originalUrl)
return res.status(options.statusCode).send(options.message) return res.status(options.statusCode).send(options.message)
} }