Update app.py

app.py

@@ -5,14 +5,14 @@ import os
 import re
 import time
 
-# 1. Setup
+# 1. API Configuration
 HF_TOKEN = os.getenv("HF_TOKEN")
 MODEL_ID = "Qwen/Qwen2.5-7B-Instruct"
 
 client_primary = InferenceClient(MODEL_ID, token=HF_TOKEN)
 client_competitor = InferenceClient(MODEL_ID, token=HF_TOKEN)
 
-# 2. Logic Controller
+# 2. Logic Controller (T3 Architecture)
 class StateController:
     __slots__ = ("_state", "_metric", "_batch", "_reg", "_rendered", "_rom60", "_symbols")
     def __init__(self):
@@ -20,13 +20,10 @@ class StateController:
         self._metric     = 60
         self._batch      = 10
         self._reg        = {}
-        self._rendered   = self._build_render()
+        self._rendered   = "".join(" [NODE_120] " if i == 120 else ("<" if i % 10 == 0 else ".") for i in range(121))
         self._rom60      = tuple(tuple((i * j) % 60 for j in range(60)) for i in range(60))
         self._symbols    = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz01234567"
 
-    def _build_render(self) -> str:
-        return "".join(" [NODE_120] " if i == 120 else ("<" if i % 10 == 0 else ".") for i in range(121))
-
     def diagnostic(self) -> str:
         return f"Diagnostic sequence initiated.\n\nGrid initialized.\n\n{self._rendered}\n\nSystem resolved."
 
@@ -38,39 +35,41 @@ class StateController:
         expected = self.generate_receipt(a, b, c)
         if receipt == expected:
             return f"[NODE_120: ACTIVE] Checksum Validated. Receipt {receipt} matches."
-        return f"[NODE_120: INACTIVE] Verification Failed."
+        return f"[NODE_120: INACTIVE] Verification Failed. Expected {expected}."
 
 controller = StateController()
 
-# 3. Instructions
 PRIMARY_SYS = {"role": "system", "content": "You are a logic-focused inference engine. Use strict state-hold memory."}
 VANILLA_SYS = {"role": "system", "content": "You are a standard helpful AI assistant."}
 
-# 4. Responses (Gradio 6 Compatible)
+# 3. Response Generation (Gradio 6.x Dictionary Format)
 def generate_responses(user_message, primary_history, competitor_history):
     msg = user_message.strip()
     if not msg:
         yield primary_history, competitor_history, ""
         return
 
-    # Gradio 6 strictly requires ChatMessage objects or dicts with 'role' and 'content'
-    # We initialize the assistant message as empty
-    primary_history = primary_history + [{"role": "user", "content": msg}, {"role": "assistant", "content": ""}]
-    competitor_history = competitor_history + [{"role": "user", "content": msg}, {"role": "assistant", "content": ""}]
+    # Ensure history is initialized
+    if primary_history is None: primary_history = []
+    if competitor_history is None: competitor_history = []
+
+    # Format: Dict-based history required for Gradio 6
+    primary_history.append({"role": "user", "content": msg})
+    primary_history.append({"role": "assistant", "content": ""})
+    competitor_history.append({"role": "user", "content": msg})
+    competitor_history.append({"role": "assistant", "content": ""})
     
     yield primary_history, competitor_history, ""
     
     start_time = time.perf_counter()
 
-    # Hardware Intercepts
+    # Diagnostic & Checksum Intercepts
     if msg.lower() == "run grid diagnostic":
-        res = controller.diagnostic()
-        primary_history[-1]["content"] = f"{res}\n\n---\n*Telemetry: {time.perf_counter()-start_time:.4f}s*"
+        primary_history[-1]["content"] = f"{controller.diagnostic()}\n\n---\n*Telemetry: {time.perf_counter()-start_time:.4f}s*"
         competitor_history[-1]["content"] = "Hardware diagnostics not supported."
         yield primary_history, competitor_history, ""
         return
 
-    # Checksum Intercept
     verify_match = re.search(r"verify receipt\s+([a-zA-Z0-9]{2})\s+for\s+(\d+),\s*(\d+),\s*(\d+)", msg, re.IGNORECASE)
     if verify_match:
         receipt, a, b, c = verify_match.group(1), int(verify_match.group(2)), int(verify_match.group(3)), int(verify_match.group(4))
@@ -80,7 +79,7 @@ def generate_responses(user_message, primary_history, competitor_history):
         yield primary_history, competitor_history, ""
         return
 
-    # Stream Primary
+    # Engine 1: Augmented
     try:
         msgs = [PRIMARY_SYS] + primary_history[:-1]
         response_text = ""
@@ -89,15 +88,14 @@ def generate_responses(user_message, primary_history, competitor_history):
             response_text += (chunk.choices[0].delta.content or "")
             primary_history[-1]["content"] = response_text
             yield primary_history, competitor_history, ""
-        primary_history[-1]["content"] += f"\n\n---\n*Telemetry: {time.perf_counter()-start_time:.2f}s | Augmented*"
+        primary_history[-1]["content"] += f"\n\n---\n*Telemetry: {time.perf_counter()-start_time:.2f}s | Augmented Engine*"
         yield primary_history, competitor_history, ""
     except Exception as e:
-        primary_history[-1]["content"] = f"Error: {str(e)}"
-        yield primary_history, competitor_history, ""
+        primary_history[-1]["content"] = f"Primary Error: {str(e)}"
 
-    # Stream Competitor
+    # Engine 2: Vanilla
     comp_start = time.perf_counter()
-    competitor_history[-1]["content"] = "*Connecting...*"
+    competitor_history[-1]["content"] = "*Connecting to vanilla infrastructure...*"
     yield primary_history, competitor_history, ""
     
     try:
@@ -108,33 +106,35 @@ def generate_responses(user_message, primary_history, competitor_history):
             response_text += (chunk.choices[0].delta.content or "")
             competitor_history[-1]["content"] = response_text
             yield primary_history, competitor_history, ""
-        competitor_history[-1]["content"] += f"\n\n---\n*Telemetry: {time.perf_counter()-comp_start:.2f}s | Vanilla*"
+        competitor_history[-1]["content"] += f"\n\n---\n*Telemetry: {time.perf_counter()-comp_start:.2f}s | Vanilla Engine*"
         yield primary_history, competitor_history, ""
     except Exception as e:
-        competitor_history[-1]["content"] = f"Error: {str(e)}"
-        yield primary_history, competitor_history, ""
+        competitor_history[-1]["content"] = f"Competitor Error: {str(e)}"
+    
+    yield primary_history, competitor_history, ""
 
-# 5. UI
+# 4. Interface Build
 custom_css = """
 body, .gradio-container { background-color: #110c08 !important; color: #fb923c !important; }
 footer { display: none !important; }
 """
 
-with gr.Blocks(theme=gr.themes.Soft(primary_hue="orange"), css=custom_css) as demo:
+with gr.Blocks() as demo:
     gr.Markdown("# [ GLYPH.IO ]\n### Dual-Engine Hardware Benchmark")
     
-    primary_chat = gr.Chatbot(label="Augmented Logic Kernel", height=320, type="messages")
+    p_chat = gr.Chatbot(label="Augmented Logic Kernel", height=320)
     
     with gr.Row():
-        msg_input = gr.Textbox(label="Message", placeholder="Enter task...", scale=8)
-        submit_btn = gr.Button("Execute", scale=1, variant="primary")
+        msg_in = gr.Textbox(label="Message", placeholder="Enter task...", scale=8)
+        btn = gr.Button("Execute", scale=1, variant="primary")
         
-    gr.Examples(examples=["Calculate the integer distribution for 120 units across 3 nodes.", "Run grid diagnostic"], inputs=msg_input)
-    
-    competitor_chat = gr.Chatbot(label="Vanilla Qwen 2.5", height=320, type="messages")
+    c_chat = gr.Chatbot(label="Vanilla Qwen 2.5", height=320)
 
-    msg_input.submit(generate_responses, [msg_input, primary_chat, competitor_chat], [primary_chat, competitor_chat, msg_input])
-    submit_btn.click(generate_responses, [msg_input, primary_chat, competitor_chat], [primary_chat, competitor_chat, msg_input])
+    msg_in.submit(generate_responses, [msg_in, p_chat, c_chat], [p_chat, c_chat, msg_in])
+    btn.click(generate_responses, [msg_in, p_chat, c_chat], [p_chat, c_chat, msg_in])
 
 if __name__ == "__main__":
-    demo.queue().launch()
+    demo.queue().launch(
+        theme=gr.themes.Soft(primary_hue="orange"), 
+        css=custom_css
+    )