Mirrors/notesnook
1
0
Fork 0
mirror of https://github.com/streetwriters/notesnook.git synced 2025-12-23 23:19:40 +01:00
Code Issues Packages Projects Releases Wiki Activity

web: close idb connection on sqlite connection close

Browse Source
This commit is contained in:
Abdullah Atta
2023-12-12 10:02:55 +05:00
parent e127b8f4ab
commit 088ef2285f
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/web/src/common/sqlite/sqlite.worker.ts
View File

@@ -34,6 +34,7 @@ type PreparedStatement = {
let sqlite: SQLiteAPI; let sqlite: SQLiteAPI;
let db: number; let db: number;
let vfs: IDBBatchAtomicVFS | AccessHandlePoolVFS | null = null;
const preparedStatements: Map<string, PreparedStatement> = new Map(); const preparedStatements: Map<string, PreparedStatement> = new Map();
async function init(dbName: string, async: boolean, url?: string) { async function init(dbName: string, async: boolean, url?: string) {
@@ -42,7 +43,7 @@ async function init(dbName: string, async: boolean, url?: string) {
? await SQLiteAsyncESMFactory(option) ? await SQLiteAsyncESMFactory(option)
: await SQLiteSyncESMFactory(option); : await SQLiteSyncESMFactory(option);
sqlite = Factory(SQLiteAsyncModule); sqlite = Factory(SQLiteAsyncModule);
const vfs = async vfs = async
? new IDBBatchAtomicVFS(dbName, { durability: "strict" }) ? new IDBBatchAtomicVFS(dbName, { durability: "strict" })
: new AccessHandlePoolVFS(dbName); : new AccessHandlePoolVFS(dbName);
if ("isReady" in vfs) await vfs.isReady; if ("isReady" in vfs) await vfs.isReady;
@@ -126,6 +127,7 @@ async function close() {
await sqlite.finalize(prepared.stmt); await sqlite.finalize(prepared.stmt);
} }
await sqlite.close(db); await sqlite.close(db);
await vfs?.close();
} }
const worker = { const worker = {