1 import { Transaction } from 'sequelize'
2 import { ActivityAudience, ActivityCreate } from '../../../../shared/models/activitypub'
3 import { VideoPrivacy } from '../../../../shared/models/videos'
4 import { getServerActor } from '../../../helpers'
5 import { ActorModel } from '../../../models/activitypub/actor'
6 import { VideoModel } from '../../../models/video/video'
7 import { VideoAbuseModel } from '../../../models/video/video-abuse'
8 import { getVideoAbuseActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoViewActivityPubUrl } from '../url'
12 getActorsInvolvedInVideo,
14 getObjectFollowersAudience,
15 getOriginVideoAudience,
19 async function sendCreateVideo (video: VideoModel, t: Transaction) {
20 if (video.privacy === VideoPrivacy.PRIVATE) return undefined
22 const byActor = video.VideoChannel.Account.Actor
23 const videoObject = video.toActivityPubObject()
25 const audience = await getAudience(byActor, t, video.privacy === VideoPrivacy.PUBLIC)
26 const data = await createActivityData(video.url, byActor, videoObject, t, audience)
28 return broadcastToFollowers(data, byActor, [ byActor ], t)
31 async function sendVideoAbuse (byActor: ActorModel, videoAbuse: VideoAbuseModel, video: VideoModel, t: Transaction) {
32 const url = getVideoAbuseActivityPubUrl(videoAbuse)
34 const audience = { to: [ video.VideoChannel.Account.Actor.url ], cc: [] }
35 const data = await createActivityData(url, byActor, videoAbuse.toActivityPubObject(), t, audience)
37 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
40 async function sendCreateViewToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
41 const url = getVideoViewActivityPubUrl(byActor, video)
42 const viewActivity = createViewActivityData(byActor, video)
44 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
45 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
46 const data = await createActivityData(url, byActor, viewActivity, t, audience)
48 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
51 async function sendCreateViewToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
52 const url = getVideoViewActivityPubUrl(byActor, video)
53 const viewActivity = createViewActivityData(byActor, video)
55 const actorsToForwardView = await getActorsInvolvedInVideo(video, t)
56 const audience = getObjectFollowersAudience(actorsToForwardView)
57 const data = await createActivityData(url, byActor, viewActivity, t, audience)
59 // Use the server actor to send the view
60 const serverActor = await getServerActor()
61 const followersException = [ byActor ]
62 return broadcastToFollowers(data, serverActor, actorsToForwardView, t, followersException)
65 async function sendCreateDislikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
66 const url = getVideoDislikeActivityPubUrl(byActor, video)
67 const dislikeActivity = createDislikeActivityData(byActor, video)
69 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
70 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
71 const data = await createActivityData(url, byActor, dislikeActivity, t, audience)
73 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
76 async function sendCreateDislikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
77 const url = getVideoDislikeActivityPubUrl(byActor, video)
78 const dislikeActivity = createDislikeActivityData(byActor, video)
80 const actorsToForwardView = await getActorsInvolvedInVideo(video, t)
81 const audience = getObjectFollowersAudience(actorsToForwardView)
82 const data = await createActivityData(url, byActor, dislikeActivity, t, audience)
84 const followersException = [ byActor ]
85 return broadcastToFollowers(data, byActor, actorsToForwardView, t, followersException)
88 async function createActivityData (
93 audience?: ActivityAudience
94 ): Promise<ActivityCreate> {
96 audience = await getAudience(byActor, t)
103 object: audiencify(object, audience)
107 function createDislikeActivityData (byActor: ActorModel, video: VideoModel) {
115 // ---------------------------------------------------------------------------
121 sendCreateViewToOrigin,
122 sendCreateViewToVideoFollowers,
123 sendCreateDislikeToOrigin,
124 sendCreateDislikeToVideoFollowers,
125 createDislikeActivityData
128 // ---------------------------------------------------------------------------
130 function createViewActivityData (byActor: ActorModel, video: VideoModel) {