diff --git a/native/redux/redux-setup.js b/native/redux/redux-setup.js --- a/native/redux/redux-setup.js +++ b/native/redux/redux-setup.js @@ -48,7 +48,6 @@ import { remoteReduxDevServerConfig } from './dev-tools.js'; import { persistConfig, setPersistor } from './persist.js'; import { onStateDifference } from './redux-debug-utils.js'; -import { processDBStoreOperations } from './redux-utils.js'; import { nonUserSpecificFieldsNative } from './state-types.js'; import type { AppState } from './state-types.js'; import { getGlobalNavContext } from '../navigation/icky-global.js'; @@ -316,8 +315,6 @@ dbOpsStore: queueDBOps(state.dbOpsStore, action.messageID, ops), }; - void processDBStoreOperations(ops); - return state; } diff --git a/web/redux/redux-setup.js b/web/redux/redux-setup.js --- a/web/redux/redux-setup.js +++ b/web/redux/redux-setup.js @@ -66,7 +66,6 @@ import { reduceServicesAccessToken } from './services-access-token-reducer.js'; import { getVisibility } from './visibility.js'; import { activeThreadSelector } from '../selectors/nav-selectors.js'; -import { processDBStoreOperations } from '../shared-worker/utils/store.js'; import type { InitialReduxState } from '../types/redux-types.js'; export type WindowDimensions = { width: number, height: number }; @@ -175,7 +174,7 @@ }, }); } - return validateStateAndProcessDBOperations( + return validateStateAndQueueOpsProcessing( action, oldState, { @@ -197,7 +196,7 @@ }, ); } else if (action.type === updateWindowDimensionsActionType) { - return validateStateAndProcessDBOperations( + return validateStateAndQueueOpsProcessing( action, oldState, { @@ -207,7 +206,7 @@ storeOperations, ); } else if (action.type === updateWindowActiveActionType) { - return validateStateAndProcessDBOperations( + return validateStateAndQueueOpsProcessing( action, oldState, { @@ -361,7 +360,7 @@ ), }; - return validateStateAndProcessDBOperations( + return validateStateAndQueueOpsProcessing( action, oldState, state, @@ -369,7 +368,7 @@ ); } -function validateStateAndProcessDBOperations( +function validateStateAndQueueOpsProcessing( action: Action, oldState: AppState, state: AppState, @@ -488,22 +487,14 @@ // As soon as one of the actions is updated, this fix (and the corresponding // one in tab-synchronization.js) can be removed. // $FlowFixMe - if (action.dispatchSource !== 'tab-sync') { - state = { - ...state, - dbOpsStore: queueDBOps( - state.dbOpsStore, - action.messageID, - storeOperations, - ), - }; - void processDBStoreOperations( - storeOperations, - state.currentUserInfo?.id ?? null, - ); + if (action.dispatchSource === 'tab-sync') { + return state; } - return state; + return { + ...state, + dbOpsStore: queueDBOps(state.dbOpsStore, action.messageID, storeOperations), + }; } export { nonUserSpecificFieldsWeb, reducer };