]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame_incremental - server/lib/activitypub/send/send-announce.ts
Split files in activitypub server
[github/Chocobozzz/PeerTube.git] / server / lib / activitypub / send / send-announce.ts
... / ...
CommitLineData
1import { Transaction } from 'sequelize'
2import { ActivityAnnounce, ActivityAudience } from '../../../../shared/models/activitypub'
3import { ActorModel } from '../../../models/activitypub/actor'
4import { VideoModel } from '../../../models/video/video'
5import { VideoShareModel } from '../../../models/video/video-share'
6import { broadcastToFollowers } from './utils'
7import { getActorsInvolvedInVideo, getAudience, getObjectFollowersAudience } from '../audience'
8
9async function buildVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
10 const announcedObject = video.url
11
12 const accountsToForwardView = await getActorsInvolvedInVideo(video, t)
13 const audience = getObjectFollowersAudience(accountsToForwardView)
14 return announceActivityData(videoShare.url, byActor, announcedObject, t, audience)
15}
16
17async function sendVideoAnnounce (byActor: ActorModel, videoShare: VideoShareModel, video: VideoModel, t: Transaction) {
18 const data = await buildVideoAnnounce(byActor, videoShare, video, t)
19
20 return broadcastToFollowers(data, byActor, [ byActor ], t)
21}
22
23async function announceActivityData (
24 url: string,
25 byActor: ActorModel,
26 object: string,
27 t: Transaction,
28 audience?: ActivityAudience
29): Promise<ActivityAnnounce> {
30 if (!audience) {
31 audience = await getAudience(byActor, t)
32 }
33
34 return {
35 type: 'Announce',
36 to: audience.to,
37 cc: audience.cc,
38 id: url,
39 actor: byActor.url,
40 object
41 }
42}
43
44// ---------------------------------------------------------------------------
45
46export {
47 sendVideoAnnounce,
48 announceActivityData,
49 buildVideoAnnounce
50}