From 136d7efde798d3dc0ec0dd18aac674365f7d162e Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Thu, 3 Jun 2021 16:02:29 +0200 Subject: Refactor AP actors --- server/lib/activitypub/outbox.ts | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) create mode 100644 server/lib/activitypub/outbox.ts (limited to 'server/lib/activitypub/outbox.ts') diff --git a/server/lib/activitypub/outbox.ts b/server/lib/activitypub/outbox.ts new file mode 100644 index 000000000..ecdc33a77 --- /dev/null +++ b/server/lib/activitypub/outbox.ts @@ -0,0 +1,24 @@ +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 +} -- cgit v1.2.3