1 import { Transaction } from 'sequelize'
2 import { ActivityAudience, ActivityFlag } from '../../../../shared/models/activitypub'
3 import { logger } from '../../../helpers/logger'
4 import { MAbuseAP, MAccountLight, MActor } from '../../../types/models'
5 import { audiencify, getAudience } from '../audience'
6 import { getLocalAbuseActivityPubUrl } from '../url'
7 import { unicastTo } from './utils'
9 function sendAbuse (byActor: MActor, abuse: MAbuseAP, flaggedAccount: MAccountLight, t: Transaction) {
10 if (!flaggedAccount.Actor.serverId) return // Local user
12 const url = getLocalAbuseActivityPubUrl(abuse)
14 logger.info('Creating job to send abuse %s.', url)
16 // Custom audience, we only send the abuse to the origin instance
17 const audience = { to: [ flaggedAccount.Actor.url ], cc: [] }
18 const flagActivity = buildFlagActivity(url, byActor, abuse, audience)
20 t.afterCommit(() => unicastTo(flagActivity, byActor, flaggedAccount.Actor.getSharedInbox()))
23 function buildFlagActivity (url: string, byActor: MActor, abuse: MAbuseAP, audience: ActivityAudience): ActivityFlag {
24 if (!audience) audience = getAudience(byActor)
26 const activity = Object.assign(
27 { id: url, actor: byActor.url },
28 abuse.toActivityPubObject()
31 return audiencify(activity, audience)
34 // ---------------------------------------------------------------------------