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'
11 getActorsInvolvedInVideo,
13 getObjectFollowersAudience,
14 getOriginVideoAudience,
18 async function sendCreateVideo (video: VideoModel, t: Transaction) {
19 const byActor = video.VideoChannel.Account.Actor
21 const videoObject = video.toActivityPubObject()
22 const audience = await getAudience(byActor, t, video.privacy === VideoPrivacy.PUBLIC)
23 const data = await createActivityData(video.url, byActor, videoObject, t, audience)
25 return broadcastToFollowers(data, byActor, [ byActor ], t)
28 async function sendVideoAbuse (byActor: ActorModel, videoAbuse: VideoAbuseModel, video: VideoModel, t: Transaction) {
29 const url = getVideoAbuseActivityPubUrl(videoAbuse)
31 const audience = { to: [ video.VideoChannel.Account.Actor.url ], cc: [] }
32 const data = await createActivityData(url, byActor, videoAbuse.toActivityPubObject(), t, audience)
34 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
37 async function sendCreateViewToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
38 const url = getVideoViewActivityPubUrl(byActor, video)
39 const viewActivity = createViewActivityData(byActor, video)
41 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
42 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
43 const data = await createActivityData(url, byActor, viewActivity, t, audience)
45 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
48 async function sendCreateViewToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
49 const url = getVideoViewActivityPubUrl(byActor, video)
50 const viewActivity = createViewActivityData(byActor, video)
52 const actorsToForwardView = await getActorsInvolvedInVideo(video, t)
53 const audience = getObjectFollowersAudience(actorsToForwardView)
54 const data = await createActivityData(url, byActor, viewActivity, t, audience)
56 // Use the server actor to send the view
57 const serverActor = await getServerActor()
58 const followersException = [ byActor ]
59 return broadcastToFollowers(data, serverActor, actorsToForwardView, t, followersException)
62 async function sendCreateDislikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
63 const url = getVideoDislikeActivityPubUrl(byActor, video)
64 const dislikeActivity = createDislikeActivityData(byActor, video)
66 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
67 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
68 const data = await createActivityData(url, byActor, dislikeActivity, t, audience)
70 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
73 async function sendCreateDislikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
74 const url = getVideoDislikeActivityPubUrl(byActor, video)
75 const dislikeActivity = createDislikeActivityData(byActor, video)
77 const actorsToForwardView = await getActorsInvolvedInVideo(video, t)
78 const audience = getObjectFollowersAudience(actorsToForwardView)
79 const data = await createActivityData(url, byActor, dislikeActivity, t, audience)
81 const followersException = [ byActor ]
82 return broadcastToFollowers(data, byActor, actorsToForwardView, t, followersException)
85 async function createActivityData (
90 audience?: ActivityAudience
91 ): Promise<ActivityCreate> {
93 audience = await getAudience(byActor, t)
106 function createDislikeActivityData (byActor: ActorModel, video: VideoModel) {
114 // ---------------------------------------------------------------------------
120 sendCreateViewToOrigin,
121 sendCreateViewToVideoFollowers,
122 sendCreateDislikeToOrigin,
123 sendCreateDislikeToVideoFollowers,
124 createDislikeActivityData
127 // ---------------------------------------------------------------------------
129 function createViewActivityData (byActor: ActorModel, video: VideoModel) {