[blob-service] Implement db type conversions
ClosedPublic
Actions

Show All 29 Lines
import type { WebNavInfo } from 'lib/types/nav-types.js';		import type { WebNavInfo } from 'lib/types/nav-types.js';
import { cookieTypes } from 'lib/types/session-types.js';		import { cookieTypes } from 'lib/types/session-types.js';
import { defaultConnectionInfo } from 'lib/types/socket-types.js';		import { defaultConnectionInfo } from 'lib/types/socket-types.js';
import { defaultGlobalThemeInfo } from 'lib/types/theme-types.js';		import { defaultGlobalThemeInfo } from 'lib/types/theme-types.js';
import type { ClientDBThreadInfo } from 'lib/types/thread-types.js';		import type { ClientDBThreadInfo } from 'lib/types/thread-types.js';
import { getConfig } from 'lib/utils/config.js';		import { getConfig } from 'lib/utils/config.js';
import { parseCookies } from 'lib/utils/cookie-utils.js';		import { parseCookies } from 'lib/utils/cookie-utils.js';
import { isDev } from 'lib/utils/dev-utils.js';		import { isDev } from 'lib/utils/dev-utils.js';
		import { stripMemberPermissionsFromRawThreadInfos } from 'lib/utils/member-info-utils.js';
import {		import {
generateIDSchemaMigrationOpsForDrafts,		generateIDSchemaMigrationOpsForDrafts,
convertDraftStoreToNewIDSchema,		convertDraftStoreToNewIDSchema,
createAsyncMigrate,		createAsyncMigrate,
type StorageMigrationFunction,		type StorageMigrationFunction,
} from 'lib/utils/migration-utils.js';		} from 'lib/utils/migration-utils.js';
import { entries } from 'lib/utils/objects.js';		import { entries } from 'lib/utils/objects.js';
import {		import {
▲ Show 20 Lines • Show All 560 Lines • ▼ Show 20 Lines	return {
tunnelbrokerDeviceToken: {		tunnelbrokerDeviceToken: {
localToken: null,		localToken: null,
tunnelbrokerToken: null,		tunnelbrokerToken: null,
},		},
},		},
ops: [],		ops: [],
};		};
},		},
		[80]: async (state: AppState) => {
		// 1. Check if `databaseModule` is supported and early-exit if not.
		const sharedWorker = await getCommSharedWorker();
		const isDatabaseSupported = await sharedWorker.isSupported();

		if (!isDatabaseSupported) {
		return {
		state,
		ops: [],
		};
		}

		// 2. Get existing `stores` from SQLite.
		const stores = await sharedWorker.schedule({
		type: workerRequestMessageTypes.GET_CLIENT_STORE,
		});

		const clientDBThreadInfos: ?$ReadOnlyArray<ClientDBThreadInfo> =
		stores?.store?.threads;

		if (
		clientDBThreadInfos === null \|\|
		clientDBThreadInfos === undefined \|\|
		clientDBThreadInfos.length === 0
		) {
		return {
		state,
		ops: [],
		};
		}

		const dbOperations = createUpdateDBOpsForThreadStoreThreadInfos(
		clientDBThreadInfos,
		// We know that we're dealing with `ThinRawThreadInfoWithPermissions`
		// at time of this migration.
		// $FlowFixMe
		stripMemberPermissionsFromRawThreadInfos,
		);

		return {
		state,
		ops: dbOperations,
		};
		},
};		};

const persistConfig: PersistConfig = {		const persistConfig: PersistConfig = {
keyPrefix: rootKeyPrefix,		keyPrefix: rootKeyPrefix,
key: rootKey,		key: rootKey,
storage: commReduxStorageEngine,		storage: commReduxStorageEngine,
whitelist: isSQLiteSupported()		whitelist: isSQLiteSupported()
? persistWhitelist		? persistWhitelist
Show All 14 Lines

[blob-service] Implement db type conversionsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 28909

services/blob/src/database/types.rs

[blob-service] Implement db type conversions
ClosedPublic
Actions

Revision Contents
Changeset List