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: Pick) { // Don't fetch ourselves 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 }