// Smoke test against a real Spectra (not part of `npm test`): the bridge

// signs, the model fills from the API, the stream delivers, a brief saved

// through the API reaches Spectra. Run with: npm run smoke

import { spawn, execFileSync } from "node:child_process";

import { mkdtempSync, rmSync } from "node:fs";

import { tmpdir } from "node:os";

import { join } from "node:path";

import assert from "node:assert/strict";

const bin = process.env.SPECTRA_BIN;

assert.ok(bin, "set SPECTRA_BIN to a spectra binary");

const dir = mkdtempSync(join(process.env.SMOKE_DIR || tmpdir(), "spectra-smoke-"));

const env = { ...process.env, HOME: dir, SPECTRA_HOME: join(dir, "owner"), SPECTRA_DATA: join(dir, "data"), XDG_DATA_HOME: join(dir, "xdg"), NO_COLOR: "1" };

Object.assign(process.env, env);

const sp = (...a) => execFileSync(bin, a, { env }).toString();

sp("identity", "create", "--name", "Smoke Owner");

sp("init");

sp("project", "add", "book", "-d", "the manuscript");

sp("agent", "add", "claude-book", "--kind", "claude-code", "--project", "book", "--home", join(dir, "agents/claude-book"), "--yes");

const serve = spawn(bin, ["serve", "--bind", "127.0.0.1:0"], { env, stdio: "ignore" });

await new Promise((r) => setTimeout(r, 1500));

const { Bridge } = await import("../out/smoke-bridge.mjs");

const { Model } = await import("../out/smoke-model.mjs");

const log = { append() {}, appendLine() {} };

const bridge = new Bridge(log);

const model = new Model(bridge);

try {

  await model.refresh();

  assert.equal(model.error, undefined);

  assert.equal(model.brief.actor, "human");

  assert.equal(model.agents[0].name, "claude-book");

  assert.ok(model.channels.some((c) => c.name === "book"));

  const seen = [];

  model.onEvent((e) => seen.push(e.kind));

  model.start();

  await new Promise((r) => setTimeout(r, 800));

  await bridge.request("POST", "/api/v1/channels/book/messages", { body: "hello from the editor" });

  await bridge.request("PUT", "/api/v1/briefs", { project: "book", text: "Chapter 3 becomes chapter 5." });

  await new Promise((r) => setTimeout(r, 1200));

  assert.ok(seen.includes("message.posted"), `the stream delivered: ${seen}`);

  assert.equal(model.briefs.projects[0]?.text, "Chapter 3 becomes chapter 5.");

  assert.match(sp("brief", "show", "--project", "book"), /chapter 5/);

  console.log("smoke: ok");

} finally {

  model.dispose();

  bridge.dispose();

  serve.kill("SIGTERM");

  await new Promise((r) => setTimeout(r, 1500));

  rmSync(dir, { recursive: true, force: true });

}