"""Read-only and one-step tools for organism layers that do not order or write state/. Dispositions follow the scoping table. A package with no safe callable stays catalog-only. Blocked trading imports are not called. """ from __future__ import annotations import ast from pathlib import Path from typing import Any from aureon_public import paths from aureon_public.quiet import quiet from aureon_public.text import AURIS_FOUR, HOLD_LINE from aureon_public.tools import _dumps, _finite # kind: public tool name, catalog (named, not called), or operator (not on this server). PACKAGES: tuple[dict[str, str], ...] = ( {"package": "accounting", "kind": "operator", "reason": "Inferred private. Not opened. No live orders."}, {"package": "alignment", "kind": "catalog", "reason": "Not opened. No safe zero-write callable was wrapped."}, {"package": "analytics", "kind": "catalog", "reason": "Lighthouse seat module was not given a separate tool. QGITA lighthouse math is wrapped on wisdom."}, {"package": "appliance", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "approval", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "atn", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "autonomous", "kind": "operator", "reason": "Self-coding and launchers. Operator server only. No live orders."}, {"package": "bio", "kind": "membrane_screen", "reason": "screen_ingress is read-only containment. The Flask transport is not re-exported."}, {"package": "bots", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "bots_intelligence", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "bridges", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "briefing", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "code_architect", "kind": "operator", "reason": "Self-coding. Operator server only. No repo writes from this server."}, {"package": "cognition", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "command_centers", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "connectors", "kind": "operator", "reason": "Inferred private. Not opened. No live orders."}, {"package": "conversion", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "core", "kind": "public", "reason": "Canonical field, LambdaEngine, circulation catalog, and the repository-layer hold."}, {"package": "data_feeds", "kind": "catalog", "reason": "Feeds are key-adjacent. Not called."}, {"package": "decoders", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "evaluation", "kind": "evidence_predict_next", "reason": "predict_next and the committed-report formatters. evaluate_organism and the self-coder harness are not called."}, {"package": "exchanges", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "gates", "kind": "catalog", "reason": "Signature pass was not done. Not called."}, {"package": "generated", "kind": "catalog", "reason": "Generated trees are not exposed."}, {"package": "governance", "kind": "catalog", "reason": "Seat resolvers were not started."}, {"package": "grants", "kind": "catalog", "reason": "Out of the public tool surface."}, {"package": "harmonic", "kind": "public", "reason": "HarmonicRealityField plus substrate, echo, observer, potential, and projection. HFT order types are not called."}, {"package": "identity", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "inhouse_ai", "kind": "catalog", "reason": "The operator tool registry is not re-exported."}, {"package": "integrations", "kind": "catalog", "reason": "External systems. Not called."}, {"package": "intelligence", "kind": "catalog", "reason": "GlobalMarketOrganism is not a stateless API. Not called."}, {"package": "launch", "kind": "operator", "reason": "Process start. Operator server only. This server does not launch it."}, {"package": "miner", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "monitors", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "observability", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "observer", "kind": "catalog", "reason": "HarmonicObserver attaches to the live daemon. Not called."}, {"package": "operator", "kind": "operator", "reason": "Flask app and the existing /mcp routes. Not mounted here."}, {"package": "organism", "kind": "repository_layers_hold", "reason": "compose_repository_layers on an empty root. No network transport."}, {"package": "plumber", "kind": "catalog", "reason": "Crypto extras. Not called."}, {"package": "portfolio", "kind": "operator", "reason": "Inferred private. Not opened. No live orders."}, {"package": "portals", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "queen", "kind": "catalog", "reason": "QueenLayer init is not called. Auris node and evaluator calls live on utils."}, {"package": "s51", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "saas", "kind": "operator", "reason": "Billing. Operator server only. No charges."}, {"package": "scanners", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "search", "kind": "catalog", "reason": "Not repo_search. Not called."}, {"package": "simulation", "kind": "catalog", "reason": "Long-running. Not called."}, {"package": "strategies", "kind": "operator", "reason": "Trading-adjacent. Operator refusal only. No live orders."}, {"package": "swarm", "kind": "catalog", "reason": "Council seat is named in organism_catalog. The council is not started."}, {"package": "swarm_motion", "kind": "catalog", "reason": "Not opened. No safe callable wrapped."}, {"package": "trading", "kind": "operator", "reason": "Blocked by guard.py. Operator refusal only. No live orders."}, {"package": "utils", "kind": "public", "reason": "Nine nodes and the coherence evaluator. QueenHiveMind.__init__ is not called."}, {"package": "vault", "kind": "catalog", "reason": "State files. Not opened and not written."}, {"package": "wisdom", "kind": "public", "reason": "QGITAMarketAnalyzer, FTCPDetector, and LighthouseModel metric calls. Signals are dropped."}, ) HOLDS = { "trade_readiness": "HOLD", "auris_to_lambda": "HOLD", "qgita_detection_rate": "HOLD", "qgita_false_alarm_rate": "HOLD", "schumann_f0": "null. HOLD", "human_eval": "not run. HOLD", } def _package_rows() -> list[dict[str, str]]: root = paths.repo_root() / "aureon" rows = [] for row in PACKAGES: present = (root / row["package"]).is_dir() or row["package"] == "unified_margin_trader" rows.append({**row, "present": "yes" if present else "no", "holds": HOLD_LINE}) return rows @quiet def package_dispositions(package: str | None = None) -> str: """Disposition of each aureon package. Label: inferred from the scoping table, except where a tool below calls a real function. Blocked packages are operator-only. This tool does not import them. Args: package: Optional package name. Omitted returns the full table. Label: inferred. """ rows = _package_rows() if package: chosen = [row for row in rows if row["package"] == package] if not chosen: return _dumps( { "holds": HOLDS, "label": "inferred", "provenance": "inferred", "reason": "Unknown package.", "status": "unavailable", } ) rows = chosen return _dumps( { "holds": HOLDS, "label": "inferred. Package dispositions. Not a measurement.", "packages": rows, "provenance": "inferred", "status": "inferred", "which_auris": AURIS_FOUR, } ) @quiet def hnc_substrate_eval(t: float = 0.0) -> str: """One HarmonicSubstrate.evaluate call. Provenance: inferred. This is not HarmonicRealityField.step. The substrate equation is the class docstring. No formula was added. Trade readiness: HOLD. Args: t: Time passed to evaluate. Label: cited, HarmonicSubstrate.evaluate. """ number = _finite(t) if number is None: return _dumps({"provenance": "cited", "reason": "t is missing", "status": "unavailable"}) from aureon.harmonic.aureon_harmonic_reality import HarmonicSubstrate substrate = HarmonicSubstrate() return _dumps( { "label": "inferred. One HarmonicSubstrate.evaluate call.", "provenance": "inferred", "status": "inferred", "t": number, "value": float(substrate.evaluate(number)), } ) @quiet def hnc_echo_eval(current_lambda: float = 0.0) -> str: """One CausalEcho.evaluate call on a new echo. Provenance: inferred. The buffer starts at zeros in CausalEcho.__init__. This is that function, not a new formula. Trade readiness: HOLD. Args: current_lambda: Value passed to evaluate. Label: cited, CausalEcho.evaluate. """ number = _finite(current_lambda) if number is None: return _dumps({"provenance": "cited", "reason": "current_lambda is missing", "status": "unavailable"}) from aureon.harmonic.aureon_harmonic_reality import CausalEcho echo = CausalEcho() return _dumps( { "label": "inferred. One CausalEcho.evaluate call on a new instance.", "provenance": "inferred", "status": "inferred", "value": float(echo.evaluate(number)), } ) @quiet def hnc_observer_eval(current_lambda: float = 0.0) -> str: """One ObserverNode.evaluate call on a new observer. Provenance: inferred. Args: current_lambda: Value passed to evaluate. Label: cited, ObserverNode.evaluate. """ number = _finite(current_lambda) if number is None: return _dumps({"provenance": "cited", "reason": "current_lambda is missing", "status": "unavailable"}) from aureon.harmonic.aureon_harmonic_reality import ObserverNode observer = ObserverNode() return _dumps( { "label": "inferred. One ObserverNode.evaluate call on a new instance.", "provenance": "inferred", "status": "inferred", "value": float(observer.evaluate(number)), } ) @quiet def hnc_potential_eval(lambda_val: float = 0.0) -> str: """One UnifiedPotential.evaluate call. Provenance: inferred. The potential string is the class docstring. No formula was added. Trade readiness: HOLD. Args: lambda_val: Value passed to evaluate. Label: cited, UnifiedPotential.evaluate. """ number = _finite(lambda_val) if number is None: return _dumps({"provenance": "cited", "reason": "lambda_val is missing", "status": "unavailable"}) from aureon.harmonic.aureon_harmonic_reality import UnifiedPotential potential = UnifiedPotential() return _dumps( { "label": "inferred. One UnifiedPotential.evaluate call.", "provenance": "inferred", "status": "inferred", "value": float(potential.evaluate(number)), } ) @quiet def hnc_translate_project(psi_5d: float = 1.0, phi: float = 0.0, delta_phi: float = 0.0, f_value: float = 1.0) -> str: """One TranslationMap.project_to_3d call with observed_residual left unset. Provenance: inferred. Noise is the method's own result when no residual is supplied. Label: cited, TranslationMap.project_to_3d. Args: psi_5d: High-dimensional state. Label: cited. phi: Extra angle. Label: cited. delta_phi: Phase difference. Label: cited. f_value: Brane frequency passed as F. Label: cited. """ numbers = { "psi_5d": _finite(psi_5d), "phi": _finite(phi), "delta_phi": _finite(delta_phi), "f_value": _finite(f_value), } if any(value is None for value in numbers.values()): return _dumps({"provenance": "cited", "reason": "A projection input is missing", "status": "unavailable"}) from aureon.harmonic.aureon_harmonic_reality import TranslationMap mapped = TranslationMap() projected, noise = mapped.project_to_3d( psi_5d=float(numbers["psi_5d"]), phi=float(numbers["phi"]), delta_phi=float(numbers["delta_phi"]), F=float(numbers["f_value"]), ) return _dumps( { "label": "inferred. project_to_3d with no observed residual.", "noise": float(noise), "projected": float(projected), "provenance": "inferred", "status": "inferred", } ) @quiet def qgita_ftcp_detect(values: list[float] | None = None) -> str: """FTCPDetector.detect_ftcps on a caller series or a short default. Provenance: inferred. Detection rate: HOLD. False-alarm rate: HOLD. This is not QGITAMarketAnalyzer.signals. Args: values: Optional series of at least three numbers. Omitted uses 0,1,1,2,3,5,8. Label: inferred for the call. The detector is cited. """ series = [0.0, 1.0, 1.0, 2.0, 3.0, 5.0, 8.0] if values is None else [] if values is not None: for item in values: number = _finite(item) if number is None: return _dumps( { "detection_rate": "HOLD", "false_alarm_rate": "HOLD", "provenance": "cited", "reason": "A value is missing", "status": "unavailable", } ) series.append(number) if len(series) < 3: return _dumps( { "detection_rate": "HOLD", "false_alarm_rate": "HOLD", "provenance": "cited", "reason": "At least three values are required", "status": "unavailable", } ) import numpy as np from aureon.wisdom.aureon_qgita_framework import FTCPDetector detector = FTCPDetector() times = np.arange(len(series), dtype=float) found = detector.detect_ftcps(times, np.asarray(series, dtype=float)) return _dumps( { "detection_rate": "HOLD", "false_alarm_rate": "HOLD", "ftcp_count": len(found), "label": "inferred. FTCPDetector.detect_ftcps. Not a detection rate.", "provenance": "inferred", "status": "inferred", } ) @quiet def qgita_lighthouse_coherence(values: list[float] | None = None) -> str: """LighthouseModel.compute_linear_coherence on one series. Provenance: inferred. Detection rate: HOLD. False-alarm rate: HOLD. validate_ftcp is not called. Signals are not returned. Args: values: Optional series. Omitted uses 1,1,1,1,1. Label: inferred for the call. The method is cited. """ series = [1.0, 1.0, 1.0, 1.0, 1.0] if values is None else [] if values is not None: for item in values: number = _finite(item) if number is None: return _dumps( { "detection_rate": "HOLD", "false_alarm_rate": "HOLD", "provenance": "cited", "reason": "A value is missing", "status": "unavailable", } ) series.append(number) import numpy as np from aureon.wisdom.aureon_qgita_framework import LighthouseModel model = LighthouseModel() signal = np.asarray(series, dtype=float) return _dumps( { "c_linear": float(model.compute_linear_coherence(signal)), "detection_rate": "HOLD", "false_alarm_rate": "HOLD", "label": "inferred. LighthouseModel.compute_linear_coherence.", "provenance": "inferred", "status": "inferred", } ) @quiet def membrane_screen(text: str = "") -> str: """screen_ingress on caller text. Provenance: cited. This does not dispatch a tool and does not trade. Args: text: Inbound text screened as data. Label: cited, aureon/bio/mcp_membrane.py screen_ingress. """ from dataclasses import asdict missing = _load_phenolic_fingerprint() if missing: return _dumps( { "label": "cited-unverified. phenolic_fingerprint was not loaded, so screen_ingress did not run.", "provenance": "cited-unverified", "reason": missing, "status": "unavailable", } ) try: from aureon.bio.mcp_membrane import screen_ingress except Exception as exc: return _dumps( { "label": "cited-unverified. screen_ingress did not import in this process.", "provenance": "cited-unverified", "reason": f"{type(exc).__name__}: {exc}"[:240], "status": "unavailable", } ) verdict = screen_ingress(str(text), source="aureon-public") body = asdict(verdict) body["label"] = ( "cited. screen_ingress. phenolic_fingerprint loaded from checkout " "after the blob check for pin 8aa6a2d9. Not an order." ) body["provenance"] = "cited" body["status"] = "cited" return _dumps(body) @quiet def repository_layers_hold() -> str: """compose_repository_layers on an empty directory. Provenance: cited. No field or market transport is passed, and the empty root has no sibling checkouts, so this does not open a network socket from those call sites. may_act stays false. Args: none: This tool takes no inputs. Label: cited, aureon/organism/repository_layers.py compose_repository_layers. """ import tempfile from aureon.organism.repository_layers import compose_repository_layers empty = Path(tempfile.mkdtemp(prefix="aureon-public-layers-")) try: report = compose_repository_layers(repos_root=empty) finally: empty.rmdir() report["label"] = "cited. Empty-root hold join. Not a network observation." report["provenance"] = "cited" return _dumps(report) @quiet def evidence_predict_next(values: list[float] | None = None) -> str: """evaluate.organism_proof.predict_next. Provenance: inferred. This does not call evaluate_organism. HumanEval: not run. HOLD. Args: values: Optional numbers. Omitted uses 1,2,3. Label: inferred for the call. The function is cited. """ series: list[float] = [] raw = [1.0, 2.0, 3.0] if values is None else values for item in raw: number = _finite(item) if number is None: return _dumps( { "human_eval": "not run. HOLD", "provenance": "cited", "reason": "A value is missing", "status": "unavailable", } ) series.append(number) from aureon.evaluation.organism_proof import predict_next predicted = predict_next(series) return _dumps( { "human_eval": "not run. HOLD", "label": "inferred. predict_next. evaluate_organism was not called.", "predicted": predicted, "provenance": "inferred", "status": "inferred", } ) @quiet def source_names(package: str) -> str: """Top-level class and function names parsed from a package's Python files. Provenance: cited. This reads source text with ast. It does not import the package and does not call those functions. Blocked packages are refused. Args: package: aureon package name, or unified_margin_trader. Label: cited, the file names on disk. """ blocked = { "exchanges", "trading", "bots", "bots_intelligence", "bridges", "scanners", } if package in blocked or package == "unified_margin_trader": return _dumps( { "label": "cited. guard.py refuses these imports. Names are not loaded.", "package": package, "provenance": "cited", "status": "unavailable", } ) root = paths.repo_root() / "aureon" / package if not root.is_dir(): return _dumps( { "provenance": "cited", "reason": "Package directory is missing", "status": "unavailable", } ) names: list[dict[str, str]] = [] for path in sorted(root.glob("*.py")): if path.name == "__init__.py": continue try: tree = ast.parse(path.read_text(encoding="utf-8", errors="replace")) except SyntaxError: continue for node in tree.body: if isinstance(node, (ast.FunctionDef, ast.AsyncFunctionDef, ast.ClassDef)): names.append({"file": path.name, "kind": type(node).__name__, "name": node.name}) if len(names) >= 40: break if len(names) >= 40: break return _dumps( { "label": "cited. ast names only. Functions were not called.", "names": names, "package": package, "provenance": "cited", "status": "cited", } ) def _load_phenolic_fingerprint(root: Path | None = None) -> str | None: """Register the checkout's phenolic_fingerprint without putting the repo root on sys.path. The file is executed only when its git blob is the blob at pin 8aa6a2d9. A different checkout copy is refused and is not loaded. """ from aureon_public.pin_blob import ( PHENOLIC_MISMATCH, PINNED_PHENOLIC_BLOB, load_pinned_source, ) base = paths.repo_root() if root is None else root path = base / "phenolic_fingerprint.py" return load_pinned_source( "phenolic_fingerprint", path, PINNED_PHENOLIC_BLOB, PHENOLIC_MISMATCH, ) def public_layer_tools() -> list[Any]: from aureon_public.alignment_layer import TOOLS as ALIGNMENT_TOOLS from aureon_public.more_layers import TOOLS from aureon_public.stage1_rest import TOOLS as STAGE1_TOOLS from aureon_public.stage2_layer import TOOLS as STAGE2_TOOLS return [ package_dispositions, hnc_substrate_eval, hnc_echo_eval, hnc_observer_eval, hnc_potential_eval, hnc_translate_project, qgita_ftcp_detect, qgita_lighthouse_coherence, membrane_screen, repository_layers_hold, evidence_predict_next, source_names, *TOOLS, *ALIGNMENT_TOOLS, *STAGE1_TOOLS, *STAGE2_TOOLS, ] def packages_resource() -> str: """Every package disposition, including operator exclusions. Provenance: inferred. Auris meanings stay separate. The conjecture is not called. The nine nodes and the coherence evaluator are the utils tools. The persona is not scored. Label: inferred. """ return package_dispositions()