From: Chocobozzz Date: Thu, 30 Nov 2017 11:00:40 +0000 (+0100) Subject: Check correctly activitypub headers X-Git-Tag: v0.0.1-alpha~158 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=6cbdbdef1786aabb2003918fad6cd8c0d4433f7c;p=oweals%2Fpeertube.git Check correctly activitypub headers --- diff --git a/server/middlewares/activitypub.ts b/server/middlewares/activitypub.ts index 34386e76d..7db84de97 100644 --- a/server/middlewares/activitypub.ts +++ b/server/middlewares/activitypub.ts @@ -37,7 +37,7 @@ async function checkSignature (req: Request, res: Response, next: NextFunction) function executeIfActivityPub (fun: RequestHandler | RequestHandler[]) { return (req: Request, res: Response, next: NextFunction) => { - if (ACTIVITY_PUB.ACCEPT_HEADERS.indexOf(req.header('Accept')) === -1) { + if (req.accepts(ACTIVITY_PUB.POTENTIAL_ACCEPT_HEADERS) === false) { return next() } diff --git a/server/tests/activitypub.ts b/server/tests/activitypub.ts new file mode 100644 index 000000000..333e02e84 --- /dev/null +++ b/server/tests/activitypub.ts @@ -0,0 +1,42 @@ +/* tslint:disable:no-unused-expression */ + +import * as chai from 'chai' +import 'mocha' +import { flushTests, killallServers, ServerInfo, setAccessTokensToServers } from './utils' +import { runServer } from './utils/servers' +import { makeActivityPubGetRequest } from './utils/activitypub' + +const expect = chai.expect + +describe('Test activitypub', function () { + let server: ServerInfo = null + + before(async function () { + this.timeout(10000) + + await flushTests() + + server = await runServer(1) + + await setAccessTokensToServers([ server ]) + }) + + it('Should return the account object', async function () { + const res = await makeActivityPubGetRequest(server.url, '/account/root') + const object = res.body + + expect(object.type).to.equal('Person') + expect(object.id).to.equal('http://localhost:9001/account/root') + expect(object.name).to.equal('root') + expect(object.preferredUsername).to.equal('root') + }) + + after(async function () { + killallServers([ server ]) + + // Keep the logs if the test failed + if (this['ok']) { + await flushTests() + } + }) +})