Page MenuHomePhabricator
Files F3515104

D12014.id40949.diff
No OneTemporary
Actions

D12014.id40949.diff
View Options

diff --git a/lib/shared/create-async-migrate.js b/lib/shared/create-async-migrate.js
deleted file mode 100644
--- a/lib/shared/create-async-migrate.js
+++ /dev/null
@@ -1,127 +0,0 @@
-// @flow
-
-import { DEFAULT_VERSION } from 'redux-persist/es/constants.js';
-
-import type { BaseNavInfo } from '../types/nav-types.js';
-import type { BaseAppState } from '../types/redux-types.js';
-import type { StoreOperations } from '../types/store-ops-types.js';
-import { syncedMetadataNames } from '../types/synced-metadata-types.js';
-import { getConfig } from '../utils/config.js';
-
-type LegacyMigrationManifest<N: BaseNavInfo, T: BaseAppState<N>> = {
- +[number | string]: (T) => Promise<T>,
-};
-type PersistedState<N: BaseNavInfo, T: BaseAppState<N>> = T | void;
-type ConfigType = {
- +debug: boolean,
-};
-
-export type StorageMigrationFunction<N: BaseNavInfo, T: BaseAppState<N>> = (
- debug: boolean,
-) => Promise<?PersistedState<N, T>>;
-
-type MigrationManifest<N: BaseNavInfo, T: BaseAppState<N>> = {
- +[number | string]: (PersistedState<N, T>) => Promise<{
- +state: T,
- +ops: StoreOperations,
- }>,
-};
-
-function createAsyncMigrate<N: BaseNavInfo, T: BaseAppState<N>>(
- legacyMigrations: LegacyMigrationManifest<N, T>,
- config: ConfigType,
- migrations: MigrationManifest<N, T>,
- handleException: (error: Error, state: T) => T,
- storageMigration: ?StorageMigrationFunction<N, T>,
-): (
- state: PersistedState<N, T>,
- currentVersion: number,
-) => Promise<?PersistedState<N, T>> {
- const debug = process.env.NODE_ENV !== 'production' && !!config?.debug;
- return async function (
- state: ?PersistedState<N, T>,
- currentVersion: number,
- ): Promise<?PersistedState<N, T>> {
- if (!state && storageMigration) {
- state = await storageMigration(debug);
- }
- if (!state) {
- if (debug) {
- console.log('redux-persist: no inbound state, skipping migration');
- }
- return undefined;
- }
-
- const inboundVersion: number = state?._persist?.version ?? DEFAULT_VERSION;
-
- if (inboundVersion === currentVersion) {
- if (debug) {
- console.log('redux-persist: versions match, noop migration');
- }
- return state;
- }
- if (inboundVersion > currentVersion) {
- if (debug) {
- console.error('redux-persist: downgrading version is not supported');
- }
- return state;
- }
-
- const migrationKeys = [
- ...Object.keys(legacyMigrations),
- ...Object.keys(migrations),
- ]
- .map(ver => parseInt(ver))
- .filter(key => currentVersion >= key && key > inboundVersion);
- const sortedMigrationKeys = migrationKeys.sort((a, b) => a - b);
-
- if (debug) {
- console.log('redux-persist: migrationKeys', sortedMigrationKeys);
- }
-
- let migratedState = state;
- for (const versionKey of sortedMigrationKeys) {
- if (debug) {
- console.log(
- 'redux-persist: running migration for versionKey',
- versionKey,
- );
- }
-
- if (!versionKey) {
- continue;
- }
-
- if (legacyMigrations[versionKey]) {
- migratedState = await legacyMigrations[versionKey](migratedState);
- } else {
- const { state: newState, ops } =
- await migrations[versionKey](migratedState);
- migratedState = newState;
- const versionUpdateOp = {
- type: 'replace_synced_metadata_entry',
- payload: {
- name: syncedMetadataNames.DB_VERSION,
- data: versionKey.toString(),
- },
- };
- const dbOps = {
- ...ops,
- syncedMetadataStoreOperations: [
- ...(ops.syncedMetadataStoreOperations ?? []),
- versionUpdateOp,
- ],
- };
- try {
- await getConfig().sqliteAPI.processDBStoreOperations(dbOps);
- } catch (exception) {
- return handleException(exception, state);
- }
- }
- }
-
- return migratedState;
- };
-}
-
-export { createAsyncMigrate };
diff --git a/lib/utils/migration-utils.js b/lib/utils/migration-utils.js
--- a/lib/utils/migration-utils.js
+++ b/lib/utils/migration-utils.js
@@ -3,6 +3,7 @@
import invariant from 'invariant';
import { authoritativeKeyserverID } from './authoritative-keyserver.js';
+import { getConfig } from './config.js';
import type { TranslatedThreadMessageInfos } from './message-ops-utils.js';
import { entries } from './objects.js';
import {
@@ -20,6 +21,10 @@
DraftStore,
} from '../types/draft-types';
import type { RawMessageInfo } from '../types/message-types.js';
+import type { BaseNavInfo } from '../types/nav-types.js';
+import type { BaseAppState } from '../types/redux-types.js';
+import type { StoreOperations } from '../types/store-ops-types.js';
+import { syncedMetadataNames } from '../types/synced-metadata-types.js';
import {
threadPermissions,
threadPermissionPropagationPrefixes,
@@ -187,6 +192,122 @@
threadPermissions.MANAGE_INVITE_LINKS,
];
+type LegacyMigrationManifest<N: BaseNavInfo, T: BaseAppState<N>> = {
+ +[number | string]: (T) => Promise<T>,
+};
+type PersistedState<N: BaseNavInfo, T: BaseAppState<N>> = T | void;
+type ConfigType = {
+ +debug: boolean,
+};
+
+export type StorageMigrationFunction<N: BaseNavInfo, T: BaseAppState<N>> = (
+ debug: boolean,
+) => Promise<?PersistedState<N, T>>;
+
+type MigrationManifest<N: BaseNavInfo, T: BaseAppState<N>> = {
+ +[number | string]: (PersistedState<N, T>) => Promise<{
+ +state: T,
+ +ops: StoreOperations,
+ }>,
+};
+
+function createAsyncMigrate<N: BaseNavInfo, T: BaseAppState<N>>(
+ legacyMigrations: LegacyMigrationManifest<N, T>,
+ config: ConfigType,
+ migrations: MigrationManifest<N, T>,
+ handleException: (error: Error, state: T) => T,
+ storageMigration: ?StorageMigrationFunction<N, T>,
+): (
+ state: PersistedState<N, T>,
+ currentVersion: number,
+) => Promise<?PersistedState<N, T>> {
+ const debug = process.env.NODE_ENV !== 'production' && !!config?.debug;
+ return async function (
+ state: ?PersistedState<N, T>,
+ currentVersion: number,
+ ): Promise<?PersistedState<N, T>> {
+ if (!state && storageMigration) {
+ state = await storageMigration(debug);
+ }
+ if (!state) {
+ if (debug) {
+ console.log('redux-persist: no inbound state, skipping migration');
+ }
+ return undefined;
+ }
+
+ const inboundVersion: number = state?._persist?.version ?? -1;
+
+ if (inboundVersion === currentVersion) {
+ if (debug) {
+ console.log('redux-persist: versions match, noop migration');
+ }
+ return state;
+ }
+ if (inboundVersion > currentVersion) {
+ if (debug) {
+ console.error('redux-persist: downgrading version is not supported');
+ }
+ return state;
+ }
+
+ const migrationKeys = [
+ ...Object.keys(legacyMigrations),
+ ...Object.keys(migrations),
+ ]
+ .map(ver => parseInt(ver))
+ .filter(key => currentVersion >= key && key > inboundVersion);
+ const sortedMigrationKeys = migrationKeys.sort((a, b) => a - b);
+
+ if (debug) {
+ console.log('redux-persist: migrationKeys', sortedMigrationKeys);
+ }
+
+ let migratedState = state;
+ for (const versionKey of sortedMigrationKeys) {
+ if (debug) {
+ console.log(
+ 'redux-persist: running migration for versionKey',
+ versionKey,
+ );
+ }
+
+ if (!versionKey) {
+ continue;
+ }
+
+ if (legacyMigrations[versionKey]) {
+ migratedState = await legacyMigrations[versionKey](migratedState);
+ } else {
+ const { state: newState, ops } =
+ await migrations[versionKey](migratedState);
+ migratedState = newState;
+ const versionUpdateOp = {
+ type: 'replace_synced_metadata_entry',
+ payload: {
+ name: syncedMetadataNames.DB_VERSION,
+ data: versionKey.toString(),
+ },
+ };
+ const dbOps = {
+ ...ops,
+ syncedMetadataStoreOperations: [
+ ...(ops.syncedMetadataStoreOperations ?? []),
+ versionUpdateOp,
+ ],
+ };
+ try {
+ await getConfig().sqliteAPI.processDBStoreOperations(dbOps);
+ } catch (exception) {
+ return handleException(exception, state);
+ }
+ }
+ }
+
+ return migratedState;
+ };
+}
+
export {
convertDraftKeyToNewIDSchema,
convertDraftStoreToNewIDSchema,
@@ -197,4 +318,5 @@
convertIDToNewSchema,
convertNotificationMessageInfoToNewIDSchema,
permissionsToRemoveInMigration,
+ createAsyncMigrate,
};
diff --git a/native/redux/persist.js b/native/redux/persist.js
--- a/native/redux/persist.js
+++ b/native/redux/persist.js
@@ -57,7 +57,6 @@
import { patchRawThreadInfosWithSpecialRole } from 'lib/permissions/special-roles.js';
import { filterThreadIDsInFilterList } from 'lib/reducers/calendar-filters-reducer.js';
import { highestLocalIDSelector } from 'lib/selectors/local-id-selectors.js';
-import { createAsyncMigrate } from 'lib/shared/create-async-migrate.js';
import { inconsistencyResponsesToReports } from 'lib/shared/report-utils.js';
import {
getContainingThreadID,
@@ -108,6 +107,7 @@
generateIDSchemaMigrationOpsForDrafts,
convertMessageStoreThreadsToNewIDSchema,
convertThreadStoreThreadInfosToNewIDSchema,
+ createAsyncMigrate,
} from 'lib/utils/migration-utils.js';
import { entries } from 'lib/utils/objects.js';
import {
diff --git a/web/redux/persist.js b/web/redux/persist.js
--- a/web/redux/persist.js
+++ b/web/redux/persist.js
@@ -13,10 +13,6 @@
import type { ClientDBMessageStoreOperation } from 'lib/ops/message-store-ops.js';
import type { ClientDBThreadStoreOperation } from 'lib/ops/thread-store-ops.js';
import { patchRawThreadInfoWithSpecialRole } from 'lib/permissions/special-roles.js';
-import {
- createAsyncMigrate,
- type StorageMigrationFunction,
-} from 'lib/shared/create-async-migrate.js';
import { keyserverStoreTransform } from 'lib/shared/transforms/keyserver-store-transform.js';
import { messageStoreMessagesBlocklistTransform } from 'lib/shared/transforms/message-store-transform.js';
import { defaultAlertInfos } from 'lib/types/alert-types.js';
@@ -35,6 +31,8 @@
import {
generateIDSchemaMigrationOpsForDrafts,
convertDraftStoreToNewIDSchema,
+ createAsyncMigrate,
+ type StorageMigrationFunction,
} from 'lib/utils/migration-utils.js';
import { entries } from 'lib/utils/objects.js';
import {

File Metadata

Mime Type
text/plain
Expires
Mon, Dec 23, 7:30 AM (18 h, 56 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2693099
Default Alt Text
D12014.id40949.diff (10 KB)

Event Timeline