Update main.py

main.py

@@ -239,7 +239,8 @@ async def process_girlsmoodaily_endpoint():
             
         records = res_get.json()
         if not records:
-            return {"status": "ok", "message": "Nenhuma postagem pendente para ser processada."}
+            publish_res = await safe_call_publish()
+            return {"status": "ok", "message": "Nenhuma postagem pendente para ser processada.", "publish_result": publish_res}
             
         record = records[0]
         record_id = record.get("id")
@@ -792,6 +793,8 @@ LEGENDA ORIGINAL:
         except Exception as _e:
             print(f"⚠️ Erro ao enviar notificação de conclusão para o Discord: {_e}")
 
+        publish_res = await safe_call_publish()
+        response_data["publish_result"] = publish_res
         return response_data
     except Exception as e:
         import traceback
@@ -815,7 +818,8 @@ LEGENDA ORIGINAL:
             except Exception as sup_e:
                 print(f"⚠️ Erro ao atualizar falha no Supabase: {sup_e}")
 
-        raise HTTPException(status_code=500, detail=f"Erro interno: {err_msg}")
+        publish_res = await safe_call_publish()
+        return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "publish_result": publish_res})
     finally:
         if temp_file and os.path.exists(temp_file.name): os.unlink(temp_file.name)
         if cropped_file_path and os.path.exists(cropped_file_path): os.unlink(cropped_file_path)
@@ -823,6 +827,30 @@ LEGENDA ORIGINAL:
         if screenshot_path and os.path.exists(screenshot_path): os.unlink(screenshot_path)
 
 
+async def safe_call_process():
+    try:
+        res = await process_girlsmoodaily_endpoint()
+        if isinstance(res, JSONResponse):
+            import json
+            return json.loads(res.body.decode('utf-8'))
+        return res
+    except HTTPException as e:
+        return {"error": e.detail, "status_code": e.status_code}
+    except Exception as e:
+        return {"error": str(e), "status_code": 500}
+
+async def safe_call_publish():
+    try:
+        res = await publish_girlsmoodaily_endpoint()
+        if isinstance(res, JSONResponse):
+            import json
+            return json.loads(res.body.decode('utf-8'))
+        return res
+    except HTTPException as e:
+        return {"error": e.detail, "status_code": e.status_code}
+    except Exception as e:
+        return {"error": str(e), "status_code": 500}
+
 @app.api_route("/filter-girlsmoodaily", methods=["GET", "POST"])
 async def filter_endpoint():
     if not client:
@@ -849,7 +877,8 @@ async def filter_endpoint():
             
         records = res_get.json()
         if not records:
-            return {"status": "ok", "message": "Nenhuma postagem pendente para ser filtrada."}
+            process_res = await safe_call_process()
+            return {"status": "ok", "message": "Nenhuma postagem pendente para ser filtrada.", "next_steps": {"process": process_res}}
             
         record = records[0]
         record_id = record.get("id")
@@ -1058,10 +1087,12 @@ Reprovando (exemplo 2):
         if not res_patch.ok:
             print(f"⚠️ Erro ao atualizar Supabase: {res_patch.text}")
 
+        process_res = await safe_call_process()
         return {
             "success": True, 
             "record_id": record_id, 
-            "filter_data": filter_data
+            "filter_data": filter_data,
+            "next_steps": {"process": process_res}
         }
     except Exception as e:
         import traceback
@@ -1089,7 +1120,8 @@ Reprovando (exemplo 2):
             except Exception as sup_e:
                 print(f"⚠️ Erro ao atualizar falha no Supabase: {sup_e}")
 
-        raise HTTPException(status_code=500, detail=f"Erro interno: {err_msg}")
+        process_res = await safe_call_process()
+        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)
         if 'cropped_file_path' in locals() and cropped_file_path and os.path.exists(cropped_file_path):
@@ -1320,23 +1352,59 @@ Rejeitando:
                 timeout=5
             )
             
-            # 2) Aviso final pro Painel de Sistema (ID 0)
+            # 2) Processo de Publicação e Aviso final pro Painel de Sistema (ID 0)
             is_published = publish_data.get("published", False)
             needs_verification = publish_data.get("superior_needs_verification", False)
             
+            sys_end_msg = ""
+            
             if is_published:
-                status_emoji = "✅"
-                status_text = "APROVOU a publicação"
-            elif needs_verification:
-                status_emoji = "🔍"
-                status_text = "SOLICITOU verificação de um superior"
-            else:
-                status_emoji = "❌"
-                status_text = "REJEITOU a publicação"
+                # Tenta publicar de fato
+                try:
+                    r0 = result_data[0] if isinstance(result_data, list) and len(result_data) > 0 else {}
+                    caption_text = r0.get("description", "")
+                    
+                    publish_payload = {
+                        "account": "girlsmoodaily",
+                        "caption": caption_text
+                    }
+                    if is_video:
+                        publish_payload["video_url"] = final_content_url
+                    else:
+                        publish_payload["image_urls"] = [final_content_url]
+                        
+                    print(f"🚀 Enviando post #{record_id} para API de publicação com proxy...")
+                    pub_resp = requests.post(
+                        "https://proxy.onrecurve.com/",
+                        params={"quest": "https://ig-publisher.arthurmribeiro51.workers.dev/"},
+                        json=publish_payload,
+                        timeout=300
+                    )
+                    
+                    if pub_resp.ok:
+                        pub_json = pub_resp.json()
+                        if pub_json.get("success"):
+                            post_url = pub_json.get("instagram", {}).get("post_url", "[URL não extraída]")
+                            sys_end_msg = f"✅ **{agent_name}** APROVOU e PUBLICOU a postagem #{record_id}!\n\n🔗 Link: {post_url}"
+                        else:
+                            err_det = pub_json.get("error", pub_json.get("instagram", {}).get("error", "Erro desconhecido"))
+                            sys_end_msg = f"⚠️ **{agent_name}** APROVOU a postagem #{record_id}, mas a publicação falhou:\n`{err_det}`"
+                            is_published = False
+                            needs_verification = True
+                    else:
+                        sys_end_msg = f"⚠️ **{agent_name}** APROVOU a postagem #{record_id}, mas a API de publicação retornou status {pub_resp.status_code}:\n`{pub_resp.text}`"
+                        is_published = False
+                        needs_verification = True
+                except Exception as pub_e:
+                    sys_end_msg = f"⚠️ **{agent_name}** APROVOU a postagem #{record_id}, mas ocorreu uma exceção ao tentar publicar:\n`{str(pub_e)}`"
+                    is_published = False
+                    needs_verification = True
             
-            sys_end_msg = f"{status_emoji} **{agent_name}** {status_text} da postagem #{record_id}."
-            if needs_verification:
-                sys_end_msg = f"@everyone\n\n{sys_end_msg}"
+            if not sys_end_msg:
+                if needs_verification:
+                    sys_end_msg = f"@everyone\n\n🔍 **{agent_name}** SOLICITOU verificação de um superior da postagem #{record_id}."
+                else:
+                    sys_end_msg = f"❌ **{agent_name}** REJEITOU a postagem #{record_id}."
 
             sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                 "mensagem": sys_end_msg,
@@ -1354,8 +1422,8 @@ Rejeitando:
         update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
         patch_payload = {
             "publish_message": publish_data.get("publish_message"),
-            "published": publish_data.get("published", False),
-            "superior_needs_verification": publish_data.get("superior_needs_verification", False)
+            "published": is_published,
+            "superior_needs_verification": needs_verification
         }
         res_patch = requests.patch(update_url, headers=headers, json=patch_payload, timeout=10)
         if not res_patch.ok:
@@ -1391,7 +1459,7 @@ Rejeitando:
             except Exception as sup_e:
                 print(f"⚠️ Erro ao atualizar falha no Supabase: {sup_e}")
 
-        raise HTTPException(status_code=500, detail=f"Erro interno: {err_msg}")
+        return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}"})
     finally:
         if temp_file and os.path.exists(temp_file.name): os.unlink(temp_file.name)