ditto/src/workers/sqlite.worker.ts

/// <reference lib="webworker" />
import { ScopedPerformance } from 'https://deno.land/x/scoped_performance@v2.0.0/mod.ts';
import { Comlink, type CompiledQuery, DenoSqlite3, type QueryResult, Stickynotes } from '@/deps.ts';
import '@/sentry.ts';

let db: DenoSqlite3 | undefined;
const console = new Stickynotes('ditto:sqlite.worker');

export const SqliteWorker = {
  open(path: string): void {
    db = new DenoSqlite3(path);
  },
  executeQuery<R>({ sql, parameters }: CompiledQuery): QueryResult<R> {
    if (!db) throw new Error('Database not open');

    const perf = (console.enabled && console.level >= 4) ? new ScopedPerformance() : undefined;

    if (perf) {
      perf.mark('start');
    }

    const result = {
      rows: db!.prepare(sql).all(...parameters as any[]) as R[],
      numAffectedRows: BigInt(db!.changes),
      insertId: BigInt(db!.lastInsertRowId),
    };

    if (perf) {
      const { duration } = perf.measure('end', 'start');

      console.debug(
        sql.replace(/\s+/g, ' '),
        JSON.stringify(parameters),
        `\x1b[90m(${(duration / 1000).toFixed(2)}s)\x1b[0m`,
      );

      perf.clearMarks();
      perf.clearMeasures();
    }

    return result;
  },
  destroy() {
    db?.close();
  },
};

Comlink.expose(SqliteWorker);

self.postMessage(['ready']);