Upload app.py

app.py

@@ -0,0 +1,478 @@
+import gradio as gr
+import requests
+import json
+import os
+import time
+from configparser import ConfigParser
+from typing import List, Dict, Any
+
+MCP_SERVER_URL = "https://whodat55-hackathon-core-mcp.hf.space/execute"
+
+# HARDCODED PROVIDER MAPPING (Directive 1.1, 1.2, 1.3)
+PROVIDER_MODEL_MAPPING = {
+    "Google Gemini": [],
+    "Anthropic": [],
+    "OpenAI": [],
+    "Custom": []
+}
+
+def classify_model_by_provider(model_label: str) -> str:
+    """Classify a model label into a provider category using keyword matching"""
+    label_lower = model_label.lower()
+    
+    if 'gemini' in label_lower:
+        return "Google Gemini"
+    elif 'claude' in label_lower or 'anthropic' in label_lower:
+        return "Anthropic"
+    elif 'gpt' in label_lower or 'openai' in label_lower:
+        return "OpenAI"
+    else:
+        return "Custom"
+
+def load_client_config():
+    config = {}
+    coder_models = {}
+    strategist_models = {}
+    
+    if os.path.exists('config.ini'):
+        parser = ConfigParser()
+        parser.read('config.ini')
+        try:
+            if 'CODER_MODELS' in parser:
+                for label, entry in parser['CODER_MODELS'].items():
+                    coder_models[label] = label
+            if 'STRATEGIST_MODELS' in parser:
+                for label, entry in parser['STRATEGIST_MODELS'].items():
+                    strategist_models[label] = label
+        except Exception as e:
+            print(f"Config parsing warning: {e}")
+
+    # Build provider-grouped structure
+    coder_by_provider = {p: [] for p in PROVIDER_MODEL_MAPPING.keys()}
+    strategist_by_provider = {p: [] for p in PROVIDER_MODEL_MAPPING.keys()}
+    
+    for label in coder_models.keys():
+        provider = classify_model_by_provider(label)
+        coder_by_provider[provider].append(label)
+    
+    for label in strategist_models.keys():
+        provider = classify_model_by_provider(label)
+        strategist_by_provider[provider].append(label)
+    
+    config['coder_by_provider'] = coder_by_provider
+    config['strategist_by_provider'] = strategist_by_provider
+    config['coder_models'] = list(coder_models.keys())
+    config['strategist_models'] = list(strategist_models.keys())
+    config['coder_default'] = os.getenv('CODER_MODEL_DEFAULT_LABEL', '')
+    config['strategist_default'] = os.getenv('STRATEGIST_MODEL_DEFAULT_LABEL', '')
+    
+    return config
+
+CLIENT_CONFIG = load_client_config()
+
+def format_conversation_log(history: List[Dict[str, Any]]) -> str:
+    log_lines = []
+    for i, msg in enumerate(history):
+        role_label = msg.get('role', 'UNKNOWN').upper()
+        text_content = ""
+        if 'parts' in msg and isinstance(msg['parts'], list):
+            text_content = msg['parts'][0].get('text', '')
+
+        log_lines.append(f"{'='*80}")
+        log_lines.append(f"[{i}] {role_label}")
+        log_lines.append(f"{'='*80}")
+        log_lines.append(text_content)
+        log_lines.append("")
+    return "\n".join(log_lines)
+
+def build_master_log(system_log_list, coder_log_list, strategist_log_list, audit_log_list, start_time):
+    actor_styles = {
+        'SYSTEM': {'icon': '🔧', 'color': '#ef4444'},
+        'CODER': {'icon': '💻', 'color': '#3b82f6'},
+        'STRATEGIST': {'icon': '🎯', 'color': '#a855f7'},
+        'TOOL': {'icon': '🛠️', 'color': '#f97316'}
+    }
+    
+    master_entries = []
+    seq_counter = 1
+    
+    for entry in system_log_list:
+        elapsed = time.time() - start_time
+        minutes = int(elapsed // 60)
+        seconds = int(elapsed % 60)
+        milliseconds = int((elapsed % 1) * 1000)
+        timestamp = f"{minutes:02d}:{seconds:02d}:{milliseconds:03d}"
+        
+        style = actor_styles['SYSTEM']
+        html_entry = f'<div style="margin-bottom: 8px; font-family: monospace;"><span style="color: {style["color"]}; font-weight: bold;">{style["icon"]} [SEQ-{seq_counter:02d}] [{timestamp}] SYSTEM:</span> {entry}</div>'
+        master_entries.append(html_entry)
+        seq_counter += 1
+    
+    for msg in coder_log_list:
+        elapsed = time.time() - start_time
+        minutes = int(elapsed // 60)
+        seconds = int(elapsed % 60)
+        milliseconds = int((elapsed % 1) * 1000)
+        timestamp = f"{minutes:02d}:{seconds:02d}:{milliseconds:03d}"
+        
+        role = msg.get('role', 'UNKNOWN').upper()
+        actor = f"CODER ({role})"
+        
+        text_content = ""
+        if 'parts' in msg and isinstance(msg['parts'], list):
+            text_content = msg['parts'][0].get('text', '')
+        
+        style = actor_styles['CODER']
+        html_entry = f'<div style="margin-bottom: 8px; font-family: monospace;"><span style="color: {style["color"]}; font-weight: bold;">{style["icon"]} [SEQ-{seq_counter:02d}] [{timestamp}] {actor}:</span> {text_content}</div>'
+        master_entries.append(html_entry)
+        seq_counter += 1
+    
+    for msg in strategist_log_list:
+        elapsed = time.time() - start_time
+        minutes = int(elapsed // 60)
+        seconds = int(elapsed % 60)
+        milliseconds = int((elapsed % 1) * 1000)
+        timestamp = f"{minutes:02d}:{seconds:02d}:{milliseconds:03d}"
+        
+        role = msg.get('role', 'UNKNOWN').upper()
+        actor = f"STRATEGIST ({role})"
+        
+        text_content = ""
+        if 'parts' in msg and isinstance(msg['parts'], list):
+            text_content = msg['parts'][0].get('text', '')
+        
+        style = actor_styles['STRATEGIST']
+        html_entry = f'<div style="margin-bottom: 8px; font-family: monospace;"><span style="color: {style["color"]}; font-weight: bold;">{style["icon"]} [SEQ-{seq_counter:02d}] [{timestamp}] {actor}:</span> {text_content}</div>'
+        master_entries.append(html_entry)
+        seq_counter += 1
+    
+    for diagnostic in audit_log_list:
+        elapsed = time.time() - start_time
+        minutes = int(elapsed // 60)
+        seconds = int(elapsed % 60)
+        milliseconds = int((elapsed % 1) * 1000)
+        timestamp = f"{minutes:02d}:{seconds:02d}:{milliseconds:03d}"
+        
+        tool_name = diagnostic.get('tool', 'UNKNOWN')
+        status = diagnostic.get('status', 'UNKNOWN')
+        latency = diagnostic.get('latency', 'N/A')
+        transaction_id = diagnostic.get('transaction_id', 'N/A')
+        
+        request_str = json.dumps(diagnostic.get('request'), indent=2)
+        response_str = json.dumps(diagnostic.get('response'), indent=2) if diagnostic.get('response') else "None"
+        
+        tool_entry = f"TOOL: {tool_name} | TRANSACTION: {transaction_id} | STATUS: {status} | LATENCY: {latency}s<br>[REQUEST]<br><pre>{request_str}</pre><br>[RESPONSE]<br><pre>{response_str}</pre>"
+        
+        style = actor_styles['TOOL']
+        html_entry = f'<div style="margin-bottom: 8px; font-family: monospace;"><span style="color: {style["color"]}; font-weight: bold;">{style["icon"]} [SEQ-{seq_counter:02d}] [{timestamp}] TOOL:</span> {tool_entry}</div>'
+        master_entries.append(html_entry)
+        seq_counter += 1
+    
+    if not master_entries:
+        return '<div style="font-family: monospace; color: #6b7280;">No log data captured.</div>'
+    
+    html_output = f'''
+    <div style="background-color: #1e1e1e; padding: 16px; border-radius: 8px; max-height: 600px; overflow-y: auto; color: #e0e0e0;">
+        {"".join(master_entries)}
+    </div>
+    '''
+    
+    return html_output
+
+def execute_remote_workflow(blueprint, intent, coder_model_label, strategist_model_label):
+    """Streaming workflow execution with real-time log updates"""
+    mission_start_time = time.time()
+    
+    payload = {
+        "blueprint": blueprint,
+        "intent": intent,
+        "coder_model_label": coder_model_label,
+        "strategist_model_label": strategist_model_label
+    }
+
+    try:
+        target_url = MCP_SERVER_URL.replace("/execute", "/execute_stream")
+        print(f"DEBUG: Connecting to streaming endpoint: {target_url}")
+        
+        with requests.post(target_url, json=payload, stream=True, timeout=300) as response:
+            if response.status_code == 404:
+                yield f"ERROR 404: Streaming endpoint not found at {target_url}. Check server version.", "", "", ""
+                return
+            
+            response.raise_for_status()
+            
+            for line in response.iter_lines():
+                if not line:
+                    continue
+                
+                decoded = line.decode('utf-8')
+                if not decoded.startswith('data: '):
+                    continue
+                
+                data_str = decoded[6:]
+                
+                try:
+                    data = json.loads(data_str)
+                except json.JSONDecodeError:
+                    continue
+                
+                if data.get("status") == "complete":
+                    break
+                
+                system_log_list = data.get("system_log", [])
+                coder_log_list = data.get("coder_log", [])
+                strategist_log_list = data.get("strategist_log", [])
+                audit_log_list = data.get("audit_log", [])
+                
+                sys_log = "\n".join(system_log_list)
+                cod_log = format_conversation_log(coder_log_list)
+                strat_log = format_conversation_log(strategist_log_list)
+                master_log = build_master_log(system_log_list, coder_log_list, 
+                                               strategist_log_list, audit_log_list, 
+                                               mission_start_time)
+                
+                yield sys_log, cod_log, strat_log, master_log
+        
+    except requests.exceptions.RequestException as e:
+        error_detail = str(e)
+        if hasattr(e, 'response') and e.response is not None:
+            error_detail += f"\nServer Response: {e.response.text}"
+            
+        error_msg = f"CONNECTION ERROR: Could not connect to MCP Server.\nDetails: {error_detail}"
+        yield error_msg, "", "", ""
+    except Exception as e:
+        error_msg = f"CLIENT ERROR: {str(e)}"
+        yield error_msg, "", "", ""
+
+def create_interface():
+    DEMO_BLUEPRINT = """# Gradio Application Blueprint
+
+Produce a pro level styled and tuned them GUI that has 1 button that when pressed displays a celebration announcement "Happy Birthday MCP!". USE specified colors or themes appropriate for the event. You must incorporate specific colors for design pieces and thematic layouts providing a fun and exciting announcement."""
+    DEMO_INTENT = """A simple test button with a clean look. That when pressed creates a simple happy birthday MCP response on the screen. The gui should be gradio and contain colors that are used in professional builds and match the Gradio, MCP or other color theme or as close as possible."""
+
+    # Get initial defaults
+    coder_default = CLIENT_CONFIG['coder_default']
+    strategist_default = CLIENT_CONFIG['strategist_default']
+    
+    # Determine initial provider for each agent
+    initial_coder_provider = "Google Gemini"
+    initial_strategist_provider = "Google Gemini"
+    
+    if coder_default:
+        initial_coder_provider = classify_model_by_provider(coder_default)
+    
+    if strategist_default:
+        initial_strategist_provider = classify_model_by_provider(strategist_default)
+
+    def load_demo_data():
+        return DEMO_BLUEPRINT, DEMO_INTENT
+
+    def start_execution_sequence():
+        return gr.update(visible=False), gr.update(visible=True), gr.update(visible=False)
+
+    def end_execution_sequence(sys_log, cod_log, strat_log, master_log):
+        return sys_log, cod_log, strat_log, master_log, gr.update(visible=False), gr.update(visible=True)
+
+    def reset_to_default():
+        return gr.update(visible=True), gr.update(visible=False), gr.update(visible=False)
+    
+    # Cascading selector update functions
+    def update_coder_models(provider):
+        models = CLIENT_CONFIG['coder_by_provider'].get(provider, [])
+        if not models:
+            return gr.update(choices=[], value=None)
+        return gr.update(choices=models, value=models[0])
+    
+    def update_strategist_models(provider):
+        models = CLIENT_CONFIG['strategist_by_provider'].get(provider, [])
+        if not models:
+            return gr.update(choices=[], value=None)
+        return gr.update(choices=models, value=models[0])
+    
+    # RESET MISSION function (Directive 2.1)
+    def reset_mission():
+        """Total system reset: clear all fields and reset to defaults"""
+        # Determine initial models for reset
+        coder_models_for_reset = CLIENT_CONFIG['coder_by_provider'].get(initial_coder_provider, [])
+        strategist_models_for_reset = CLIENT_CONFIG['strategist_by_provider'].get(initial_strategist_provider, [])
+        
+        coder_reset_value = coder_models_for_reset[0] if coder_models_for_reset else None
+        strategist_reset_value = strategist_models_for_reset[0] if strategist_models_for_reset else None
+        
+        return (
+            "",  # blueprint_input
+            "",  # intent_input
+            "",  # system_terminal
+            "",  # coder_log
+            "",  # strategist_log
+            '<div style="font-family: monospace; color: #6b7280;">*Mission reset complete. All systems cleared.*</div>',  # master_log
+            gr.update(value=initial_coder_provider),  # coder_provider
+            gr.update(choices=coder_models_for_reset, value=coder_reset_value),  # coder_model
+            gr.update(value=initial_strategist_provider),  # strategist_provider
+            gr.update(choices=strategist_models_for_reset, value=strategist_reset_value)  # strategist_model
+        )
+
+    with gr.Blocks(title="Project: Conductor V4.0 Client") as interface:
+        gr.Markdown("# Project: Conductor V4.0 (Client Mode)")
+        gr.Markdown(f"### The Command Center: Connected to MCP Server at `{MCP_SERVER_URL}`")
+        
+        # PRIMARY INTERFACE ROW - Three Columns (Directive: Command Console Layout)
+        with gr.Row():
+            # COLUMN 1 - CODER (Left Flank)
+            with gr.Column():
+                gr.Markdown("### Coder Agent")
+                coder_provider = gr.Dropdown(
+                    choices=list(PROVIDER_MODEL_MAPPING.keys()),
+                    value=initial_coder_provider,
+                    label="Provider",
+                    interactive=True
+                )
+                coder_model = gr.Dropdown(
+                    choices=CLIENT_CONFIG['coder_by_provider'].get(initial_coder_provider, []),
+                    value=coder_default if coder_default else None,
+                    label="Model",
+                    interactive=True
+                )
+                blueprint_input = gr.Textbox(
+                    label="Architect's Blueprint",
+                    placeholder="Enter detailed technical specifications...",
+                    lines=8
+                )
+            
+            # COLUMN 2 - MEDIA BOX (Center Stage)
+            with gr.Column():
+                default_image = gr.Image(
+                    value="ai_creative_tech .png", 
+                    show_label=False, 
+                    visible=True, 
+                    interactive=False,
+                    type="filepath",
+                    height=450
+                )
+                working_video = gr.Video(
+                    value="ai_ct_working.mp4", 
+                    show_label=False, 
+                    visible=False, 
+                    autoplay=True, 
+                    loop=True,
+                    height=450
+                )
+                celebrate_video = gr.Video(
+                    value="ai_creative_tech_celebrate.mp4", 
+                    show_label=False, 
+                    visible=False, 
+                    autoplay=True, 
+                    loop=False,
+                    height=450
+                )
+            
+            # COLUMN 3 - STRATEGIST (Right Flank)
+            with gr.Column():
+                gr.Markdown("### Strategist Agent")
+                strategist_provider = gr.Dropdown(
+                    choices=list(PROVIDER_MODEL_MAPPING.keys()),
+                    value=initial_strategist_provider,
+                    label="Provider",
+                    interactive=True
+                )
+                strategist_model = gr.Dropdown(
+                    choices=CLIENT_CONFIG['strategist_by_provider'].get(initial_strategist_provider, []),
+                    value=strategist_default if strategist_default else None,
+                    label="Model",
+                    interactive=True
+                )
+                intent_input = gr.Textbox(
+                    label="Architect's Intent",
+                    placeholder="Enter project goals and context...",
+                    lines=8
+                )
+        
+        # ACTION ROW - Buttons
+        with gr.Row():
+            demo_btn = gr.Button("LOAD DEMO MODE", variant="secondary")
+            execute_btn = gr.Button("EXECUTE VIA MCP", variant="primary")
+            reset_btn = gr.Button("RESET MISSION", variant="secondary")
+        
+        # LOG ROWS
+        with gr.Row():
+            system_terminal = gr.Textbox(label="SYSTEM LOG", interactive=False, lines=15, max_lines=15)
+            coder_log = gr.Textbox(label="CODER LOG", interactive=False, lines=15, max_lines=15)
+            strategist_log = gr.Textbox(label="STRATEGIST LOG", interactive=False, lines=15, max_lines=15)
+        
+        with gr.Row():
+            master_log_output = gr.HTML(
+                value='<div style="font-family: monospace; color: #6b7280;">No mission log data available.</div>',
+                label="MASTER LOG WINDOW"
+            )
+        
+        # EVENT HANDLERS
+        
+        # Cascading model selector logic
+        coder_provider.change(
+            fn=update_coder_models,
+            inputs=[coder_provider],
+            outputs=[coder_model]
+        )
+        
+        strategist_provider.change(
+            fn=update_strategist_models,
+            inputs=[strategist_provider],
+            outputs=[strategist_model]
+        )
+        
+        # Demo button
+        demo_btn.click(
+            fn=load_demo_data,
+            inputs=None,
+            outputs=[blueprint_input, intent_input]
+        )
+        
+        # Execute button
+        execute_btn.click(
+            fn=start_execution_sequence,
+            inputs=None,
+            outputs=[default_image, working_video, celebrate_video]
+        ).then(
+            fn=execute_remote_workflow,
+            inputs=[blueprint_input, intent_input, coder_model, strategist_model],
+            outputs=[system_terminal, coder_log, strategist_log, master_log_output]
+        ).then(
+            fn=end_execution_sequence,
+            inputs=[system_terminal, coder_log, strategist_log, master_log_output],
+            outputs=[system_terminal, coder_log, strategist_log, master_log_output, working_video, celebrate_video]
+        )
+        
+        # Celebrate video auto-reset
+        celebrate_video.stop(
+            fn=reset_to_default,
+            inputs=None,
+            outputs=[default_image, working_video, celebrate_video]
+        )
+        
+        # RESET MISSION button (Directive 2.1)
+        reset_btn.click(
+            fn=reset_mission,
+            inputs=[],
+            outputs=[
+                blueprint_input,
+                intent_input,
+                system_terminal,
+                coder_log,
+                strategist_log,
+                master_log_output,
+                coder_provider,
+                coder_model,
+                strategist_provider,
+                strategist_model
+            ]
+        )
+        
+        gr.Markdown("---")
+        gr.Markdown("**Note:** This client requires the Conductor MCP Server V4.0 with streaming support. Logs now update in real-time with color-coded visual differentiation.")
+
+    return interface
+
+if __name__ == "__main__":
+    app = create_interface()
+    app.queue()
+    app.launch()