Class FileSpendControlStorage

src/spend-control.ts:69–131

}

export class FileSpendControlStorage implements SpendControlStorage {
  private readonly spendingFile: string;

  constructor() {
    this.spendingFile = path.join(WALLET_DIR, "spending.json");
  }

  load(): { limits: SpendLimits; history: SpendRecord[] } | null {
    try {
      if (fs.existsSync(this.spendingFile)) {
        const data = JSON.parse(readTextFileSync(this.spendingFile));
        const rawLimits = data.limits ?? {};
        const rawHistory = data.history ?? [];

        const limits: SpendLimits = {};
        for (const key of ["perRequest", "hourly", "daily", "session"] as const) {
          const val = rawLimits[key];
          if (typeof val === "number" && val > 0 && Number.isFinite(val)) {
            limits[key] = val;
          }
        }

        const history: SpendRecord[] = [];
        if (Array.isArray(rawHistory)) {
          for (const r of rawHistory) {
            if (
              typeof r?.timestamp === "number" &&
              typeof r?.amount === "number" &&
              Number.isFinite(r.timestamp) &&
              Number.isFinite(r.amount) &&
              r.amount >= 0
            ) {
              history.push({
                timestamp: r.timestamp,
                amount: r.amount,
                model: typeof r.model === "string" ? r.model : undefined,
                action: typeof r.action === "string" ? r.action : undefined,
              });
            }
          }
        }

        return { limits, history };
      }
    } catch (err) {
      console.error(`[ClawRouter] Failed to load spending data, starting fresh: ${err}`);
    }
    return null;
  }

  save(data: { limits: SpendLimits; history: SpendRecord[] }): void {
    try {
      if (!fs.existsSync(WALLET_DIR)) {
        fs.mkdirSync(WALLET_DIR, { recursive: true, mode: 0o700 });
      }
      fs.writeFileSync(this.spendingFile, JSON.stringify(data, null, 2), {
        mode: 0o600,
      });