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/activitypub/actor'
   5 import { VideoModel } from '../../models/video/video'
   6 import { VideoShareModel } from '../../models/video/video-share'
   7 import { MActorFollowersUrl, MActorLight, MCommentOwner, MCommentOwnerVideo, MVideo, MVideoAccountLight } from '../../typings/models'
   8
   9 function getRemoteVideoAudience (video: MVideoAccountLight, actorsInvolvedInVideo: MActorFollowersUrl[]): ActivityAudience {
  10   return {
  11     to: [ video.VideoChannel.Account.Actor.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     cc.push(parentComment.Account.Actor.url)
  36   }
  37
  38   return {
  39     to,
  40     cc: cc.concat(actorsInvolvedInVideo.map(a => a.followersUrl))
  41   }
  42 }
  43
  44 function getAudienceFromFollowersOf (actorsInvolvedInObject: MActorFollowersUrl[]): ActivityAudience {
  45   return {
  46     to: [ ACTIVITY_PUB.PUBLIC ].concat(actorsInvolvedInObject.map(a => a.followersUrl)),
  47     cc: []
  48   }
  49 }
  50
  51 async function getActorsInvolvedInVideo (video: MVideo, t: Transaction) {
  52   const actors: MActorLight[] = await VideoShareModel.loadActorsByShare(video.id, t)
  53
  54   const videoAll = video as VideoModel
  55
  56   const videoActor = videoAll.VideoChannel && videoAll.VideoChannel.Account
  57     ? videoAll.VideoChannel.Account.Actor
  58     : await ActorModel.loadFromAccountByVideoId(video.id, t)
  59
  60   actors.push(videoActor)
  61
  62   return actors
  63 }
  64
  65 function getAudience (actorSender: MActorFollowersUrl, isPublic = true) {
  66   return buildAudience([ actorSender.followersUrl ], isPublic)
  67 }
  68
  69 function buildAudience (followerUrls: string[], isPublic = true) {
  70   let to: string[] = []
  71   let cc: string[] = []
  72
  73   if (isPublic) {
  74     to = [ ACTIVITY_PUB.PUBLIC ]
  75     cc = followerUrls
  76   } else { // Unlisted
  77     to = []
  78     cc = []
  79   }
  80
  81   return { to, cc }
  82 }
  83
  84 function audiencify<T> (object: T, audience: ActivityAudience) {
  85   return Object.assign(object, audience)
  86 }
  87
  88 // ---------------------------------------------------------------------------
  89
  90 export {
  91   buildAudience,
  92   getAudience,
  93   getRemoteVideoAudience,
  94   getActorsInvolvedInVideo,
  95   getAudienceFromFollowersOf,
  96   audiencify,
  97   getVideoCommentAudience
  98 }