1 import { Transaction } from 'sequelize'
8 } from '../../../../shared/models/activitypub'
9 import { ActorModel } from '../../../models/activitypub/actor'
10 import { ActorFollowModel } from '../../../models/activitypub/actor-follow'
11 import { VideoModel } from '../../../models/video/video'
12 import { getActorFollowActivityPubUrl, getUndoActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoLikeActivityPubUrl } from '../url'
15 getActorsInvolvedInVideo,
17 getObjectFollowersAudience,
18 getOriginVideoAudience,
21 import { createActivityData, createDislikeActivityData } from './send-create'
22 import { followActivityData } from './send-follow'
23 import { likeActivityData } from './send-like'
25 async function sendUndoFollow (actorFollow: ActorFollowModel, t: Transaction) {
26 const me = actorFollow.ActorFollower
27 const following = actorFollow.ActorFollowing
29 const followUrl = getActorFollowActivityPubUrl(actorFollow)
30 const undoUrl = getUndoActivityPubUrl(followUrl)
32 const object = followActivityData(followUrl, me, following)
33 const data = await undoActivityData(undoUrl, me, object, t)
35 return unicastTo(data, me, following.inboxUrl, t)
38 async function sendUndoLikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
39 const likeUrl = getVideoLikeActivityPubUrl(byActor, video)
40 const undoUrl = getUndoActivityPubUrl(likeUrl)
42 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
43 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
44 const object = await likeActivityData(likeUrl, byActor, video, t)
45 const data = await undoActivityData(undoUrl, byActor, object, t, audience)
47 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
50 async function sendUndoLikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
51 const likeUrl = getVideoLikeActivityPubUrl(byActor, video)
52 const undoUrl = getUndoActivityPubUrl(likeUrl)
54 const toActorsFollowers = await getActorsInvolvedInVideo(video, t)
55 const audience = getObjectFollowersAudience(toActorsFollowers)
56 const object = await likeActivityData(likeUrl, byActor, video, t)
57 const data = await undoActivityData(undoUrl, byActor, object, t, audience)
59 const followersException = [ byActor ]
60 return broadcastToFollowers(data, byActor, toActorsFollowers, t, followersException)
63 async function sendUndoDislikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
64 const dislikeUrl = getVideoDislikeActivityPubUrl(byActor, video)
65 const undoUrl = getUndoActivityPubUrl(dislikeUrl)
67 const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
68 const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
69 const dislikeActivity = createDislikeActivityData(byActor, video)
70 const object = await createActivityData(undoUrl, byActor, dislikeActivity, t)
72 const data = await undoActivityData(undoUrl, byActor, object, t, audience)
74 return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
77 async function sendUndoDislikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
78 const dislikeUrl = getVideoDislikeActivityPubUrl(byActor, video)
79 const undoUrl = getUndoActivityPubUrl(dislikeUrl)
81 const dislikeActivity = createDislikeActivityData(byActor, video)
82 const object = await createActivityData(undoUrl, byActor, dislikeActivity, t)
84 const data = await undoActivityData(undoUrl, byActor, object, t)
86 const toActorsFollowers = await getActorsInvolvedInVideo(video, t)
88 const followersException = [ byActor ]
89 return broadcastToFollowers(data, byActor, toActorsFollowers, t, followersException)
92 // ---------------------------------------------------------------------------
97 sendUndoLikeToVideoFollowers,
98 sendUndoDislikeToOrigin,
99 sendUndoDislikeToVideoFollowers
102 // ---------------------------------------------------------------------------
104 async function undoActivityData (
107 object: ActivityFollow | ActivityLike | ActivityCreate,
109 audience?: ActivityAudience
110 ): Promise<ActivityUndo> {
112 audience = await getAudience(byActor, t)