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

   1 import { logger } from '../../../helpers/logger'
   2 import { doRequest } from '../../../helpers/requests'
   3 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
   4 import { ActivityPubHttpPayload, buildSignedRequestOptions, computeBody, maybeRetryRequestLater } from './activitypub-http-job-scheduler'
   5
   6 async function process (payload: ActivityPubHttpPayload, jobId: number) {
   7   logger.info('Processing ActivityPub unicast in job %d.', jobId)
   8
   9   const uri = payload.uris[0]
  10
  11   const body = await computeBody(payload)
  12   const httpSignatureOptions = await buildSignedRequestOptions(payload)
  13
  14   const options = {
  15     method: 'POST',
  16     uri,
  17     json: body,
  18     httpSignature: httpSignatureOptions
  19   }
  20
  21   try {
  22     await doRequest(options)
  23     ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([ uri ], [], undefined)
  24   } catch (err) {
  25     const isRetryingLater = await maybeRetryRequestLater(err, payload, uri)
  26     if (isRetryingLater === false) {
  27       ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes([], [ uri ], undefined)
  28     }
  29
  30     throw err
  31   }
  32 }
  33
  34 function onError (err: Error, jobId: number) {
  35   logger.error('Error when sending ActivityPub request in job %d.', jobId, err)
  36   return Promise.resolve()
  37 }
  38
  39 function onSuccess (jobId: number) {
  40   logger.info('Job %d is a success.', jobId)
  41   return Promise.resolve()
  42 }
  43
  44 // ---------------------------------------------------------------------------
  45
  46 export {
  47   process,
  48   onError,
  49   onSuccess
  50 }