{"detail": "Error message here"}

import requests
import time
import json

class HypernymClient:
    def __init__(self, api_key: str):
        self.api_key = api_key
        self.base_url = "https://zephyr.hypernym.ai"
        self.headers = {
            "Content-Type": "application/json",
            "X-API-Key": api_key
        }

    def submit(self, text: str, sector: str = "prose") -> str:
        """Submit text and return experiment_id."""
        resp = requests.post(
            f"{self.base_url}/api/omnifact/begin",
            headers=self.headers,
            json={"text": text, "sector": sector}
        )
        resp.raise_for_status()
        return resp.json()["experiment_id"]

    def poll(self, experiment_id: str, interval: int = 30) -> dict:
        """Poll until experiment completes. Returns final status."""
        while True:
            resp = requests.get(
                f"{self.base_url}/api/omnifact/{experiment_id}/status",
                headers=self.headers
            )
            resp.raise_for_status()
            data = resp.json()

            status = data["status"]
            if status == "COMPLETED":
                return data
            elif status in ("FAILED", "CANCELLED"):
                raise RuntimeError(f"Experiment {status}: {data.get('error', '')}")

            phase = data.get("phase", "?")
            pct = data.get("progress_pct", 0)
            print(f"  {phase} {pct}%")
            time.sleep(interval)

    def get_facts(self, experiment_id: str, top: int = 50) -> dict:
        """Get top-N semantic facts."""
        resp = requests.get(
            f"{self.base_url}/api/omnifact/{experiment_id}/facts",
            headers=self.headers,
            params={"top": top}
        )
        resp.raise_for_status()
        return resp.json()

    def get_result(self, experiment_id: str) -> dict:
        """Get full experiment result with all pipeline data."""
        resp = requests.get(
            f"{self.base_url}/api/omnifact/{experiment_id}/result",
            headers=self.headers
        )
        resp.raise_for_status()
        return resp.json()

# Usage
client = HypernymClient("your-api-key")

exp_id = client.submit(
    text=open("document.txt").read(),
    sector="medical"
)
print(f"Experiment: {exp_id}")

client.poll(exp_id)

facts = client.get_facts(exp_id, top=20)
for f in facts["facts"]:
    print(f"  [{f['frequency_pct']:.0f}%] {f['element']}: {f['detail'][:80]}...")