File size: 3,801 Bytes
ca4d83b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 | """Hugging Face Space entry for aureon-public. This file does not deploy it.
The process sets AUREON_PUBLIC_REQUIRE_PIN=1 and AUREON_OBSERVER_MODE=dry_run.
AUREON_PUBLIC_SWEEP must be unset. The image must not contain an API key.
Set AUREON_PUBLIC_API_KEY at runtime to require a bearer token. Set
AUREON_PUBLIC_OPEN=1, with no key, to serve the read-only surface on a
public bind. With neither, the listener is 127.0.0.1.
"""
from __future__ import annotations
import json
import os
import sys
from aureon_public.http_guard import resolve_http_bind
from aureon_public.server import (
build_server,
enforce_public_pin,
refuse_sweep_environment,
serve_streamable_http,
)
_QUEEN_MODULE = "queen/temporal_ground.py"
_QUEEN_SYMBOL = "compute_zpe_ground"
_QUEEN_REASON = "plan stage 4 is not open"
_CLOSED_PACKAGES = ("miner", "accounting", "queen", "exchanges", "trading")
def prepare_space_environment() -> None:
"""Pin, dry-run, and the sweep refusal. Does not set a key or OPEN."""
if os.environ.get("AUREON_PUBLIC_SWEEP"):
raise SystemExit("AUREON_PUBLIC_SWEEP must not be set. The server will not start.")
mode = os.environ.get("AUREON_OBSERVER_MODE", "").strip()
if mode and mode != "dry_run":
raise SystemExit("AUREON_OBSERVER_MODE must be dry_run.")
os.environ["AUREON_OBSERVER_MODE"] = "dry_run"
os.environ["AUREON_PUBLIC_REQUIRE_PIN"] = "1"
refuse_sweep_environment()
enforce_public_pin()
def closed_stage_report() -> dict:
"""Stage 3 and 4 stay closed inside this entry point."""
from aureon_public.body import body_call, package_depth
depth = package_depth()
queen_text = body_call(_QUEEN_MODULE, _QUEEN_SYMBOL)
queen = json.loads(queen_text)
packages = {name: depth[name] for name in _CLOSED_PACKAGES}
reachable = {name: packages[name]["reachable"] for name in _CLOSED_PACKAGES}
queen_refused = queen.get("called") is not True and queen.get("reason") == _QUEEN_REASON
closed = all(reachable[name] == 0 for name in _CLOSED_PACKAGES)
return {
"closed_packages_reachable": reachable,
"observer_mode": os.environ.get("AUREON_OBSERVER_MODE", ""),
"ok": bool(queen_refused and closed and os.environ.get("AUREON_OBSERVER_MODE") == "dry_run"),
"queen_call": queen,
"require_pin": os.environ.get("AUREON_PUBLIC_REQUIRE_PIN", ""),
"sweep_set": bool(os.environ.get("AUREON_PUBLIC_SWEEP")),
}
def space_host() -> str:
"""0.0.0.0 when a key or OPEN=1 allows it. Otherwise 127.0.0.1."""
requested = os.environ.get("AUREON_PUBLIC_HOST", "").strip()
if not requested:
unlocked = bool(os.environ.get("AUREON_PUBLIC_API_KEY", "").strip())
unlocked = unlocked or os.environ.get("AUREON_PUBLIC_OPEN") == "1"
requested = "0.0.0.0" if unlocked else "127.0.0.1"
return resolve_http_bind(requested)
def space_port() -> int:
raw = os.environ.get("PORT", "7860").strip() or "7860"
try:
port = int(raw)
except ValueError as exc:
raise SystemExit("PORT must be an integer") from exc
if port <= 0:
raise SystemExit("PORT must be an integer")
return port
def main(argv: list[str] | None = None) -> None:
"""Serve Streamable HTTP, or print the closed-stage report for --check."""
args = list(sys.argv[1:] if argv is None else argv)
prepare_space_environment()
if "--check" in args:
report = closed_stage_report()
sys.stdout.write(json.dumps(report, sort_keys=True) + "\n")
if not report["ok"]:
raise SystemExit(1)
return
host = space_host()
port = space_port()
server = build_server(host=host, port=port)
serve_streamable_http(server, host, port)
if __name__ == "__main__":
main()
|