1 import { ActorModel } from '../../../models/activitypub/actor'
2 import { VideoModel } from '../../../models/video/video'
3 import { VideoAbuseModel } from '../../../models/video/video-abuse'
4 import { getVideoAbuseActivityPubUrl } from '../url'
5 import { unicastTo } from './utils'
6 import { logger } from '../../../helpers/logger'
7 import { ActivityAudience, ActivityFlag } from '../../../../shared/models/activitypub'
8 import { audiencify, getAudience } from '../audience'
10 async function sendVideoAbuse (byActor: ActorModel, videoAbuse: VideoAbuseModel, video: VideoModel) {
11 if (!video.VideoChannel.Account.Actor.serverId) return // Local user
13 const url = getVideoAbuseActivityPubUrl(videoAbuse)
15 logger.info('Creating job to send video abuse %s.', url)
17 // Custom audience, we only send the abuse to the origin instance
18 const audience = { to: [ video.VideoChannel.Account.Actor.url ], cc: [] }
19 const flagActivity = buildFlagActivity(url, byActor, videoAbuse, audience)
21 return unicastTo(flagActivity, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl)
24 function buildFlagActivity (url: string, byActor: ActorModel, videoAbuse: VideoAbuseModel, audience: ActivityAudience): ActivityFlag {
25 if (!audience) audience = getAudience(byActor)
27 const activity = Object.assign(
28 { id: url, actor: byActor.url },
29 videoAbuse.toActivityPubObject()
32 return audiencify(activity, audience)
35 // ---------------------------------------------------------------------------