Page MenuHomePhabricator
Files F3185333

D7590.id25618.diff
No OneTemporary
Actions

D7590.id25618.diff
View Options

diff --git a/native/redux/client-db-utils.js b/native/redux/client-db-utils.js
new file mode 100644
--- /dev/null
+++ b/native/redux/client-db-utils.js
@@ -0,0 +1,73 @@
+// @flow
+
+import type {
+ ClientDBThreadInfo,
+ ClientDBThreadStoreOperation,
+ RawThreadInfo,
+} from 'lib/types/thread-types.js';
+import {
+ convertClientDBThreadInfoToRawThreadInfo,
+ convertRawThreadInfoToClientDBThreadInfo,
+} from 'lib/utils/thread-ops-utils.js';
+
+import type { AppState } from './state-types.js';
+import { commCoreModule } from '../native-modules.js';
+
+type ThreadStoreThreadInfos = { +[id: string]: RawThreadInfo };
+
+function updateClientDBThreadStoreThreadInfos(
+ state: AppState,
+ migrationFunc: ThreadStoreThreadInfos => ThreadStoreThreadInfos,
+): AppState {
+ // 1. Get threads from SQLite `threads` table.
+ const clientDBThreadInfos = commCoreModule.getAllThreadsSync();
+
+ // 2. Translate `ClientDBThreadInfo`s to `RawThreadInfo`s.
+ const rawThreadInfos = clientDBThreadInfos.map(
+ convertClientDBThreadInfoToRawThreadInfo,
+ );
+
+ // 3. Convert `rawThreadInfo`s to a map of `threadID` => `threadInfo`.
+ const threadIDToThreadInfo = rawThreadInfos.reduce((acc, threadInfo) => {
+ acc[threadInfo.id] = threadInfo;
+ return acc;
+ }, {});
+
+ // 4. Apply `migrationFunc` to `threadInfo`s.
+ const updatedThreadIDToThreadInfo: ThreadStoreThreadInfos =
+ migrationFunc(threadIDToThreadInfo);
+
+ // 5. Convert the updated `threadInfo`s back into an array.
+ const updatedRawThreadInfos: $ReadOnlyArray<RawThreadInfo> = Object.keys(
+ updatedThreadIDToThreadInfo,
+ ).map(id => updatedThreadIDToThreadInfo[id]);
+
+ // 6. Translate `RawThreadInfo`s to `ClientDBThreadInfo`s.
+ const convertedClientDBThreadInfos: $ReadOnlyArray<ClientDBThreadInfo> =
+ updatedRawThreadInfos.map(convertRawThreadInfoToClientDBThreadInfo);
+
+ // 7. Construct `ClientDBThreadStoreOperation`s to clear SQLite `threads`
+ // table and repopulate with `ClientDBThreadInfo`s.
+ const operations: $ReadOnlyArray<ClientDBThreadStoreOperation> = [
+ {
+ type: 'remove_all',
+ },
+ ...convertedClientDBThreadInfos.map((thread: ClientDBThreadInfo) => ({
+ type: 'replace',
+ payload: thread,
+ })),
+ ];
+
+ // 8. Try processing `ClientDBThreadStoreOperation`s and log out if
+ // `processThreadStoreOperationsSync(...)` throws an exception.
+ try {
+ commCoreModule.processThreadStoreOperationsSync(operations);
+ } catch (exception) {
+ console.log(exception);
+ return { ...state, cookie: null };
+ }
+
+ return state;
+}
+
+export { updateClientDBThreadStoreThreadInfos };

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 9, 12:48 PM (18 h, 24 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2452327
Default Alt Text
D7590.id25618.diff (2 KB)

Event Timeline