Method rollbackSession

src/filesystem/transaction.ts:358–390

Rollback every committed transaction in a session, newest first.

(sessionId: string)

  }

  async begin(sessionId: string, toolCallId?: string, cwd?: string): Promise<Transaction> {
    await fs.mkdir(this.blobsDir, { recursive: true });
    const row = this.getNextIdStmt.get() as { value: number };
    const txnId = row.value;
    this.incrementStmt.run();
    return new Transaction(txnId, this, sessionId, toolCallId, cwd);
  }

  persistOps(
    txnId: number,
    sessionId: string,
    ops: JournaledOp[],
    gitSha: string | null,
    toolCallId: string | undefined,
    summary: string | undefined,
    gitStatus?: string,
    gitFailReason?: string | null,
  ): void {
    const tx = this.db.transaction(() => {
      for (const op of ops) {
        this.writeStmt.run(
          txnId, sessionId, op.operation, op.path,
          op.beforeHash, op.afterHash, gitSha, gitStatus ?? null, gitFailReason ?? null,
          toolCallId ?? null, summary ?? null,
        );
      }
    });
    tx();
  }

  markRolledBack(txnId: number): void {
    this.markRolledBackStmt.run(txnId);
  }

  async storeBlob(hash: string, content: string): Promise<void> {
    const blobPath = path.join(this.blobsDir, hash.slice(0, 2), hash);