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

   1 import { ActivityCreate, ActivityFlag, VideoAbuseState } from '../../../../shared'
   2 import { VideoAbuseObject } from '../../../../shared/models/activitypub/objects'
   3 import { retryTransactionWrapper } from '../../../helpers/database-utils'
   4 import { logger } from '../../../helpers/logger'
   5 import { sequelizeTypescript } from '../../../initializers'
   6 import { ActorModel } from '../../../models/activitypub/actor'
   7 import { VideoAbuseModel } from '../../../models/video/video-abuse'
   8 import { getOrCreateVideoAndAccountAndChannel } from '../videos'
   9 import { Notifier } from '../../notifier'
  10 import { getAPId } from '../../../helpers/activitypub'
  11
  12 async function processFlagActivity (activity: ActivityCreate | ActivityFlag, byActor: ActorModel) {
  13   return retryTransactionWrapper(processCreateVideoAbuse, activity, byActor)
  14 }
  15
  16 // ---------------------------------------------------------------------------
  17
  18 export {
  19   processFlagActivity
  20 }
  21
  22 // ---------------------------------------------------------------------------
  23
  24 async function processCreateVideoAbuse (activity: ActivityCreate | ActivityFlag, byActor: ActorModel) {
  25   const flag = activity.type === 'Flag' ? activity : (activity.object as VideoAbuseObject)
  26
  27   logger.debug('Reporting remote abuse for video %s.', getAPId(flag.object))
  28
  29   const account = byActor.Account
  30   if (!account) throw new Error('Cannot create dislike with the non account actor ' + byActor.url)
  31
  32   const { video } = await getOrCreateVideoAndAccountAndChannel({ videoObject: flag.object })
  33
  34   return sequelizeTypescript.transaction(async t => {
  35     const videoAbuseData = {
  36       reporterAccountId: account.id,
  37       reason: flag.content,
  38       videoId: video.id,
  39       state: VideoAbuseState.PENDING
  40     }
  41
  42     const videoAbuseInstance = await VideoAbuseModel.create(videoAbuseData, { transaction: t })
  43     videoAbuseInstance.Video = video
  44
  45     Notifier.Instance.notifyOnNewVideoAbuse(videoAbuseInstance)
  46
  47     logger.info('Remote abuse for video uuid %s created', flag.object)
  48   })
  49 }