Update main.py

main.py

@@ -801,6 +801,7 @@ async def process_account_endpoint(account: str):
         if crop_url:
             print(f"✨ [{time.time()-t_start:.1f}s] Usando vídeo já cortado (crop_content_url). Pulando processamento de crop.")
             cropped_video_path = video_path_to_analyze
+            cropped_video_url = crop_url
             files_to_send.append(cropped_video_path)
             
             # Adicionar o original como segundo anexo para contexto
@@ -907,8 +908,25 @@ async def process_account_endpoint(account: str):
 
         result_json = titles_data if isinstance(titles_data, list) else [titles_data]
 
+        # ETAPA IMEDIATA: Notificar Discord (Vicky) e salvar Títulos no Supabase
+        try:
+            print(f"📢 [{time.time()-t_start:.1f}s] Notificando Discord sobre criação do conteúdo...")
+            import urllib.parse as _up
+            _r0 = result_json[0] if result_json else {}
+            process_natural_msg = _r0.get("process_message", "Oi! Acabei de criar o conteúdo e as legendas. Agora estou preparando o vídeo final... ⏳")
+            
+            # Vicky manda a mensagem natural dela
+            vicky_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": process_natural_msg, "id": discord_id})
+            requests.get("https://proxy.onrecurve.com/", params={"quest": vicky_url}, timeout=5)
+            
+            # Atualizar Supabase com dados parciais (Títulos/Descrição)
+            requests.patch(f"{supabase_url}/rest/v1/posts?id=eq.{record_id}", headers=headers, json={"result": result_json}, timeout=10)
+        except Exception as _early_dc:
+            print(f"⚠️ Erro na notificação imediata do Discord: {_early_dc}")
+
         final_content_url = None
         srt_for_export = None
+        cropped_video_url = record.get("crop_content_url") # Garantir que pegamos a URL do banco se já existir
         if result_json:
             result_data = result_json[0] if isinstance(result_json[0], dict) else {}
             title_text = result_data.get("title", "")
@@ -1269,22 +1287,15 @@ LEGENDA ORIGINAL:
         if srt_for_export:
             response_data["subtitle_srt"] = srt_for_export
 
-        # Notificação de conclusão: Vicky (ID 2) + sistema (ID 0)
+        # 10. Notificação de conclusão: Sistema (ID 0) avisando que mídia está pronta
         try:
             import urllib.parse as _up
             _r0 = result_json[0] if result_json else {}
             legenda_done = _r0.get("description", "")
-            process_natural_msg = _r0.get("process_message", "")
-
-            # Mensagem natural do agente + URL oculta
-            process_dc_msg = process_natural_msg if process_natural_msg else "Postagem processada!"
-            if final_content_url:
-                process_dc_msg += f"\n\n{final_content_url}"
-            _process_dc_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": process_dc_msg, "id": discord_id})
-            requests.get("https://proxy.onrecurve.com/", params={"quest": _process_dc_url}, timeout=5)
-
-            # ID 0 (sistema): marcou como finalizada + legenda completa
-            _sys_end_msg = f"✅ **{agent_name}** marcou a postagem #{record_id} como finalizada.\n\n💬 **Legenda:** {legenda_done}"
+            
+            # ID 0 (sistema): marcou como finalizada + legenda completa + link
+            final_msg_add = f"\n\n🔗 **Vídeo Final:** {final_content_url}" if final_content_url else ""
+            _sys_end_msg = f"✅ **{agent_name}** finalizou a renderização para o post #{record_id}.\n\n💬 **Legenda:** {legenda_done}{final_msg_add}"
             _sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": _sys_end_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": _sys_end_url}, timeout=5)
         except Exception as _e:
@@ -1346,10 +1357,10 @@ async def safe_call_publish(account: str):
 
 @app.api_route("/filter/{account}", methods=["GET", "POST"])
 async def filter_account_endpoint(account: str, background_tasks: BackgroundTasks):
-    background_tasks.add_task(run_filter_account, account)
+    background_tasks.add_task(run_filter_account, account, background_tasks)
     return {"status": "ok", "message": "Solicitação enviada com sucesso! O processo continuará em background."}
 
-async def run_filter_account(account: str):
+async def run_filter_account(account: str, background_tasks: BackgroundTasks = None):
     if not client:
         raise HTTPException(status_code=500, detail="Gemini client is not initialized")
     temp_file = None
@@ -1562,7 +1573,13 @@ async def run_filter_account(account: str):
         if not res_patch.ok:
             print(f"⚠️ Erro ao atualizar Supabase: {res_patch.text}")
 
-        process_res = await safe_call_process(account)
+        # Desacoplar processamento: não dar 'await' se tivermos background_tasks
+        if background_tasks:
+            background_tasks.add_task(safe_call_process, account)
+            process_res = {"status": "started", "message": "Processamento iniciado em background."}
+        else:
+            process_res = await safe_call_process(account)
+
         return {
             "success": True, 
             "record_id": record_id, 
@@ -1578,7 +1595,7 @@ async def run_filter_account(account: str):
             import urllib.parse as _up
             sys_err_msg = f"<@1331348103806189675> 🚨 **ERRO CRÍTICO** ao filtrar post #{record_id if record_id else 'desconhecido'}:\n\n`{err_msg}`\n\nNão foi possível concluir a solicitação."
             sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": system_discord_id})
-            requests.get("https://proxy.onrecurve.com/", params={"quest": sys_err_url}, timeout=5)
+            requests.get("https://proxy.onrecurve.com/", params={"quest": _sys_url}, timeout=5)
         except Exception as dc_e:
             print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
 
@@ -1587,7 +1604,12 @@ async def run_filter_account(account: str):
             # Só salvará quando de fato o filtro não aprovar.
             pass
 
-        process_res = await safe_call_process(account)
+        # Mesmo em erro no filtro, tentamos rodar o process (talvez pra outros posts)
+        if background_tasks:
+            background_tasks.add_task(safe_call_process, account)
+            process_res = {"status": "started", "message": "Processamento iniciado em background."}
+        else:
+            process_res = await safe_call_process(account)
         return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "next_steps": {"process": process_res}})
     finally:
         if temp_file and os.path.exists(temp_file.name): os.unlink(temp_file.name)