server/lib/job-queue/handlers/actor-keys.ts

   1 import { Job } from 'bull'
   2 import { generateAndSaveActorKeys } from '@server/lib/activitypub/actors'
   3 import { ActorModel } from '@server/models/actor/actor'
   4 import { ActorKeysPayload } from '@shared/models'
   5 import { logger } from '../../../helpers/logger'
   6
   7 async function processActorKeys (job: Job) {
   8   const payload = job.data as ActorKeysPayload
   9   logger.info('Processing actor keys in job %d.', job.id)
  10
  11   const actor = await ActorModel.load(payload.actorId)
  12
  13   await generateAndSaveActorKeys(actor)
  14 }
  15
  16 // ---------------------------------------------------------------------------
  17
  18 export {
  19   processActorKeys
  20 }