Spaces:
Running
Running
Deploy Aureon OS (deploy/selfhost stack: nginx edge + fusion API x2 + console + HNC organ + redis + postgres; paper mode) (part 20)
8495bb8 verified | """HNCLiveDaemon attach_observer flag and singleton wiring. | |
| Verifies that: | |
| * attach_observer=True (default) constructs an observer | |
| * The observer claims the singleton | |
| * Caller-provided observers take precedence | |
| * attach_observer=False with no observer disables the integration | |
| * The daemon never raises on attach failures (graceful degrade) | |
| """ | |
| from __future__ import annotations | |
| import asyncio | |
| import time | |
| from pathlib import Path | |
| from typing import Any | |
| import pytest | |
| from aureon.core.aureon_lambda_engine import SubsystemReading | |
| from aureon.core.hnc_live_daemon import ( | |
| HNCLiveDaemon, | |
| SourceObservation, | |
| SourceReceipt, | |
| ) | |
| from aureon.observer import HarmonicObserver, get_observer | |
| def _daemon(tmp_path: Path, **kwargs: Any) -> HNCLiveDaemon: | |
| return HNCLiveDaemon( | |
| state_path=tmp_path / "lambda_history.json", | |
| trace_path=tmp_path / "hnc_trace.jsonl", | |
| **kwargs, | |
| ) | |
| def _offline_receipt_daemon(tmp_path: Path) -> HNCLiveDaemon: | |
| daemon = _daemon(tmp_path) | |
| daemon._sources.clear() | |
| daemon._fetchers.clear() | |
| async def fetch_fixture() -> SourceObservation: | |
| observed_at = time.time() | |
| return SourceObservation( | |
| reading=SubsystemReading( | |
| name="fixture", | |
| value=0.62, | |
| confidence=0.9, | |
| state="live", | |
| ), | |
| receipt=SourceReceipt( | |
| source_id="test.fixture", | |
| source_timestamp=observed_at, | |
| received_at=observed_at, | |
| receipt_id=f"test:fixture:{time.time_ns()}", | |
| receipt_type="test_provider_measurement", | |
| truth_status="real_observed", | |
| generated_values=False, | |
| ), | |
| ) | |
| daemon.register_source( | |
| "fixture", | |
| 0.05, | |
| fetch_fixture, | |
| max_age_s=60.0, | |
| ) | |
| return daemon | |
| def test_default_attach_observer_constructs(tmp_path: Path): | |
| d = _daemon(tmp_path) | |
| assert d._observer is not None | |
| assert get_observer() is d._observer | |
| def test_attach_observer_false_disables(tmp_path: Path): | |
| d = _daemon(tmp_path, attach_observer=False) | |
| assert d._observer is None | |
| def test_caller_provided_observer_used(tmp_path: Path): | |
| custom = HarmonicObserver(publish_to_bus=False) | |
| d = _daemon(tmp_path, attach_observer=False, observer=custom) | |
| assert d._observer is custom | |
| def test_caller_observer_overrides_attach_flag(tmp_path: Path): | |
| """If caller provides an observer, attach_observer=True does NOT | |
| construct a second one.""" | |
| custom = HarmonicObserver(publish_to_bus=False) | |
| d = _daemon(tmp_path, attach_observer=True, observer=custom) | |
| assert d._observer is custom | |
| def test_compute_loop_feeds_observer_ingest_state(tmp_path: Path): | |
| """Run a tiny duration-bounded loop; verify ingest_state was called.""" | |
| d = _offline_receipt_daemon(tmp_path) | |
| asyncio.run(d.run(duration_s=0.5)) | |
| snap = d._observer.metrics_snapshot() | |
| assert snap["n_ingested"] >= 1 | |
| latest = snap["latest_field"] | |
| assert latest["lambda_t"] is not None | |
| # ingest_state must have populated psi/level — these only flow from | |
| # ingest_state, never from plain ingest(). | |
| assert latest["consciousness_psi"] is not None | |
| assert latest["consciousness_level"] is not None | |
| def test_predictionbus_auto_picks_up_observer(tmp_path: Path): | |
| """Stage B + Stage E together: bus auto-wires; daemon installs observer; | |
| bus then sees real observer state.""" | |
| from aureon.autonomous.aureon_autonomy_hub import PredictionBus | |
| bus = PredictionBus() | |
| d = _offline_receipt_daemon(tmp_path) | |
| asyncio.run(d.run(duration_s=0.5)) | |
| results = bus.run_predictions({}, symbol="BTCUSD") | |
| assert "harmonic_observer" in results | |
| sig = results["harmonic_observer"] | |
| assert sig.direction in ("BULLISH", "BEARISH", "NEUTRAL") | |
| assert 0.0 <= sig.confidence <= 1.0 | |