server/lib/activitypub/fetch.ts

   1 import { logger } from '../../helpers/logger'
   2 import { getServerActor } from '../../helpers/utils'
   3 import { ActorModel } from '../../models/activitypub/actor'
   4 import { JobQueue } from '../job-queue'
   5
   6 async function addFetchOutboxJob (actor: ActorModel) {
   7   // Don't fetch ourselves
   8   const serverActor = await getServerActor()
   9   if (serverActor.id === actor.id) {
  10     logger.error('Cannot fetch our own outbox!')
  11     return undefined
  12   }
  13
  14   const payload = {
  15     uris: [ actor.outboxUrl ]
  16   }
  17
  18   return JobQueue.Instance.createJob({ type: 'activitypub-http-fetcher', payload })
  19 }
  20
  21 export {
  22   addFetchOutboxJob
  23 }