Differential D7658 Diff 26168 web/redux/create-async-migrate.js

Changeset View

Standalone View

web/redux/create-async-migrate.js

This file was added.

				// @flow

				import { DEFAULT_VERSION } from 'redux-persist/es/constants.js';
				import type { PersistState } from 'redux-persist/es/types.js';

				type MigrationManifest = {
				+[number \| string]: (PersistedState) => Promise<PersistedState>,
				};
				type PersistedState = {
				+_persist: PersistState,
				...
				} \| void;

				function createAsyncMigrate(
				migrations: MigrationManifest,
				config: { +debug: boolean },
				): (state: PersistedState, currentVersion: number) => Promise<PersistedState> {
				const debug = !!config?.debug;
				return async function (
				state: PersistedState,
				currentVersion: number,
				): Promise<PersistedState> {
				if (!state) {
				if (process.env.NODE_ENV !== 'production' && debug) {
				console.log('redux-persist: no inbound state, skipping migration');
				}
				return undefined;
				}

				const inboundVersion: number =
				state._persist && state._persist.version !== undefined
				? state._persist.version
				: DEFAULT_VERSION;

				if (inboundVersion === currentVersion) {
				if (process.env.NODE_ENV !== 'production' && debug) {
				console.log('redux-persist: versions match, noop migration');
				}
				return state;
				}
				if (inboundVersion > currentVersion) {
				if (process.env.NODE_ENV !== 'production') {
				console.error('redux-persist: downgrading version is not supported');
				}
				return state;
				}

				const migrationKeys = Object.keys(migrations)
				.map(ver => parseInt(ver))
				.filter(key => currentVersion >= key && key > inboundVersion)
				.sort((a, b) => a - b);

				if (process.env.NODE_ENV !== 'production' && debug) {
				console.log('redux-persist: migrationKeys', migrationKeys);
				}

				let migratedState: PersistedState = state;
				for (const versionKey of migrationKeys) {
				if (process.env.NODE_ENV !== 'production' && debug) {
				console.log(
				'redux-persist: running migration for versionKey',
				versionKey,
				);
				}
				if (versionKey) {
				migratedState = await migrations[versionKey](migratedState);
				}
				}

				return migratedState;
				};
				}

				export { createAsyncMigrate };