Differential D7101 Diff 24017 web/database/worker/db-worker.js

Changeset View

Standalone View

web/database/worker/db-worker.js

	// @flow			// @flow

	import localforage from 'localforage';			import localforage from 'localforage';
	import initSqlJs from 'sql.js';			import initSqlJs, { type SqliteDatabase } from 'sql.js';

	import {			import {
	type SharedWorkerMessageEvent,			type SharedWorkerMessageEvent,
	type WorkerRequestMessage,			type WorkerRequestMessage,
	type WorkerResponseMessage,			type WorkerResponseMessage,
	workerRequestMessageTypes,			workerRequestMessageTypes,
	workerResponseMessageTypes,			workerResponseMessageTypes,
	type WorkerRequestProxyMessage,			type WorkerRequestProxyMessage,
	} from '../../types/worker-types.js';			} from '../../types/worker-types.js';
	import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.js';			import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.js';
	import { generateDatabaseCryptoKey } from '../utils/worker-crypto-utils.js';			import { generateDatabaseCryptoKey } from '../utils/worker-crypto-utils.js';

	const localforageConfig: PartialConfig = {			const localforageConfig: PartialConfig = {
	driver: localforage.INDEXEDDB,			driver: localforage.INDEXEDDB,
	name: 'comm',			name: 'comm',
	storeName: 'commStorage',			storeName: 'commStorage',
	description: 'Comm encrypted database storage',			description: 'Comm encrypted database storage',
	version: '1.0',			version: '1.0',
	};			};
	localforage.config(localforageConfig);			localforage.config(localforageConfig);

	let sqliteDb = null;			let sqliteDb: ?SqliteDatabase = null;

	async function initDatabase(sqljsFilePath: string, sqljsFilename: ?string) {			async function initDatabase(sqljsFilePath: string, sqljsFilename: ?string) {
	const content = await localforage.getItem(SQLITE_CONTENT);			const content = await localforage.getItem(SQLITE_CONTENT);

	const locateFile = defaultFilename => {			const locateFile = defaultFilename => {
	if (sqljsFilename) {			if (sqljsFilename) {
	return `${sqljsFilePath}/${sqljsFilename}`;			return `${sqljsFilePath}/${sqljsFilename}`;
	}			}
	return `${sqljsFilePath}/${defaultFilename}`;			return `${sqljsFilePath}/${defaultFilename}`;
	};			};
	const SQL = await initSqlJs({			const SQL = await initSqlJs({
	locateFile,			locateFile,
	});			});

	if (content) {			if (content) {
	sqliteDb = new SQL.Database(new Uint8Array(content));			sqliteDb = new SQL.Database(new Uint8Array(content));
	} else {			} else {
	sqliteDb = new SQL.Database();			sqliteDb = new SQL.Database();
	}			}

	const versionData = sqliteDb.exec('PRAGMA user_version;');			const versionData = sqliteDb.exec('PRAGMA user_version;');
	if (versionData.length && versionData[0].values.length) {			if (!versionData.length \|\| !versionData[0].values.length) {
	console.info(`Db version: ${versionData[0].values[0]}`);			throw new Error('Error while retrieving database version');
				}
				const [dbVersion] = versionData[0].values[0];
				kamilAuthorUnsubmitted Done Inline Actions Because it was badly typed previously I needed to do some enhancement here to satisfy Flow. It is refactored later in the stack anyway kamil: Because it was badly typed previously I needed to do some enhancement here to satisfy Flow. It…
				if (typeof dbVersion === 'number') {
				console.info(`Db version: ${dbVersion}`);
	} else {			} else {
	throw new Error('Error while retrieving database version');			throw new Error('Error while retrieving database version');
	}			}
	}			}

	async function processAppRequest(			async function processAppRequest(
	message: WorkerRequestMessage,			message: WorkerRequestMessage,
	): Promise<?WorkerResponseMessage> {			): Promise<?WorkerResponseMessage> {
	▲ Show 20 Lines • Show All 52 Lines • Show Last 20 Lines