Differential D6991 Diff 23832 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 { type SharedWorkerMessageEvent } from '../../types/worker-types.js';			import {
				type SharedWorkerMessageEvent,
				type WorkerRequestMessage,
				type WorkerResponseMessage,
				workerRequestMessageTypes,
				workerResponseMessageTypes,
				} 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',
	};			};
	localforage.config(localforageConfig);			localforage.config(localforageConfig);

				function processAppRequest(
				message: WorkerRequestMessage,
				): ?WorkerResponseMessage {
				if (message.type === workerRequestMessageTypes.PING) {
				return {
				type: workerResponseMessageTypes.PONG,
				text: 'PONG',
				};
				}

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

	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) {
	console.log('message from main thread: ', messageEvent.data);			const message: WorkerRequestMessage = (messageEvent.data: any);

	port.postMessage({ message: 'response from worker' });			try {
				const result = processAppRequest(message);
				port.postMessage(result);
				} catch (e) {
				port.postMessage({
				error: e,
				});
				}
	};			};
	}			}

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