Changeset View
Changeset View
Standalone View
Standalone View
web/database/worker/db-worker.js
| Show All 12 Lines | import { | ||||
| type SharedWorkerMessageEvent, | type SharedWorkerMessageEvent, | ||||
| type WorkerRequestMessage, | type WorkerRequestMessage, | ||||
| type WorkerResponseMessage, | type WorkerResponseMessage, | ||||
| workerRequestMessageTypes, | workerRequestMessageTypes, | ||||
| workerResponseMessageTypes, | workerResponseMessageTypes, | ||||
| type WorkerRequestProxyMessage, | type WorkerRequestProxyMessage, | ||||
| workerWriteRequests, | workerWriteRequests, | ||||
| } from '../../types/worker-types.js'; | } from '../../types/worker-types.js'; | ||||
| import { getSQLiteDBVersion, setupSQLiteDB } from '../queries/db-queries.js'; | import { migrate, setupSQLiteDB } from '../queries/db-queries.js'; | ||||
| import { | import { | ||||
| getAllDrafts, | getAllDrafts, | ||||
| moveDraft, | moveDraft, | ||||
| removeAllDrafts, | removeAllDrafts, | ||||
| updateDraft, | updateDraft, | ||||
| } from '../queries/draft-queries.js'; | } from '../queries/draft-queries.js'; | ||||
| import { getMetadata, setMetadata } from '../queries/metadata-queries.js'; | import { getMetadata, setMetadata } from '../queries/metadata-queries.js'; | ||||
| import { | import { | ||||
| ▲ Show 20 Lines • Show All 56 Lines • ▼ Show 20 Lines | const SQL = await initSqlJs({ | ||||
| locateFile, | locateFile, | ||||
| }); | }); | ||||
| if (dbContent) { | if (dbContent) { | ||||
| sqliteDb = new SQL.Database(dbContent); | sqliteDb = new SQL.Database(dbContent); | ||||
| console.info( | console.info( | ||||
| 'Database exists and is properly encrypted, using persisted data', | 'Database exists and is properly encrypted, using persisted data', | ||||
| ); | ); | ||||
| migrate(sqliteDb); | |||||
| } else { | } else { | ||||
| sqliteDb = new SQL.Database(); | sqliteDb = new SQL.Database(); | ||||
| setupSQLiteDB(sqliteDb); | setupSQLiteDB(sqliteDb); | ||||
| console.info('Creating fresh database'); | console.info('Creating fresh database'); | ||||
| } | } | ||||
| const dbVersion = getSQLiteDBVersion(sqliteDb); | |||||
| console.info(`Db version: ${dbVersion}`); | |||||
| } | } | ||||
| function processDraftStoreOperations( | function processDraftStoreOperations( | ||||
| operations: $ReadOnlyArray<ClientDBDraftStoreOperation>, | operations: $ReadOnlyArray<ClientDBDraftStoreOperation>, | ||||
| ) { | ) { | ||||
| if (!sqliteDb) { | if (!sqliteDb) { | ||||
| throw new Error('Database not initialized'); | throw new Error('Database not initialized'); | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 169 Lines • Show Last 20 Lines | |||||