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 { audiencify, getActorsInvolvedInVideo, getAudience, getAudienceFromFollowersOf } from '../audience'
   8 import { logger } from '../../../helpers/logger'
   9
  10 async function buildAnnounceWithVideoAudience (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  11   const announcedObject = video.url
  12
  13   const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
  14   const audience = getAudienceFromFollowersOf(actorsInvolvedInVideo)
  15
  16   const activity = buildAnnounceActivity(videoShare.url, byActor, announcedObject, audience)
  17
  18   return { activity, actorsInvolvedInVideo }
  19 }
  20
  21 async function sendVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
  22   const { activity, actorsInvolvedInVideo } = await buildAnnounceWithVideoAudience(byActor, videoShare, video, t)
  23
  24   logger.info('Creating job to send announce %s.', videoShare.url)
  25
  26   const followersException = [ byActor ]
  27   return broadcastToFollowers(activity, byActor, actorsInvolvedInVideo, t, followersException)
  28 }
  29
  30 function buildAnnounceActivity (url: string, byActor: ActorModel, object: string, audience?: ActivityAudience): ActivityAnnounce {
  31   if (!audience) audience = getAudience(byActor)
  32
  33   return audiencify({
  34     type: 'Announce' as 'Announce',
  35     id: url,
  36     actor: byActor.url,
  37     object
  38   }, audience)
  39 }
  40
  41 // ---------------------------------------------------------------------------
  42
  43 export {
  44   sendVideoAnnounce,
  45   buildAnnounceActivity,
  46   buildAnnounceWithVideoAudience
  47 }