Class SQLiteWasmDatabase

packages/worker/web-worker/sqlite-wasm-server.ts:15–160

// SQLiteWasmDatabase extends BaseServerDatabase for sqlite-wasm
export class SQLiteWasmDatabase extends BaseServerDatabase {
  filename?: string
  private db: Database // Using any for now to avoid type issues

  constructor(db: Database) {
    super()
    this.db = db
    this.filename = db.filename
  }

  get isWalMode() {
    return true
  }

  /**
   * Check if currently inside a transaction.
   * Uses PRAGMA transaction_state (SQLite 3.37.0+).
   * Returns "idle" | "active" | "conflict"
   */
  get inTransaction(): boolean {
    try {
      const result = this.db.exec({
        sql: "PRAGMA transaction_state",
        returnValue: "resultRows",
        rowMode: "array",
      })
      // result is [["idle"]] or [["active"]] or [["conflict"]]
      const state = result?.[0]?.[0]
      return state === "active" || state === "conflict"
    } catch (e) {
      // Fallback: try to detect via autocommit mode
      try {
        // If we can't get transaction_state, assume not in transaction
        return false
      } catch {
        return false
      }
    }
  }

  selectObjectsSync(): { [columnName: string]: any }[] {
    throw new Error("selectObjectsSync is not implemented")
  }

  table() {
    throw new Error("table is not implemented")
  }

  pages(): Promise<{ [key: string]: any }> {
    return Promise.resolve({})
  }

  status(): Promise<{ [key: string]: any }> {
    return Promise.resolve({})
  }

  pull(): Promise<{ [key: string]: any }> {
    return Promise.resolve({})