Differential D6992 Diff 23833 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 {			import {
	type SharedWorkerMessageEvent,			type SharedWorkerMessageEvent,
	type WorkerRequestMessage,			type WorkerRequestMessage,
	type WorkerResponseMessage,			type WorkerResponseMessage,
	workerRequestMessageTypes,			workerRequestMessageTypes,
	workerResponseMessageTypes,			workerResponseMessageTypes,
				type WorkerRequestProxyMessage,
	} from '../../types/worker-types.js';			} from '../../types/worker-types.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 16 Lines
	function connectHandler(event: SharedWorkerMessageEvent) {			function connectHandler(event: SharedWorkerMessageEvent) {
	if (!event.ports.length) {			if (!event.ports.length) {
	return;			return;
	}			}
	const port: MessagePort = event.ports[0];			const port: MessagePort = event.ports[0];
	console.log('Web database worker alive!');			console.log('Web database worker alive!');

	port.onmessage = async function (messageEvent: MessageEvent) {			port.onmessage = async function (messageEvent: MessageEvent) {
	const message: WorkerRequestMessage = (messageEvent.data: any);			const data: WorkerRequestProxyMessage = (messageEvent.data: any);
				const { id, message } = data;

				if (!id) {
				port.postMessage({
				error: new Error('Request without identifier'),
				});
				}

	try {			try {
	const result = processAppRequest(message);			const result = processAppRequest(message);
	port.postMessage(result);			port.postMessage({
				id,
				message: result,
				});
	} catch (e) {			} catch (e) {
	port.postMessage({			port.postMessage({
				id,
	error: e,			error: e,
	});			});
	}			}
	};			};
	}			}

	self.addEventListener('connect', connectHandler);			self.addEventListener('connect', connectHandler);