Changeset View
Changeset View
Standalone 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 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 } from '../utils/constants.js'; | import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.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', | ||||
| }; | }; | ||||
| Show All 34 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(message.sqljsFilePath, message.sqljsFilename); | await initDatabase(message.sqljsFilePath, message.sqljsFilename); | ||||
| return; | return; | ||||
| } else if ( | |||||
| message.type === workerRequestMessageTypes.GENERATE_DATABASE_ENCRYPTION_KEY | |||||
| ) { | |||||
| const cryptoKey = await generateDatabaseCryptoKey(); | |||||
| 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) { | ||||
| if (!event.ports.length) { | if (!event.ports.length) { | ||||
| return; | return; | ||||
| Show All 30 Lines | |||||