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

   1 import { ActivityAnnounce } from '../../../../shared/models/activitypub/activity'
   2 import { logger } from '../../../helpers/logger'
   3 import { database as db } from '../../../initializers/index'
   4 import { VideoInstance } from '../../../models/index'
   5 import { VideoChannelInstance } from '../../../models/video/video-channel-interface'
   6 import { processAddActivity } from './process-add'
   7 import { processCreateActivity } from './process-create'
   8 import { getOrCreateAccountAndServer } from '../account'
   9
  10 async function processAnnounceActivity (activity: ActivityAnnounce) {
  11   const announcedActivity = activity.object
  12   const accountAnnouncer = await getOrCreateAccountAndServer(activity.actor)
  13
  14   if (announcedActivity.type === 'Create' && announcedActivity.object.type === 'VideoChannel') {
  15     // Add share entry
  16     const videoChannel: VideoChannelInstance = await processCreateActivity(announcedActivity)
  17     await db.VideoChannelShare.create({
  18       accountId: accountAnnouncer.id,
  19       videoChannelId: videoChannel.id
  20     })
  21
  22     return undefined
  23   } else if (announcedActivity.type === 'Add' && announcedActivity.object.type === 'Video') {
  24     // Add share entry
  25     const video: VideoInstance = await processAddActivity(announcedActivity)
  26     await db.VideoShare.create({
  27       accountId: accountAnnouncer.id,
  28       videoId: video.id
  29     })
  30
  31     return undefined
  32   }
  33
  34   logger.warn(
  35     'Unknown activity object type %s -> %s when announcing activity.', announcedActivity.type, announcedActivity.object.type,
  36     { activity: activity.id }
  37   )
  38
  39   return undefined
  40 }
  41
  42 // ---------------------------------------------------------------------------
  43
  44 export {
  45   processAnnounceActivity
  46 }