Page MenuHomePhabricator
Files F3390127

D11615.diff
No OneTemporary
Actions

D11615.diff
View Options

diff --git a/lib/types/store-ops-types.js b/lib/types/store-ops-types.js
--- a/lib/types/store-ops-types.js
+++ b/lib/types/store-ops-types.js
@@ -50,7 +50,10 @@
ClientDBSyncedMetadataEntry,
ClientDBSyncedMetadataStoreOperation,
} from '../ops/synced-metadata-store-ops.js';
-import type { ClientDBThreadActivityEntry } from '../ops/thread-activity-store-ops.js';
+import type {
+ ClientDBThreadActivityEntry,
+ ClientDBThreadActivityStoreOperation,
+} from '../ops/thread-activity-store-ops.js';
import type {
ClientDBThreadStoreOperation,
ThreadStoreOperation,
@@ -85,6 +88,7 @@
+integrityStoreOperations?: $ReadOnlyArray<ClientDBIntegrityStoreOperation>,
+syncedMetadataStoreOperations?: $ReadOnlyArray<ClientDBSyncedMetadataStoreOperation>,
+auxUserStoreOperations?: $ReadOnlyArray<ClientDBAuxUserStoreOperation>,
+ +threadActivityStoreOperations?: $ReadOnlyArray<ClientDBThreadActivityStoreOperation>,
};
export type ClientDBStore = {
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
@@ -7,6 +7,7 @@
import type { ClientDBMessageStoreOperation } from 'lib/ops/message-store-ops.js';
import type { ClientDBReportStoreOperation } from 'lib/ops/report-store-ops.js';
import type { ClientDBSyncedMetadataStoreOperation } from 'lib/ops/synced-metadata-store-ops.js';
+import type { ClientDBThreadActivityStoreOperation } from 'lib/ops/thread-activity-store-ops.js';
import type { ClientDBThreadStoreOperation } from 'lib/ops/thread-store-ops.js';
import type { ClientDBUserStoreOperation } from 'lib/ops/user-store-ops.js';
import type {
@@ -360,6 +361,7 @@
auxUserStoreOperations,
userStoreOperations,
messageStoreOperations,
+ threadActivityStoreOperations,
} = storeOperations;
try {
@@ -437,6 +439,16 @@
module,
);
}
+ if (
+ threadActivityStoreOperations &&
+ threadActivityStoreOperations.length > 0
+ ) {
+ processThreadActivityStoreOperations(
+ sqliteQueryExecutor,
+ threadActivityStoreOperations,
+ module,
+ );
+ }
sqliteQueryExecutor.commitTransaction();
} catch (e) {
sqliteQueryExecutor.rollbackTransaction();
@@ -476,6 +488,40 @@
}
}
+function processThreadActivityStoreOperations(
+ sqliteQueryExecutor: SQLiteQueryExecutor,
+ operations: $ReadOnlyArray<ClientDBThreadActivityStoreOperation>,
+ module: EmscriptenModule,
+) {
+ for (const operation: ClientDBThreadActivityStoreOperation of operations) {
+ try {
+ if (operation.type === 'remove_all_thread_activity_entries') {
+ sqliteQueryExecutor.removeAllThreadActivityEntries();
+ } else if (operation.type === 'remove_thread_activity_entries') {
+ const { ids } = operation.payload;
+ sqliteQueryExecutor.removeThreadActivityEntries(ids);
+ } else if (operation.type === 'replace_thread_activity_entry') {
+ const { id, threadActivityStoreEntry } = operation.payload;
+ sqliteQueryExecutor.replaceThreadActivityEntry({
+ id,
+ threadActivityStoreEntry,
+ });
+ } else {
+ throw new Error('Unsupported thread activity operation');
+ }
+ } catch (e) {
+ throw new Error(
+ `Error while processing ${
+ operation.type
+ } thread activity operation: ${getProcessingStoreOpsExceptionMessage(
+ e,
+ module,
+ )}`,
+ );
+ }
+ }
+}
+
function getClientStoreFromQueryExecutor(
sqliteQueryExecutor: SQLiteQueryExecutor,
): ClientDBStore {
@@ -500,7 +546,7 @@
integrityThreadHashes: sqliteQueryExecutor.getAllIntegrityThreadHashes(),
syncedMetadata: sqliteQueryExecutor.getAllSyncedMetadata(),
auxUserInfos: sqliteQueryExecutor.getAllAuxUserInfos(),
- threadActivityEntries: [],
+ threadActivityEntries: sqliteQueryExecutor.getAllThreadActivityEntries(),
};
}

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 30, 10:20 PM (19 h, 36 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2602589
Default Alt Text
D11615.diff (3 KB)

Event Timeline