Page MenuHomePhorge
Files F32159002

redux-utils.js
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

redux-utils.js
View Options

// @flow
import { useSelector as reactReduxUseSelector } from 'react-redux';
import { messageStoreOpsHandlers } from 'lib/ops/message-store-ops.js';
import { reportStoreOpsHandlers } from 'lib/ops/report-store-ops.js';
import { threadStoreOpsHandlers } from 'lib/ops/thread-store-ops.js';
import { userStoreOpsHandlers } from 'lib/ops/user-store-ops.js';
import type { StoreOperations } from 'lib/types/store-ops-types.js';
import type { AppState } from './state-types.js';
import { commCoreModule } from '../native-modules.js';
import { isTaskCancelledError } from '../utils/error-handling.js';
function useSelector<SS>(
selector: (state: AppState) => SS,
equalityFn?: (a: SS, b: SS) => boolean,
): SS {
return reactReduxUseSelector(selector, equalityFn);
}
async function processDBStoreOperations(
storeOperations: StoreOperations,
): Promise<void> {
const {
draftStoreOperations,
threadStoreOperations,
messageStoreOperations,
reportStoreOperations,
userStoreOperations,
} = storeOperations;
const convertedThreadStoreOperations =
threadStoreOpsHandlers.convertOpsToClientDBOps(threadStoreOperations);
const convertedMessageStoreOperations =
messageStoreOpsHandlers.convertOpsToClientDBOps(messageStoreOperations);
const convertedReportStoreOperations =
reportStoreOpsHandlers.convertOpsToClientDBOps(reportStoreOperations);
const convertedUserStoreOperations =
userStoreOpsHandlers.convertOpsToClientDBOps(userStoreOperations);
try {
const promises = [];
if (convertedThreadStoreOperations.length > 0) {
promises.push(
commCoreModule.processThreadStoreOperations(
convertedThreadStoreOperations,
),
);
}
if (convertedMessageStoreOperations.length > 0) {
promises.push(
commCoreModule.processMessageStoreOperations(
convertedMessageStoreOperations,
),
);
}
if (draftStoreOperations.length > 0) {
promises.push(
commCoreModule.processDraftStoreOperations(draftStoreOperations),
);
}
if (convertedReportStoreOperations.length > 0) {
promises.push(
commCoreModule.processReportStoreOperations(
convertedReportStoreOperations,
),
);
}
if (convertedUserStoreOperations.length > 0) {
promises.push(
commCoreModule.processUserStoreOperations(convertedUserStoreOperations),
);
}
await Promise.all(promises);
} catch (e) {
if (isTaskCancelledError(e)) {
return;
}
// this code will make an entry in SecureStore and cause re-creating
// database when user will open app again
commCoreModule.reportDBOperationsFailure();
commCoreModule.terminate();
}
}
export { useSelector, processDBStoreOperations };

File Metadata

Mime Type
text/x-java
Expires
Sun, Dec 7, 4:24 PM (6 h, 58 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5828482
Default Alt Text
redux-utils.js (2 KB)

Event Timeline