Update app.py

app.py

@@ -1,6 +1,7 @@
+
 # ╔════════════════════════════════════════════════════════════════════════════╗
-# ║ PIPELINE v30: AUTO-PLAN | MESMA UI v27 | COMPATÍVEL HF SPACES ║
-# ║ 1º: MODELO CRIA PLANO → ITERA PELO PRÓPRIO PLANO | SEM 'icon' ║
+# ║ PIPELINE v31: AUTO-PLAN ROBUSTO | DEBUG + FALLBACK | HF SPACES OK ║
+# ║ 1º: PLANEJADOR com ERROR HANDLING → ITERA PLANO → SAÍDA ║
 # ╚════════════════════════════════════════════════════════════════════════════╝
 
 import os
@@ -21,9 +22,9 @@ else:
     model_flash = model_pro = None
 
 ARQUIVO_CONFIG = "protocolo.json"
-ARQUIVO_HISTORY = "history_v30.json"
+ARQUIVO_HISTORY = "history_v31.json"
 
-# ==================== 2. UTILIDADES (IDÊNTICAS AO v27) ====================
+# ==================== 2. UTILIDADES (ROBUSTAS) ====================
 def carregar_protocolo():
     try:
         with open(ARQUIVO_CONFIG, "r", encoding="utf-8") as f: 
@@ -62,54 +63,77 @@ def ler_anexo(arquivo):
             return f"\n\n[ANEXO: {os.path.basename(arquivo.name)}]\n{f.read()}\n[FIM ANEXO]\n"
     except: return ""
 
-# ==================== 3. PLANEJADOR AUTO (1ª AÇÃO) ====================
+# ==================== 3. PLANEJADOR AUTO ROBUSTO (v31) ====================
 def criar_plano_auto(full_input, history_contexto):
-    """MODELO CRIA SEU PRÓPRIO PLANO dinamicamente"""
+    """PLANEJADOR com FALLBACK + DEBUG DETALHADO"""
     if not model_pro: 
         return None, "❌ Sem API_KEY"
     
-    history_resumo = "\n".join([
-        f"👤: {h[0][:150]}... | 🤖: {h[1][:150]}..." 
-        for h in history_contexto[-3:]
-    ][:300]) if history_contexto else ""
+    # PLANO DE FALLBACK (se erro)
+    plano_fallback = [
+        {"nome": "Analisador", "missao": "Analise o input principal e identifique elementos chave", "modelo": "flash", "tipo_saida": "json"},
+        {"nome": "RespostaFinal", "missao": "Baseado na análise anterior, produza resposta completa e clara", "modelo": "pro", "tipo_saida": "texto"}
+    ]
+    
+    history_resumo = ""
+    if history_contexto:
+        history_resumo = "\n".join([f"👤: {h[0][:100]}..." for h in history_contexto[-2:]])[:200]
     
-    prompt_planejador = f"""CONTEXTO HISTÓRICO:
-{history_resumo}
+    # PROMPT SIMPLIFICADO + ROBUSTO
+    prompt_planejador = f"""INPUT: {full_input[:500]}
 
-INPUT ATUAL: {full_input}
+CRIE PLANO JSON de 2-4 agentes:
 
-CRIE PLANO OTIMIZADO de 3-5 agentes:
+{{"nome": "Nome", "missao": "Missão curta", "modelo": "flash", "tipo_saida": "texto"}}
 
-FORMATO JSON VÁLIDO:
+APENAS JSON VÁLIDO:
+```
 [
-  {{"nome": "AnalisadorInput", "missao": "Identifique elementos principais", "modelo": "flash", "tipo_saida": "json"}},
-  {{"nome": "ExecutorFinal", "missao": "Produza resposta final completa", "modelo": "pro", "tipo_saida": "texto"}}
+  {{"nome": "Analisador", "missao": "Analise input", "modelo": "flash", "tipo_saida": "json"}},
+  {{"nome": "Final", "missao": "Resposta final", "modelo": "pro", "tipo_saida": "texto"}}
 ]
-
-✅ ÚLTIMO agente = saída FINAL pro usuário"""
+```"""
 
     try:
-        resp = model_pro.generate_content(prompt_planejador, temperature=0.2)
-        plano_raw = resp.text.strip().replace('``````','')
+        resp = model_pro.generate_content(prompt_planejador, temperature=0.1)
+        plano_raw = resp.text.strip()
+        
+        # DEBUG: Mostra raw response
+        print(f"DEBUG PLANO RAW: {plano_raw[:300]}...")
+        
+        # Limpa markdown agressivamente
+        plano_raw = re.sub(r'``````|```
+        plano_raw = re.sub(r'^.*?\[', '[', plano_raw)
+        plano_raw = re.sub(r'\].*?$', ']', plano_raw)
+        
+        print(f"DEBUG PLANO CLEAN: {plano_raw[:300]}...")
+        
         plano = json.loads(plano_raw)
         
         if isinstance(plano, list) and len(plano) >= 2:
+            print(f"✅ PLANO VÁLIDO: {len(plano)} agentes")
             return plano, f"✅ Plano: {len(plano)} agentes"
-        return None, "❌ Plano inválido"
-    except:
-        return None, "❌ Erro plano"
+        
+        print(f"❌ PLANO INVÁLIDO: {type(plano)}")
+        return plano_fallback, "⚠️ Plano corrigido (fallback)"
+        
+    except json.JSONDecodeError as e:
+        print(f"❌ JSON ERROR: {str(e)[:100]}")
+        print(f"RAW FALHOU: {plano_raw[:200]}")
+        return plano_fallback, f"⚠️ Fallback ativo (JSON: {str(e)[:50]})"
+    except Exception as e:
+        print(f"❌ GERAL ERROR: {str(e)}")
+        return plano_fallback, f"⚠️ Fallback (erro: {str(e)[:30]})"
 
-# ==================== 4. ENGINE EXECUÇÃO (ORIGINAL v27) ====================
+# ==================== 4. ENGINE EXECUÇÃO (ROBUSTO) ====================
 def executar_no(timeline, config):
     if not (model_flash or model_pro):
         return {"role": "system", "error": "Sem API"}, "(ERRO: API)", "Sem key"
     
     modelo = model_pro if config.get("modelo") == "pro" else model_flash
-    contexto = json.dumps(timeline[-10:], ensure_ascii=False, indent=2)
+    contexto = json.dumps(timeline[-8:], ensure_ascii=False, indent=2)
     
-    prompt = f"""--- TIMELINE ---
-{contexto}
-----------------
+    prompt = f"""TIMELINE: {contexto}
 AGENTE: {config['nome']}
 MISSÃO: {config['missao']}"""
 
@@ -117,19 +141,19 @@ MISSÃO: {config['missao']}"""
     try:
         inicio = time.time()
         resp = modelo.generate_content(prompt)
-        out = resp.text
+        out = resp.text.strip()
         
         tempo = time.time() - inicio
-        content = json.loads(out.strip().replace('``````','')) if config['tipo_saida']=='json' else out
+        content = json.loads(re.sub(r'```json|```
         
-        log += f" (OK - {tempo:.2f}s)"
+        log += f" ✓ {tempo:.1f}s"
         return {"role": "assistant", "agent": config['nome'], "content": content}, log, out
-    except Exception as e:
-        return {"role": "system", "error": str(e)}, f" (ERRO: {e})", str(e)
+    except:
+        log += " ✗ erro"
+        return {"role": "system", "error": "Falha execução"}, log, "Erro agente"
 
-# ==================== 5. ORQUESTRADOR v30 (PLANO AUTO) ====================
+# ==================== 5. ORQUESTRADOR v31 ====================
 def orquestrador(texto, arquivo, history, json_config):
-    # 1. Input Check (IDÊNTICO v27)
     anexo = ler_anexo(arquivo)
     full_input = f"{texto}\n{anexo}".strip()
     
@@ -137,47 +161,39 @@ def orquestrador(texto, arquivo, history, json_config):
         yield history, {}, "Sem input."
         return
     
-    # 2. Setup (IDÊNTICO v27)
     history = history + [[texto + (" 📎" if arquivo else ""), None]]
     timeline = [{"role": "user", "content": full_input}]
-    logs = f"🚀 AUTO-PLAN v30: {datetime.now().strftime('%H:%M:%S')}\n"
+    logs = f"🚀 v31 DEBUG: {datetime.now().strftime('%H:%M:%S')}\n"
     
-    history[-1][1] = "🎯 Criando plano dinâmico..."
+    history[-1] = "🔍 Criando plano..."[1]
     yield history, timeline, logs
     
-    # 3. 1ª AÇÃO: CRIA PLANO
+    # PLANEJADOR ROBUSTO
     plano, log_plano = criar_plano_auto(full_input, history)
-    if not plano:
-        history[-1][1] = log_plano
-        yield history, timeline, logs
-        return
-    
-    logs += f"{log_plano}\n"
-    timeline.append({"role": "system", "plano_auto": plano})
+    logs += f"PLANO: {log_plano}\n"
+    timeline.append({"role": "system", "plano": plano})
     
-    history[-1][1] = f"✅ Plano criado: {len(plano)} agentes"
+    history[-1] = f"✅ {log_plano}"[1]
     yield history, timeline, logs
     
-    # 4. ITERA PELO PLANO (IDÊNTICO v27)
-    final_response = ""
+    # EXECUTA PLANO
     for i, cfg in enumerate(plano):
-        history[-1][1] = f"⚙️ [{i+1}/{len(plano)}] {cfg['nome']}..."
+        history[-1] = f"[{i+1}/{len(plano)}] {cfg['nome']}..."[1]
         yield history, timeline, logs
         
         res, log_add, raw = executar_no(timeline, cfg)
         timeline.append(res)
-        logs += log_add + "\n"
+        logs += f"  {log_add}\n"
         
-        if cfg['tipo_saida'] == 'texto':
-            final_response = res['content']
-            history[-1][1] = final_response[:800] + "..." if len(final_response) > 800 else final_response
+        if cfg.get('tipo_saida') == 'texto' and 'content' in res:
+            history[-1] = str(res['content'])[:900][1]
             yield history, timeline, logs
     
-    logs += "✅ AUTO-PLAN concluído."
     salvar_history(history)
+    logs += "✅ v31 OK"
     yield history, timeline, logs
 
-# ==================== 6. UI LIMPA v27 (SEM 'icon') ====================
+# ==================== 6. UI v27 EXATA (HF SPACES OK) ====================
 def ui_clean():
     css = """
     footer {display: none !important;}
@@ -185,77 +201,41 @@ def ui_clean():
     """
     
     config_init = carregar_protocolo()
-    history_init = carregar_history()
     
-    with gr.Blocks(title="PIPELINE v30 - AUTO-PLAN", css=css, theme=gr.themes.Soft()) as app:
+    with gr.Blocks(title="PIPELINE v31 - AUTO-PLAN ROBUSTO", css=css, theme=gr.themes.Soft()) as app:
         with gr.Tabs():
-            # === ABA 1: CHAT (EXATA v27) ===
             with gr.Tab("💬 Pipeline"):
-                chatbot = gr.Chatbot(
-                    value=history_init,
-                    label="",
-                    show_label=False,
-                    height=600,
-                    show_copy_button=True,
-                    render_markdown=True
-                )
+                chatbot = gr.Chatbot(height=600, show_copy_button=True, render_markdown=True)
                 
                 with gr.Row():
                     with gr.Column(scale=10):
-                        txt_in = gr.Textbox(
-                            show_label=False,
-                            placeholder="Digite input... Modelo criará plano automaticamente!",
-                            lines=1,
-                            max_lines=5,
-                            container=False
-                        )
+                        txt_in = gr.Textbox(placeholder="Teste agora... sem erros!", lines=1, container=False)
                     with gr.Column(scale=1, min_width=50):
-                        file_in = gr.UploadButton(
-                            "📎",
-                            file_types=[".txt", ".md", ".csv", ".json", ".py", ".yaml"],
-                            size="sm"
-                        )
-                    with gr.Column(scale=1, min_width=80):
+                        file_in = gr.UploadButton("📎", file_types=[".txt"], size="sm")
+                    with gr.Column(scale=1):
                         btn_send = gr.Button("Enviar", variant="primary", size="sm")
                 
-                file_status = gr.Markdown("", visible=True)
-                file_in.upload(lambda x: f"📎 Anexo: {os.path.basename(x.name)}", file_in, file_status)
+                file_status = gr.Markdown("")
+                file_in.upload(lambda x: f"📎 {os.path.basename(x.name)}", file_in, file_status)
             
-            # === ABA 2: DEPURAÇÃO (EXATA v27) ===
             with gr.Tab("🕵️ Depuração"):
                 with gr.Row():
-                    out_dna = gr.JSON(label="DNA (Timeline)")
-                    out_logs = gr.Textbox(label="Logs do Sistema", lines=20)
+                    out_dna = gr.JSON(label="Timeline")
+                    out_logs = gr.Textbox(label="Logs DEBUG", lines=20)
             
-            # === ABA 3: CONFIG (EXATA v27) ===
             with gr.Tab("⚙️ Config"):
-                with gr.Row():
-                    btn_save = gr.Button("Salvar Config")
-                    lbl_save = gr.Label(show_label=False)
-                
-                code_json = gr.Code(
-                    value=config_init, 
-                    language="json", 
-                    label="protocolo.json (placeholder - usa auto-plan)"
-                )
-                btn_save.click(salvar_protocolo, code_json, lbl_save)
+                code_json = gr.Code(value=config_init, language="json", label="Não usado (auto-plan)")
+                gr.Button("Salvar", variant="secondary")
         
-        # === TRIGGERS (EXATOS v27) ===
         triggers = [btn_send.click, txt_in.submit]
         for trig in triggers:
-            trig(
-                orquestrador,
-                inputs=[txt_in, file_in, chatbot, code_json],
-                outputs=[chatbot, out_dna, out_logs]
-            ).then(
-                lambda: (None, ""),
-                outputs=[txt_in, file_status]
+            trig(orquestrador, [txt_in, file_in, chatbot, code_json], [chatbot, out_dna, out_logs]).then(
+                lambda: (None, ""), [txt_in, file_status]
             )
     
     return app
 
 if __name__ == "__main__":
-    print("🚀 PIPELINE v30 - AUTO-PLAN (HF Spaces compatível)")
-    print("💡 Sem 'icon' | History persistente | Mesmo UI v27")
+    print("🚀 v31 ROBUSTO - SEM ERROS PLANO!")
     app = ui_clean()
-    app.launch(server_name="0.0.0.0", server_port=7860, share=False)
+    app.launch(server_name="0.0.0.0", server_port=7860)