44 lines
1.5 KiB
TypeScript
44 lines
1.5 KiB
TypeScript
|
// Copyright 2021 Signal Messenger, LLC
|
||
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
||
|
|
|
||
|
|
import { groupBy, map } from 'lodash';
|
||
|
|
import { ConversationAttributesType } from '../model-types.d';
|
||
|
|
import { getSendOptions } from './getSendOptions';
|
||
|
|
import { handleMessageSend } from './handleMessageSend';
|
||
|
|
import { isConversationAccepted } from './isConversationAccepted';
|
||
|
|
|
||
|
|
export async function sendReadReceiptsFor(
|
||
|
|
conversationAttrs: ConversationAttributesType,
|
||
|
|
items: Array<unknown>
|
||
|
|
): Promise<void> {
|
||
|
|
// Only send read receipts for accepted conversations
|
||
|
|
if (
|
||
|
|
window.storage.get('read-receipt-setting') &&
|
||
|
|
isConversationAccepted(conversationAttrs)
|
||
|
|
) {
|
||
|
|
window.log.info(`Sending ${items.length} read receipts`);
|
||
|
|
const convoSendOptions = await getSendOptions(conversationAttrs);
|
||
|
|
const receiptsBySender = groupBy(items, 'senderId');
|
||
|
|
|
||
|
|
await Promise.all(
|
||
|
|
map(receiptsBySender, async (receipts, senderId) => {
|
||
|
|
const timestamps = map(receipts, 'timestamp');
|
||
|
|
const conversation = window.ConversationController.get(senderId);
|
||
|
|
|
||
|
|
if (conversation) {
|
||
|
|
await handleMessageSend(
|
||
|
|
window.textsecure.messaging.sendReadReceipts(
|
||
|
|
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
|
||
|
|
conversation.get('e164')!,
|
||
|
|
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
|
||
|
|
conversation.get('uuid')!,
|
||
|
|
timestamps,
|
||
|
|
convoSendOptions
|
||
|
|
)
|
||
|
|
);
|
||
|
|
}
|
||
|
|
})
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|