import assert from "node:assert/strict";
import { readFileSync } from "node:fs";
import test from "node:test";

const route = readFileSync(new URL("../src/app/api/consult/route.ts", import.meta.url), "utf8");
const reportsRoute = readFileSync(new URL("../src/app/api/reports/route.ts", import.meta.url), "utf8");
const mastra = readFileSync(new URL("../src/mastra/index.ts", import.meta.url), "utf8");
const tools = readFileSync(new URL("../src/mastra/consultation-tools.ts", import.meta.url), "utf8");
const stream = readFileSync(new URL("../src/lib/stream-agent-response.ts", import.meta.url), "utf8");
const workflow = readFileSync(new URL("../src/mastra/consultation-workflow.ts", import.meta.url), "utf8");
const plan = readFileSync(new URL("../src/lib/consultation-plan.ts", import.meta.url), "utf8");
const stagingCompose = readFileSync(new URL("../../deploy/docker-compose.staging.yml", import.meta.url), "utf8");



test("consultation plans are server-owned and bounded", () => {
  assert.match(plan, /consultationPlanSchema/);
  assert.match(plan, /requestedDomains/);
  assert.match(plan, /requiredEvidenceCategories/);
  assert.match(plan, /createConsultationPlan/);
  assert.match(tools, /createConsultationPlan\(\{ userIntent: input\.question, theme: input\.theme \}\)/);
  assert.match(workflow, /packet_version: "consultation-evidence-packet-v2"/);
  assert.match(workflow, /claim_cards/);
  assert.match(tools, /toModelOutput\(toAgentConsultationContext\(guarded\), plan\)/);
  assert.match(tools, /const modelOutput = toModelOutput[\s\S]*ctx\.state\.consultationToolCompleted = true/);
  assert.doesNotMatch(plan, /birth|latitude|longitude|engine|script/i);
});

test("uses one runtime step append entry and no scattered hard-coded step cap", () => {
  assert.match(tools, /export function appendConsultationRuntimeStep/);
  assert.doesNotMatch(tools, /steps\.length\s*>=\s*32/);
  assert.doesNotMatch(stream, /state\.steps\.push/);
  assert.doesNotMatch(stream, /steps\.length\s*<\s*32/);
});

test("personal consultation lets the Agent invoke the server-bound workflow tool", () => {
  const agenticStart = route.indexOf("async function runAgenticConsultation");
  const agenticBranch = route.slice(
    agenticStart,
    route.indexOf("    const { history } = parsed.data;", agenticStart),
  );
  assert.match(agenticBranch, /createConsultationAgentContext/);
  assert.match(agenticBranch, /getJyotishAgent\(selectedModel, agentContext\)/);
  assert.doesNotMatch(agenticBranch, /await runConsultationWorkflow/);
  assert.doesNotMatch(agenticBranch, /JSON\.stringify\(toolInput\)/);
  assert.match(tools, /\(ctx\.runWorkflow \?\? runConsultationWorkflow\)\(toolInput, \{/);
  assert.match(tools, /return \{ "run-jyotish-consultation": consultationTool \};/);
  assert.match(agenticBranch, /state\.workflowReceipt\?\.preciseTiming === "allowed"/);
  assert.match(route, /createConsultationReplyMetadata/);
});

test("defers optional external evidence only for foreground chat", () => {
  assert.match(workflow, /defer_optional_external_evidence: options\?\.foreground === true/);
  assert.match(reportsRoute, /runWorkflow: \(input\) => runConsultationWorkflow\(input\)/);
  assert.doesNotMatch(reportsRoute, /foreground:\s*true/);
});

test("personal Agent owns the Skill and context-bound calculation tool", () => {
  const personalFactory = mastra.slice(
    mastra.indexOf("export function getJyotishAgent"),
    mastra.indexOf("export function getLegacyJyotishAgent"),
  );
  assert.match(personalFactory, /getJyotishAgent\(model: ResolvedLanguageModel, context: ConsultationAgentContext\)/);
  assert.match(personalFactory, /skills: \[jyotishSkillPath\]/);
  assert.match(personalFactory, /tools: createConsultationTools\(context\)/);
  assert.doesNotMatch(personalFactory, /server-computed-jyotish-workflow/);
});

test("validates and emits non-sensitive workflow and execution receipts", () => {
  assert.match(workflow, /consultationWorkflowResponseSchema/);
  assert.match(workflow, /safeParse\(data\)/);
  assert.match(workflow, /consultationWorkflowReceipt/);
  assert.match(route, /agentExecutionReceipt/);
  assert.match(route, /streamAgentResponse/);
});

test("carries commercial technique truth into the model contract", () => {
  assert.match(workflow, /technique_truth/);
  assert.match(mastra, /deterministic_claims_forbidden_for/);
  assert.doesNotMatch(mastra, /AYANAM_SUGGESTIONS|AYANAM_TITLE/);
  assert.doesNotMatch(mastra, /2-5 short paragraphs/);
  assert.match(mastra, /reference_only/);
  assert.match(mastra, /Do not use a restricted technique/);
});

test("projects consultation themes through explicit strict workflow taxonomy", () => {
  const projection = readFileSync(new URL("../src/lib/consultation-workflow-request.ts", import.meta.url), "utf8");
  assert.match(projection, /strictWorkflowRoute/);
  assert.match(projection, /claimBoundary/);
  assert.match(projection, /requiredLayers/);
  assert.match(projection, /negative holdout gate/);
});


test("agentic consultation is the safe default and legacy is explicit rollback", () => {
  assert.match(stagingCompose, /CONSULTATION_AGENTIC_RUNTIME: enabled/);
  assert.match(route, /CONSULTATION_AGENTIC_RUNTIME\?\.trim\(\)\.toLowerCase\(\) \?\? "enabled"/);
  assert.match(route, /mode === "legacy"/);
  assert.match(route, /mode !== "canary"/);
});