Update app.py

app.py

@@ -600,6 +600,8 @@ def send_to_webhook(url):
     except Exception as e:
         return f"⚠️ Connection error: {str(e)}"
 
+# ... [Keep all the imports, config, and function definitions above] ...
+
 # === GRADIO UI ===
 with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as demo:
     gr.Markdown("# 🧠 DeepSeek Hexa-Agent Discussion System")
@@ -624,6 +626,15 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
             clear_btn = gr.Button("🔄 New Discussion", variant="stop")
             topic_btn = gr.Button("🎲 Random Topic", variant="secondary")
             ruling_btn = gr.Button("⚖️ Request Ruling", variant="primary")
+        
+        with gr.Accordion("💬 Guide the Discussion", open=False):
+            topic_input = gr.Textbox(label="Set Custom Topic", placeholder="e.g., Ethics of AGI in cultural contexts...")
+            with gr.Row():
+                qbox = gr.Textbox(label="Ask the Depth Guardian", placeholder="What perspectives are missing?")
+                ruling_qbox = gr.Textbox(label="Specific Question for Judge", placeholder="What should be our guiding principle?")
+            with gr.Row():
+                overseer_out = gr.Textbox(label="Depth Guardian Response", interactive=False)
+                judge_out = gr.Textbox(label="Judge's Response", interactive=False)
     
     with gr.Tab("Agent Perspectives"):
         with gr.Row():
@@ -689,15 +700,16 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
     with gr.Tab("Agent Configuration"):
         gr.Markdown("### Customize Agent Behavior")
         with gr.Row():
+            agent_sliders = {}
             for agent in ["Initiator", "Responder", "Guardian", "Provocateur", "Cultural", "Judge"]:
                 with gr.Column():
                     gr.Markdown(f"#### {agent}")
-                    agent_params[f"{agent}_creativity"] = gr.Slider(
-                        0.0, 1.0, value=agent_params[agent]["creativity"], 
+                    agent_sliders[f"{agent}_creativity"] = gr.Slider(
+                        0.0, 1.0, value=0.7, 
                         label="Creativity", interactive=True
                     )
-                    agent_params[f"{agent}_critical"] = gr.Slider(
-                        0.0, 1.0, value=agent_params[agent]["criticality"], 
+                    agent_sliders[f"{agent}_critical"] = gr.Slider(
+                        0.0, 1.0, value=0.5, 
                         label="Criticality", interactive=True
                     )
     
@@ -730,7 +742,7 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
         return (
             "<div class='convo-container'>New discussion started</div>", 
             "", "", "", "", "", 0, "",
-            {"agents": [], "counts": []}, "", None, ""
+            {"agents": [], "counts": []}, "", None, "", ""
         )
     
     def new_topic():
@@ -738,6 +750,29 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
         topic = generate_topic()
         return clear_result[:6] + (topic,) + clear_result[7:]
     
+    # === OVERSEER QUERY HANDLER ===
+    def overseer_respond(query):
+        try:
+            context = "\n".join([m['text'] for m in conversation[-3:]]) if conversation else "No context"
+            messages = [{"role": "user", "content": f"Discussion Topic: {current_topic}\n\nRecent context:\n{context}\n\nQuery: {query}"}]
+            return safe_chat_completion(
+                OVERSEER_PROMPT, 
+                messages,
+                temperature=0.5 + agent_params["Guardian"]["criticality"] * 0.4
+            )
+        except Exception as e:
+            return f"[Overseer Error: {str(e)}]"
+    
+    # === JUDGE RULING HANDLER ===
+    def request_ruling():
+        try:
+            ruling = judge_ruling()
+            conversation.append({"agent": "⚖️ Judge", "text": ruling})
+            embed_and_store(ruling, "Judge")
+            return ruling
+        except Exception as e:
+            return f"[Judge Error: {str(e)}]"
+    
     def ask_judge(query):
         try:
             context = "\n".join([m['text'] for m in conversation[-3:]]) if conversation else "No context"
@@ -779,174 +814,34 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
             return format_convo(), f"✅ Added: '{text[:30]}...'"
         return format_convo(), "Please enter text"
     
-    def update_agent_params(*args):
-        # Update global agent_params based on UI sliders
-        params = agent_params.copy()
-        for agent in params.keys():
-            params[agent]["creativity"] = globals()[f"{agent}_creativity"].value
-            params[agent]["criticality"] = globals()[f"{agent}_critical"].value
-        return "Agent parameters updated!"
-    
-    # Connect UI components
-    step_btn.click(
-        step, 
-        inputs=[topic_display],
-        outputs=[
-            convo_display, intervention_display, outsider_display, 
-            cultural_display, judge_display, topic_display, turn_counter, agent_status
-        ]
-    )
-
-# === GRADIO UI ===
-with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as demo:
-    gr.Markdown("# 🧠 DeepSeek Hexa-Agent Discussion System")
-    gr.Markdown("### AI-Powered Complex Discourse Analysis")
-    
-    # Status panel
-    with gr.Row():
-        turn_counter = gr.Number(label="Turn Count", value=0, interactive=False)
-        topic_display = gr.Textbox(label="Current Topic", interactive=False, lines=2)
-        agent_status = gr.Textbox(label="Active Agents", value="💡 Initiator, 🔍 Responder", interactive=False)
-    
-    # Tabbed interface
-    with gr.Tab("Live Discussion"):
-        convo_display = gr.HTML(
-            value="<div class='convo-container'>Discussion will appear here</div>", 
-            elem_id="convo-display"
-        )
-        
-        with gr.Row():
-            step_btn = gr.Button("▶️ Next Turn", variant="primary")
-            auto_btn = gr.Button("🔴 Auto: OFF", variant="secondary")
-            clear_btn = gr.Button("🔄 New Discussion", variant="stop")
-            topic_btn = gr.Button("🎲 Random Topic", variant="secondary")
-            ruling_btn = gr.Button("⚖️ Request Ruling", variant="primary")
-        
-        # ADDED: Guide the Discussion section in Live Discussion tab
-        with gr.Accordion("💬 Guide the Discussion", open=False):
-            topic_input = gr.Textbox(label="Set Custom Topic", placeholder="e.g., Ethics of AGI in cultural contexts...")
-            with gr.Row():
-                qbox = gr.Textbox(label="Ask the Depth Guardian", placeholder="What perspectives are missing?")
-                ruling_qbox = gr.Textbox(label="Specific Question for Judge", placeholder="What should be our guiding principle?")
-            with gr.Row():
-                overseer_out = gr.Textbox(label="Depth Guardian Response", interactive=False)
-                judge_out = gr.Textbox(label="Judge's Response", interactive=False)
-    
-    with gr.Tab("Agent Perspectives"):
-        with gr.Row():
-            with gr.Column(scale=1):
-                gr.Markdown("### ⚖️ Depth Guardian")
-                intervention_display = gr.Textbox(label="", interactive=False)
-            with gr.Column(scale=1):
-                gr.Markdown("### 🌐 Cross-Disciplinary")
-                outsider_display = gr.Textbox(label="", interactive=False)
-            with gr.Column(scale=1):
-                gr.Markdown("### 🌍 Cultural Lens")
-                cultural_display = gr.Textbox(label="", interactive=False)
-        
-        with gr.Row():
-            with gr.Column(scale=3):
-                gr.Markdown("### ⚖️ Final Judgment")
-                judge_display = gr.Textbox(label="", interactive=False, lines=4)
-    
-    with gr.Tab("Analysis Dashboard"):
-        gr.Markdown("### Conversation Insights")
-        with gr.Row():
-            sentiment_display = gr.Textbox(label="Discussion Sentiment", interactive=False)
-            topics_display = gr.JSON(label="Key Topics")
-        
-        with gr.Row():
-            agent_plot = gr.Plot(label="Agent Participation")
-            analysis_btn = gr.Button("Generate Insights", variant="primary")
-        
-        with gr.Row():
-            gr.Markdown("### Knowledge Graph")
-            graph_btn = gr.Button("Generate Knowledge Graph", variant="secondary")
-            graph_display = gr.Image(label="Concept Relationships", interactive=False)
-    
-    with gr.Tab("Collaboration"):
-        gr.Markdown("### Real-Time Collaboration")
-        with gr.Row():
-            user_input = gr.Textbox(label="Your Contribution", placeholder="Add your perspective...")
-            submit_btn = gr.Button("Add to Discussion")
-        
-        with gr.Row():
-            voting_btn = gr.Button("👍 Vote for Current Direction")
-            flag_btn = gr.Button("🚩 Flag Issue")
-        
-        with gr.Row():
-            user_feedback = gr.Textbox(label="Community Feedback", interactive=False)
-    
-    with gr.Tab("Export & Integrate"):
-        with gr.Row():
-            format_radio = gr.Radio(
-                ["PDF Report", "JSON Data", "Text Transcript"], 
-                label="Export Format",
-                value="PDF Report"
-            )
-            export_btn = gr.Button("Export Discussion", variant="primary")
-            export_result = gr.File(label="Download File")
-        
-        with gr.Row():
-            gr.Markdown("### API Integration")
-            webhook_url = gr.Textbox(label="Webhook URL", placeholder="https://your-platform.com/webhook")
-            integrate_btn = gr.Button("Connect to External Platform", variant="secondary")
-            integration_status = gr.Textbox(label="Status", interactive=False)
-    
-    with gr.Tab("Agent Configuration"):
-        gr.Markdown("### Customize Agent Behavior")
-        with gr.Row():
-            agent_sliders = {}
-            for agent in ["Initiator", "Responder", "Guardian", "Provocateur", "Cultural", "Judge"]:
-                with gr.Column():
-                    gr.Markdown(f"#### {agent}")
-                    agent_sliders[f"{agent}_creativity"] = gr.Slider(
-                        0.0, 1.0, value=0.7, 
-                        label="Creativity", interactive=True
-                    )
-                    agent_sliders[f"{agent}_critical"] = gr.Slider(
-                        0.0, 1.0, value=0.5, 
-                        label="Criticality", interactive=True
-                    )
-    
-    # Custom CSS
-    demo.css = """
-    .convo-container {
-        max-height: 400px;
-        overflow-y: auto;
-        padding: 15px;
-        border: 1px solid #e0e0e0;
-        border-radius: 8px;
-        background-color: #f9f9f9;
-        line-height: 1.6;
-    }
-    .convo-container p {
-        margin-bottom: 10px;
-    }
-    #topic-display {
-        font-weight: bold;
-        font-size: 1.1em;
-    }
-    """
+    def toggle_auto():
+        global auto_mode
+        auto_mode = not auto_mode
+        if auto_mode:
+            threading.Thread(target=auto_loop, daemon=True).start()
+        return "🔴 Auto: OFF" if not auto_mode else "🟢 Auto: ON"
     
-    # Event handlers
-    def clear_convo():
-        global conversation, turn_count, current_topic
-        conversation = []
-        turn_count = 0
-        current_topic = ""
-        return (
-            "<div class='convo-container'>New discussion started</div>", 
-            "", "", "", "", "", 0, "",
-            {"agents": [], "counts": []}, "", None, "", ""
-        )
+    def auto_loop():
+        global auto_mode
+        while auto_mode:
+            step()
+            time.sleep(6)
     
-    def new_topic():
-        clear_result = clear_convo()
-        topic = generate_topic()
-        return clear_result[:6] + (topic,) + clear_result[7:]
+    def update_agent_params(init_creat, init_crit, resp_creat, resp_crit, 
+                           guard_creat, guard_crit, prov_creat, prov_crit,
+                           cult_creat, cult_crit, judge_creat, judge_crit):
+        global agent_params
+        agent_params = {
+            "Initiator": {"creativity": init_creat, "criticality": init_crit},
+            "Responder": {"creativity": resp_creat, "criticality": resp_crit},
+            "Guardian": {"creativity": guard_creat, "criticality": guard_crit},
+            "Provocateur": {"creativity": prov_creat, "criticality": prov_crit},
+            "Cultural": {"creativity": cult_creat, "criticality": cult_crit},
+            "Judge": {"creativity": judge_creat, "criticality": judge_crit}
+        }
+        return "✅ Agent parameters updated!"
     
-    # Connect qbox and ruling_qbox submit handlers
+    # Connect UI components
     qbox.submit(
         overseer_respond, 
         inputs=qbox, 
@@ -959,7 +854,6 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
         outputs=judge_out
     )
     
-    # Connect other UI components
     step_btn.click(
         step, 
         inputs=[topic_input],
@@ -1031,21 +925,6 @@ with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as
         outputs=[user_feedback]
     )
     
-    # Connect agent parameter sliders
-    def update_agent_params(init_creat, init_crit, resp_creat, resp_crit, 
-                           guard_creat, guard_crit, prov_creat, prov_crit,
-                           cult_creat, cult_crit, judge_creat, judge_crit):
-        global agent_params
-        agent_params = {
-            "Initiator": {"creativity": init_creat, "criticality": init_crit},
-            "Responder": {"creativity": resp_creat, "criticality": resp_crit},
-            "Guardian": {"creativity": guard_creat, "criticality": guard_crit},
-            "Provocateur": {"creativity": prov_creat, "criticality": prov_crit},
-            "Cultural": {"creativity": cult_creat, "criticality": cult_crit},
-            "Judge": {"creativity": judge_creat, "criticality": judge_crit}
-        }
-        return "✅ Agent parameters updated!"
-    
     # Create input list for slider change events
     slider_inputs = [agent_sliders[f"{agent}_{param}"] 
                     for agent in ["Initiator", "Responder", "Guardian", "Provocateur", "Cultural", "Judge"]