Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py - Advanced Discussion Simulator with Quad-Agent System
+# app.py - Advanced Discussion Simulator with Hexa-Agent System
 import gradio as gr
 import openai
 import threading
@@ -44,7 +44,7 @@ except:
 # === AGENT SYSTEM PROMPTS ===
 AGENT_A_PROMPT = """You are the Discussion Initiator. Your role:
 1. Introduce complex topics requiring multidisciplinary perspectives
-2. Frame debates with nuanced questions exploring tensions between values
+2. Frame debates exploring tensions between values, ethics, and progress
 3. Challenge assumptions while maintaining intellectual humility
 4. Connect concepts across domains (science, ethics, policy, technology)
 5. Elevate discussions beyond surface-level analysis"""
@@ -72,11 +72,31 @@ OUTSIDER_PROMPT = """You are the Cross-Disciplinary Provocateur. Your role:
 5. Highlight overlooked connections and systemic relationships
 6. Question the framing of the discussion itself"""
 
+CULTURAL_LENS_PROMPT = """You are the Cultural Perspective. Your role:
+1. Provide viewpoints from diverse global cultures (Eastern, Western, Indigenous, African, etc.)
+2. Highlight how cultural values shape perspectives on the topic
+3. Identify cultural biases in arguments and assumptions
+4. Share traditions and practices relevant to the discussion
+5. Suggest culturally inclusive approaches to solutions
+6. Bridge cultural divides through nuanced understanding
+7. Consider post-colonial and decolonial perspectives"""
+
+JUDGE_PROMPT = """You are the Impartial Judge. Your role:
+1. Periodically review the discussion and provide balanced rulings
+2. Identify areas of agreement and unresolved tensions
+3. Evaluate the strength of arguments from different perspectives
+4. Highlight the most compelling insights and critical flaws
+5. Suggest pathways toward resolution or further inquiry
+6. Deliver rulings with clear justification and constructive guidance
+7. Maintain objectivity while acknowledging valid points from all sides
+8. Consider ethical implications and practical feasibility"""
+
 # === GLOBAL STATE ===
 conversation = []
 turn_count = 0
 auto_mode = False
 current_topic = ""
+last_ruling_turn = 0
 
 # === CHAT COMPLETION ===
 def chat_completion(system, messages, model=CHAT_MODEL):
@@ -172,12 +192,48 @@ def detect_repetition():
     similarity = cosine_similarity(embeddings[-1], embeddings[-3])
     return similarity > 0.82
 
+def detect_cultural_relevance():
+    """Check if cultural perspectives are needed"""
+    if len(conversation) < 2:
+        return False
+        
+    last_texts = " ".join([m['text'] for m in conversation[-2:]])
+    cultural_triggers = [
+        "society", "culture", "values", "tradition",
+        "global", "western", "eastern", "indigenous",
+        "community", "norms", "beliefs", "diversity",
+        "equity", "identity", "heritage", "colonial"
+    ]
+    
+    for trigger in cultural_triggers:
+        if trigger in last_texts.lower():
+            return True
+    return False
+
+def detect_judgment_opportunity():
+    """Identify when the discussion is ripe for judgment"""
+    if len(conversation) < 8:
+        return False
+        
+    # Check for unresolved tensions
+    last_texts = " ".join([m['text'] for m in conversation[-4:]])
+    judgment_triggers = [
+        "tension", "dilemma", "paradox", "conflict",
+        "disagreement", "opposing views", "unresolved",
+        "contradiction", "impasse", "standoff"
+    ]
+    
+    for trigger in judgment_triggers:
+        if trigger in last_texts.lower():
+            return True
+    return False
+
 # === AGENT FUNCTIONS ===
 def generate_topic():
     """Generate a complex discussion topic"""
     topic = chat_completion(
-        "Generate a complex discussion topic requiring multidisciplinary analysis",
-        [{"role": "user", "content": "Create a topic addressing tensions between technological progress and human values"}]
+        "Generate a complex discussion topic requiring multidisciplinary and multicultural analysis",
+        [{"role": "user", "content": "Create a topic addressing tensions between technological progress, ethics, and cultural values"}]
     )
     return topic.split(":")[-1].strip() if ":" in topic else topic
 
@@ -187,9 +243,41 @@ def outsider_comment():
     prompt = f"Conversation Context:\n{context}\n\nProvide your cross-disciplinary perspective:"
     return chat_completion(OUTSIDER_PROMPT, [{"role": "user", "content": prompt}])
 
+def cultural_perspective():
+    """Generate cultural diversity perspective"""
+    context = "\n".join([f"{m['agent']}: {m['text']}" for m in conversation[-4:]])
+    prompt = f"Conversation Context:\n{context}\n\nProvide diverse cultural perspectives on this topic:"
+    return chat_completion(CULTURAL_LENS_PROMPT, [{"role": "user", "content": prompt}])
+
+def judge_ruling():
+    """Generate final judgment or ruling"""
+    global last_ruling_turn
+    
+    # Create comprehensive context
+    context = "\n\n".join([
+        f"Discussion Topic: {current_topic}",
+        "Key Arguments:",
+        *[f"- {m['agent']}: {m['text']}" for m in conversation[-8:]]
+    ])
+    
+    prompt = f"""After reviewing this discussion, provide your impartial judgment:
+{context}
+
+Your ruling should:
+1. Identify areas of agreement and unresolved tensions
+2. Evaluate the strength of key arguments
+3. Highlight the most compelling insights
+4. Suggest pathways toward resolution
+5. Consider ethical and practical implications
+6. Provide constructive guidance for next steps"""
+    
+    ruling = chat_completion(JUDGE_PROMPT, [{"role": "user", "content": prompt}])
+    last_ruling_turn = turn_count
+    return ruling
+
 # === CORE CONVERSATION FLOW ===
 def step(topic_input=""):
-    global conversation, turn_count, current_topic
+    global conversation, turn_count, current_topic, last_ruling_turn
     
     # Initialize new discussion
     if not conversation:  
@@ -201,7 +289,8 @@ def step(topic_input=""):
         conversation.append({"agent": "💡 Initiator", "text": msg})
         embed_and_store(msg, "Initiator")
         turn_count = 1
-        return format_convo(), "", "", current_topic
+        last_ruling_turn = 0
+        return format_convo(), "", "", "", "", current_topic
     
     # Critical Responder engages
     last_msg = conversation[-1]['text']
@@ -236,8 +325,24 @@ def step(topic_input=""):
         conversation.append({"agent": "🌐 Provocateur", "text": outsider_msg})
         embed_and_store(outsider_msg, "Outsider")
     
+    # Cultural perspective
+    cultural_msg = ""
+    if turn_count % 5 == 0 or detect_cultural_relevance():
+        cultural_msg = cultural_perspective()
+        conversation.append({"agent": "🌍 Cultural Lens", "text": cultural_msg})
+        embed_and_store(cultural_msg, "Cultural")
+    
+    # Judge ruling
+    judge_msg = ""
+    ruling_interval = 6  # Turns between rulings
+    if (turn_count - last_ruling_turn >= ruling_interval and 
+        (turn_count % ruling_interval == 0 or detect_judgment_opportunity())):
+        judge_msg = judge_ruling()
+        conversation.append({"agent": "⚖️ Judge", "text": judge_msg})
+        embed_and_store(judge_msg, "Judge")
+    
     turn_count += 1
-    return format_convo(), intervention, outsider_msg, current_topic
+    return format_convo(), intervention, outsider_msg, cultural_msg, judge_msg, current_topic
 
 # === OVERSEER QUERY HANDLER ===
 def overseer_respond(query):
@@ -248,6 +353,16 @@ def overseer_respond(query):
     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)}]"
+
 # === AUTO MODE HANDLER ===
 def auto_loop():
     global auto_mode
@@ -265,32 +380,60 @@ def toggle_auto():
 # === GRADIO UI ===
 with gr.Blocks(title="Advanced Discussion Simulator") as demo:
     gr.Markdown("# 🧠 Advanced Discussion Simulator")
-    gr.Markdown("### Quad-Agent System for Complex Discourse")
+    gr.Markdown("### Hexa-Agent System for Complex Discourse")
     
     with gr.Row():
         topic_display = gr.Textbox(label="Current Topic", interactive=False)
     
     with gr.Row():
-        convo_display = gr.Markdown(value="**Discussion will appear here**")
+        convo_display = gr.Markdown(
+            value="**Discussion will appear here**", 
+            elem_id="convo-display",
+            elem_classes="convo-scroll"
+        )
         
     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")
     
     with gr.Row():
         with gr.Column(scale=1):
             gr.Markdown("### ⚖️ Depth Guardian")
-            intervention_display = gr.Textbox(label="Intervention", interactive=False)
+            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("### 🌐 Cross-Disciplinary View")
-            outsider_display = gr.Textbox(label="Provocation", interactive=False)
+            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.Accordion("💬 Guide the Discussion", open=False):
-        topic_input = gr.Textbox(label="Set Custom Topic", placeholder="e.g., Ethics of generative AI in creative industries...")
-        qbox = gr.Textbox(label="Ask the Depth Guardian", placeholder="What perspectives are missing in this discussion?")
-        overseer_out = gr.Textbox(label="Response", interactive=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)
+    
+    # Custom CSS for scrollable conversation
+    demo.css = """
+    .convo-scroll {
+        max-height: 400px;
+        overflow-y: auto;
+        padding: 10px;
+        border: 1px solid #e0e0e0;
+        border-radius: 5px;
+    }
+    """
     
     # Event handlers
     def clear_convo():
@@ -298,27 +441,40 @@ with gr.Blocks(title="Advanced Discussion Simulator") as demo:
         conversation = []
         turn_count = 0
         current_topic = ""
-        return "**New discussion started**", "", "", "", ""
+        return "**New discussion started**", "", "", "", "", "", ""
     
     def new_topic():
         clear_convo()
         topic = generate_topic()
-        return "", "", "", topic, topic
+        return "", "", "", "", "", topic, topic
+    
+    def ask_judge(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\nSpecific Question: {query}"}]
+            return chat_completion(JUDGE_PROMPT, messages)
+        except Exception as e:
+            return f"[Judge Error: {str(e)}]"
     
     step_btn.click(
         step, 
         inputs=[topic_input],
-        outputs=[convo_display, intervention_display, outsider_display, topic_display]
+        outputs=[convo_display, intervention_display, outsider_display, cultural_display, judge_display, topic_display]
     )
     qbox.submit(overseer_respond, inputs=qbox, outputs=overseer_out)
+    ruling_qbox.submit(ask_judge, inputs=ruling_qbox, outputs=judge_out)
     auto_btn.click(toggle_auto, outputs=auto_btn)
     clear_btn.click(
         clear_convo, 
-        outputs=[convo_display, intervention_display, outsider_display, topic_display, overseer_out]
+        outputs=[convo_display, intervention_display, outsider_display, cultural_display, judge_display, topic_display, overseer_out]
     )
     topic_btn.click(
         new_topic,
-        outputs=[convo_display, intervention_display, outsider_display, topic_display, overseer_out]
+        outputs=[convo_display, intervention_display, outsider_display, cultural_display, judge_display, topic_display, overseer_out]
+    )
+    ruling_btn.click(
+        request_ruling,
+        outputs=[judge_display]
     )
 
 demo.launch()