X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fshare.ts;h=53ecd3dab7a857b40c95dd28c5b663b00fd1ac84;hb=4ba3b8ea1be85d95a508ac479f26b96ceea15971;hp=f79c4e532af10d1da5b4578680b1e752ed4a3e46;hpb=50d6de9c286abcb34ff4234d56d9cbb803db7665;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/share.ts b/server/lib/activitypub/share.ts index f79c4e532..53ecd3dab 100644 --- a/server/lib/activitypub/share.ts +++ b/server/lib/activitypub/share.ts @@ -1,20 +1,41 @@ import { Transaction } from 'sequelize' -import { getServerActor } from '../../helpers' +import { VideoPrivacy } from '../../../shared/models/videos' +import { getServerActor } from '../../helpers/utils' import { VideoModel } from '../../models/video/video' import { VideoShareModel } from '../../models/video/video-share' import { sendVideoAnnounceToFollowers } from './send' +import { getAnnounceActivityPubUrl } from './url' + +async function shareVideoByServerAndChannel (video: VideoModel, t: Transaction) { + if (video.privacy === VideoPrivacy.PRIVATE) return undefined -async function shareVideoByServer (video: VideoModel, t: Transaction) { const serverActor = await getServerActor() - await VideoShareModel.create({ + const serverShareUrl = getAnnounceActivityPubUrl(video.url, serverActor) + const serverSharePromise = VideoShareModel.create({ actorId: serverActor.id, - videoId: video.id + videoId: video.id, + url: serverShareUrl + }, { transaction: t }) + + const videoChannelShareUrl = getAnnounceActivityPubUrl(video.url, video.VideoChannel.Actor) + const videoChannelSharePromise = VideoShareModel.create({ + actorId: video.VideoChannel.actorId, + videoId: video.id, + url: videoChannelShareUrl }, { transaction: t }) - return sendVideoAnnounceToFollowers(serverActor, video, t) + const [ serverShare, videoChannelShare ] = await Promise.all([ + serverSharePromise, + videoChannelSharePromise + ]) + + return Promise.all([ + sendVideoAnnounceToFollowers(serverActor, videoChannelShare, video, t), + sendVideoAnnounceToFollowers(serverActor, serverShare, video, t) + ]) } export { - shareVideoByServer + shareVideoByServerAndChannel }