Create app.py

app.py

@@ -0,0 +1,347 @@
+# app.py - DeepSeek Hexa-Agent Discussion Platform (Free Version)
+import gradio as gr
+import requests
+import threading
+import time
+import numpy as np
+import faiss
+import os
+import pickle
+from datetime import datetime
+import re
+import json
+import matplotlib.pyplot as plt
+import networkx as nx
+from reportlab.lib.pagesizes import letter
+from reportlab.platypus import SimpleDocTemplate, Paragraph, Spacer
+from reportlab.lib.styles import getSampleStyleSheet
+from functools import lru_cache
+from sentence_transformers import SentenceTransformer
+
+# === CONFIG ===
+EMBEDDING_MODEL = "all-MiniLM-L6-v2"  # Local embedding model
+CHAT_MODEL = "HuggingFaceH4/zephyr-7b-beta"  # Free model via Hugging Face API
+MEMORY_FILE = "memory.pkl"
+INDEX_FILE = "memory.index"
+HF_API_TOKEN = os.environ.get("HF_API_TOKEN", "")  # Optional for higher rate limits
+
+# Initialize local embedding model
+embedding_model = SentenceTransformer(EMBEDDING_MODEL)
+
+# === EMBEDDING UTILS ===
+@lru_cache(maxsize=500)
+def get_embedding(text):
+    """Local embedding function"""
+    return embedding_model.encode(text)
+
+def cosine_similarity(vec1, vec2):
+    vec1 = np.array(vec1)
+    vec2 = np.array(vec2)
+    return np.dot(vec1, vec2) / (np.linalg.norm(vec1) * np.linalg.norm(vec2))
+
+# === MEMORY INITIALIZATION ===
+memory_data = []
+try:
+    memory_index = faiss.read_index(INDEX_FILE)
+    with open(MEMORY_FILE, "rb") as f:
+        memory_data = pickle.load(f)
+except:
+    memory_index = faiss.IndexFlatL2(384)  # 384 dimensions for MiniLM
+
+# === AGENT SYSTEM PROMPTS ===
+AGENT_A_PROMPT = """You are the Discussion Initiator. Your role:
+1. Introduce complex topics requiring multidisciplinary perspectives
+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"""
+
+AGENT_B_PROMPT = """You are the Critical Responder. Your role:
+1. Provide counterpoints with evidence-based reasoning
+2. Identify logical fallacies and cognitive biases in arguments
+3. Analyze implications at different scales (individual, societal, global)
+4. Consider second and third-order consequences
+5. Balance idealism with practical constraints"""
+
+OVERSEER_PROMPT = """You are the Depth Guardian. Your role:
+1. Ensure discussions maintain intellectual rigor
+2. Intervene when conversations become superficial or repetitive
+3. Highlight unexamined assumptions and blind spots
+4. Introduce relevant frameworks (systems thinking, ethical paradigms)
+5. Prompt consideration of marginalized perspectives
+6. Synthesize key tensions and paradoxes"""
+
+OUTSIDER_PROMPT = """You are the Cross-Disciplinary Provocateur. Your role:
+1. Introduce radical perspectives from unrelated fields
+2. Challenge conventional wisdom with contrarian viewpoints
+3. Surface historical precedents and analogies
+4. Propose unconventional solutions to complex problems
+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
+agent_params = {
+    "Initiator": {"creativity": 0.7, "criticality": 0.5},
+    "Responder": {"creativity": 0.5, "criticality": 0.8},
+    "Guardian": {"creativity": 0.6, "criticality": 0.9},
+    "Provocateur": {"creativity": 0.9, "criticality": 0.7},
+    "Cultural": {"creativity": 0.7, "criticality": 0.6},
+    "Judge": {"creativity": 0.4, "criticality": 0.9}
+}
+
+# === FREE CHAT COMPLETION API ===
+def safe_chat_completion(system, messages, temperature=0.7):
+    """Use free Hugging Face Inference API"""
+    try:
+        # Format messages for Hugging Face API
+        formatted = [{"role": "system", "content": system}]
+        formatted.extend(messages)
+        
+        # Prepare payload
+        payload = {
+            "inputs": formatted,
+            "parameters": {
+                "max_new_tokens": 300,
+                "temperature": temperature,
+                "return_full_text": False
+            }
+        }
+        
+        headers = {"Authorization": f"Bearer {HF_API_TOKEN}"} if HF_API_TOKEN else {}
+        
+        response = requests.post(
+            f"https://api-inference.huggingface.co/models/{CHAT_MODEL}",
+            json=payload,
+            headers=headers,
+            timeout=60
+        )
+        
+        if response.status_code == 200:
+            return response.json()[0]['generated_text'].strip()
+        elif response.status_code == 503:  # Model loading
+            time.sleep(15)
+            return safe_chat_completion(system, messages, temperature)
+        else:
+            return f"⚠️ API Error: {response.text}"
+            
+    except Exception as e:
+        return f"⚠️ System Error: {str(e)}"
+
+# === MEMORY MANAGEMENT ===
+def embed_and_store(text, agent=None):
+    try:
+        vec = get_embedding(text)
+        memory_index.add(np.array([vec], dtype='float32'))
+        memory_data.append({
+            "text": text,
+            "timestamp": datetime.now().isoformat(),
+            "agent": agent or "system",
+            "topic": current_topic
+        })
+        if len(memory_data) % 5 == 0:
+            with open(MEMORY_FILE, "wb") as f:
+                pickle.dump(memory_data, f)
+            faiss.write_index(memory_index, INDEX_FILE)
+    except Exception as e:
+        print(f"Memory Error: {str(e)}")
+
+def retrieve_relevant_memory(query, k=3):
+    """Retrieve relevant past discussions"""
+    try:
+        query_embedding = get_embedding(query)
+        distances, indices = memory_index.search(np.array([query_embedding], dtype='float32'), k)
+        
+        relevant = []
+        for i, idx in enumerate(indices[0]):
+            if idx < len(memory_data) and idx >= 0:
+                relevant.append({
+                    "text": memory_data[idx]['text'][:200] + "...",
+                    "topic": memory_data[idx].get('topic', 'Unknown'),
+                    "agent": memory_data[idx].get('agent', 'Unknown'),
+                    "similarity": 1 - distances[0][i]  # Convert distance to similarity
+                })
+        return relevant
+    except Exception as e:
+        print(f"Memory retrieval error: {str(e)}")
+        return []
+
+# ... [Rest of the functions remain the same as previous implementation] ...
+# Keep all the functions from the previous implementation except:
+# - safe_chat_completion (already replaced above)
+# - get_embedding (already replaced above)
+
+# === GRADIO UI ===
+with gr.Blocks(theme=gr.themes.Soft(), title="DeepSeek Discussion Platform") as demo:
+    gr.Markdown("# 🧠 Hexa-Agent Discussion System (Free Version)")
+    gr.Markdown("### Powered by Open-Source Models")
+    
+    # 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")
+        
+        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;
+    }
+    .free-model-notice {
+        background-color: #e6f7ff;
+        padding: 10px;
+        border-radius: 5px;
+        margin-bottom: 15px;
+        border-left: 4px solid #1890ff;
+    }
+    """
+    
+    # Free model notice
+    gr.Markdown("""
+    <div class="free-model-notice">
+        <b>Using Free Models:</b> This version uses open-source models from Hugging Face.
+        Responses may be slower and less refined than commercial APIs.
+        Consider using local GPU for better performance.
+    </div>
+    """)
+    
+    # ... [Keep all the event handlers from the previous implementation] ...
+    # The event handlers remain unchanged from the last working version
+
+demo.launch()