Differential D6996 Diff 23603 web/database/worker/web-db-worker.js

Changeset View

Standalone View

web/database/worker/web-db-worker.js

// @flow		// @flow

import localforage from 'localforage';		import localforage from 'localforage';
import initSqlJs from 'sql.js';		import initSqlJs from 'sql.js';

import { isDev } from 'lib/utils/dev-utils.js';		import { isDev } from 'lib/utils/dev-utils.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 } from '../utils/constants.js';		import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.js';
		import { generateCryptoKey } 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',
};		};
Show All 29 Lines	): Promise<?WorkerResponseMessage> {
if (message.type === workerRequestMessageTypes.PING) {		if (message.type === workerRequestMessageTypes.PING) {
return {		return {
type: workerResponseMessageTypes.PONG,		type: workerResponseMessageTypes.PONG,
text: 'PONG',		text: 'PONG',
};		};
} else if (message.type === workerRequestMessageTypes.INIT) {		} else if (message.type === workerRequestMessageTypes.INIT) {
await initDatabase();		await initDatabase();
return;		return;
		} else if (
		message.type === workerRequestMessageTypes.GENERATE_DATABASE_ENCRYPTION_KEY
		) {
		const cryptoKey = await generateCryptoKey();
		await localforage.setItem(SQLITE_ENCRYPTION_KEY, cryptoKey);
		return;
}		}

throw new Error('Request type not supported');		throw new Error('Request type not supported');
}		}

function connectHandler(event: SharedWorkerMessageEvent) {		function connectHandler(event: SharedWorkerMessageEvent) {
const port: MessagePort = event.ports[0];		const port: MessagePort = event.ports[0];
console.log('Web database worker alive!');		console.log('Web database worker alive!');
Show All 27 Lines