diff options
Diffstat (limited to 'server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts')
-rw-r--r-- | server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts index f7f3dabbd..4c95197c4 100644 --- a/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts +++ b/server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts | |||
@@ -1,21 +1,17 @@ | |||
1 | import { logger } from '../../../helpers' | 1 | import { logger } from '../../../helpers' |
2 | import { doRequest } from '../../../helpers/requests' | 2 | import { doRequest } from '../../../helpers/requests' |
3 | import { ActivityPubHttpPayload, maybeRetryRequestLater } from './activitypub-http-job-scheduler' | 3 | import { ActivityPubHttpPayload, computeBody, maybeRetryRequestLater } from './activitypub-http-job-scheduler' |
4 | import { database as db } from '../../../initializers/database' | ||
5 | import { buildSignedActivity } from '../../../helpers/activitypub' | ||
6 | 4 | ||
7 | async function process (payload: ActivityPubHttpPayload, jobId: number) { | 5 | async function process (payload: ActivityPubHttpPayload, jobId: number) { |
8 | logger.info('Processing ActivityPub unicast in job %d.', jobId) | 6 | logger.info('Processing ActivityPub unicast in job %d.', jobId) |
9 | 7 | ||
10 | const accountSignature = await db.Account.load(payload.signatureAccountId) | 8 | const body = await computeBody(payload) |
11 | if (!accountSignature) throw new Error('Unknown signature account id.') | ||
12 | 9 | ||
13 | const signedBody = await buildSignedActivity(accountSignature, payload.body) | ||
14 | const uri = payload.uris[0] | 10 | const uri = payload.uris[0] |
15 | const options = { | 11 | const options = { |
16 | method: 'POST', | 12 | method: 'POST', |
17 | uri, | 13 | uri, |
18 | json: signedBody | 14 | json: body |
19 | } | 15 | } |
20 | 16 | ||
21 | try { | 17 | try { |