Changeset View
Changeset View
Standalone View
Standalone View
native/redux/redux-setup.js
Show All 12 Lines | import { | ||||
logInActionTypes, | logInActionTypes, | ||||
keyserverAuthActionTypes, | keyserverAuthActionTypes, | ||||
deleteKeyserverAccountActionTypes, | deleteKeyserverAccountActionTypes, | ||||
identityRegisterActionTypes, | identityRegisterActionTypes, | ||||
} from 'lib/actions/user-actions.js'; | } from 'lib/actions/user-actions.js'; | ||||
import { setNewSessionActionType } from 'lib/keyserver-conn/keyserver-conn-types.js'; | import { setNewSessionActionType } from 'lib/keyserver-conn/keyserver-conn-types.js'; | ||||
import type { ThreadStoreOperation } from 'lib/ops/thread-store-ops.js'; | import type { ThreadStoreOperation } from 'lib/ops/thread-store-ops.js'; | ||||
import { threadStoreOpsHandlers } from 'lib/ops/thread-store-ops.js'; | import { threadStoreOpsHandlers } from 'lib/ops/thread-store-ops.js'; | ||||
import { queueDBOps } from 'lib/reducers/db-ops-reducer.js'; | |||||
import { reduceLoadingStatuses } from 'lib/reducers/loading-reducer.js'; | import { reduceLoadingStatuses } from 'lib/reducers/loading-reducer.js'; | ||||
import baseReducer from 'lib/reducers/master-reducer.js'; | import baseReducer from 'lib/reducers/master-reducer.js'; | ||||
import { | import { | ||||
invalidSessionDowngrade, | invalidSessionDowngrade, | ||||
invalidSessionRecovery, | invalidSessionRecovery, | ||||
identityInvalidSessionDowngrade, | identityInvalidSessionDowngrade, | ||||
} from 'lib/shared/session-utils.js'; | } from 'lib/shared/session-utils.js'; | ||||
import { isStaff } from 'lib/shared/staff-utils.js'; | import { isStaff } from 'lib/shared/staff-utils.js'; | ||||
▲ Show 20 Lines • Show All 266 Lines • ▼ Show 20 Lines | function reducer(state: AppState = defaultState, inputAction: Action) { | ||||
const fixUnreadActiveThreadResult = fixUnreadActiveThread(state, action); | const fixUnreadActiveThreadResult = fixUnreadActiveThread(state, action); | ||||
state = fixUnreadActiveThreadResult.state; | state = fixUnreadActiveThreadResult.state; | ||||
const threadStoreOperationsWithUnreadFix = [ | const threadStoreOperationsWithUnreadFix = [ | ||||
...threadStoreOperations, | ...threadStoreOperations, | ||||
...fixUnreadActiveThreadResult.threadStoreOperations, | ...fixUnreadActiveThreadResult.threadStoreOperations, | ||||
]; | ]; | ||||
void processDBStoreOperations({ | const ops = { | ||||
draftStoreOperations, | draftStoreOperations, | ||||
messageStoreOperations, | messageStoreOperations, | ||||
threadStoreOperations: threadStoreOperationsWithUnreadFix, | threadStoreOperations: threadStoreOperationsWithUnreadFix, | ||||
reportStoreOperations, | reportStoreOperations, | ||||
userStoreOperations, | userStoreOperations, | ||||
keyserverStoreOperations, | keyserverStoreOperations, | ||||
communityStoreOperations, | communityStoreOperations, | ||||
integrityStoreOperations, | integrityStoreOperations, | ||||
}); | }; | ||||
state = { | |||||
...state, | |||||
dbOpsStore: queueDBOps(state.dbOpsStore, action.messageID, ops), | |||||
}; | |||||
void processDBStoreOperations(ops); | |||||
return state; | return state; | ||||
} | } | ||||
function sessionInvalidationAlert(payload: SetSessionPayload) { | function sessionInvalidationAlert(payload: SetSessionPayload) { | ||||
if ( | if ( | ||||
!payload.sessionChange.cookieInvalidated || | !payload.sessionChange.cookieInvalidated || | ||||
!payload.preRequestUserState || | !payload.preRequestUserState || | ||||
▲ Show 20 Lines • Show All 124 Lines • Show Last 20 Lines |