Update main.py

main.py

@@ -1177,6 +1177,75 @@ async def publish_girlsmoodaily_endpoint():
         discord_id = 3
         agent_name = "Amanda"
         
+        publish_message = record.get("publish_message")
+        if publish_message and not record.get("published", False):
+            print(f"🔄 Post #{record_id} já possui publish_message. Tentando publicar direto no Instagram...")
+            try:
+                head_resp = requests.head(final_content_url, timeout=15)
+                content_type = head_resp.headers.get('content-type', '').lower()
+                is_video = 'image' not in content_type
+                
+                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 (RETRY)...")
+                pub_resp = requests.post(
+                    "https://igpublish.onrecurve.com/",
+                    json=publish_payload,
+                    timeout=300
+                )
+                
+                is_published = False
+                needs_verification = False
+                sys_end_msg = ""
+                
+                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}** PUBLICOU a postagem #{record_id} com sucesso (RETRY)!\n\n🔗 Link: {post_url}"
+                        is_published = True
+                    else:
+                        err_det = pub_json.get("error", pub_json.get("instagram", {}).get("error", "Erro desconhecido"))
+                        sys_end_msg = f"⚠️ A publicação do post #{record_id} falhou novamente (RETRY):\n`{err_det}`"
+                        needs_verification = True
+                else:
+                    sys_end_msg = f"⚠️ API de publicação retornou status {pub_resp.status_code} no RETRY:\n`{pub_resp.text}`"
+                    needs_verification = True
+                    
+                if sys_end_msg:
+                    import urllib.parse
+                    sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
+                        "mensagem": sys_end_msg,
+                        "id": 0
+                    })
+                    requests.get("https://proxy.onrecurve.com/", params={"quest": sys_end_url}, timeout=5)
+                
+                update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
+                patch_payload = {
+                    "published": is_published,
+                    "superior_needs_verification": needs_verification
+                }
+                requests.patch(update_url, headers=headers, json=patch_payload, timeout=10)
+                
+                return {
+                    "success": True, 
+                    "record_id": record_id, 
+                    "retry_published": is_published
+                }
+            except Exception as retry_e:
+                print(f"⚠️ Erro no retry de publicação: {retry_e}")
+                raise
+        
         # Notificação de início no Discord
         try:
             import urllib.parse
@@ -1459,7 +1528,7 @@ Rejeitando:
             try:
                 update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
                 patch_payload = {
-                    "publish_message": f"Erro interno: {err_msg}", 
+                    "publish_message": None, 
                     "published": False, 
                     "superior_needs_verification": True
                 }