/**
 * embed Flock Direct 联调：POST /api/flock/quotes → 轮询 GET /api/quotes/:id
 * 用法: npx tsx scripts/smoke-flock-embed-direct.ts
 */
import { randomUUID } from "node:crypto";

const BASE = process.env.SMOKE_BASE_URL ?? "http://127.0.0.1:3000";
const TOKEN = process.env.SMOKE_HOST_TOKEN ?? "demo-host-token";
const CUSTOMER = process.env.SMOKE_CUSTOMER_ID ?? "CUST_001";

function tomorrowMmDdYyyy(): string {
  const d = new Date();
  d.setDate(d.getDate() + 1);
  const mm = String(d.getMonth() + 1).padStart(2, "0");
  const dd = String(d.getDate()).padStart(2, "0");
  return `${mm}/${dd}/${d.getFullYear()}`;
}

async function main(): Promise<void> {
  const requestId = randomUUID();
  const body = {
    request_id: requestId,
    customer_id: CUSTOMER,
    flock_input: {
      pickup_date: tomorrowMmDdYyyy(),
      pickup_zip: "90001",
      delivery_zip: "75201",
      pallet_count: 6,
      total_weight: { value: 10000, unit: "lb" },
      dimensions: { length: 48, width: 40, height: 48, unit: "in" },
    },
  };

  console.log(`[smoke-flock] POST ${BASE}/api/flock/quotes`);
  const createRes = await fetch(`${BASE}/api/flock/quotes`, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${TOKEN}`,
      "X-Customer-Id": CUSTOMER,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(body),
  });
  const created = (await createRes.json()) as {
    code: number;
    message?: string;
    data?: { quote_id: string };
  };
  if (created.code !== 0 || !created.data?.quote_id) {
    console.error("[smoke-flock] create FAIL", createRes.status, created);
    process.exit(1);
  }
  const quoteId = created.data.quote_id;
  console.log(`[smoke-flock] quote_id=${quoteId} polling…`);

  const deadline = Date.now() + 120_000;
  while (Date.now() < deadline) {
    const getRes = await fetch(`${BASE}/api/quotes/${quoteId}`, {
      headers: {
        Authorization: `Bearer ${TOKEN}`,
        "X-Customer-Id": CUSTOMER,
      },
    });
    const detail = (await getRes.json()) as {
      code: number;
      message?: string;
      data?: {
        status: string;
        error_message?: string;
        flock?: { lines?: Array<{ label: string; total: number }> };
      };
    };
    if (detail.code !== 0 || !detail.data) {
      console.error("[smoke-flock] get FAIL", detail);
      process.exit(1);
    }
    const st = detail.data.status;
    if (st === "processing") {
      await new Promise((r) => setTimeout(r, 2000));
      continue;
    }
    if (st === "done") {
      const lines = detail.data.flock?.lines ?? [];
      console.log(
        `[smoke-flock] OK lines=${lines.length} ` +
          lines.map((l) => `${l.label}:$${l.total}`).join(", "),
      );
      if (lines.length < 1) process.exit(1);
      return;
    }
    console.error(
      `[smoke-flock] status=${st} ${detail.data.error_message ?? detail.message}`,
    );
    process.exit(1);
  }
  console.error("[smoke-flock] timeout");
  process.exit(1);
}

main().catch((e) => {
  console.error(e);
  process.exit(1);
});