X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fsend%2Fsend-undo.ts;h=a50673c7975cb042f1a8d2d5fa4dce467ce4d2fa;hb=d61b817890d5d5bba61d447518321870498028d8;hp=53fddd0cbfb4b8be0d2f161455b2cc6c363e04f7;hpb=0032ebe94aa83fab761c7de3ceb6210ac4532824;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-undo.ts b/server/lib/activitypub/send/send-undo.ts index 53fddd0cb..a50673c79 100644 --- a/server/lib/activitypub/send/send-undo.ts +++ b/server/lib/activitypub/send/send-undo.ts @@ -1,100 +1,146 @@ import { Transaction } from 'sequelize' -import { ActivityCreate, ActivityFollow, ActivityLike, ActivityUndo } from '../../../../shared/models/activitypub/activity' -import { AccountInstance } from '../../../models' -import { AccountFollowInstance } from '../../../models/account/account-follow-interface' -import { broadcastToFollowers, getAccountsToForwardVideoAction, unicastTo } from './misc' -import { followActivityData } from './send-follow' -import { getAccountFollowActivityPubUrl, getUndoActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoLikeActivityPubUrl } from '../url' -import { VideoInstance } from '../../../models/video/video-interface' -import { likeActivityData } from './send-like' -import { createActivityData, createDislikeActivityData } from './send-create' -import { getServerAccount } from '../../../helpers/utils' - -async function sendUndoFollow (accountFollow: AccountFollowInstance, t: Transaction) { - const me = accountFollow.AccountFollower - const following = accountFollow.AccountFollowing - - const followUrl = getAccountFollowActivityPubUrl(accountFollow) +import { + ActivityAnnounce, + ActivityAudience, + ActivityCreate, + ActivityFollow, + ActivityLike, + ActivityUndo +} from '../../../../shared/models/activitypub' +import { ActorModel } from '../../../models/activitypub/actor' +import { ActorFollowModel } from '../../../models/activitypub/actor-follow' +import { VideoModel } from '../../../models/video/video' +import { getActorFollowActivityPubUrl, getUndoActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoLikeActivityPubUrl } from '../url' +import { broadcastToFollowers, unicastTo } from './utils' +import { audiencify, getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience, getVideoAudience } from '../audience' +import { buildCreateActivity, buildDislikeActivity } from './send-create' +import { buildFollowActivity } from './send-follow' +import { buildLikeActivity } from './send-like' +import { VideoShareModel } from '../../../models/video/video-share' +import { buildAnnounceWithVideoAudience } from './send-announce' +import { logger } from '../../../helpers/logger' +import { VideoRedundancyModel } from '../../../models/redundancy/video-redundancy' + +async function sendUndoFollow (actorFollow: ActorFollowModel, 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 followUrl = getActorFollowActivityPubUrl(actorFollow) const undoUrl = getUndoActivityPubUrl(followUrl) - const object = await followActivityData(followUrl, me, following) - const data = await undoActivityData(undoUrl, me, object) + const followActivity = buildFollowActivity(followUrl, me, following) + const undoActivity = undoActivityData(undoUrl, me, followActivity) - return unicastTo(data, me, following.inboxUrl, t) + return unicastTo(undoActivity, me, following.inboxUrl) } -async function sendUndoLikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const likeUrl = getVideoLikeActivityPubUrl(byAccount, video) +async function sendUndoLike (byActor: ActorModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to undo a like of video %s.', video.url) + + const likeUrl = getVideoLikeActivityPubUrl(byActor, video) const undoUrl = getUndoActivityPubUrl(likeUrl) - const object = await likeActivityData(likeUrl, byAccount, video) - const data = await undoActivityData(undoUrl, byAccount, object) + const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) + const likeActivity = buildLikeActivity(likeUrl, byActor, video) + + // Send to origin + if (video.isOwned() === false) { + const audience = getVideoAudience(video, actorsInvolvedInVideo) + const undoActivity = undoActivityData(undoUrl, byActor, likeActivity, audience) + + return unicastTo(undoActivity, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) + } + + const audience = getObjectFollowersAudience(actorsInvolvedInVideo) + const undoActivity = undoActivityData(undoUrl, byActor, likeActivity, audience) - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) + const followersException = [ byActor ] + return broadcastToFollowers(undoActivity, byActor, actorsInvolvedInVideo, t, followersException) } -async function sendUndoLikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const likeUrl = getVideoLikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(likeUrl) +async function sendUndoDislike (byActor: ActorModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to undo a dislike of video %s.', video.url) + + const dislikeUrl = getVideoDislikeActivityPubUrl(byActor, video) + const undoUrl = getUndoActivityPubUrl(dislikeUrl) - const object = await likeActivityData(likeUrl, byAccount, video) - const data = await undoActivityData(undoUrl, byAccount, object) + const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) + const dislikeActivity = buildDislikeActivity(byActor, video) + const createDislikeActivity = buildCreateActivity(dislikeUrl, byActor, dislikeActivity) - const accountsToForwardView = await getAccountsToForwardVideoAction(byAccount, video) - const serverAccount = await getServerAccount() + if (video.isOwned() === false) { + const audience = getVideoAudience(video, actorsInvolvedInVideo) + const undoActivity = undoActivityData(undoUrl, byActor, createDislikeActivity, audience) - const followersException = [ byAccount ] - return broadcastToFollowers(data, serverAccount, accountsToForwardView, t, followersException) + return unicastTo(undoActivity, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) + } + + const undoActivity = undoActivityData(undoUrl, byActor, createDislikeActivity) + + const followersException = [ byActor ] + return broadcastToFollowers(undoActivity, byActor, actorsInvolvedInVideo, t, followersException) } -async function sendUndoDislikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const dislikeUrl = getVideoDislikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(dislikeUrl) +async function sendUndoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to undo announce %s.', videoShare.url) - const dislikeActivity = createDislikeActivityData(byAccount, video) - const object = await createActivityData(undoUrl, byAccount, dislikeActivity) + const undoUrl = getUndoActivityPubUrl(videoShare.url) - const data = await undoActivityData(undoUrl, byAccount, object) + const { activity: announceActivity, actorsInvolvedInVideo } = await buildAnnounceWithVideoAudience(byActor, videoShare, video, t) + const undoActivity = undoActivityData(undoUrl, byActor, announceActivity) - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) + const followersException = [ byActor ] + return broadcastToFollowers(undoActivity, byActor, actorsInvolvedInVideo, t, followersException) } -async function sendUndoDislikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const dislikeUrl = getVideoDislikeActivityPubUrl(byAccount, video) - const undoUrl = getUndoActivityPubUrl(dislikeUrl) +async function sendUndoCacheFile (byActor: ActorModel, redundancyModel: VideoRedundancyModel, t: Transaction) { + logger.info('Creating job to undo cache file %s.', redundancyModel.url) - const dislikeActivity = createDislikeActivityData(byAccount, video) - const object = await createActivityData(undoUrl, byAccount, dislikeActivity) + const undoUrl = getUndoActivityPubUrl(redundancyModel.url) - const data = await undoActivityData(undoUrl, byAccount, object) + const video = await VideoModel.loadAndPopulateAccountAndServerAndTags(redundancyModel.VideoFile.Video.id) + const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) - const accountsToForwardView = await getAccountsToForwardVideoAction(byAccount, video) - const serverAccount = await getServerAccount() + const audience = getVideoAudience(video, actorsInvolvedInVideo) + const createActivity = buildCreateActivity(redundancyModel.url, byActor, redundancyModel.toActivityPubObject()) - const followersException = [ byAccount ] - return broadcastToFollowers(data, serverAccount, accountsToForwardView, t, followersException) -} + const undoActivity = undoActivityData(undoUrl, byActor, createActivity, audience) + return unicastTo(undoActivity, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) +} // --------------------------------------------------------------------------- export { sendUndoFollow, - sendUndoLikeToOrigin, - sendUndoLikeToVideoFollowers, - sendUndoDislikeToOrigin, - sendUndoDislikeToVideoFollowers + sendUndoLike, + sendUndoDislike, + sendUndoAnnounce, + sendUndoCacheFile } // --------------------------------------------------------------------------- -async function undoActivityData (url: string, byAccount: AccountInstance, object: ActivityFollow | ActivityLike | ActivityCreate) { - const activity: ActivityUndo = { - type: 'Undo', - id: url, - actor: byAccount.url, - object - } - - return activity +function undoActivityData ( + url: string, + byActor: ActorModel, + object: ActivityFollow | ActivityLike | ActivityCreate | ActivityAnnounce, + audience?: ActivityAudience +): ActivityUndo { + if (!audience) audience = getAudience(byActor) + + return audiencify( + { + type: 'Undo' as 'Undo', + id: url, + actor: byActor.url, + object + }, + audience + ) }