Method constructor

src/filesystem/transaction.ts:282–306

(dbPath: string = QODEX_TXN_DB, blobsDir: string = QODEX_BLOBS_DIR)

    return this.ops;
  }

  private ensureOpen(): void {
    if (this.status !== 'open') {
      throw new Error(`Transaction ${this.id} is ${this.status}`);
    }
  }

  private autoSummary(): string {
    const first = this.ops.slice(0, 3).map(o => `${o.operation} ${path.basename(o.path)}`).join(', ');
    return first + (this.ops.length > 3 ? ` +${this.ops.length - 3} more` : '');
  }
}

export class TransactionJournal {
  readonly db: Database.Database;
  private blobsDir: string;
  private writeStmt: Database.Statement;
  private incrementStmt: Database.Statement;
  private getNextIdStmt: Database.Statement;
  private markRolledBackStmt: Database.Statement;

  constructor(dbPath: string = QODEX_TXN_DB, blobsDir: string = QODEX_BLOBS_DIR) {
    this.db = openDatabase(dbPath);
    this.db.exec(SCHEMA);

    // Idempotent migrations: add columns if upgrading from v0.1.0
    const existingCols = this.db.prepare("PRAGMA table_info(transactions)").all() as Array<{ name: string }>;
    const colNames = new Set(existingCols.map(c => c.name));