""" Application UI Server — 43-node prime array dashboard. Hosts an HTML5+Canvas visualization at http://localhost:8000 and bridges the binary 348-byte stream from engine.py (tcp/8081) and the JSON telemetry beacon (udp/9000) into a /api/metrics endpoint polled by the front-end. """ import http.server import socketserver import socket import threading import json import struct import time PORT_SERVER = 8000 ui_telemetry_mirror = { "energy_invariant_c0": 0.0, "active_nodes": 43, "status": "BOOTING", "math_coords": [0.0] * 43, "truth_coords": [0.0] * 43, } DASHBOARD_HTML = r""" Absolute Infinity Matrix UI & Vector Canvas

Absolute Infinity Lattice System Workspace

System Metrics Monitor

Engine Core Target : localhost:8081

Active Topology Nodes : 43 (Prime Field)

Energy Invariant C0 : 0.000000

Pipeline Sync State : CHECKING_LINK

Real-Time HTML5 Canvas Vector Graph

""" class CoreAppDashboardRequestHandler(http.server.SimpleHTTPRequestHandler): def do_GET(self): if self.path == "/api/metrics": self.send_response(200) self.send_header("Content-Type", "application/json") self.send_header("Access-Control-Allow-Origin", "*") self.end_headers() self.wfile.write(json.dumps(ui_telemetry_mirror).encode("utf-8")) else: self.send_response(200) self.send_header("Content-Type", "text/html") self.end_headers() self.wfile.write(DASHBOARD_HTML.encode("utf-8")) def listen_to_engine_data_stream(): while True: client_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) try: client_sock.connect(("127.0.0.1", 8081)) print("[server] connected to engine binary stream on 8081") while True: raw_bytes = bytearray() while len(raw_bytes) < 348: chunk = client_sock.recv(348 - len(raw_bytes)) if not chunk: raise socket.error("engine closed the stream") raw_bytes.extend(chunk) offset = 4 m_list = [] t_list = [] for _ in range(43): m_val, t_val = struct.unpack("!ff", raw_bytes[offset:offset + 8]) m_list.append(m_val) t_list.append(t_val) offset += 8 ui_telemetry_mirror["math_coords"] = m_list ui_telemetry_mirror["truth_coords"] = t_list except socket.error as e: ui_telemetry_mirror["status"] = "ENGINE_LINK_DISCONNECTED" print(f"[server] engine stream lost: {e}; retrying in 2s") time.sleep(2.0) finally: client_sock.close() def listen_to_engine_beacon_channel(): udp_receiver = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) udp_receiver.bind(("127.0.0.1", 9000)) udp_receiver.settimeout(2.0) while True: try: raw_bytes, _ = udp_receiver.recvfrom(2048) decoded = json.loads(raw_bytes.decode("utf-8")) ui_telemetry_mirror["energy_invariant_c0"] = decoded["core_matrix"][ "energy_invariant_c0" ] if ui_telemetry_mirror["status"] != "ENGINE_LINK_DISCONNECTED": ui_telemetry_mirror["status"] = "MATRIX_LOCKED" except socket.timeout: if ui_telemetry_mirror["status"] != "ENGINE_LINK_DISCONNECTED": ui_telemetry_mirror["status"] = "ENGINE_LINK_TIMEOUT" except Exception: ui_telemetry_mirror["status"] = "TRACKING_FAULT" if __name__ == "__main__": threading.Thread(target=listen_to_engine_beacon_channel, daemon=True).start() threading.Thread(target=listen_to_engine_data_stream, daemon=True).start() with socketserver.TCPServer(("127.0.0.1", PORT_SERVER), CoreAppDashboardRequestHandler) as server_daemon: print(f"[server] dashboard at http://localhost:{PORT_SERVER}") server_daemon.serve_forever()