fix: Bun worker onerror, batch CSS imports, sqlite wrapper improvements

- Add missing onerror handler on Bun Worker path (audit #3) — prevents
  promise hang when a parse worker crashes
- Batch CSS imports instead of inserting one-at-a-time (audit S1) — both
  full-rebuild and incremental paths now pass the full array to
  insertImports, letting batchInsert chunk properly
- Hoist inner.query() in wrap() to avoid redundant rawDb.prepare() on
  Node when .get()/.all() is called multiple times (audit S2)
- Fix SCHEMA_VERSION comment to match actual value of 1 (audit #4)
- Skip PRAGMA optimize on closeDb for read-only query paths (audit S4)

Author: SutuSebastian

src/application/index-engine.ts

@@ -186,19 +186,18 @@ function insertParsedResults(
           }
           if (parsed.markers?.length) insertMarkers(db, parsed.markers);
 
-          if (parsed.cssImportSources) {
-            for (const importSource of parsed.cssImportSources) {
-              insertImports(db, [
-                {
-                  file_path: parsed.relPath,
-                  source: importSource,
-                  resolved_path: null,
-                  specifiers: "[]",
-                  is_type_only: 0,
-                  line_number: 0,
-                },
-              ]);
-            }
+          if (parsed.cssImportSources?.length) {
+            insertImports(
+              db,
+              parsed.cssImportSources.map((importSource) => ({
+                file_path: parsed.relPath,
+                source: importSource,
+                resolved_path: null,
+                specifiers: "[]",
+                is_type_only: 0,
+                line_number: 0,
+              })),
+            );
           }
         } else {
           if (parsed.symbols?.length) insertSymbols(db, parsed.symbols);
@@ -333,17 +332,18 @@ export async function indexFiles(
               insertCssKeyframes(db, cssData.keyframes);
             }
             if (cssData.markers.length) insertMarkers(db, cssData.markers);
-            for (const importSource of cssData.importSources) {
-              insertImports(db, [
-                {
+            if (cssData.importSources.length) {
+              insertImports(
+                db,
+                cssData.importSources.map((importSource) => ({
                   file_path: relPath,
                   source: importSource,
                   resolved_path: null,
                   specifiers: "[]",
                   is_type_only: 0,
                   line_number: 0,
-                },
-              ]);
+                })),
+              );
             }
           } else {
             const data = extractFileData(absPath, source, relPath);
@@ -475,7 +475,7 @@ export function printQueryResult(
     }
     return 1;
   } finally {
-    if (db !== undefined) closeDb(db);
+    if (db !== undefined) closeDb(db, { readonly: true });
   }
 }
 
@@ -488,6 +488,6 @@ export function queryRows(sql: string): unknown[] {
   try {
     return db.query(sql).all();
   } finally {
-    closeDb(db);
+    closeDb(db, { readonly: true });
   }
 }

src/db.ts

@@ -5,7 +5,7 @@ import {
 } from "./sqlite-db";
 
 /**
- * Pre-release: keep at **2** until the first npm release — do not bump for DDL
+ * Pre-release: keep at **1** until the first npm release — do not bump for DDL
  * tweaks; run `--full` locally after pulling. After v1.0, bump in lockstep with
  * `createTables` / `createIndexes` when the on-disk schema changes.
  */
@@ -17,9 +17,11 @@ export function openDb(): CodemapDatabase {
   return openCodemapDatabase();
 }
 
-export function closeDb(db: CodemapDatabase) {
-  db.run("PRAGMA analysis_limit = 400");
-  db.run("PRAGMA optimize");
+export function closeDb(db: CodemapDatabase, opts?: { readonly?: boolean }) {
+  if (!opts?.readonly) {
+    db.run("PRAGMA analysis_limit = 400");
+    db.run("PRAGMA optimize");
+  }
   db.close();
 }
 

src/sqlite-db.ts

@@ -107,12 +107,13 @@ function wrap(inner: SqliteInner): CodemapDatabase {
       runSql(inner, sql, params);
     },
     query<T>(sql: string) {
+      const stmt = inner.query(sql);
       return {
         get(...params: unknown[]) {
-          return inner.query(sql).get(...params) as T | undefined;
+          return stmt.get(...params) as T | undefined;
         },
         all(...params: unknown[]) {
-          return inner.query(sql).all(...params) as T[];
+          return stmt.all(...params) as T[];
         },
       };
     },

src/worker-pool.ts

@@ -44,6 +44,10 @@ export function parseFilesParallel(filePaths: string[]): Promise<ParsedFile[]> {
               resolve(event.data.results);
               worker.terminate();
             };
+            worker.onerror = (event: ErrorEvent) => {
+              reject(new Error(event.message));
+              worker.terminate();
+            };
             worker.postMessage(input);
             return;
           }