server/lib/activitypub/process/process-accept.ts

   1 import { ActivityAccept } from '../../../../shared/models/activitypub'
   2 import { ActorModel } from '../../../models/activitypub/actor'
   3 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
   4 import { addFetchOutboxJob } from '../actor'
   5 import { APProcessorOptions } from '../../../typings/activitypub-processor.model'
   6 import { SignatureActorModel } from '../../../typings/models'
   7
   8 async function processAcceptActivity (options: APProcessorOptions<ActivityAccept>) {
   9   const { byActor: targetActor, inboxActor } = options
  10   if (inboxActor === undefined) throw new Error('Need to accept on explicit inbox.')
  11
  12   return processAccept(inboxActor, targetActor)
  13 }
  14
  15 // ---------------------------------------------------------------------------
  16
  17 export {
  18   processAcceptActivity
  19 }
  20
  21 // ---------------------------------------------------------------------------
  22
  23 async function processAccept (actor: ActorModel, targetActor: SignatureActorModel) {
  24   const follow = await ActorFollowModel.loadByActorAndTarget(actor.id, targetActor.id)
  25   if (!follow) throw new Error('Cannot find associated follow.')
  26
  27   if (follow.state !== 'accepted') {
  28     follow.set('state', 'accepted')
  29     await follow.save()
  30
  31     await addFetchOutboxJob(targetActor)
  32   }
  33 }