mocode-software/meldestelle
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor: streamline deep link handling and improve sqlite worker initialization

Browse Source 
- Simplified `DeepLinkHandler` logic by removing redundant return values and enhancing route parsing with `ifBlank()`.
- Refactored `sqlite.worker.js` for better modularity and error handling.
- Added helper methods for script imports and initialization error management.

Signed-off-by: Stefan Mogeritsch <stefan.mo.co@gmail.com>
This commit is contained in:
Stefan Mogeritsch
2026-03-16 10:26:41 +01:00
parent d1fce33716
commit 2c822f8007
2 changed files with 86 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files
frontend/core/local-db/src/jsMain/resources/sqlite.worker.js
+80 -57
View File
@@ -28,10 +28,24 @@ function processMessage(event) {
const data = event.data;
if (!data) return;
let result;
try {
switch (data.action) {
result = executeAction(data);
} catch (err) {
console.error('[sqlite.worker] Error processing message:', err);
postMessage({id: data.id, error: err?.message ?? String(err)});
return;
}
postMessage({id: data.id, ...result});
}
function executeAction(data) {
switch (data.action) {
case 'exec': {
if (!data.sql) throw new Error('exec: Missing sql string');
if (!data.sql) {
postMessage({id: data.id, error: 'exec: Missing sql string'});
return null;
}
const rows = [];
db.exec({
sql: data.sql,
@@ -39,84 +53,93 @@ function processMessage(event) {
rowMode: 'array',
callback: (row) => rows.push(row),
});
postMessage({id: data.id, results: {values: rows}});
break;
return {results: {values: rows}};
}
case 'begin_transaction':
db.exec('BEGIN TRANSACTION;');
postMessage({id: data.id, results: []});
break;
return {results: []};
case 'end_transaction':
db.exec('END TRANSACTION;');
postMessage({id: data.id, results: []});
break;
return {results: []};
case 'rollback_transaction':
db.exec('ROLLBACK TRANSACTION;');
postMessage({id: data.id, results: []});
break;
return {results: []};
default:
throw new Error(`Unsupported action: ${data.action}`);
}
} catch (err) {
console.error('[sqlite.worker] Error processing message:', err);
postMessage({id: data.id, error: err?.message ?? String(err)});
postMessage({id: data.id, error: `Unsupported action: ${data.action}`});
return null;
}
}
// --- Initialization ---
async function init() {
try {
// Load sqlite3.js via importScripts (avoids Webpack bundling issues)
try {
importScripts('sqlite3.js');
} catch (e) {
throw new Error(`importScripts('sqlite3.js') failed – is the file served at root? ${e.message}`);
}
// Load sqlite3.js via importScripts (avoids Webpack bundling issues)
const loadResult = tryImportScripts();
if (loadResult !== null) {
handleInitError(loadResult);
return;
}
if (typeof self.sqlite3InitModule !== 'function') {
throw new Error('sqlite3InitModule not found after importScripts – sqlite3.js may be corrupt or wrong version.');
}
if (typeof self.sqlite3InitModule !== 'function') {
handleInitError('sqlite3InitModule not found after importScripts – sqlite3.js may be corrupt or wrong version.');
return;
}
// Fetch WASM binary manually so we control the URL and can detect failures early
const wasmResponse = await fetch('sqlite3.wasm');
if (!wasmResponse.ok) {
throw new Error(`Failed to fetch sqlite3.wasm: ${wasmResponse.status} ${wasmResponse.statusText}`);
}
const wasmBinary = await wasmResponse.arrayBuffer();
// Fetch WASM binary manually so we control the URL and can detect failures early
let wasmBinary;
try {
const wasmResponse = await fetch('sqlite3.wasm');
if (!wasmResponse.ok) {
handleInitError(`Failed to fetch sqlite3.wasm: ${wasmResponse.status} ${wasmResponse.statusText}`);
return;
}
wasmBinary = await wasmResponse.arrayBuffer();
} catch (e) {
handleInitError(`Failed to fetch sqlite3.wasm: ${e.message}`);
return;
}
const sqlite3 = await self.sqlite3InitModule({
print: console.log,
printErr: console.error,
wasmBinary,
});
try {
const sqlite3 = await self.sqlite3InitModule({
print: console.log,
printErr: console.error,
wasmBinary,
});
const opfsAvailable = 'opfs' in sqlite3;
const dbName = 'app.db';
const dbName = 'app.db';
if ('opfs' in sqlite3) {
console.log(`[sqlite.worker] Using persistent OPFS database: ${dbName}`);
db = new sqlite3.oo1.OpfsDb(dbName);
} else {
console.warn('[sqlite.worker] OPFS not available – falling back to in-memory database');
db = new sqlite3.oo1.DB(dbName);
}
if (opfsAvailable) {
console.log(`[sqlite.worker] Using persistent OPFS database: ${dbName}`);
db = new sqlite3.oo1.OpfsDb(dbName);
} else {
console.warn('[sqlite.worker] OPFS not available – falling back to in-memory database');
db = new sqlite3.oo1.DB(dbName);
}
// Flush buffered messages
isReady = true;
console.log(`[sqlite.worker] Ready. Flushing ${messageQueue.length} buffered message(s).`);
while (messageQueue.length > 0) {
processMessage(messageQueue.shift());
}
// Flush buffered messages
isReady = true;
console.log(`[sqlite.worker] Ready. Flushing ${messageQueue.length} buffered message(s).`);
while (messageQueue.length > 0) {
processMessage(messageQueue.shift());
}
} catch (e) {
handleInitError(e?.message ?? String(e));
}
}
function tryImportScripts() {
try {
importScripts('sqlite3.js');
return null;
} catch (e) {
initError = e?.message ?? String(e);
console.error('[sqlite.worker] Initialization failed:', e);
return `importScripts('sqlite3.js') failed – is the file served at root? ${e.message}`;
}
}
// Notify all buffered callers so they don't hang indefinitely
while (messageQueue.length > 0) {
function handleInitError(message) {
initError = message;
console.error('[sqlite.worker] Initialization failed:', message);
while (messageQueue.length > 0) {
const queued = messageQueue.shift();
postMessage({id: queued.data?.id, error: `Worker initialization failed: ${initError}`});
}
}
}