X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;ds=sidebyside;f=server%2Flib%2Factivitypub%2Fsend%2Fsend-like.ts;h=83225f5df1d62186561e40a43953815d35773c13;hb=8e0fd45e14993793c64e06682a4a05c29068d398;hp=0c464b2d3f401c6c185632abb945359e12caf0f1;hpb=25ed141c7c7631ef21d8764c1163fbf8a6591391;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-like.ts b/server/lib/activitypub/send/send-like.ts index 0c464b2d3..83225f5df 100644 --- a/server/lib/activitypub/send/send-like.ts +++ b/server/lib/activitypub/send/send-like.ts @@ -1,64 +1,52 @@ import { Transaction } from 'sequelize' -import { ActivityAudience, ActivityLike } from '../../../../shared/models/activitypub/activity' -import { AccountInstance, VideoInstance } from '../../../models' +import { ActivityAudience, ActivityLike } from '../../../../shared/models/activitypub' +import { ActorModel } from '../../../models/activitypub/actor' +import { VideoModel } from '../../../models/video/video' import { getVideoLikeActivityPubUrl } from '../url' -import { - broadcastToFollowers, - getAccountsInvolvedInVideo, - getAudience, - getOriginVideoAudience, - getObjectFollowersAudience, - unicastTo -} from './misc' +import { broadcastToFollowers, unicastTo } from './utils' +import { audiencify, getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience, getVideoAudience } from '../audience' +import { logger } from '../../../helpers/logger' -async function sendLikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const url = getVideoLikeActivityPubUrl(byAccount, video) +async function sendLike (byActor: ActorModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to like %s.', video.url) - const accountsInvolvedInVideo = await getAccountsInvolvedInVideo(video, t) - const audience = getOriginVideoAudience(video, accountsInvolvedInVideo) - const data = await likeActivityData(url, byAccount, video, t, audience) + const url = getVideoLikeActivityPubUrl(byActor, video) - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) -} + const accountsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) + + // Send to origin + if (video.isOwned() === false) { + const audience = getVideoAudience(video, accountsInvolvedInVideo) + const data = likeActivityData(url, byActor, video, audience) -async function sendLikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const url = getVideoLikeActivityPubUrl(byAccount, video) + return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) + } - const accountsInvolvedInVideo = await getAccountsInvolvedInVideo(video, t) + // Send to followers const audience = getObjectFollowersAudience(accountsInvolvedInVideo) - const data = await likeActivityData(url, byAccount, video, t, audience) + const data = likeActivityData(url, byActor, video, audience) - const followersException = [ byAccount ] - return broadcastToFollowers(data, byAccount, accountsInvolvedInVideo, t, followersException) + const followersException = [ byActor ] + return broadcastToFollowers(data, byActor, accountsInvolvedInVideo, t, followersException) } -async function likeActivityData ( - url: string, - byAccount: AccountInstance, - video: VideoInstance, - t: Transaction, - audience?: ActivityAudience -) { - if (!audience) { - audience = await getAudience(byAccount, t) - } - - const activity: ActivityLike = { - type: 'Like', - id: url, - actor: byAccount.url, - to: audience.to, - cc: audience.cc, - object: video.url - } - - return activity +function likeActivityData (url: string, byActor: ActorModel, video: VideoModel, audience?: ActivityAudience): ActivityLike { + if (!audience) audience = getAudience(byActor) + + return audiencify( + { + type: 'Like' as 'Like', + id: url, + actor: byActor.url, + object: video.url + }, + audience + ) } // --------------------------------------------------------------------------- export { - sendLikeToOrigin, - sendLikeToVideoFollowers, + sendLike, likeActivityData }