import fs from "node:fs";import path from "node:path"; import { openSqliteDatabase, type SqliteDatabase } from "./sqliteAdapter";import { runStateMigrations } from "./stateMigrations"; export interface StateDbOptions {  dbPath: string;} export class StateDb {  readonly dbPath: string;  readonly db: SqliteDatabase;   constructor(options: StateDbOptions) {    this.dbPath = path.resolve(options.dbPath);    fs.mkdirSync(path.dirname(this.dbPath), { recursive: true });    this.db = openSqliteDatabase(this.dbPath);    try {      runStateMigrations(this.db);    } catch (error) {      try {        this.db.close();      } catch {        // Best effort close on failed initialization.      }      throw error;    }  }   close(): void {    this.db.close();  }   transaction<T>(fn: () => T): T {    this.db.exec("BEGIN IMMEDIATE;");    try {      const result = fn();      this.db.exec("COMMIT;");      return result;    } catch (error) {      try {        this.db.exec("ROLLBACK;");      } catch {        // Preserve the original transactional failure.      }      throw error;    }  }}