1 files changed, 0 insertions, 103 deletions

diff --git a/server/lib/activitypub/process/process-flag.ts b/server/lib/activitypub/process/process-flag.ts
deleted file mode 100644
index bea285670..000000000
--- a/server/lib/activitypub/process/process-flag.ts
+++ /dev/null
@@ -1,103 +0,0 @@
-import { createAccountAbuse, createVideoAbuse, createVideoCommentAbuse } from '@server/lib/moderation'
-import { AccountModel } from '@server/models/account/account'
-import { VideoModel } from '@server/models/video/video'
-import { VideoCommentModel } from '@server/models/video/video-comment'
-import { abusePredefinedReasonsMap } from '@shared/core-utils/abuse'
-import { AbuseState, ActivityFlag } from '@shared/models'
-import { retryTransactionWrapper } from '../../../helpers/database-utils'
-import { logger } from '../../../helpers/logger'
-import { sequelizeTypescript } from '../../../initializers/database'
-import { getAPId } from '../../../lib/activitypub/activity'
-import { APProcessorOptions } from '../../../types/activitypub-processor.model'
-import { MAccountDefault, MActorSignature, MCommentOwnerVideo } from '../../../types/models'
-
-async function processFlagActivity (options: APProcessorOptions<ActivityFlag>) {
-  const { activity, byActor } = options
-
-  return retryTransactionWrapper(processCreateAbuse, activity, byActor)
-}
-
-// ---------------------------------------------------------------------------
-
-export {
-  processFlagActivity
-}
-
-// ---------------------------------------------------------------------------
-
-async function processCreateAbuse (flag: ActivityFlag, byActor: MActorSignature) {
-  const account = byActor.Account
-  if (!account) throw new Error('Cannot create abuse with the non account actor ' + byActor.url)
-
-  const reporterAccount = await AccountModel.load(account.id)
-
-  const objects = Array.isArray(flag.object) ? flag.object : [ flag.object ]
-
-  const tags = Array.isArray(flag.tag) ? flag.tag : []
-  const predefinedReasons = tags.map(tag => abusePredefinedReasonsMap[tag.name])
-                                .filter(v => !isNaN(v))
-
-  const startAt = flag.startAt
-  const endAt = flag.endAt
-
-  for (const object of objects) {
-    try {
-      const uri = getAPId(object)
-
-      logger.debug('Reporting remote abuse for object %s.', uri)
-
-      await sequelizeTypescript.transaction(async t => {
-        const video = await VideoModel.loadByUrlAndPopulateAccount(uri, t)
-        let videoComment: MCommentOwnerVideo
-        let flaggedAccount: MAccountDefault
-
-        if (!video) videoComment = await VideoCommentModel.loadByUrlAndPopulateAccountAndVideo(uri, t)
-        if (!videoComment) flaggedAccount = await AccountModel.loadByUrl(uri, t)
-
-        if (!video && !videoComment && !flaggedAccount) {
-          logger.warn('Cannot flag unknown entity %s.', object)
-          return
-        }
-
-        const baseAbuse = {
-          reporterAccountId: reporterAccount.id,
-          reason: flag.content,
-          state: AbuseState.PENDING,
-          predefinedReasons
-        }
-
-        if (video) {
-          return createVideoAbuse({
-            baseAbuse,
-            startAt,
-            endAt,
-            reporterAccount,
-            transaction: t,
-            videoInstance: video,
-            skipNotification: false
-          })
-        }
-
-        if (videoComment) {
-          return createVideoCommentAbuse({
-            baseAbuse,
-            reporterAccount,
-            transaction: t,
-            commentInstance: videoComment,
-            skipNotification: false
-          })
-        }
-
-        return await createAccountAbuse({
-          baseAbuse,
-          reporterAccount,
-          transaction: t,
-          accountInstance: flaggedAccount,
-          skipNotification: false
-        })
-      })
-    } catch (err) {
-      logger.debug('Cannot process report of %s', getAPId(object), { err })
-    }
-  }
-}