server/lib/activitypub/send/send-announce.ts

   1 import { Transaction } from 'sequelize'
   2 import { ActivityAnnounce, ActivityAudience, ActivityCreate } from '../../../../shared/models/activitypub'
   3 import { VideoPrivacy } from '../../../../shared/models/videos'
   4 import { ActorModel } from '../../../models/activitypub/actor'
   5 import { VideoModel } from '../../../models/video/video'
   6 import { getAnnounceActivityPubUrl } from '../url'
   7 import {
   8   broadcastToFollowers,
   9   getActorsInvolvedInVideo,
  10   getAudience,
  11   getObjectFollowersAudience,
  12   getOriginVideoAudience,
  13   unicastTo
  14 } from './misc'
  15 import { createActivityData } from './send-create'
  16
  17 async function buildVideoAnnounceToFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
  18   const url = getAnnounceActivityPubUrl(video.url, byActor)
  19   const videoObject = video.toActivityPubObject()
  20
  21   const announcedAudience = await getAudience(byActor, t, video.privacy === VideoPrivacy.PUBLIC)
  22   const announcedActivity = await createActivityData(url, video.VideoChannel.Account.Actor, videoObject, t, announcedAudience)
  23
  24   const accountsToForwardView = await getActorsInvolvedInVideo(video, t)
  25   const audience = getObjectFollowersAudience(accountsToForwardView)
  26   return announceActivityData(url, byActor, announcedActivity, t, audience)
  27 }
  28
  29 async function sendVideoAnnounceToFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
  30   const data = await buildVideoAnnounceToFollowers(byActor, video, t)
  31
  32   return broadcastToFollowers(data, byActor, [ byActor ], t)
  33 }
  34
  35 async function sendVideoAnnounceToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
  36   const url = getAnnounceActivityPubUrl(video.url, byActor)
  37
  38   const videoObject = video.toActivityPubObject()
  39   const announcedActivity = await createActivityData(url, video.VideoChannel.Account.Actor, videoObject, t)
  40
  41   const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
  42   const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
  43   const data = await createActivityData(url, byActor, announcedActivity, t, audience)
  44
  45   return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
  46 }
  47
  48 async function announceActivityData (
  49   url: string,
  50   byActor: ActorModel,
  51   object: ActivityCreate,
  52   t: Transaction,
  53   audience?: ActivityAudience
  54 ): Promise<ActivityAnnounce> {
  55   if (!audience) {
  56     audience = await getAudience(byActor, t)
  57   }
  58
  59   return {
  60     type: 'Announce',
  61     to: audience.to,
  62     cc: audience.cc,
  63     id: url,
  64     actor: byActor.url,
  65     object
  66   }
  67 }
  68
  69 // ---------------------------------------------------------------------------
  70
  71 export {
  72   sendVideoAnnounceToFollowers,
  73   sendVideoAnnounceToOrigin,
  74   announceActivityData,
  75   buildVideoAnnounceToFollowers
  76 }