83 lines
2.2 KiB
TypeScript
83 lines
2.2 KiB
TypeScript
// Copyright 2022 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import type { MessageAttributesType } from '../model-types.d';
|
|
import type { MessageModel } from '../models/messages';
|
|
import type { SignalService as Proto } from '../protobuf';
|
|
import * as log from '../logging/log';
|
|
import { find } from './iterables';
|
|
import { getContactId } from '../messages/helpers';
|
|
import { getTimestampFromLong } from './timestampLongUtils';
|
|
|
|
export async function findStoryMessage(
|
|
conversationId: string,
|
|
storyContext?: Proto.DataMessage.IStoryContext
|
|
): Promise<MessageModel | undefined> {
|
|
if (!storyContext) {
|
|
return;
|
|
}
|
|
|
|
const { authorUuid, sentTimestamp } = storyContext;
|
|
|
|
if (!authorUuid || !sentTimestamp) {
|
|
return;
|
|
}
|
|
|
|
const sentAt = getTimestampFromLong(sentTimestamp);
|
|
const ourConversationId =
|
|
window.ConversationController.getOurConversationIdOrThrow();
|
|
|
|
const inMemoryMessages = window.MessageController.filterBySentAt(sentAt);
|
|
const matchingMessage = find(inMemoryMessages, item =>
|
|
isStoryAMatch(
|
|
item.attributes,
|
|
conversationId,
|
|
ourConversationId,
|
|
authorUuid,
|
|
sentAt
|
|
)
|
|
);
|
|
|
|
if (matchingMessage) {
|
|
return matchingMessage;
|
|
}
|
|
|
|
log.info('findStoryMessage: db lookup needed', sentAt);
|
|
const messages = await window.Signal.Data.getMessagesBySentAt(sentAt);
|
|
const found = messages.find(item =>
|
|
isStoryAMatch(item, conversationId, ourConversationId, authorUuid, sentAt)
|
|
);
|
|
|
|
if (!found) {
|
|
log.info('findStoryMessage: message not found', sentAt);
|
|
return;
|
|
}
|
|
|
|
const message = window.MessageController.register(found.id, found);
|
|
return message;
|
|
}
|
|
|
|
function isStoryAMatch(
|
|
message: MessageAttributesType | null | undefined,
|
|
conversationId: string,
|
|
ourConversationId: string,
|
|
authorUuid: string,
|
|
sentTimestamp: number
|
|
): message is MessageAttributesType {
|
|
if (!message) {
|
|
return false;
|
|
}
|
|
|
|
const authorConversation = window.ConversationController.lookupOrCreate({
|
|
e164: undefined,
|
|
uuid: authorUuid,
|
|
});
|
|
|
|
return (
|
|
message.sent_at === sentTimestamp &&
|
|
getContactId(message) === authorConversation?.id &&
|
|
(message.conversationId === conversationId ||
|
|
message.conversationId === ourConversationId)
|
|
);
|
|
}
|