Fix for missing replacement text in bodyRanges

ts/background.ts

@@ -2,10 +2,12 @@
 // SPDX-License-Identifier: AGPL-3.0-only
 
 import { DataMessageClass } from './textsecure.d';
+import { MessageAttributesType } from './model-types.d';
 import { WhatIsThis } from './window.d';
 import { assert } from './util/assert';
 
 export async function startApp(): Promise<void> {
+  window.attachmentDownloadQueue = [];
   try {
     window.log.info('Initializing SQL in renderer');
     await window.sqlInitializer.initialize();
@@ -2073,11 +2075,20 @@ export async function startApp(): Promise<void> {
           attachmentsToDownload.length,
           attachmentDownloadQueue.length
         );
-        await Promise.all(
+        window.attachmentDownloadQueue = undefined;
+        const messagesWithDownloads = await Promise.all(
           attachmentsToDownload.map(message =>
             message.queueAttachmentDownloads()
           )
         );
+        const messagesToSave: Array<MessageAttributesType> = [];
+        messagesWithDownloads.forEach((shouldSave, messageKey) => {
+          if (shouldSave) {
+            const message = attachmentsToDownload[messageKey];
+            messagesToSave.push(message.attributes);
+          }
+        });
+        await window.Signal.Data.saveMessages(messagesToSave, {});
       }
     }, 500);
 

ts/models/messages.ts

@@ -3614,8 +3614,15 @@ export class MessageModel extends window.Backbone.Model<MessageAttributesType> {
           (this.getConversation()!.getAccepted() || message.isOutgoing()) &&
           !shouldHoldOffDownload
         ) {
-          window.attachmentDownloadQueue = window.attachmentDownloadQueue || [];
-          window.attachmentDownloadQueue.unshift(message);
+          if (window.attachmentDownloadQueue) {
+            window.attachmentDownloadQueue.unshift(message);
+            window.log.info(
+              'Adding to attachmentDownloadQueue',
+              message.get('sent_at')
+            );
+          } else {
+            await message.queueAttachmentDownloads();
+          }
         }
 
         // Does this message have any pending, previously-received associated reactions?

ts/state/selectors/search.ts

@@ -28,6 +28,8 @@ import {
   getConversationSelector,
 } from './conversations';
 
+import { BodyRangeType } from '../../types/Util';
+
 export const getSearch = (state: StateType): SearchStateType => state.search;
 
 export const getQuery = createSelector(
@@ -110,29 +112,6 @@ export const getSearchResults = createSelector(
   }
 );
 
-export function _messageSearchResultSelector(
-  message: MessageSearchResultType,
-  from: ConversationType,
-  to: ConversationType,
-  searchConversationId?: string,
-  selectedMessageId?: string
-): MessageSearchResultPropsDataType {
-  return {
-    from,
-    to,
-
-    id: message.id,
-    conversationId: message.conversationId,
-    sentAt: message.sent_at,
-    snippet: message.snippet,
-    bodyRanges: message.bodyRanges,
-    body: message.body,
-
-    isSelected: Boolean(selectedMessageId && message.id === selectedMessageId),
-    isSearchingInConversation: Boolean(searchConversationId),
-  };
-}
-
 // A little optimization to reset our selector cache whenever high-level application data
 //   changes: regionCode and userNumber.
 type CachedMessageSearchResultSelectorType = (
@@ -142,18 +121,58 @@ type CachedMessageSearchResultSelectorType = (
   searchConversationId?: string,
   selectedMessageId?: string
 ) => MessageSearchResultPropsDataType;
+
 export const getCachedSelectorForMessageSearchResult = createSelector(
   getUserConversationId,
-  (): CachedMessageSearchResultSelectorType => {
+  getConversationSelector,
+  (
+    _,
+    conversationSelector: GetConversationByIdType
+  ): CachedMessageSearchResultSelectorType => {
     // Note: memoizee will check all parameters provided, and only run our selector
     //   if any of them have changed.
-    return memoizee(_messageSearchResultSelector, { max: 500 });
+    return memoizee(
+      (
+        message: MessageSearchResultType,
+        from: ConversationType,
+        to: ConversationType,
+        searchConversationId?: string,
+        selectedMessageId?: string
+      ) => {
+        const bodyRanges = message.bodyRanges || [];
+        return {
+          from,
+          to,
+
+          id: message.id,
+          conversationId: message.conversationId,
+          sentAt: message.sent_at,
+          snippet: message.snippet,
+          bodyRanges: bodyRanges.map((bodyRange: BodyRangeType) => {
+            const conversation = conversationSelector(bodyRange.mentionUuid);
+
+            return {
+              ...bodyRange,
+              replacementText: conversation.title,
+            };
+          }),
+          body: message.body,
+
+          isSelected: Boolean(
+            selectedMessageId && message.id === selectedMessageId
+          ),
+          isSearchingInConversation: Boolean(searchConversationId),
+        };
+      },
+      { max: 500 }
+    );
   }
 );
 
 type GetMessageSearchResultByIdType = (
   id: string
 ) => MessageSearchResultPropsDataType | undefined;
+
 export const getMessageSearchResultSelector = createSelector(
   getCachedSelectorForMessageSearchResult,
   getMessageSearchResultLookup,

ts/test-both/state/selectors/search_test.ts

@@ -204,9 +204,6 @@ describe('both/state/selectors/search', () => {
         ...state,
         conversations: {
           ...state.conversations,
-          conversationLookup: {
-            ...state.conversations.conversationLookup,
-          },
         },
       };
       const secondSelector = getMessageSearchResultSelector(secondState);

ts/util/messageBatcher.ts

@@ -8,17 +8,17 @@ import { createWaitBatcher } from './waitBatcher';
 export const updateMessageBatcher = createBatcher<MessageAttributesType>({
   wait: 500,
   maxSize: 50,
-  processBatch: async (messages: Array<MessageAttributesType>) => {
-    window.log.info('updateMessageBatcher', messages.length);
-    await window.Signal.Data.saveMessages(messages, {});
+  processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
+    window.log.info('updateMessageBatcher', messageAttrs.length);
+    await window.Signal.Data.saveMessages(messageAttrs, {});
   },
 });
 
 export const saveNewMessageBatcher = createWaitBatcher<MessageAttributesType>({
   wait: 500,
   maxSize: 30,
-  processBatch: async (messages: Array<MessageAttributesType>) => {
-    window.log.info('saveNewMessageBatcher', messages.length);
-    await window.Signal.Data.saveMessages(messages, { forceSave: true });
+  processBatch: async (messageAttrs: Array<MessageAttributesType>) => {
+    window.log.info('saveNewMessageBatcher', messageAttrs.length);
+    await window.Signal.Data.saveMessages(messageAttrs, { forceSave: true });
   },
 });

ts/window.d.ts

@@ -137,7 +137,7 @@ declare global {
 
     WhatIsThis: WhatIsThis;
 
-    attachmentDownloadQueue: Array<MessageModel>;
+    attachmentDownloadQueue: Array<MessageModel> | undefined;
     baseAttachmentsPath: string;
     baseStickersPath: string;
     baseTempPath: string;