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

   1 import { getVideoAbuseActivityPubUrl } from '../url'
   2 import { unicastTo } from './utils'
   3 import { logger } from '../../../helpers/logger'
   4 import { ActivityAudience, ActivityFlag } from '../../../../shared/models/activitypub'
   5 import { audiencify, getAudience } from '../audience'
   6 import { Transaction } from 'sequelize'
   7 import { MActor, MVideoFullLight } from '../../../types/models'
   8 import { MVideoAbuseVideo } from '../../../types/models/video'
   9
  10 function sendVideoAbuse (byActor: MActor, videoAbuse: MVideoAbuseVideo, video: MVideoFullLight, t: Transaction) {
  11   if (!video.VideoChannel.Account.Actor.serverId) return // Local user
  12
  13   const url = getVideoAbuseActivityPubUrl(videoAbuse)
  14
  15   logger.info('Creating job to send video abuse %s.', url)
  16
  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)
  20
  21   t.afterCommit(() => unicastTo(flagActivity, byActor, video.VideoChannel.Account.Actor.getSharedInbox()))
  22 }
  23
  24 function buildFlagActivity (url: string, byActor: MActor, videoAbuse: MVideoAbuseVideo, audience: ActivityAudience): ActivityFlag {
  25   if (!audience) audience = getAudience(byActor)
  26
  27   const activity = Object.assign(
  28     { id: url, actor: byActor.url },
  29     videoAbuse.toActivityPubObject()
  30   )
  31
  32   return audiencify(activity, audience)
  33 }
  34
  35 // ---------------------------------------------------------------------------
  36
  37 export {
  38   sendVideoAbuse
  39 }