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   const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
  24   const followersException = [ byActor ]
  25
  26   return broadcastToFollowers(data, byActor, actorsInvolvedInVideo, t, followersException)
  27 }
  28
  29 function announceActivityData (url: string, byActor: ActorModel, object: string, audience?: ActivityAudience): ActivityAnnounce {
  30   if (!audience) audience = getAudience(byActor)
  31
  32   return {
  33     type: 'Announce',
  34     to: audience.to,
  35     cc: audience.cc,
  36     id: url,
  37     actor: byActor.url,
  38     object
  39   }
  40 }
  41
  42 // ---------------------------------------------------------------------------
  43
  44 export {
  45   sendVideoAnnounce,
  46   announceActivityData,
  47   buildVideoAnnounce
  48 }