diff --git a/web/shared-worker/worker/process-operations.js b/web/shared-worker/worker/process-operations.js --- a/web/shared-worker/worker/process-operations.js +++ b/web/shared-worker/worker/process-operations.js @@ -302,6 +302,15 @@ } else if (operation.type === 'remove_messages_for_threads') { const { threadIDs } = operation.payload; sqliteQueryExecutor.removeMessagesForThreads(threadIDs); + } else if (operation.type === 'replace_local_message_info') { + sqliteQueryExecutor.replaceMessageStoreLocalMessageInfo( + operation.payload, + ); + } else if (operation.type === 'remove_local_message_infos') { + const { ids } = operation.payload; + sqliteQueryExecutor.removeMessageStoreLocalMessageInfos(ids); + } else if (operation.type === 'remove_all_local_message_infos') { + sqliteQueryExecutor.removeAllMessageStoreLocalMessageInfos(); } else { throw new Error('Unsupported message operation'); }