import { logger } from '@server/helpers/logger' ; import { ActorModel } from '@server/models/actor/actor' ; import { getServerActor } from '@server/models/application/application' ; import { JobQueue } from '../job-queue' ; async function addFetchOutboxJob ( actor ) { const serverActor = await getServerActor ( ) ; if ( serverActor . id === actor . id ) { logger . error ( 'Cannot fetch our own outbox!' ) ; return undefined ; } const payload = { uri : actor . outboxUrl , type : 'activity' as 'activity' } ; return JobQueue . Instance . createJob ( { type : 'activitypub-http-fetcher' , payload } ) ; } export { addFetchOutboxJob } ;