]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame - server/lib/activitypub/process/process-accept.ts
Only use account name in routes
[github/Chocobozzz/PeerTube.git] / server / lib / activitypub / process / process-accept.ts
CommitLineData
3fd3ab2d 1import { ActivityAccept } from '../../../../shared/models/activitypub'
6be84cbc 2import { getActorUrl } from '../../../helpers/activitypub'
50d6de9c
C
3import { ActorModel } from '../../../models/activitypub/actor'
4import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
c46edbc2 5import { addFetchOutboxJob } from '../fetch'
7a7724e6 6
50d6de9c
C
7async function processAcceptActivity (activity: ActivityAccept, inboxActor?: ActorModel) {
8 if (inboxActor === undefined) throw new Error('Need to accept on explicit inbox.')
7a7724e6 9
6be84cbc
C
10 const actorUrl = getActorUrl(activity.actor)
11 const targetActor = await ActorModel.loadByUrl(actorUrl)
7a7724e6 12
50d6de9c 13 return processAccept(inboxActor, targetActor)
7a7724e6
C
14}
15
16// ---------------------------------------------------------------------------
17
18export {
19 processAcceptActivity
20}
21
22// ---------------------------------------------------------------------------
23
50d6de9c
C
24async function processAccept (actor: ActorModel, targetActor: ActorModel) {
25 const follow = await ActorFollowModel.loadByActorAndTarget(actor.id, targetActor.id)
7a7724e6
C
26 if (!follow) throw new Error('Cannot find associated follow.')
27
7bc29171
C
28 if (follow.state !== 'accepted') {
29 follow.set('state', 'accepted')
30 await follow.save()
94a5ff8a 31 await addFetchOutboxJob(targetActor)
7bc29171 32 }
7a7724e6 33}