]>
Commit | Line | Data |
---|---|---|
136d7efd C |
1 | import { logger } from '@server/helpers/logger' |
2 | import { ActorModel } from '@server/models/actor/actor' | |
3 | import { getServerActor } from '@server/models/application/application' | |
4 | import { JobQueue } from '../job-queue' | |
5 | ||
6 | async function addFetchOutboxJob (actor: Pick<ActorModel, 'id' | 'outboxUrl'>) { | |
7 | // Don't fetch ourselves | |
8 | const serverActor = await getServerActor() | |
9 | if (serverActor.id === actor.id) { | |
10 | logger.error('Cannot fetch our own outbox!') | |
11 | return undefined | |
12 | } | |
13 | ||
14 | const payload = { | |
15 | uri: actor.outboxUrl, | |
16 | type: 'activity' as 'activity' | |
17 | } | |
18 | ||
bd911b54 | 19 | return JobQueue.Instance.createJobAsync({ type: 'activitypub-http-fetcher', payload }) |
136d7efd C |
20 | } |
21 | ||
22 | export { | |
23 | addFetchOutboxJob | |
24 | } |