Page MenuHomePhabricator
Files F3359015

D11680.id39192.diff
No OneTemporary
Actions

D11680.id39192.diff
View Options

diff --git a/web/redux/persist.js b/web/redux/persist.js
--- a/web/redux/persist.js
+++ b/web/redux/persist.js
@@ -10,6 +10,7 @@
keyserverStoreOpsHandlers,
type ReplaceKeyserverOperation,
} from 'lib/ops/keyserver-store-ops.js';
+import type { ClientDBMessageStoreOperation } from 'lib/ops/message-store-ops.js';
import {
createAsyncMigrate,
type StorageMigrationFunction,
@@ -19,6 +20,8 @@
import { defaultAlertInfos } from 'lib/types/alert-types.js';
import { defaultCalendarQuery } from 'lib/types/entry-types.js';
import type { KeyserverInfo } from 'lib/types/keyserver-types.js';
+import { messageTypes } from 'lib/types/message-types-enum.js';
+import type { ClientDBMessageInfo } from 'lib/types/message-types.js';
import { cookieTypes } from 'lib/types/session-types.js';
import { defaultConnectionInfo } from 'lib/types/socket-types.js';
import { defaultGlobalThemeInfo } from 'lib/types/theme-types.js';
@@ -384,6 +387,59 @@
return newState;
},
+ [16]: async (state: AppState) => {
+ // 1. Check if `databaseModule` is supported and early-exist if not.
+ const sharedWorker = await getCommSharedWorker();
+ const isDatabaseSupported = await sharedWorker.isSupported();
+
+ if (!isDatabaseSupported) {
+ return state;
+ }
+
+ // 2. Get existing `stores` from SQLite.
+ const stores = await sharedWorker.schedule({
+ type: workerRequestMessageTypes.GET_CLIENT_STORE,
+ });
+ invariant(stores?.store, 'Stores should exist.');
+ const messages: $ReadOnlyArray<ClientDBMessageInfo> = stores.store.messages;
+
+ if (messages.length === 0) {
+ return state;
+ }
+
+ // 3. Filter out `UNSUPPORTED.UPDATE_RELATIONSHIP` `ClientDBMessageInfo`s.
+ const unsupportedMessageIDsToRemove = messages
+ .filter((message: ClientDBMessageInfo) => {
+ if (parseInt(message.type) !== messageTypes.UPDATE_RELATIONSHIP) {
+ return false;
+ }
+
+ invariant(
+ message.content,
+ 'message.content must be set in migration 16',
+ );
+ const { operation } = JSON.parse(message.content);
+ return operation === 'farcaster_mutual';
+ })
+ .map(message => message.id);
+
+ // 4. Construct `ClientDBMessageStoreOperation`s
+ const messageStoreOperations: $ReadOnlyArray<ClientDBMessageStoreOperation> =
+ [
+ {
+ type: 'remove',
+ payload: { ids: unsupportedMessageIDsToRemove },
+ },
+ ];
+
+ // 5. Process the constructed `messageStoreOperations`.
+ await sharedWorker.schedule({
+ type: workerRequestMessageTypes.PROCESS_STORE_OPERATIONS,
+ storeOperations: { messageStoreOperations },
+ });
+
+ return state;
+ },
};
const migrateStorageToSQLite: StorageMigrationFunction = async debug => {
@@ -429,7 +485,7 @@
{ debug: isDev },
migrateStorageToSQLite,
): any),
- version: 15,
+ version: 16,
transforms: [messageStoreMessagesBlocklistTransform, keyserverStoreTransform],
};

File Metadata

Mime Type
text/plain
Expires
Mon, Nov 25, 6:44 AM (20 h, 6 s)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2578828
Default Alt Text
D11680.id39192.diff (2 KB)

Event Timeline