import { describe, expect, test } from "bun:test";
import type { MoneyMarketRow, MoneyMarketsPayload } from "../../../api-client/money-markets";
import { ApiRequestError } from "../../../api-client/errors";
import { fetchMoneyMarkets, validateMoneyMarkets } from "./client";
import { moneyMarketCurves, moneyMarketHistory, moneyMarketNotices, moneyMarketRows } from "./model";

function row(id = "sofr", overrides: Partial<MoneyMarketRow> = {}): MoneyMarketRow {
  return { id, label: id, seriesId: "SOFR", sourceSeriesIds: ["SOFR"], sourceUrl: null,
    group: "rates", unit: "percent", frequency: "daily", value: 0, asOf: "2026-09-21", previousValue: -0.01,
    previousAsOf: "2026-09-18", change: 1, changeUnit: "basis-points",
    percentile: { value: 50, rank: 2, sampleCount: 4, windowStart: "2025-09-21", windowEnd: "2026-09-21", min: -0.01, max: 0, mean: 0 },
    history: [{ date: "2026-09-18", value: -0.01 }, { date: "2026-09-21", value: 0 }], status: "available", fetchedAt: "2026-09-22T10:00:00Z", unavailableReason: null, notes: [], ...overrides };
}
function payload(): MoneyMarketsPayload {
  return { generatedAt: "2026-09-22T10:00:00Z", status: "available", rows: [row()],
    netLiquidity: row("net-liquidity", { group: "liquidity", unit: "usd-billions", changeUnit: "usd-billions" }),
    billsCurve: { asOf: "2026-09-21", status: "available", basis: "discount",
      points: [{ tenor: "4W", maturityYears: 28 / 365, seriesId: "DTB4WK", value: 0 }],
      comparisons: [{ period: "1W", targetDate: "2026-09-14", asOf: "2026-09-11", points: [{ tenor: "4W", maturityYears: 28 / 365, seriesId: "DTB4WK", value: -0.1 }] }, { period: "1Y", targetDate: "2025-09-21", asOf: null, points: [] }],
      slope: { valueBps: null, asOf: null, percentile: row().percentile, history: [] } } };
}

describe("money-market boundary", () => {
  test("keeps explicit zero, negative rates and a partially missing source", () => {
    const data = payload();
    data.status = "partial";
    data.rows.push(row("effr", { value: null, asOf: null, change: null, history: [], status: "unavailable", unavailableReason: "metadata-mismatch" }));
    expect(validateMoneyMarkets(data).rows[0]?.value).toBe(0);
    expect(moneyMarketRows(data, "rates")).toHaveLength(2);
    expect(moneyMarketNotices(data)).toContain("effr: metadata mismatch.");
    expect(moneyMarketRows(data, "liquidity").map((row) => row.id)).toEqual(["net-liquidity"]);
  });
  test("rejects impossible dates, nonfinite rates, incompatible units and undated curves", () => {
    for (const mutate of [
      (data: MoneyMarketsPayload) => { data.rows[0]!.asOf = "2026-02-30"; },
      (data: MoneyMarketsPayload) => { data.rows[0]!.value = NaN; },
      (data: MoneyMarketsPayload) => { data.rows[0]!.changeUnit = "usd-billions"; },
      (data: MoneyMarketsPayload) => { data.rows[0]!.percentile.value = 101; },
      (data: MoneyMarketsPayload) => { data.billsCurve.asOf = null; },
      (data: MoneyMarketsPayload) => { data.rows[0]!.percentile.windowStart = "2025-02-29"; },
    ]) { const data = payload(); mutate(data); expect(() => validateMoneyMarkets(data)).toThrow(); }
  });
  test("preserves distinct ghost dates and omits unavailable comparisons", () => {
    const curves = moneyMarketCurves(payload());
    expect(curves.map((curve) => [curve.id, curve.asOf])).toEqual([["today", "2026-09-21"], ["1W", "2026-09-11"]]);
    expect(curves[1]?.points[0]?.value).toBe(-0.1);
    expect(curves[1]?.points[0]?.asOf).toBe("2026-09-11");
  });
  test("history charts use the percentile window and retain explicit gaps", () => {
    const observation = row("sofr", { history: [
      { date: "2025-08-22", value: 9 }, { date: "2025-09-21", value: 4 },
      { date: "2026-09-18", value: null }, { date: "2026-09-21", value: 0 },
    ] });
    expect(moneyMarketHistory(observation)).toEqual(observation.history.slice(1));
  });
  test("missing endpoint gives an actionable unavailable state without hiding auth errors", async () => {
    await expect(fetchMoneyMarkets({ getCloudMoneyMarkets: async () => { throw new ApiRequestError("not found", 404); } })).rejects.toThrow("not available on this Gloom Cloud server yet");
    const denied = new ApiRequestError("sign in", 401);
    await expect(fetchMoneyMarkets({ getCloudMoneyMarkets: async () => { throw denied; } })).rejects.toBe(denied);
  });
});