-function executeIfActivityPub (fun: RequestHandler | RequestHandler[]) {
- return (req: Request, res: Response, next: NextFunction) => {
- const accepted = req.accepts(ACCEPT_HEADERS)
- if (accepted === false || ACTIVITY_PUB.POTENTIAL_ACCEPT_HEADERS.indexOf(accepted) === -1) {
- return next()
+// ---------------------------------------------------------------------------
+
+export {
+ checkSignature,
+ executeIfActivityPub,
+ checkHttpSignature
+}
+
+// ---------------------------------------------------------------------------
+
+async function checkHttpSignature (req: Request, res: Response) {
+ return wrapWithSpanAndContext('peertube.activitypub.checkHTTPSignature', async () => {
+ // FIXME: compatibility with http-signature < v1.3
+ const sig = req.headers[HTTP_SIGNATURE.HEADER_NAME] as string
+ if (sig && sig.startsWith('Signature ') === true) req.headers[HTTP_SIGNATURE.HEADER_NAME] = sig.replace(/^Signature /, '')
+
+ let parsed: any
+
+ try {
+ parsed = parseHTTPSignature(req, HTTP_SIGNATURE.CLOCK_SKEW_SECONDS)
+ } catch (err) {
+ logger.warn('Invalid signature because of exception in signature parser', { reqBody: req.body, err })
+
+ res.fail({
+ status: HttpStatusCode.FORBIDDEN_403,
+ message: err.message
+ })
+ return false
+ }
+
+ const keyId = parsed.keyId
+ if (!keyId) {
+ res.fail({
+ status: HttpStatusCode.FORBIDDEN_403,
+ message: 'Invalid key ID',
+ data: {
+ keyId
+ }
+ })
+ return false