server/lib/activitypub/send/send-flag.ts

   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'
   9 import { Transaction } from 'sequelize'
  10
  11 async function sendVideoAbuse (byActor: ActorModel, videoAbuse: VideoAbuseModel, video: VideoModel, t: Transaction) {
  12   if (!video.VideoChannel.Account.Actor.serverId) return // Local user
  13
  14   const url = getVideoAbuseActivityPubUrl(videoAbuse)
  15
  16   logger.info('Creating job to send video abuse %s.', url)
  17
  18   // Custom audience, we only send the abuse to the origin instance
  19   const audience = { to: [ video.VideoChannel.Account.Actor.url ], cc: [] }
  20   const flagActivity = buildFlagActivity(url, byActor, videoAbuse, audience)
  21
  22   t.afterCommit(() => unicastTo(flagActivity, byActor, video.VideoChannel.Account.Actor.sharedInboxUrl))
  23 }
  24
  25 function buildFlagActivity (url: string, byActor: ActorModel, videoAbuse: VideoAbuseModel, audience: ActivityAudience): ActivityFlag {
  26   if (!audience) audience = getAudience(byActor)
  27
  28   const activity = Object.assign(
  29     { id: url, actor: byActor.url },
  30     videoAbuse.toActivityPubObject()
  31   )
  32
  33   return audiencify(activity, audience)
  34 }
  35
  36 // ---------------------------------------------------------------------------
  37
  38 export {
  39   sendVideoAbuse
  40 }