X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fsend%2Fsend-like.ts;h=29fcfc4049c9e6b783040d5dbffefc26c9716fff;hb=2291a412d25bd139398ca9e7a5131d0c1e4ffd7d;hp=70a7d886feb8453f9816790223a8d817a80eee98;hpb=0032ebe94aa83fab761c7de3ceb6210ac4532824;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-like.ts b/server/lib/activitypub/send/send-like.ts index 70a7d886f..29fcfc404 100644 --- a/server/lib/activitypub/send/send-like.ts +++ b/server/lib/activitypub/send/send-like.ts @@ -1,60 +1,40 @@ import { Transaction } from 'sequelize' -import { ActivityLike } from '../../../../shared/models/activitypub/activity' -import { getServerAccount } from '../../../helpers/utils' -import { AccountInstance, VideoInstance } from '../../../models' +import { ActivityAudience, ActivityLike } from '../../../../shared/models/activitypub' import { getVideoLikeActivityPubUrl } from '../url' -import { - broadcastToFollowers, - getAccountsToForwardVideoAction, - getAudience, - getOriginVideoAudience, - getVideoFollowersAudience, - unicastTo -} from './misc' - -async function sendLikeToOrigin (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const url = getVideoLikeActivityPubUrl(byAccount, video) - - const audience = getOriginVideoAudience(video) - const data = await likeActivityData(url, byAccount, video, audience) - - return unicastTo(data, byAccount, video.VideoChannel.Account.sharedInboxUrl, t) -} - -async function sendLikeToVideoFollowers (byAccount: AccountInstance, video: VideoInstance, t: Transaction) { - const url = getVideoLikeActivityPubUrl(byAccount, video) - - const audience = getVideoFollowersAudience(video) - const data = await likeActivityData(url, byAccount, video, audience) +import { sendVideoRelatedActivity } from './utils' +import { audiencify, getAudience } from '../audience' +import { logger } from '../../../helpers/logger' +import { MActor, MActorAudience, MVideoAccountLight, MVideoUrl } from '../../../types/models' - const accountsToForwardView = await getAccountsToForwardVideoAction(byAccount, video) - const serverAccount = await getServerAccount() +function sendLike (byActor: MActor, video: MVideoAccountLight, t: Transaction) { + logger.info('Creating job to like %s.', video.url) - const followersException = [ byAccount ] - return broadcastToFollowers(data, serverAccount, accountsToForwardView, t, followersException) -} + const activityBuilder = (audience: ActivityAudience) => { + const url = getVideoLikeActivityPubUrl(byActor, video) -async function likeActivityData (url: string, byAccount: AccountInstance, video: VideoInstance, audience?: { to: string[], cc: string[] }) { - if (!audience) { - audience = await getAudience(byAccount) + return buildLikeActivity(url, byActor, video, audience) } - const activity: ActivityLike = { - type: 'Like', - id: url, - actor: byAccount.url, - to: audience.to, - cc: audience.cc, - object: video.url - } + return sendVideoRelatedActivity(activityBuilder, { byActor, video, transaction: t }) +} - return activity +function buildLikeActivity (url: string, byActor: MActorAudience, video: MVideoUrl, audience?: ActivityAudience): ActivityLike { + if (!audience) audience = getAudience(byActor) + + return audiencify( + { + id: url, + type: 'Like' as 'Like', + actor: byActor.url, + object: video.url + }, + audience + ) } // --------------------------------------------------------------------------- export { - sendLikeToOrigin, - sendLikeToVideoFollowers, - likeActivityData + sendLike, + buildLikeActivity }