PeerTube/server/lib/activitypub/send/send-update.ts

78 lines
2.8 KiB
TypeScript
Raw Normal View History

2017-11-20 09:43:39 +01:00
import { Transaction } from 'sequelize'
2017-12-14 17:38:41 +01:00
import { ActivityAudience, ActivityUpdate } from '../../../../shared/models/activitypub'
import { VideoPrivacy } from '../../../../shared/models/videos'
import { AccountModel } from '../../../models/account/account'
2017-12-14 17:38:41 +01:00
import { ActorModel } from '../../../models/activitypub/actor'
2017-12-12 17:53:50 +01:00
import { VideoModel } from '../../../models/video/video'
import { VideoChannelModel } from '../../../models/video/video-channel'
2017-12-12 17:53:50 +01:00
import { VideoShareModel } from '../../../models/video/video-share'
import { getUpdateActivityPubUrl } from '../url'
2018-05-25 11:32:36 +02:00
import { broadcastToFollowers } from './utils'
import { audiencify, getAudience } from '../audience'
2018-07-30 17:02:40 +02:00
import { logger } from '../../../helpers/logger'
2017-11-20 09:43:39 +01:00
2017-12-12 17:53:50 +01:00
async function sendUpdateVideo (video: VideoModel, t: Transaction) {
2018-07-30 17:02:40 +02:00
logger.info('Creating job to update video %s.', video.url)
2017-12-14 17:38:41 +01:00
const byActor = video.VideoChannel.Account.Actor
2017-11-20 09:43:39 +01:00
const url = getUpdateActivityPubUrl(video.url, video.updatedAt.toISOString())
const videoObject = video.toActivityPubObject()
const audience = getAudience(byActor, video.privacy === VideoPrivacy.PUBLIC)
2017-12-14 17:38:41 +01:00
const data = updateActivityData(url, byActor, videoObject, audience)
2017-11-20 09:43:39 +01:00
2017-12-14 17:38:41 +01:00
const actorsInvolved = await VideoShareModel.loadActorsByShare(video.id, t)
actorsInvolved.push(byActor)
2017-11-20 09:43:39 +01:00
2017-12-14 17:38:41 +01:00
return broadcastToFollowers(data, byActor, actorsInvolved, t)
2017-11-20 09:43:39 +01:00
}
async function sendUpdateActor (accountOrChannel: AccountModel | VideoChannelModel, t: Transaction) {
const byActor = accountOrChannel.Actor
2018-01-03 16:38:50 +01:00
2018-07-30 17:02:40 +02:00
logger.info('Creating job to update actor %s.', byActor.url)
2018-01-03 16:38:50 +01:00
const url = getUpdateActivityPubUrl(byActor.url, byActor.updatedAt.toISOString())
const accountOrChannelObject = accountOrChannel.toActivityPubObject()
const audience = getAudience(byActor)
const data = updateActivityData(url, byActor, accountOrChannelObject, audience)
let actorsInvolved: ActorModel[]
if (accountOrChannel instanceof AccountModel) {
// Actors that shared my videos are involved too
actorsInvolved = await VideoShareModel.loadActorsByVideoOwner(byActor.id, t)
} else {
// Actors that shared videos of my channel are involved too
actorsInvolved = await VideoShareModel.loadActorsByVideoChannel(accountOrChannel.id, t)
}
2018-01-03 16:38:50 +01:00
actorsInvolved.push(byActor)
return broadcastToFollowers(data, byActor, actorsInvolved, t)
}
2017-11-20 09:43:39 +01:00
// ---------------------------------------------------------------------------
export {
sendUpdateActor,
2017-11-20 09:43:39 +01:00
sendUpdateVideo
}
// ---------------------------------------------------------------------------
function updateActivityData (url: string, byActor: ActorModel, object: any, audience?: ActivityAudience): ActivityUpdate {
if (!audience) audience = getAudience(byActor)
2017-12-14 17:38:41 +01:00
return audiencify(
{
type: 'Update' as 'Update',
id: url,
actor: byActor.url,
object: audiencify(object, audience
)
},
audience
)
2017-11-20 09:43:39 +01:00
}