server/lib/jobs/activitypub-http-job-scheduler/activitypub-http-unicast-handler.ts

   1 import { logger } from '../../../helpers'
   2 import { doRequest } from '../../../helpers/requests'
   3 import { ActivityPubHttpPayload } from './activitypub-http-job-scheduler'
   4 import { database as db } from '../../../initializers/database'
   5 import { buildSignedActivity } from '../../../helpers/activitypub'
   6
   7 async function process (payload: ActivityPubHttpPayload, jobId: number) {
   8   logger.info('Processing ActivityPub unicast in job %d.', jobId)
   9
  10   const accountSignature = await db.Account.load(payload.signatureAccountId)
  11   if (!accountSignature) throw new Error('Unknown signature account id.')
  12
  13   const signedBody = await buildSignedActivity(accountSignature, payload.body)
  14   const uri = payload.uris[0]
  15   const options = {
  16     method: 'POST',
  17     uri,
  18     json: signedBody
  19   }
  20
  21   await doRequest(options)
  22 }
  23
  24 function onError (err: Error, jobId: number) {
  25   logger.error('Error when sending ActivityPub request in job %d.', jobId, err)
  26   return Promise.resolve()
  27 }
  28
  29 function onSuccess (jobId: number) {
  30   logger.info('Job %d is a success.', jobId)
  31   return Promise.resolve()
  32 }
  33
  34 // ---------------------------------------------------------------------------
  35
  36 export {
  37   process,
  38   onError,
  39   onSuccess
  40 }