]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame - server/middlewares/validators/activitypub/activity.ts
Merge branch 'release/3.3.0' into develop
[github/Chocobozzz/PeerTube.git] / server / middlewares / validators / activitypub / activity.ts
CommitLineData
0d0e8dd0 1import * as express from 'express'
8dc8a34e 2import { getServerActor } from '@server/models/application/application'
c0e8b12e 3import { HttpStatusCode } from '../../../../shared/models/http/http-error-codes'
4c7e60bc
C
4import { isRootActivityValid } from '../../../helpers/custom-validators/activitypub/activity'
5import { logger } from '../../../helpers/logger'
0d0e8dd0 6
ee28cdf1
C
7async function activityPubValidator (req: express.Request, res: express.Response, next: express.NextFunction) {
8 logger.debug('Checking activity pub parameters')
0d0e8dd0 9
ee28cdf1
C
10 if (!isRootActivityValid(req.body)) {
11 logger.warn('Incorrect activity parameters.', { activity: req.body })
3866ea02 12 return res.fail({ message: 'Incorrect activity' })
ee28cdf1 13 }
285fe7c9 14
ee28cdf1 15 const serverActor = await getServerActor()
dae86118 16 const remoteActor = res.locals.signature.actor
3933a127 17 if (serverActor.id === remoteActor.id || remoteActor.serverId === null) {
ee28cdf1 18 logger.error('Receiving request in INBOX by ourselves!', req.body)
3866ea02 19 return res.status(HttpStatusCode.CONFLICT_409).end()
0d0e8dd0 20 }
ee28cdf1
C
21
22 return next()
23}
0d0e8dd0
C
24
25// ---------------------------------------------------------------------------
26
27export {
28 activityPubValidator
29}