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

   1 import { Transaction } from 'sequelize'
   2 import { ActivityAnnounce, ActivityAudience } from '../../../../shared/models/activitypub'
   3 import { ActorModel } from '../../../models/activitypub/actor'
   4 import { VideoModel } from '../../../models/video/video'
   5 import { VideoShareModel } from '../../../models/video/video-share'
   6 import { broadcastToFollowers } from './utils'
   7 import { getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience } from '../audience'
   8 import { logger } from '../../../helpers/logger'
   9
  10 async function buildVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  11   const announcedObject = video.url
  12
  13   const accountsToForwardView = await getActorsInvolvedInVideo(video, t)
  14   const audience = getObjectFollowersAudience(accountsToForwardView)
  15   return announceActivityData(videoShare.url, byActor, announcedObject, audience)
  16 }
  17
  18 async function sendVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  19   const data = await buildVideoAnnounce(byActor, videoShare, video, t)
  20
  21   logger.info('Creating job to send announce %s.', videoShare.url)
  22
  23   return broadcastToFollowers(data, byActor, [ byActor ], t)
  24 }
  25
  26 function announceActivityData (url: string, byActor: ActorModel, object: string, audience?: ActivityAudience): ActivityAnnounce {
  27   if (!audience) audience = getAudience(byActor)
  28
  29   return {
  30     type: 'Announce',
  31     to: audience.to,
  32     cc: audience.cc,
  33     id: url,
  34     actor: byActor.url,
  35     object
  36   }
  37 }
  38
  39 // ---------------------------------------------------------------------------
  40
  41 export {
  42   sendVideoAnnounce,
  43   announceActivityData,
  44   buildVideoAnnounce
  45 }