diff --git a/lib/utils/message-ops-utils.js b/lib/utils/message-ops-utils.js
--- a/lib/utils/message-ops-utils.js
+++ b/lib/utils/message-ops-utils.js
@@ -19,6 +19,9 @@
   assertMessageType,
   type MessageStoreOperation,
   type ClientDBMessageStoreOperation,
+  type ClientDBThreadMessageInfo,
+  type ThreadMessageInfo,
+  type MessageStoreThreads,
 } from '../types/message-types.js';
 import type { MediaMessageServerDBContent } from '../types/messages/media.js';
 
@@ -228,26 +231,58 @@
   );
 }
 
+function translateThreadMessageInfoToClientDBThreadMessageInfo(
+  id: string,
+  threadMessageInfo: ThreadMessageInfo,
+): ClientDBThreadMessageInfo {
+  const startReached = threadMessageInfo.startReached ? 1 : 0;
+  const lastNavigatedTo = threadMessageInfo.lastNavigatedTo ?? 0;
+  const lastPruned = threadMessageInfo.lastPruned ?? 0;
+  return {
+    id,
+    start_reached: startReached.toString(),
+    last_navigated_to: lastNavigatedTo.toString(),
+    last_pruned: lastPruned.toString(),
+  };
+}
+
 function convertMessageStoreOperationsToClientDBOperations(
   messageStoreOperations: $ReadOnlyArray<MessageStoreOperation>,
 ): $ReadOnlyArray<ClientDBMessageStoreOperation> {
   const convertedOperations = messageStoreOperations.map(
     messageStoreOperation => {
-      if (
-        messageStoreOperation.type === 'replace_threads' ||
-        messageStoreOperation.type === 'remove_threads' ||
-        messageStoreOperation.type === 'remove_all_threads'
-      ) {
-        return undefined;
+      if (messageStoreOperation.type === 'replace') {
+        return {
+          type: 'replace',
+          payload: translateRawMessageInfoToClientDBMessageInfo(
+            messageStoreOperation.payload.messageInfo,
+          ),
+        };
       }
-      if (messageStoreOperation.type !== 'replace') {
+
+      if (messageStoreOperation.type !== 'replace_threads') {
         return messageStoreOperation;
       }
+
+      const threadMessageInfo: MessageStoreThreads =
+        messageStoreOperation.payload.threads;
+      const dbThreadMessageInfos: ClientDBThreadMessageInfo[] = [];
+      for (const threadID in threadMessageInfo) {
+        dbThreadMessageInfos.push(
+          translateThreadMessageInfoToClientDBThreadMessageInfo(
+            threadID,
+            threadMessageInfo[threadID],
+          ),
+        );
+      }
+      if (dbThreadMessageInfos.length === 0) {
+        return undefined;
+      }
       return {
-        type: 'replace',
-        payload: translateRawMessageInfoToClientDBMessageInfo(
-          messageStoreOperation.payload.messageInfo,
-        ),
+        type: 'replace_threads',
+        payload: {
+          threads: dbThreadMessageInfos,
+        },
       };
     },
   );