server/lib/activitypub/fetch.ts

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