server/lib/activitypub/fetch.ts

   1 import { Transaction } from 'sequelize'
   2 import { ActorModel } from '../../models/activitypub/actor'
   3 import { activitypubHttpJobScheduler, ActivityPubHttpPayload } from '../jobs/activitypub-http-job-scheduler'
   4
   5 async function addFetchOutboxJob (actor: ActorModel, t: Transaction) {
   6   const jobPayload: ActivityPubHttpPayload = {
   7     uris: [ actor.outboxUrl ]
   8   }
   9
  10   return activitypubHttpJobScheduler.createJob(t, 'activitypubHttpFetcherHandler', jobPayload)
  11 }
  12
  13 export {
  14   addFetchOutboxJob
  15 }