Page MenuHomePhabricator
Files F2834578

D7470.diff
No OneTemporary
Actions

D7470.diff
View Options

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,
+ },
};
},
);

File Metadata

Mime Type
text/plain
Expires
Sun, Sep 29, 11:49 AM (22 h, 31 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2200288
Default Alt Text
D7470.diff (2 KB)

Event Timeline