Differential D6992 Diff 23510 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 {		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 13 Lines	): ?WorkerResponseMessage {
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!');

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);