feat: Full multi-agent orchestration workflow with user-defined model selection (Gemma 4, Qwen 3 support)

backend/app/services/llm.py

@@ -139,62 +139,89 @@ def generate_mock_analysis(tender: Tender, company: CompanyProfile) -> AnalysisR
         audit_log=["Iniciando análisis de respaldo...", "Generando datos mock."]
     )
 
-def generate_analysis(tender: Tender, company: CompanyProfile, document_text: str | None = None) -> AnalysisResult:
-    # Build a prompt that emphasizes the collaboration
-    prompt = _build_analysis_prompt(tender, company, document_text)
-    
-    output = ""
-    audit_messages = []
-
-    # Strategy: Use Featherless (DeepSeek) for deep technical reasoning if available
-    if settings.featherless_api_key:
-        audit_messages.append("🧠 Multi-Model Consensus: DeepSeek-V3.2 (via Featherless) selected for Technical Reasoning.")
-        output = call_featherless(prompt, model="deepseek-ai/DeepSeek-V3.2")
-        if not output:
-             audit_messages.append("⚠️ Featherless failed, falling back to Gemini.")
-             
-    # Fallback or Primary if no Featherless
-    if not output:
-        if not settings.gemini_api_key:
-            analysis = generate_mock_analysis(tender, company)
-            analysis.audit_log = ["⚠️ Error: No LLM keys configured (Gemini/Featherless).", "Fallback: Using mock analysis."]
-            return analysis
+def generate_analysis(tender: Tender, company: CompanyProfile, document_text: str | None = None, models: dict | None = None) -> AnalysisResult:
+    # Default model mapping
+    model_map = {
+        "Gemini 2.5 Flash": "gemini",
+        "DeepSeek-V3.2 (Featherless)": "deepseek-ai/DeepSeek-V3.2",
+        "Qwen-3-32B (Featherless)": "Qwen/Qwen3-32B",
+        "Gemma-4-31B (Featherless)": "google/gemma-4-31B-it",
+        "Llama-3.1-8B (Featherless)": "meta-llama/Meta-Llama-3.1-8B-Instruct"
+    }
+
+    # Get selected models or defaults
+    chosen = models or {
+        "legal": "Gemini 2.5 Flash",
+        "tech": "DeepSeek-V3.2 (Featherless)",
+        "risk": "Qwen-3-32B (Featherless)"
+    }
+
+    audit_messages = ["🚀 Launching Multi-Agent Orchestration Pipeline."]
+    agent_outputs = {}
+
+    # Define Agent roles for separate calls
+    agent_definitions = {
+        "legal": "Experto Legal & Cumplimiento: Evalúa bases administrativas, multas y garantías.",
+        "tech": "Ingeniero Técnico: Evalúa arquitectura, stack tecnológico y capacidad de ejecución.",
+        "risk": "Estratega Comercial: Evalúa rentabilidad, competencia y riesgos de mercado."
+    }
+
+    for agent_id, role_desc in agent_definitions.items():
+        model_name = chosen.get(agent_id, "Gemini 2.5 Flash")
+        model_id = model_map.get(model_name, "gemini")
         
-        audit_messages.append("🧠 Using Gemini 2.5 Flash for unified agent analysis.")
-        try:
-            model = get_gemini_model()
-            response = model.generate_content(prompt)
-            output = response.text
-        except Exception as e:
-            audit_messages.append(f"❌ Gemini Error: {str(e)}")
-
-    if not output:
-        analysis = generate_mock_analysis(tender, company)
-        analysis.audit_log = audit_messages + ["Fallback: System default analysis."]
-        return analysis
-
-    parse_result = _parse_gemini_response(output)
+        audit_messages.append(f"🤖 Agent {agent_id.upper()} calling {model_name}...")
+        
+        agent_prompt = f"""
+        Actúa como {role_desc}
+        Licitación: {tender.name} ({tender.code})
+        Empresa: {company.name}
+        Contexto Adicional: {document_text[:5000] if document_text else 'No adjunto.'}
+        
+        PROPORCIONA TU ANÁLISIS ESPECÍFICO (Máx 200 palabras) EN ESPAÑOL.
+        """
+        
+        if model_id == "gemini":
+            agent_outputs[agent_id] = call_gemini(agent_prompt)
+        else:
+            agent_outputs[agent_id] = call_featherless(agent_prompt, model=model_id)
+
+    # FINAL CONSENSUS AGENT (Synthesis)
+    audit_messages.append("⚖️ Final Consensus Agent synthesizing results...")
+    synthesis_prompt = f"""
+    Eres el AGENTE DE CONSENSO. Debes unificar estos 3 análisis en un único JSON de 'AnalysisResult':
+    
+    1. LEGAL: {agent_outputs.get('legal')}
+    2. TECH: {agent_outputs.get('tech')}
+    3. RISK: {agent_outputs.get('risk')}
+    
+    Genera el JSON final siguiendo estas reglas:
+    - executive_summary: Resumen integrador en español.
+    - fit_score: Promedio de encaje (0-100).
+    - decision: 'Recommended', 'Review Carefully' o 'Not Recommended'.
+    - risks, key_requirements, compliance_gaps, action_plan.
+    - audit_log: Incluye los pasos tomados.
+    
+    RESPONDE SOLO EL JSON.
+    """
+    
+    final_json = call_gemini(synthesis_prompt)
+    parse_result = _parse_gemini_response(final_json)
     
     if parse_result:
         try:
-            if not parse_result.get("proposal_draft") or len(parse_result["proposal_draft"]) < 50:
+            if not parse_result.get("proposal_draft"):
                 parse_result["proposal_draft"] = generate_proposal_draft(parse_result, company)
             
-            if not parse_result.get("report_markdown"):
-                parse_result["report_markdown"] = generate_markdown_report(parse_result)
-            
             result = AnalysisResult(**parse_result)
-            # Add our multimodal logs
             result.audit_log = audit_messages + (result.audit_log or [])
             return result
         except Exception as e:
-            print(f"Error mapping to AnalysisResult: {e}")
-            error_msg = f"🔍 Data Mapping Error: {str(e)[:50]}..."
-    else:
-        error_msg = "🧩 Format Error: Response was not valid JSON."
-    
+            print(f"Synthesis Mapping Error: {e}")
+
+    # Final Fallback
     analysis = generate_mock_analysis(tender, company)
-    analysis.audit_log = audit_messages + [error_msg, "Fallback: Reverting to system default."]
+    analysis.audit_log = audit_messages + ["⚠️ Synthesis failed, using emergency fallback."]
     return analysis
 
 def generate_proposal_draft(analysis: dict, company: CompanyProfile) -> str:

frontend/app/page.tsx

@@ -128,9 +128,9 @@ export default function HomePage() {
     }
   };
 
-  const handleRunAnalysis = async (documentText?: string) => {
+  const handleRunAnalysis = async (documentText?: string, models?: Record<string, string>) => {
     if (!selectedTender) return;
-    const result = await analyzeTender(selectedTender, companyProfile, documentText);
+    const result = await analyzeTender(selectedTender, companyProfile, documentText, models);
     setAnalysisResult(result);
 
     try {

frontend/components/AgentAnalysis.tsx

@@ -8,7 +8,7 @@ type Props = {
   tender: Tender | null;
   companyProfile: CompanyProfile;
   analysis: AnalysisResult | null;
-  onAnalyze: (documentText?: string) => Promise<void>;
+  onAnalyze: (documentText?: string, models?: Record<string, string>) => Promise<void>;
 };
 
 const agents = [
@@ -23,6 +23,13 @@ export default function AgentAnalysis({ tender, companyProfile, analysis, onAnal
   const [file, setFile] = useState<File | null>(null);
   const [isUploading, setIsUploading] = useState(false);
   const [documentText, setDocumentText] = useState<string | "">("");
+  const [agentModels, setAgentModels] = useState({
+    legal: "Gemini 2.5 Flash",
+    tech: "DeepSeek-V3.2 (Featherless)",
+    risk: "Qwen-2.5 (Featherless)"
+  });
+  const [activeSettings, setActiveSettings] = useState<string | null>(null);
+
 
   const handleFileChange = (event: React.ChangeEvent<HTMLInputElement>) => {
     if (event.target.files && event.target.files[0]) {
@@ -42,7 +49,7 @@ export default function AgentAnalysis({ tender, companyProfile, analysis, onAnal
         extractedText = uploadResult.text;
         setDocumentText(extractedText);
       }
-      await onAnalyze(extractedText);
+      await onAnalyze(extractedText, agentModels);
     } catch (error) {
       console.error("Error during analysis flow:", error);
     } finally {
@@ -151,16 +158,55 @@ export default function AgentAnalysis({ tender, companyProfile, analysis, onAnal
         </div>
       </div>
 
-      {/* Agents Row (Visual feedback) */}
+      {/* Agents Row (Visual feedback & Configuration) */}
       <div className="grid gap-6 md:grid-cols-3">
         {agents.map((agent) => (
-          <div key={agent.id} className={`glass-card rounded-3xl p-6 flex items-center gap-4 transition-all duration-700 ${isRunning ? 'ring-2 ring-purple-500/50 animate-pulse' : ''} ${analysis ? 'border-purple-500/30' : 'border-white/5'}`}>
-             <div className={`text-4xl ${isRunning ? 'animate-bounce' : ''}`}>{agent.avatar}</div>
-             <div>
-                <div className={`text-[10px] font-bold uppercase tracking-widest ${agent.color}`}>{agent.role}</div>
-                <div className="text-sm font-bold text-white">{agent.name}</div>
-                {analysis && <div className="text-[9px] text-green-400 font-bold mt-1 uppercase tracking-tighter tracking-widest">Analysis Ready ✓</div>}
-             </div>
+          <div key={agent.id} className="relative group">
+            <div className={`glass-card rounded-3xl p-6 flex items-center gap-4 transition-all duration-700 ${isRunning ? 'ring-2 ring-purple-500/50 animate-pulse' : ''} ${analysis ? 'border-purple-500/30' : 'border-white/5'} hover:border-purple-500/20`}>
+               <div className={`text-4xl ${isRunning ? 'animate-bounce' : ''}`}>{agent.avatar}</div>
+               <div className="flex-1">
+                  <div className={`text-[10px] font-bold uppercase tracking-widest ${agent.color}`}>{agent.role}</div>
+                  <div className="text-sm font-bold text-white">{agent.name}</div>
+                  <div className="text-[9px] text-slate-500 font-mono mt-1 flex items-center gap-1">
+                    <span className="w-1 h-1 rounded-full bg-slate-500" />
+                    {agentModels[agent.id as keyof typeof agentModels]}
+                  </div>
+               </div>
+               <button 
+                 onClick={() => setActiveSettings(activeSettings === agent.id ? null : agent.id)}
+                 className="p-2 rounded-xl bg-white/5 text-slate-500 hover:bg-white/10 hover:text-white transition-all active:scale-90"
+               >
+                 ⚙️
+               </button>
+            </div>
+
+            {/* Model Selector Popover */}
+            {activeSettings === agent.id && (
+              <div className="absolute top-full left-0 right-0 mt-2 z-50 glass-card rounded-2xl p-4 border border-purple-500/30 shadow-2xl animate-in fade-in zoom-in-95 duration-200">
+                <p className="text-[9px] font-black uppercase text-purple-400 mb-3 tracking-widest px-1">Select Engine</p>
+                <div className="space-y-1">
+                  {[
+                    "Gemini 2.5 Flash", 
+                    "DeepSeek-V3.2 (Featherless)", 
+                    "Qwen-3-32B (Featherless)", 
+                    "Gemma-4-31B (Featherless)",
+                    "Llama-3.1-8B (Featherless)"
+                  ].map(model => (
+                    <button
+                      key={model}
+                      onClick={() => {
+                        setAgentModels(prev => ({ ...prev, [agent.id]: model }));
+                        setActiveSettings(null);
+                      }}
+                      className={`w-full text-left px-3 py-2 rounded-xl text-xs transition-all flex items-center justify-between ${agentModels[agent.id as keyof typeof agentModels] === model ? 'bg-purple-500/20 text-white border border-purple-500/30' : 'text-slate-400 hover:bg-white/5 hover:text-slate-200'}`}
+                    >
+                      <span>{model}</span>
+                      {agentModels[agent.id as keyof typeof agentModels] === model && <span>✓</span>}
+                    </button>
+                  ))}
+                </div>
+              </div>
+            )}
           </div>
         ))}
       </div>