diff options
Diffstat (limited to 'server/lib/activitypub/process/process-accept.ts')
| -rw-r--r-- | server/lib/activitypub/process/process-accept.ts | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/server/lib/activitypub/process/process-accept.ts b/server/lib/activitypub/process/process-accept.ts deleted file mode 100644 index 077b01eda..000000000 --- a/server/lib/activitypub/process/process-accept.ts +++ /dev/null | |||
| @@ -1,32 +0,0 @@ | |||
| 1 | import { ActivityAccept } from '../../../../shared/models/activitypub' | ||
| 2 | import { ActorFollowModel } from '../../../models/actor/actor-follow' | ||
| 3 | import { APProcessorOptions } from '../../../types/activitypub-processor.model' | ||
| 4 | import { MActorDefault, MActorSignature } from '../../../types/models' | ||
| 5 | import { addFetchOutboxJob } from '../outbox' | ||
| 6 | |||
| 7 | async function processAcceptActivity (options: APProcessorOptions<ActivityAccept>) { | ||
| 8 | const { byActor: targetActor, inboxActor } = options | ||
| 9 | if (inboxActor === undefined) throw new Error('Need to accept on explicit inbox.') | ||
| 10 | |||
| 11 | return processAccept(inboxActor, targetActor) | ||
| 12 | } | ||
| 13 | |||
| 14 | // --------------------------------------------------------------------------- | ||
| 15 | |||
| 16 | export { | ||
| 17 | processAcceptActivity | ||
| 18 | } | ||
| 19 | |||
| 20 | // --------------------------------------------------------------------------- | ||
| 21 | |||
| 22 | async function processAccept (actor: MActorDefault, targetActor: MActorSignature) { | ||
| 23 | const follow = await ActorFollowModel.loadByActorAndTarget(actor.id, targetActor.id) | ||
| 24 | if (!follow) throw new Error('Cannot find associated follow.') | ||
| 25 | |||
| 26 | if (follow.state !== 'accepted') { | ||
| 27 | follow.state = 'accepted' | ||
| 28 | await follow.save() | ||
| 29 | |||
| 30 | await addFetchOutboxJob(targetActor) | ||
| 31 | } | ||
| 32 | } | ||