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=41b879b8ac6f59768d46e01842ebeb8d465b5650;hpb=4e50b6a1c9a3eb261e04ede73241648e6edf21d6;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-like.ts b/server/lib/activitypub/send/send-like.ts index 41b879b8a..83225f5df 100644 --- a/server/lib/activitypub/send/send-like.ts +++ b/server/lib/activitypub/send/send-like.ts @@ -1,60 +1,52 @@ import { Transaction } from 'sequelize' -import { 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' - -async function sendLikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const url = getVideoLikeActivityPubUrl(byAccount, video) - - const accountsInvolvedInVideo = await getAccountsInvolvedInVideo(video) - const audience = getOriginVideoAudience(video, accountsInvolvedInVideo) - const data = await likeActivityData(url, byAccount, video, audience) - - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) -} +import { broadcastToFollowers, unicastTo } from './utils' +import { audiencify, getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience, getVideoAudience } from '../audience' +import { logger } from '../../../helpers/logger' -async function sendLikeToVideoFollowers (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) - const audience = getObjectFollowersAudience(accountsInvolvedInVideo) - const data = await likeActivityData(url, byAccount, video, audience) + const url = getVideoLikeActivityPubUrl(byActor, video) - const toAccountsFollowers = await getAccountsInvolvedInVideo(video) + const accountsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) - const followersException = [ byAccount ] - return broadcastToFollowers(data, byAccount, toAccountsFollowers, t, followersException) -} + // Send to origin + if (video.isOwned() === false) { + const audience = getVideoAudience(video, accountsInvolvedInVideo) + const data = likeActivityData(url, byActor, video, audience) -async function likeActivityData (url: string, byAccount: AccountInstance, video: VideoInstance, audience?: { to: string[], cc: string[] }) { - if (!audience) { - audience = await getAudience(byAccount) + return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) } - const activity: ActivityLike = { - type: 'Like', - id: url, - actor: byAccount.url, - to: audience.to, - cc: audience.cc, - object: video.url - } + // Send to followers + const audience = getObjectFollowersAudience(accountsInvolvedInVideo) + const data = likeActivityData(url, byActor, video, audience) + + const followersException = [ byActor ] + return broadcastToFollowers(data, byActor, accountsInvolvedInVideo, t, followersException) +} - 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 }