import type { AskResponse, HealthResponse } from "./types";

const MOCK_ASK_RESPONSE: AskResponse = {

  answer:

    "Hermes v2.5 is running on CT-REDACTED (REDACTED-IP). The service is active and auto-restarting via systemd. " +

    "Last deployment was from /shared/projects/hermes/main.py. The bot uses RSA-PSS auth against the Kalshi API " +

    "and Grok's /v1/responses endpoint with web_search + x_search tools for market intelligence. " +

    "Auto-execute trading is enabled. The radar v2 pipeline handles signal generation.",

  receipts: [

    {

      id: "r1",

      source: "rag",

      path: "/shared/projects/CLAUDE.md",

      last_seen: "2026-06-23T18:42:00Z",

      confidence: 0.96,

      snippet:

        "Hermes v2.5 - Kalshi Trading Bot (CT-REDACTED). Code: $HERMES_HOME/main.py on CT-REDACTED (3883 lines). Service: systemd hermes (enabled, auto-restarts).",

    },

    {

      id: "r2",

      source: "cbm",

      path: "/shared/projects/hermes/main.py#RadarV2Pipeline",

      last_seen: "2026-06-23T17:15:00Z",

      confidence: 0.89,

      snippet:

        "class RadarV2Pipeline: async def run(self, market_id: str) -> Signal: ... # Grok web_search + x_search, RSA-PSS Kalshi auth",

    },

    {

      id: "r3",

      source: "memgraph",

      path: "entity:hermes-trading-bot",

      last_seen: "2026-06-23T16:00:00Z",

      confidence: 0.82,

      snippet: "Hermes v2.5 deployed CT-REDACTED pve-gpu node. Auto-execute enabled. Last trade signal 14m ago.",

    },

    {

      id: "r4",

      source: "proxmox",

      path: "ct/210/status",

      last_seen: "2026-06-23T18:55:00Z",

      confidence: 0.99,

      snippet: "CT-REDACTED status: running. CPU 1.2% / 2c. RAM 812MB / 2GB. Uptime 4d 7h 22m.",

    },

  ],

  hits: [

    {

      engine: "homelab-rag",

      title: "Hermes Trading Bot - CLAUDE.md",

      path: "/shared/projects/CLAUDE.md",

      snippet: "Hermes v2.5 - Kalshi Trading Bot (CT-REDACTED). Stack: Python - Discord bot + FastAPI + Kalshi API + Grok Responses API",

      score: 0.97,

      last_seen: "2026-06-23T18:42:00Z",

      confidence: 0.96,

    },

    {

      engine: "cbm-homelab",

      title: "RadarV2Pipeline class",

      path: "/shared/projects/hermes/main.py",

      snippet: "class RadarV2Pipeline - signal generation, Grok API integration, market scoring",

      score: 0.91,

      last_seen: "2026-06-23T17:15:00Z",

      confidence: 0.89,

    },

    {

      engine: "proxmox-api",

      title: "CT-REDACTED - hermes container",

      path: "pve-gpu/lxc/210",

      snippet: "Container running on pve-gpu (REDACTED-IP). Resources: 2c/2GB/30GB.",

      score: 0.88,

      last_seen: "2026-06-23T18:55:00Z",

      confidence: 0.99,

    },

    {

      engine: "memory-graph",

      title: "Hermes entity",

      path: "graph:hermes-v25",

      snippet: "Bot active. Auto-execute mode. Last deploy 2026-06-22. Radar v2 pipeline live.",

      score: 0.84,

      last_seen: "2026-06-23T16:00:00Z",

      confidence: 0.82,

    },

    {

      engine: "serena",

      title: "KalshiClient.place_order()",

      path: "/shared/projects/hermes/main.py#L2104",

      snippet: "async def place_order(self, ticker: str, count: int, side: str, price: float) -> dict",

      score: 0.79,

      last_seen: "2026-06-23T14:30:00Z",

      confidence: 0.77,

    },

  ],

  conflicts: [],

  engines: [

    { engine: "homelab-rag", status: "up", ms: 42 },

    { engine: "cbm-homelab", status: "up", ms: 88 },

    { engine: "serena", status: "up", ms: 134 },

    { engine: "memory-graph", status: "up", ms: 22 },

    { engine: "proxmox-api", status: "up", ms: 61 },

  ],

  took_ms: 312,

};

const MOCK_HEALTH_RESPONSE: HealthResponse = {

  engines: [

    { engine: "proxmox", status: "up", last_ingest: "2026-06-23T18:55:00Z", staleness_h: 0.08 },

    { engine: "white-pc", status: "up", last_ingest: "2026-06-23T17:30:00Z", staleness_h: 1.4 },

    { engine: "3060", status: "up", last_ingest: "2026-06-23T18:45:00Z", staleness_h: 0.17 },

    { engine: "browser-history", status: "down", last_ingest: "2026-06-22T08:00:00Z", staleness_h: 34.9 },

    { engine: "agents", status: "up", last_ingest: "2026-06-23T18:58:00Z", staleness_h: 0.03 },

    { engine: "rag", status: "up", last_ingest: "2026-06-23T18:50:00Z", staleness_h: 0.13 },

    { engine: "cbm", status: "up", last_ingest: "2026-06-23T17:15:00Z", staleness_h: 1.73 },

    { engine: "serena", status: "up", last_ingest: "2026-06-23T18:00:00Z", staleness_h: 0.97 },

    { engine: "memgraph", status: "up", last_ingest: "2026-06-23T16:00:00Z", staleness_h: 2.97 },

    { engine: "inbox", status: "up", last_ingest: "2026-06-23T18:59:00Z", staleness_h: 0.02 },

  ],

  ok: true,

};

const CORTEX_URL_DEFAULT = "http://REDACTED-IP:9890";

function getCortexUrl(): string {

  if (typeof window === "undefined") return CORTEX_URL_DEFAULT;

  return (process.env.NEXT_PUBLIC_CORTEX_URL as string) || CORTEX_URL_DEFAULT;

}

export async function ask(query: string): Promise<AskResponse> {

  const base = getCortexUrl();

  try {

    const res = await fetch(`${base}/ask`, {

      method: "POST",

      headers: { "Content-Type": "application/json" },

      body: JSON.stringify({ query }),

      signal: AbortSignal.timeout(30_000),

      cache: "no-store",

    });

    if (!res.ok) throw new Error(`HTTP ${res.status}`);

    return (await res.json()) as AskResponse;

  } catch (err) {

    console.warn("[darwin] /ask failed, using mock:", err);

    return simulateDelay(MOCK_ASK_RESPONSE);

  }

}

export async function health(): Promise<HealthResponse> {

  const base = getCortexUrl();

  try {

    const res = await fetch(`${base}/health`, {

      signal: AbortSignal.timeout(8_000),

      cache: "no-store",

    });

    if (!res.ok) throw new Error(`HTTP ${res.status}`);

    return (await res.json()) as HealthResponse;

  } catch (err) {

    console.warn("[darwin] /health failed, using mock:", err);

    return simulateDelay(MOCK_HEALTH_RESPONSE, 200);

  }

}

function simulateDelay<T>(data: T, ms = 800): Promise<T> {

  return new Promise((resolve) => setTimeout(() => resolve(data), ms));

}