1 import { Transaction } from 'sequelize'
10 } from '../../../../shared/models/activitypub'
11 import { logger } from '../../../helpers/logger'
12 import { VideoModel } from '../../../models/video/video'
20 MVideoRedundancyVideo,
22 } from '../../../types/models'
23 import { audiencify, getAudience } from '../audience'
24 import { getUndoActivityPubUrl, getVideoDislikeActivityPubUrlByLocalActor, getVideoLikeActivityPubUrlByLocalActor } from '../url'
25 import { buildAnnounceWithVideoAudience } from './send-announce'
26 import { buildCreateActivity } from './send-create'
27 import { buildDislikeActivity } from './send-dislike'
28 import { buildFollowActivity } from './send-follow'
29 import { buildLikeActivity } from './send-like'
30 import { broadcastToFollowers, sendVideoRelatedActivity, unicastTo } from './utils'
32 function sendUndoFollow (actorFollow: MActorFollowActors, t: Transaction) {
33 const me = actorFollow.ActorFollower
34 const following = actorFollow.ActorFollowing
36 // Same server as ours
37 if (!following.serverId) return
39 logger.info('Creating job to send an unfollow request to %s.', following.url)
41 const undoUrl = getUndoActivityPubUrl(actorFollow.url)
43 const followActivity = buildFollowActivity(actorFollow.url, me, following)
44 const undoActivity = undoActivityData(undoUrl, me, followActivity)
46 t.afterCommit(() => unicastTo(undoActivity, me, following.inboxUrl))
49 async function sendUndoAnnounce (byActor: MActorLight, videoShare: MVideoShare, video: MVideo, t: Transaction) {
50 logger.info('Creating job to undo announce %s.', videoShare.url)
52 const undoUrl = getUndoActivityPubUrl(videoShare.url)
54 const { activity: announceActivity, actorsInvolvedInVideo } = await buildAnnounceWithVideoAudience(byActor, videoShare, video, t)
55 const undoActivity = undoActivityData(undoUrl, byActor, announceActivity)
57 const followersException = [ byActor ]
58 return broadcastToFollowers(undoActivity, byActor, actorsInvolvedInVideo, t, followersException)
61 async function sendUndoLike (byActor: MActor, video: MVideoAccountLight, t: Transaction) {
62 logger.info('Creating job to undo a like of video %s.', video.url)
64 const likeUrl = getVideoLikeActivityPubUrlByLocalActor(byActor, video)
65 const likeActivity = buildLikeActivity(likeUrl, byActor, video)
67 return sendUndoVideoRelatedActivity({ byActor, video, url: likeUrl, activity: likeActivity, transaction: t })
70 async function sendUndoDislike (byActor: MActor, video: MVideoAccountLight, t: Transaction) {
71 logger.info('Creating job to undo a dislike of video %s.', video.url)
73 const dislikeUrl = getVideoDislikeActivityPubUrlByLocalActor(byActor, video)
74 const dislikeActivity = buildDislikeActivity(dislikeUrl, byActor, video)
76 return sendUndoVideoRelatedActivity({ byActor, video, url: dislikeUrl, activity: dislikeActivity, transaction: t })
79 async function sendUndoCacheFile (byActor: MActor, redundancyModel: MVideoRedundancyVideo, t: Transaction) {
80 logger.info('Creating job to undo cache file %s.', redundancyModel.url)
82 const associatedVideo = redundancyModel.getVideo()
83 if (!associatedVideo) {
84 logger.warn('Cannot send undo activity for redundancy %s: no video files associated.', redundancyModel.url)
88 const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(associatedVideo.id)
89 const createActivity = buildCreateActivity(redundancyModel.url, byActor, redundancyModel.toActivityPubObject())
91 return sendUndoVideoRelatedActivity({ byActor, video, url: redundancyModel.url, activity: createActivity, transaction: t })
94 // ---------------------------------------------------------------------------
104 // ---------------------------------------------------------------------------
106 function undoActivityData (
108 byActor: MActorAudience,
109 object: ActivityFollow | ActivityLike | ActivityDislike | ActivityCreate | ActivityAnnounce,
110 audience?: ActivityAudience
112 if (!audience) audience = getAudience(byActor)
116 type: 'Undo' as 'Undo',
125 async function sendUndoVideoRelatedActivity (options: {
127 video: MVideoAccountLight
129 activity: ActivityFollow | ActivityLike | ActivityDislike | ActivityCreate | ActivityAnnounce
130 transaction: Transaction
132 const activityBuilder = (audience: ActivityAudience) => {
133 const undoUrl = getUndoActivityPubUrl(options.url)
135 return undoActivityData(undoUrl, options.byActor, options.activity, audience)
138 return sendVideoRelatedActivity(activityBuilder, options)