52 lines
1.7 KiB
TypeScript
52 lines
1.7 KiB
TypeScript
// Copyright 2021 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import { assertDev } from '../../util/assert';
|
|
import { isDirectConversation } from '../../util/whatTypeOfConversation';
|
|
import * as log from '../../logging/log';
|
|
import type { ConversationAttributesType } from '../../model-types.d';
|
|
import { isAciString } from '../../util/isAciString';
|
|
import type { reportSpamJobQueue } from '../reportSpamJobQueue';
|
|
|
|
export async function addReportSpamJob({
|
|
conversation,
|
|
getMessageServerGuidsForSpam,
|
|
jobQueue,
|
|
}: Readonly<{
|
|
conversation: Readonly<
|
|
Pick<
|
|
ConversationAttributesType,
|
|
'id' | 'type' | 'serviceId' | 'reportingToken'
|
|
>
|
|
>;
|
|
getMessageServerGuidsForSpam: (
|
|
conversationId: string
|
|
) => Promise<Array<string>>;
|
|
jobQueue: Pick<typeof reportSpamJobQueue, 'add'>;
|
|
}>): Promise<void> {
|
|
assertDev(
|
|
isDirectConversation(conversation),
|
|
'addReportSpamJob: cannot report spam for non-direct conversations'
|
|
);
|
|
|
|
const { serviceId: aci } = conversation;
|
|
if (!aci || !isAciString(aci)) {
|
|
log.info(
|
|
'addReportSpamJob got a conversation with no aci, which the server does not support. Doing nothing'
|
|
);
|
|
return;
|
|
}
|
|
|
|
const serverGuids = await getMessageServerGuidsForSpam(conversation.id);
|
|
if (!serverGuids.length) {
|
|
// This can happen under normal conditions. We haven't always stored server GUIDs, so
|
|
// a user might try to report spam for a conversation that doesn't have them. (It
|
|
// may also indicate developer error, but that's not necessarily the case.)
|
|
log.info(
|
|
'addReportSpamJob got no server GUIDs from the database. Doing nothing'
|
|
);
|
|
return;
|
|
}
|
|
|
|
await jobQueue.add({ aci, serverGuids, token: conversation.reportingToken });
|
|
}
|