server/lib/activitypub/send/send-undo.ts

   1 import { Transaction } from 'sequelize'
   2 import {
   3   ActivityAudience,
   4   ActivityCreate,
   5   ActivityFollow,
   6   ActivityLike,
   7   ActivityUndo
   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'
  13 import {
  14   audiencify,
  15   broadcastToFollowers,
  16   getActorsInvolvedInVideo,
  17   getAudience,
  18   getObjectFollowersAudience,
  19   getOriginVideoAudience,
  20   unicastTo
  21 } from './misc'
  22 import { createActivityData, createDislikeActivityData } from './send-create'
  23 import { followActivityData } from './send-follow'
  24 import { likeActivityData } from './send-like'
  25
  26 async function sendUndoFollow (actorFollow: ActorFollowModel, t: Transaction) {
  27   const me = actorFollow.ActorFollower
  28   const following = actorFollow.ActorFollowing
  29
  30   const followUrl = getActorFollowActivityPubUrl(actorFollow)
  31   const undoUrl = getUndoActivityPubUrl(followUrl)
  32
  33   const object = followActivityData(followUrl, me, following)
  34   const data = await undoActivityData(undoUrl, me, object, t)
  35
  36   return unicastTo(data, me, following.inboxUrl, t)
  37 }
  38
  39 async function sendUndoLikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
  40   const likeUrl = getVideoLikeActivityPubUrl(byActor, video)
  41   const undoUrl = getUndoActivityPubUrl(likeUrl)
  42
  43   const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
  44   const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
  45   const object = await likeActivityData(likeUrl, byActor, video, t)
  46   const data = await undoActivityData(undoUrl, byActor, object, t, audience)
  47
  48   return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
  49 }
  50
  51 async function sendUndoLikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
  52   const likeUrl = getVideoLikeActivityPubUrl(byActor, video)
  53   const undoUrl = getUndoActivityPubUrl(likeUrl)
  54
  55   const toActorsFollowers = await getActorsInvolvedInVideo(video, t)
  56   const audience = getObjectFollowersAudience(toActorsFollowers)
  57   const object = await likeActivityData(likeUrl, byActor, video, t)
  58   const data = await undoActivityData(undoUrl, byActor, object, t, audience)
  59
  60   const followersException = [ byActor ]
  61   return broadcastToFollowers(data, byActor, toActorsFollowers, t, followersException)
  62 }
  63
  64 async function sendUndoDislikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) {
  65   const dislikeUrl = getVideoDislikeActivityPubUrl(byActor, video)
  66   const undoUrl = getUndoActivityPubUrl(dislikeUrl)
  67
  68   const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
  69   const audience = getOriginVideoAudience(video, actorsInvolvedInVideo)
  70   const dislikeActivity = createDislikeActivityData(byActor, video)
  71   const object = await createActivityData(undoUrl, byActor, dislikeActivity, t)
  72
  73   const data = await undoActivityData(undoUrl, byActor, object, t, audience)
  74
  75   return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t)
  76 }
  77
  78 async function sendUndoDislikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) {
  79   const dislikeUrl = getVideoDislikeActivityPubUrl(byActor, video)
  80   const undoUrl = getUndoActivityPubUrl(dislikeUrl)
  81
  82   const dislikeActivity = createDislikeActivityData(byActor, video)
  83   const object = await createActivityData(undoUrl, byActor, dislikeActivity, t)
  84
  85   const data = await undoActivityData(undoUrl, byActor, object, t)
  86
  87   const toActorsFollowers = await getActorsInvolvedInVideo(video, t)
  88
  89   const followersException = [ byActor ]
  90   return broadcastToFollowers(data, byActor, toActorsFollowers, t, followersException)
  91 }
  92
  93 // ---------------------------------------------------------------------------
  94
  95 export {
  96   sendUndoFollow,
  97   sendUndoLikeToOrigin,
  98   sendUndoLikeToVideoFollowers,
  99   sendUndoDislikeToOrigin,
 100   sendUndoDislikeToVideoFollowers
 101 }
 102
 103 // ---------------------------------------------------------------------------
 104
 105 async function undoActivityData (
 106   url: string,
 107   byActor: ActorModel,
 108   object: ActivityFollow | ActivityLike | ActivityCreate,
 109   t: Transaction,
 110   audience?: ActivityAudience
 111 ): Promise<ActivityUndo> {
 112   if (!audience) {
 113     audience = await getAudience(byActor, t)
 114   }
 115
 116   return audiencify({
 117     type: 'Undo',
 118     id: url,
 119     actor: byActor.url,
 120     object
 121   }, audience)
 122 }