server/lib/job-queue/handlers/activitypub-http-broadcast.ts

   1 import * as kue from 'kue'
   2 import { logger } from '../../../helpers/logger'
   3 import { doRequest } from '../../../helpers/requests'
   4 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
   5 import { buildSignedRequestOptions, computeBody } from './utils/activitypub-http-utils'
   6
   7 export type ActivitypubHttpBroadcastPayload = {
   8   uris: string[]
   9   signatureActorId?: number
  10   body: any
  11 }
  12
  13 async function processActivityPubHttpBroadcast (job: kue.Job) {
  14   logger.info('Processing ActivityPub broadcast in job %d.', job.id)
  15
  16   const payload = job.data as ActivitypubHttpBroadcastPayload
  17
  18   const body = await computeBody(payload)
  19   const httpSignatureOptions = await buildSignedRequestOptions(payload)
  20
  21   const options = {
  22     method: 'POST',
  23     uri: '',
  24     json: body,
  25     httpSignature: httpSignatureOptions
  26   }
  27
  28   const badUrls: string[] = []
  29   const goodUrls: string[] = []
  30
  31   for (const uri of payload.uris) {
  32     options.uri = uri
  33
  34     try {
  35       await doRequest(options)
  36       goodUrls.push(uri)
  37     } catch (err) {
  38       badUrls.push(uri)
  39     }
  40   }
  41
  42   return ActorFollowModel.updateActorFollowsScoreAndRemoveBadOnes(goodUrls, badUrls, undefined)
  43 }
  44
  45 // ---------------------------------------------------------------------------
  46
  47 export {
  48   processActivityPubHttpBroadcast
  49 }