X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fsend%2Fsend-undo.ts;h=442178c420461922206317c5ceee7e9b521a3aaa;hb=bae616273d455d225d131eb17c56db6c20a0b6b3;hp=878acd21e3ff5eb8e4b5ad6184dfb6f8a5a953ad;hpb=5e3bb76cb6cc17ff2ba5a492ea3ed8358e66a00a;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-undo.ts b/server/lib/activitypub/send/send-undo.ts index 878acd21e..442178c42 100644 --- a/server/lib/activitypub/send/send-undo.ts +++ b/server/lib/activitypub/send/send-undo.ts @@ -1,124 +1,181 @@ import { Transaction } from 'sequelize' import { + ActivityAnnounce, ActivityAudience, ActivityCreate, + ActivityDislike, ActivityFollow, ActivityLike, - ActivityUndo -} from '../../../../shared/models/activitypub/activity' -import { AccountInstance } from '../../../models' -import { AccountFollowInstance } from '../../../models/account/account-follow-interface' -import { VideoInstance } from '../../../models/video/video-interface' -import { getAccountFollowActivityPubUrl, getUndoActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoLikeActivityPubUrl } from '../url' + ActivityUndo, + ContextType +} from '@shared/models' +import { logger } from '../../../helpers/logger' +import { VideoModel } from '../../../models/video/video' import { - broadcastToFollowers, - getAccountsInvolvedInVideo, - getAudience, - getObjectFollowersAudience, - getOriginVideoAudience, - unicastTo -} from './misc' -import { createActivityData, createDislikeActivityData } from './send-create' -import { followActivityData } from './send-follow' -import { likeActivityData } from './send-like' - -async function sendUndoFollow (accountFollow: AccountFollowInstance, t: Transaction) { - const me = accountFollow.AccountFollower - const following = accountFollow.AccountFollowing - - const followUrl = getAccountFollowActivityPubUrl(accountFollow) - const undoUrl = getUndoActivityPubUrl(followUrl) - - const object = await followActivityData(followUrl, me, following) - const data = await undoActivityData(undoUrl, me, object) - - return unicastTo(data, me, following.inboxUrl, t) + MActor, + MActorAudience, + MActorFollowActors, + MActorLight, + MVideo, + MVideoAccountLight, + MVideoRedundancyVideo, + MVideoShare +} from '../../../types/models' +import { audiencify, getAudience } from '../audience' +import { getUndoActivityPubUrl, getVideoDislikeActivityPubUrlByLocalActor, getVideoLikeActivityPubUrlByLocalActor } from '../url' +import { buildAnnounceWithVideoAudience } from './send-announce' +import { buildCreateActivity } from './send-create' +import { buildDislikeActivity } from './send-dislike' +import { buildFollowActivity } from './send-follow' +import { buildLikeActivity } from './send-like' +import { broadcastToFollowers, sendVideoActivityToOrigin, sendVideoRelatedActivity, unicastTo } from './shared/send-utils' + +function sendUndoFollow (actorFollow: MActorFollowActors, t: Transaction) { + const me = actorFollow.ActorFollower + const following = actorFollow.ActorFollowing + + // Same server as ours + if (!following.serverId) return + + logger.info('Creating job to send an unfollow request to %s.', following.url) + + const undoUrl = getUndoActivityPubUrl(actorFollow.url) + + const followActivity = buildFollowActivity(actorFollow.url, me, following) + const undoActivity = undoActivityData(undoUrl, me, followActivity) + + t.afterCommit(() => { + return unicastTo({ + data: undoActivity, + byActor: me, + toActorUrl: following.inboxUrl, + contextType: 'Follow' + }) + }) } -async function sendUndoLikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const likeUrl = getVideoLikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(likeUrl) +// --------------------------------------------------------------------------- + +async function sendUndoAnnounce (byActor: MActorLight, videoShare: MVideoShare, video: MVideo, transaction: Transaction) { + logger.info('Creating job to undo announce %s.', videoShare.url) + + const undoUrl = getUndoActivityPubUrl(videoShare.url) - const accountsInvolvedInVideo = await getAccountsInvolvedInVideo(video) - const audience = getOriginVideoAudience(video, accountsInvolvedInVideo) - const object = await likeActivityData(likeUrl, byAccount, video) - const data = await undoActivityData(undoUrl, byAccount, object, audience) + const { activity: announce, actorsInvolvedInVideo } = await buildAnnounceWithVideoAudience(byActor, videoShare, video, transaction) + const undoActivity = undoActivityData(undoUrl, byActor, announce) - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) + return broadcastToFollowers({ + data: undoActivity, + byActor, + toFollowersOf: actorsInvolvedInVideo, + transaction, + actorsException: [ byActor ], + contextType: 'Announce' + }) } -async function sendUndoLikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const likeUrl = getVideoLikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(likeUrl) +async function sendUndoCacheFile (byActor: MActor, redundancyModel: MVideoRedundancyVideo, transaction: Transaction) { + logger.info('Creating job to undo cache file %s.', redundancyModel.url) - const toAccountsFollowers = await getAccountsInvolvedInVideo(video) - const audience = getObjectFollowersAudience(toAccountsFollowers) - const object = await likeActivityData(likeUrl, byAccount, video) - const data = await undoActivityData(undoUrl, byAccount, object, audience) + const associatedVideo = redundancyModel.getVideo() + if (!associatedVideo) { + logger.warn('Cannot send undo activity for redundancy %s: no video files associated.', redundancyModel.url) + return + } - const followersException = [ byAccount ] - return broadcastToFollowers(data, byAccount, toAccountsFollowers, t, followersException) + const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(associatedVideo.id) + const createActivity = buildCreateActivity(redundancyModel.url, byActor, redundancyModel.toActivityPubObject()) + + return sendUndoVideoRelatedActivity({ + byActor, + video, + url: redundancyModel.url, + activity: createActivity, + contextType: 'CacheFile', + transaction + }) } -async function sendUndoDislikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const dislikeUrl = getVideoDislikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(dislikeUrl) +// --------------------------------------------------------------------------- - const accountsInvolvedInVideo = await getAccountsInvolvedInVideo(video) - const audience = getOriginVideoAudience(video, accountsInvolvedInVideo) - const dislikeActivity = createDislikeActivityData(byAccount, video) - const object = await createActivityData(undoUrl, byAccount, dislikeActivity, audience) +async function sendUndoLike (byActor: MActor, video: MVideoAccountLight, t: Transaction) { + logger.info('Creating job to undo a like of video %s.', video.url) - const data = await undoActivityData(undoUrl, byAccount, object) + const likeUrl = getVideoLikeActivityPubUrlByLocalActor(byActor, video) + const likeActivity = buildLikeActivity(likeUrl, byActor, video) - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) + return sendUndoVideoRateToOriginActivity({ byActor, video, url: likeUrl, activity: likeActivity, transaction: t }) } -async function sendUndoDislikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const dislikeUrl = getVideoDislikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(dislikeUrl) - - const dislikeActivity = createDislikeActivityData(byAccount, video) - const object = await createActivityData(undoUrl, byAccount, dislikeActivity) +async function sendUndoDislike (byActor: MActor, video: MVideoAccountLight, t: Transaction) { + logger.info('Creating job to undo a dislike of video %s.', video.url) - const data = await undoActivityData(undoUrl, byAccount, object) + const dislikeUrl = getVideoDislikeActivityPubUrlByLocalActor(byActor, video) + const dislikeActivity = buildDislikeActivity(dislikeUrl, byActor, video) - const toAccountsFollowers = await getAccountsInvolvedInVideo(video) - - const followersException = [ byAccount ] - return broadcastToFollowers(data, byAccount, toAccountsFollowers, t, followersException) + return sendUndoVideoRateToOriginActivity({ byActor, video, url: dislikeUrl, activity: dislikeActivity, transaction: t }) } // --------------------------------------------------------------------------- export { sendUndoFollow, - sendUndoLikeToOrigin, - sendUndoLikeToVideoFollowers, - sendUndoDislikeToOrigin, - sendUndoDislikeToVideoFollowers + sendUndoLike, + sendUndoDislike, + sendUndoAnnounce, + sendUndoCacheFile } // --------------------------------------------------------------------------- -async function undoActivityData ( +function undoActivityData ( url: string, - byAccount: AccountInstance, - object: ActivityFollow | ActivityLike | ActivityCreate, + byActor: MActorAudience, + object: ActivityFollow | ActivityLike | ActivityDislike | ActivityCreate | ActivityAnnounce, audience?: ActivityAudience -) { - if (!audience) { - audience = await getAudience(byAccount) +): ActivityUndo { + if (!audience) audience = getAudience(byActor) + + return audiencify( + { + type: 'Undo' as 'Undo', + id: url, + actor: byActor.url, + object + }, + audience + ) +} + +async function sendUndoVideoRelatedActivity (options: { + byActor: MActor + video: MVideoAccountLight + url: string + activity: ActivityFollow | ActivityCreate | ActivityAnnounce + contextType: ContextType + transaction: Transaction +}) { + const activityBuilder = (audience: ActivityAudience) => { + const undoUrl = getUndoActivityPubUrl(options.url) + + return undoActivityData(undoUrl, options.byActor, options.activity, audience) } - const activity: ActivityUndo = { - type: 'Undo', - id: url, - actor: byAccount.url, - to: audience.to, - cc: audience.cc, - object + return sendVideoRelatedActivity(activityBuilder, options) +} + +async function sendUndoVideoRateToOriginActivity (options: { + byActor: MActor + video: MVideoAccountLight + url: string + activity: ActivityLike | ActivityDislike + transaction: Transaction +}) { + const activityBuilder = (audience: ActivityAudience) => { + const undoUrl = getUndoActivityPubUrl(options.url) + + return undoActivityData(undoUrl, options.byActor, options.activity, audience) } - return activity + return sendVideoActivityToOrigin(activityBuilder, { ...options, contextType: 'Rate' }) }