server/lib/activitypub/audience.ts

   1 import { Transaction } from 'sequelize'
   2 import { ActivityAudience } from '../../../shared/models/activitypub'
   3 import { ACTIVITY_PUB } from '../../initializers/constants'
   4 import { ActorModel } from '../../models/actor/actor'
   5 import { VideoModel } from '../../models/video/video'
   6 import { VideoShareModel } from '../../models/video/video-share'
   7 import { MActorFollowersUrl, MActorLight, MActorUrl, MCommentOwner, MCommentOwnerVideo, MVideoId } from '../../types/models'
   8
   9 function getRemoteVideoAudience (accountActor: MActorUrl, actorsInvolvedInVideo: MActorFollowersUrl[]): ActivityAudience {
  10   return {
  11     to: [ accountActor.url ],
  12     cc: actorsInvolvedInVideo.map(a => a.followersUrl)
  13   }
  14 }
  15
  16 function getVideoCommentAudience (
  17   videoComment: MCommentOwnerVideo,
  18   threadParentComments: MCommentOwner[],
  19   actorsInvolvedInVideo: MActorFollowersUrl[],
  20   isOrigin = false
  21 ): ActivityAudience {
  22   const to = [ ACTIVITY_PUB.PUBLIC ]
  23   const cc: string[] = []
  24
  25   // Owner of the video we comment
  26   if (isOrigin === false) {
  27     cc.push(videoComment.Video.VideoChannel.Account.Actor.url)
  28   }
  29
  30   // Followers of the poster
  31   cc.push(videoComment.Account.Actor.followersUrl)
  32
  33   // Send to actors we reply to
  34   for (const parentComment of threadParentComments) {
  35     if (parentComment.isDeleted()) continue
  36
  37     cc.push(parentComment.Account.Actor.url)
  38   }
  39
  40   return {
  41     to,
  42     cc: cc.concat(actorsInvolvedInVideo.map(a => a.followersUrl))
  43   }
  44 }
  45
  46 function getAudienceFromFollowersOf (actorsInvolvedInObject: MActorFollowersUrl[]): ActivityAudience {
  47   return {
  48     to: [ ACTIVITY_PUB.PUBLIC ].concat(actorsInvolvedInObject.map(a => a.followersUrl)),
  49     cc: []
  50   }
  51 }
  52
  53 async function getActorsInvolvedInVideo (video: MVideoId, t: Transaction) {
  54   const actors: MActorLight[] = await VideoShareModel.loadActorsByShare(video.id, t)
  55
  56   const videoAll = video as VideoModel
  57
  58   const videoActor = videoAll.VideoChannel?.Account
  59     ? videoAll.VideoChannel.Account.Actor
  60     : await ActorModel.loadFromAccountByVideoId(video.id, t)
  61
  62   actors.push(videoActor)
  63
  64   return actors
  65 }
  66
  67 function getAudience (actorSender: MActorFollowersUrl, isPublic = true) {
  68   return buildAudience([ actorSender.followersUrl ], isPublic)
  69 }
  70
  71 function buildAudience (followerUrls: string[], isPublic = true) {
  72   let to: string[] = []
  73   let cc: string[] = []
  74
  75   if (isPublic) {
  76     to = [ ACTIVITY_PUB.PUBLIC ]
  77     cc = followerUrls
  78   } else { // Unlisted
  79     to = []
  80     cc = []
  81   }
  82
  83   return { to, cc }
  84 }
  85
  86 function audiencify<T> (object: T, audience: ActivityAudience) {
  87   return Object.assign(object, audience)
  88 }
  89
  90 // ---------------------------------------------------------------------------
  91
  92 export {
  93   buildAudience,
  94   getAudience,
  95   getRemoteVideoAudience,
  96   getActorsInvolvedInVideo,
  97   getAudienceFromFollowersOf,
  98   audiencify,
  99   getVideoCommentAudience
 100 }