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, { type SqliteDatabase } from 'sql.js'; | import initSqlJs, { type SqliteDatabase } 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 { getSQLiteDBVersion } from '../queries/db-queries.js'; | import { getSQLiteDBVersion, setupSQLiteDB } from '../queries/db-queries.js'; | ||||
| import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.js'; | import { SQLITE_CONTENT, SQLITE_ENCRYPTION_KEY } from '../utils/constants.js'; | ||||
| import { generateDatabaseCryptoKey } from '../utils/worker-crypto-utils.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', | ||||
| Show All 15 Lines | async function initDatabase(sqljsFilePath: string, sqljsFilename: ?string) { | ||||
| const SQL = await initSqlJs({ | const SQL = await initSqlJs({ | ||||
| locateFile, | locateFile, | ||||
| }); | }); | ||||
| if (content) { | if (content) { | ||||
| sqliteDb = new SQL.Database(new Uint8Array(content)); | sqliteDb = new SQL.Database(new Uint8Array(content)); | ||||
| } else { | } else { | ||||
| sqliteDb = new SQL.Database(); | sqliteDb = new SQL.Database(); | ||||
| setupSQLiteDB(sqliteDb); | |||||
| } | } | ||||
| const dbVersion = getSQLiteDBVersion(sqliteDb); | const dbVersion = getSQLiteDBVersion(sqliteDb); | ||||
| console.info(`Db version: ${dbVersion}`); | console.info(`Db version: ${dbVersion}`); | ||||
| } | } | ||||
| async function processAppRequest( | async function processAppRequest( | ||||
| message: WorkerRequestMessage, | message: WorkerRequestMessage, | ||||
| ▲ Show 20 Lines • Show All 53 Lines • Show Last 20 Lines | |||||