X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fsend%2Fsend-create.ts;h=fc76cdd8abdb058feee52ded0841ea04deb81034;hb=a651038487faa838bda3ce04695b08bc65baff70;hp=249dd91dc846155f1dcb821621fe3a480a198812;hpb=e12a009254de33bcdbd8334992980fa029c3e10d;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/send/send-create.ts b/server/lib/activitypub/send/send-create.ts index 249dd91dc..fc76cdd8a 100644 --- a/server/lib/activitypub/send/send-create.ts +++ b/server/lib/activitypub/send/send-create.ts @@ -1,107 +1,149 @@ import { Transaction } from 'sequelize' import { ActivityAudience, ActivityCreate } from '../../../../shared/models/activitypub' import { VideoPrivacy } from '../../../../shared/models/videos' -import { getServerActor } from '../../../helpers' +import { getServerActor } from '../../../helpers/utils' import { ActorModel } from '../../../models/activitypub/actor' import { VideoModel } from '../../../models/video/video' import { VideoAbuseModel } from '../../../models/video/video-abuse' +import { VideoCommentModel } from '../../../models/video/video-comment' import { getVideoAbuseActivityPubUrl, getVideoDislikeActivityPubUrl, getVideoViewActivityPubUrl } from '../url' +import { broadcastToActors, broadcastToFollowers, unicastTo } from './utils' import { audiencify, - broadcastToFollowers, getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience, - getOriginVideoAudience, - unicastTo -} from './misc' + getVideoAudience, + getVideoCommentAudience +} from '../audience' +import { logger } from '../../../helpers/logger' async function sendCreateVideo (video: VideoModel, t: Transaction) { - if (video.privacy === VideoPrivacy.PRIVATE) return + if (video.privacy === VideoPrivacy.PRIVATE) return undefined + + logger.info('Creating job to send video creation of %s.', video.url) const byActor = video.VideoChannel.Account.Actor const videoObject = video.toActivityPubObject() - const audience = await getAudience(byActor, t, video.privacy === VideoPrivacy.PUBLIC) - const data = await createActivityData(video.url, byActor, videoObject, t, audience) + const audience = getAudience(byActor, video.privacy === VideoPrivacy.PUBLIC) + const data = createActivityData(video.url, byActor, videoObject, audience) return broadcastToFollowers(data, byActor, [ byActor ], t) } async function sendVideoAbuse (byActor: ActorModel, videoAbuse: VideoAbuseModel, video: VideoModel, t: Transaction) { + if (!video.VideoChannel.Account.Actor.serverId) return // Local + const url = getVideoAbuseActivityPubUrl(videoAbuse) + logger.info('Creating job to send video abuse %s.', url) + const audience = { to: [ video.VideoChannel.Account.Actor.url ], cc: [] } - const data = await createActivityData(url, byActor, videoAbuse.toActivityPubObject(), t, audience) + const data = createActivityData(url, byActor, videoAbuse.toActivityPubObject(), audience) - return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t) + return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) } -async function sendCreateViewToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) { - const url = getVideoViewActivityPubUrl(byActor, video) - const viewActivity = createViewActivityData(byActor, video) +async function sendCreateVideoComment (comment: VideoCommentModel, t: Transaction) { + logger.info('Creating job to send comment %s.', comment.url) - const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) - const audience = getOriginVideoAudience(video, actorsInvolvedInVideo) - const data = await createActivityData(url, byActor, viewActivity, t, audience) + const isOrigin = comment.Video.isOwned() + + const byActor = comment.Account.Actor + const threadParentComments = await VideoCommentModel.listThreadParentComments(comment, t) + const commentObject = comment.toActivityPubObject(threadParentComments) + + const actorsInvolvedInComment = await getActorsInvolvedInVideo(comment.Video, t) + actorsInvolvedInComment.push(byActor) + + const parentsCommentActors = threadParentComments.map(c => c.Account.Actor) + + let audience: ActivityAudience + if (isOrigin) { + audience = getVideoCommentAudience(comment, threadParentComments, actorsInvolvedInComment, isOrigin) + } else { + audience = getObjectFollowersAudience(actorsInvolvedInComment.concat(parentsCommentActors)) + } + + const data = createActivityData(comment.url, byActor, commentObject, audience) + + // This was a reply, send it to the parent actors + const actorsException = [ byActor ] + await broadcastToActors(data, byActor, parentsCommentActors, actorsException) - return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t) + // Broadcast to our followers + await broadcastToFollowers(data, byActor, [ byActor ], t) + + // Send to actors involved in the comment + if (isOrigin) return broadcastToFollowers(data, byActor, actorsInvolvedInComment, t, actorsException) + + // Send to origin + return unicastTo(data, byActor, comment.Video.VideoChannel.Account.Actor.sharedInboxUrl) } -async function sendCreateViewToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) { +async function sendCreateView (byActor: ActorModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to send view of %s.', video.url) + const url = getVideoViewActivityPubUrl(byActor, video) - const viewActivity = createViewActivityData(byActor, video) + const viewActivityData = createViewActivityData(byActor, video) - const actorsToForwardView = await getActorsInvolvedInVideo(video, t) - const audience = getObjectFollowersAudience(actorsToForwardView) - const data = await createActivityData(url, byActor, viewActivity, t, audience) + const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) + + // Send to origin + if (video.isOwned() === false) { + const audience = getVideoAudience(video, actorsInvolvedInVideo) + const data = createActivityData(url, byActor, viewActivityData, audience) + + return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) + } + + // Send to followers + const audience = getObjectFollowersAudience(actorsInvolvedInVideo) + const data = createActivityData(url, byActor, viewActivityData, audience) // Use the server actor to send the view const serverActor = await getServerActor() - const followersException = [ byActor ] - return broadcastToFollowers(data, serverActor, actorsToForwardView, t, followersException) + const actorsException = [ byActor ] + return broadcastToFollowers(data, serverActor, actorsInvolvedInVideo, t, actorsException) } -async function sendCreateDislikeToOrigin (byActor: ActorModel, video: VideoModel, t: Transaction) { +async function sendCreateDislike (byActor: ActorModel, video: VideoModel, t: Transaction) { + logger.info('Creating job to dislike %s.', video.url) + const url = getVideoDislikeActivityPubUrl(byActor, video) - const dislikeActivity = createDislikeActivityData(byActor, video) + const dislikeActivityData = createDislikeActivityData(byActor, video) const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t) - const audience = getOriginVideoAudience(video, actorsInvolvedInVideo) - const data = await createActivityData(url, byActor, dislikeActivity, t, audience) - return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl, t) -} + // Send to origin + if (video.isOwned() === false) { + const audience = getVideoAudience(video, actorsInvolvedInVideo) + const data = createActivityData(url, byActor, dislikeActivityData, audience) -async function sendCreateDislikeToVideoFollowers (byActor: ActorModel, video: VideoModel, t: Transaction) { - const url = getVideoDislikeActivityPubUrl(byActor, video) - const dislikeActivity = createDislikeActivityData(byActor, video) + return unicastTo(data, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl) + } - const actorsToForwardView = await getActorsInvolvedInVideo(video, t) - const audience = getObjectFollowersAudience(actorsToForwardView) - const data = await createActivityData(url, byActor, dislikeActivity, t, audience) + // Send to followers + const audience = getObjectFollowersAudience(actorsInvolvedInVideo) + const data = createActivityData(url, byActor, dislikeActivityData, audience) - const followersException = [ byActor ] - return broadcastToFollowers(data, byActor, actorsToForwardView, t, followersException) + const actorsException = [ byActor ] + return broadcastToFollowers(data, byActor, actorsInvolvedInVideo, t, actorsException) } -async function createActivityData ( - url: string, - byActor: ActorModel, - object: any, - t: Transaction, - audience?: ActivityAudience -): Promise { - if (!audience) { - audience = await getAudience(byActor, t) - } - - return audiencify({ - type: 'Create', - id: url, - actor: byActor.url, - object: audiencify(object, audience) - }, audience) +function createActivityData (url: string, byActor: ActorModel, object: any, audience?: ActivityAudience): ActivityCreate { + if (!audience) audience = getAudience(byActor) + + return audiencify( + { + type: 'Create' as 'Create', + id: url + '/activity', + actor: byActor.url, + object: audiencify(object, audience) + }, + audience + ) } function createDislikeActivityData (byActor: ActorModel, video: VideoModel) { @@ -112,21 +154,6 @@ function createDislikeActivityData (byActor: ActorModel, video: VideoModel) { } } -// --------------------------------------------------------------------------- - -export { - sendCreateVideo, - sendVideoAbuse, - createActivityData, - sendCreateViewToOrigin, - sendCreateViewToVideoFollowers, - sendCreateDislikeToOrigin, - sendCreateDislikeToVideoFollowers, - createDislikeActivityData -} - -// --------------------------------------------------------------------------- - function createViewActivityData (byActor: ActorModel, video: VideoModel) { return { type: 'View', @@ -134,3 +161,15 @@ function createViewActivityData (byActor: ActorModel, video: VideoModel) { object: video.url } } + +// --------------------------------------------------------------------------- + +export { + sendCreateVideo, + sendVideoAbuse, + createActivityData, + sendCreateView, + sendCreateDislike, + createDislikeActivityData, + sendCreateVideoComment +}