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
   9 async function buildVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  10   const announcedObject = video.url
  11
  12   const accountsToForwardView = await getActorsInvolvedInVideo(video, t)
  13   const audience = getObjectFollowersAudience(accountsToForwardView)
  14   return announceActivityData(videoShare.url, byActor, announcedObject, audience)
  15 }
  16
  17 async function sendVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  18   const data = await buildVideoAnnounce(byActor, videoShare, video, t)
  19
  20   return broadcastToFollowers(data, byActor, [ byActor ], t)
  21 }
  22
  23 function announceActivityData (url: string, byActor: ActorModel, object: string, audience?: ActivityAudience): ActivityAnnounce {
  24   if (!audience) audience = getAudience(byActor)
  25
  26   return {
  27     type: 'Announce',
  28     to: audience.to,
  29     cc: audience.cc,
  30     id: url,
  31     actor: byActor.url,
  32     object
  33   }
  34 }
  35
  36 // ---------------------------------------------------------------------------
  37
  38 export {
  39   sendVideoAnnounce,
  40   announceActivityData,
  41   buildVideoAnnounce
  42 }