25 lines
686 B
TypeScript
25 lines
686 B
TypeScript
|
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<ActorModel, 'id' | 'outboxUrl'>) {
|
||
|
|
// 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
|
||
|
|
}
|