Update app.py

app.py

@@ -360,39 +360,47 @@ def automacao_upload_processamento(files, history, config_json):
 
 
 def chat_orquestrador(message, history, config_json):
+    """
+    Orquestra a conversa, passando o contexto e as missões para cada agente em sequência.
+    Agora também retorna a trilha de auditoria para a nova aba.
+    """
     try:
         prompt_contexto = gerenciador.gerar_prompt_com_transcricoes(message)
     except Exception as e:
         history.append([message, f"❌ Erro ao gerar contexto: {str(e)}"])
-        yield history
+        yield history, []
         return
     
     try:
         protocolo = json.loads(config_json)
     except:
         history.append([message, "❌ Erro no JSON de Configuração."])
-        yield history
+        yield history, []
         return
 
     history.append([message, None])
-    yield history
-
-    timeline_execucao = [{"role": "user", "content": prompt_contexto}]
     
+    # A trilha de auditoria começa com o prompt completo enviado pelo usuário
+    timeline_execucao = [{"passo": 1, "tipo": "prompt_usuario", "conteudo": prompt_contexto}]
+    yield history, timeline_execucao
+
+    passo_atual = 2
     for cfg in protocolo:
         nome_agente = cfg.get("nome", "Agente")
         modelo_agente = model_pro if cfg.get("modelo") == "pro" else model_flash
         
-        history[-1][1] = f"⏳ **{nome_agente}** está analisando..."
-        yield history
+        # Atualiza o chatbot com o status do agente atual
+        msg_atual = history[-1][1] or ""
+        history[-1][1] = msg_atual + f"⏳ **{nome_agente}** está analisando...\n"
+        yield history, timeline_execucao
         
         prompt_agente = f"""
---- HISTÓRICO ---
-{json.dumps(timeline_execucao, ensure_ascii=False)}
+--- HISTÓRICO DA CONVERSA ATÉ AGORA ---
+{json.dumps(timeline_execucao, ensure_ascii=False, indent=2)}
 -----------------
-Você é: {nome_agente}
-Sua Missão: {cfg['missao']}
-Responda de forma concisa e direta.
+Sua Identidade: {nome_agente}
+Sua Missão Específica Agora: {cfg['missao']}
+Responda de forma concisa e direta, focando apenas na sua missão.
 """
         try:
             inicio = time.time()
@@ -400,19 +408,25 @@ Responda de forma concisa e direta.
             texto_resp = resp.text
             duracao = time.time() - inicio
             
-            timeline_execucao.append({"role": "model", "content": f"[{nome_agente}]: {texto_resp}"})
+            # Adiciona a resposta do agente à trilha de auditoria
+            timeline_execucao.append({"passo": passo_atual, "tipo": "resposta_agente", "agente": nome_agente, "resposta": texto_resp})
             
+            # Remove o status "analisando..." e adiciona a resposta final do agente
             msg_atual = history[-1][1]
-            if "⏳" in msg_atual: msg_atual = ""
+            msg_atual = msg_atual.replace(f"⏳ **{nome_agente}** está analisando...\n", "")
             
             novo_trecho = f"**[{nome_agente}]** ({duracao:.1f}s):\n{texto_resp}\n\n"
             history[-1][1] = msg_atual + novo_trecho
-            yield history
+            yield history, timeline_execucao
             
         except Exception as e:
+            # Adiciona o erro à trilha de auditoria e ao chat
+            timeline_execucao.append({"passo": passo_atual, "tipo": "erro_agente", "agente": nome_agente, "erro": str(e)})
             msg_atual = history[-1][1]
-            history[-1][1] = msg_atual + f"\n❌ Erro em {nome_agente}: {str(e)}\n"
-            yield history
+            history[-1][1] = msg_atual.replace(f"⏳ **{nome_agente}** está analisando...\n", "") + f"\n❌ Erro em {nome_agente}: {str(e)}\n"
+            yield history, timeline_execucao
+        
+        passo_atual += 1
 
 # ==================== 6. UI (Gradio) ====================
 
@@ -455,6 +469,11 @@ def ui_v28_corrected():
                         label="Arraste arquivos aqui ou clique para selecionar"
                     )
 
+            # NOVA ABA DE AUDITORIA
+            with gr.Tab("🕵️ Auditoria"):
+                gr.Markdown("### Trilha de Auditoria\nExibe o histórico completo de prompts e respostas de cada agente na última execução. O conteúdo é atualizado a cada nova mensagem enviada.")
+                json_audit = gr.JSON(label="Timeline da Execução da Última Mensagem")
+
             with gr.Tab("⚙️ Contexto & Config"):
                 gr.Markdown("### Protocolo dos Agentes")
                 with gr.Row():
@@ -466,10 +485,11 @@ def ui_v28_corrected():
                 btn_save_cfg.click(salvar_protocolo, inputs=[code_config], outputs=[lbl_cfg_status])
                 btn_save_cfg.click(lambda x: x, inputs=[code_config], outputs=[state_config])
 
+        # A ação de clique agora atualiza tanto o chatbot quanto a aba de auditoria
         btn_enviar.click(
             chat_orquestrador,
             inputs=[txt_input, chatbot, state_config],
-            outputs=[chatbot]
+            outputs=[chatbot, json_audit]  # Adicionado json_audit como saída
         ).then(
             lambda: "", outputs=[txt_input]
         )
@@ -483,4 +503,4 @@ def ui_v28_corrected():
     return app
 
 if __name__ == "__main__":
-    ui_v28_corrected().launch()
+    ui_v28_corrected().launch()```