]>
Commit | Line | Data |
---|---|---|
285fe7c9 C |
1 | import { logger } from '../../helpers/logger' |
2 | import { getServerActor } from '../../helpers/utils' | |
50d6de9c | 3 | import { ActorModel } from '../../models/activitypub/actor' |
94a5ff8a | 4 | import { JobQueue } from '../job-queue' |
c986175d | 5 | |
94a5ff8a | 6 | async function addFetchOutboxJob (actor: ActorModel) { |
285fe7c9 C |
7 | // Don't fetch ourselves |
8 | const serverActor = await getServerActor() | |
9 | if (serverActor.id === actor.id) { | |
10 | logger.error('Cannot fetch our own outbox!') | |
e3bb78a2 | 11 | return undefined |
285fe7c9 C |
12 | } |
13 | ||
94a5ff8a | 14 | const payload = { |
50d6de9c | 15 | uris: [ actor.outboxUrl ] |
c986175d C |
16 | } |
17 | ||
94a5ff8a | 18 | return JobQueue.Instance.createJob({ type: 'activitypub-http-fetcher', payload }) |
c986175d C |
19 | } |
20 | ||
21 | export { | |
22 | addFetchOutboxJob | |
23 | } |