Update main.py

main.py

@@ -739,6 +739,11 @@ LEGENDA ORIGINAL:
                 except Exception as e:
                     print(f"⚠️ Erro ao gerar URL do meme: {e}")
         
+        # Add generated subtitles to the result JSON for Supabase
+        if result_json and srt_for_export:
+            if isinstance(result_json[0], dict):
+                result_json[0]["subtitle_srt"] = srt_for_export
+
         # Atualizar no Supabase
         update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
         patch_payload = {
@@ -1033,6 +1038,256 @@ Reprovando (exemplo 2):
             os.unlink(cropped_file_path)
 
 
+@app.api_route("/publish-girlsmoodaily", methods=["GET", "POST"])
+async def publish_girlsmoodaily_endpoint():
+    if not client:
+        raise HTTPException(status_code=500, detail="Gemini client is not initialized")
+    temp_file = None
+    try:
+        supabase_url = os.getenv("SUPABASE_URL", "").rstrip("/")
+        supabase_key = os.getenv("SUPABASE_KEY", "")
+        if not supabase_url or not supabase_key:
+            raise HTTPException(status_code=500, detail="Credenciais do Supabase não configuradas no ambiente.")
+            
+        headers = {
+            "apikey": supabase_key,
+            "Authorization": f"Bearer {supabase_key}",
+            "Content-Type": "application/json"
+        }
+        
+        # Buscar 1 post pronto para publicação: tem result, tem final_content_url, published=false, superior_needs_verification IS NULL
+        select_url = f"{supabase_url}/rest/v1/posts?select=*&result=not.is.null&final_content_url=not.is.null&published=eq.false&superior_needs_verification=is.null&limit=1"
+        res_get = requests.get(select_url, headers=headers, timeout=10)
+        if not res_get.ok:
+            raise HTTPException(status_code=500, detail=f"Erro ao ler posts: {res_get.text}")
+            
+        records = res_get.json()
+        if not records:
+            return {"status": "ok", "message": "Nenhuma postagem pendente para publicação."}
+            
+        record = records[0]
+        record_id = record.get("id")
+        final_content_url = record.get("final_content_url", "")
+        result_data = record.get("result", [])
+        
+        if not final_content_url:
+            raise HTTPException(status_code=400, detail=f"Registro ID {record_id} falhou: final_content_url inválida.")
+
+        discord_id = 3
+        agent_name = "Amanda"
+        
+        # Notificação de início no Discord
+        try:
+            import urllib.parse
+            sys_msg = f"📦 **{agent_name}** começou a revisar uma postagem para publicação...\n\n📎 **Conteúdo:** {final_content_url}"
+            sys_target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
+                "mensagem": sys_msg,
+                "id": 0
+            })
+            requests.get(
+                "https://proxy.onrecurve.com/",
+                params={"quest": sys_target_url},
+                timeout=5
+            )
+        except Exception as e:
+            print(f"⚠️ Erro ao enviar mensagem de sistema para o Discord: {e}")
+
+        # Baixar o conteúdo final para enviar ao Gemini
+        print(f"📥 Baixando conteúdo final para revisão: {final_content_url}")
+        response = download_file_with_retry(final_content_url, timeout=600)
+        
+        content_type = response.headers.get('content-type', '').lower()
+        if 'image' in content_type:
+            if 'png' in content_type: ext = '.png'
+            elif 'webp' in content_type: ext = '.webp'
+            else: ext = '.jpg'
+        else:
+            ext = '.webm' if 'webm' in content_type else '.mp4'
+        
+        temp_file = tempfile.NamedTemporaryFile(delete=False, suffix=ext)
+        for chunk in response.iter_content(chunk_size=1024*1024):
+            if chunk: temp_file.write(chunk)
+        temp_file.close()
+
+        # Montar contexto do que a Vicky produziu
+        vicky_result = ""
+        if result_data and isinstance(result_data, list) and len(result_data) > 0:
+            r0 = result_data[0] if isinstance(result_data[0], dict) else {}
+            vicky_result = f"""
+RESULTADO DA VICKY (o que foi produzido):
+- Título: {r0.get('title', 'N/A')}
+- Descrição: {r0.get('description', 'N/A')}
+- Legenda (subtítulos): {r0.get('legenda', False)}
+- Tipo: {r0.get('result_type', 'N/A')}
+"""
+
+        is_video = 'image' not in content_type
+
+        prompt = f"""Você é AMANDA, a Gestora de Distribuição da @girlsmoodaily no Instagram.
+
+QUEM VOCÊ É
+
+Você é a Amanda, organizada, detalhista e com olho clínico para qualidade. Você é a última pessoa que vê o conteúdo antes de ele ir ao ar. Nada sai sem a sua aprovação. Você fala de forma profissional mas acessível, como uma gerente de redes sociais que leva o trabalho muito a sério mas não é robótica. Você se comunica exclusivamente em português brasileiro.
+
+Sua personalidade: responsável, metódica e confiante. Você não deixa passar nada. Se algo está errado, você percebe. Se está tudo certo, você aprova com segurança. Você é firme mas não arrogante, e sempre explica suas decisões com clareza.
+
+
+SUA MISSÃO
+
+Você é o último filtro antes da publicação. Você recebe o conteúdo FINAL (já editado, com título aplicado, exportado e pronto) e verifica se ele está apto para ser publicado na @girlsmoodaily.
+
+Sua verificação é sobre o PRODUTO FINAL, não sobre o conteúdo bruto original. A Diana já filtrou o conteúdo e a Vicky já criou o post. Você está olhando para o resultado final que vai pro feed/reels.
+
+{vicky_result}
+
+O QUE VOCÊ DEVE VERIFICAR
+
+1. QUALIDADE VISUAL GERAL
+   - O conteúdo final está visualmente limpo e profissional?
+   - A resolução e qualidade são aceitáveis para publicação?
+   - Se for vídeo: a imagem do título está bem posicionada? O vídeo está cortado corretamente?
+   - Se for meme/imagem: o texto está legível? A composição visual está harmoniosa?
+
+2. MARCAS D'ÁGUA E TEXTOS INDESEJADOS
+   - Há marcas d'água visíveis de outras plataformas (TikTok, Instagram de terceiros, etc.)?
+   - Há textos em idiomas estrangeiros que não deveriam estar ali (exceto se forem parte natural do conteúdo, como um meme em inglês que foi traduzido no título)?
+   - Há logos ou arrobas de outras páginas visíveis no conteúdo final?
+
+3. TÍTULO E TEXTO DA @GIRLSMOODAILY
+   - O título aplicado pela Vicky está visível e legível?
+   - O título faz sentido com o conteúdo visual?
+   - Se for meme: o texto central está correto e bem formatado?
+   - IMPORTANTE: Se houver texto no conteúdo que NÃO seja o título/texto central da @girlsmoodaily (como texto residual do post original que não foi removido), isso é um problema que merece atenção.
+
+4. LEGENDAS (SUBTÍTULOS) - SOMENTE PARA VÍDEOS
+   - Se o vídeo tem legendas incorporadas, elas estão em português?
+   - As legendas são legíveis e bem posicionadas?
+   - Se o vídeo deveria ter legendas mas não tem, isso é um problema.
+
+5. ALINHAMENTO COM A IDENTIDADE DA PÁGINA
+   - O produto final parece algo que a @girlsmoodaily publicaria?
+   - A estética geral está alinhada com a vibe feminina, leve e alto-astral da página?
+
+REGRAS DE DECISÃO
+
+PUBLICAR (published: true, superior_needs_verification: false):
+- Tudo está perfeito. Conteúdo limpo, título legível, sem marcas d'água, qualidade boa, alinhado com a página. Pode ir ao ar.
+
+PRECISA DE VERIFICAÇÃO SUPERIOR (published: false, superior_needs_verification: true):
+- O conteúdo provavelmente está ok, mas você tem alguma dúvida ou incerteza. Exemplos:
+  - Há um texto residual no conteúdo que pode ou não ser problemático
+  - A imagem do título parece levemente desalinhada ou cortada de forma estranha
+  - Você não tem certeza se uma marca d'água sutil é realmente uma marca d'água
+  - O conteúdo é bom mas algo te deixa com uma pulga atrás da orelha
+  - Use isso quando você ACHA que deveria publicar mas não tem 100% de certeza
+
+REJEITAR (published: false, superior_needs_verification: false):
+- O conteúdo tem problemas claros e óbvios que impedem a publicação. Exemplos:
+  - Marca d'água enorme e visível
+  - Texto completamente ilegível
+  - Conteúdo claramente quebrado ou corrompido
+  - Qualidade visual inaceitável
+  - Problema grave que não tem como ser ignorado
+
+FORMATO DE SAÍDA
+
+Você deve retornar APENAS um objeto JSON puro, sem markdown, sem blocos de código, sem nenhum texto antes ou depois.
+
+{{
+  "publish_message": "<sua mensagem aqui>",
+  "published": true ou false,
+  "superior_needs_verification": true ou false
+}}
+
+Regras para publish_message: escrita em português brasileiro, casual mas profissional, sem formatações, sem negrito, sem travessão, sem listas. Deve soar como uma gestora de redes sociais real falando. Explique sua decisão de forma clara e direta. Varie sempre a abertura. Nunca comece com "gente" ou "pessoal". Entre 2 e 4 frases.
+
+EXEMPLOS DE TOM
+
+Publicando:
+"Revisei o conteúdo final e tá tudo impecável. Título legível, sem marcas d'água, qualidade visual ótima e totalmente alinhado com a vibe da página. Pode ir ao ar sem nenhuma preocupação. ✅"
+
+Pedindo verificação:
+"O conteúdo tá bom no geral, mas percebi um texto pequeno no canto inferior do vídeo que pode ser uma marca d'água ou pode ser parte do conteúdo original. Não consigo ter certeza, então prefiro que alguém dê uma segunda olhada antes de publicar. 🔍"
+
+Rejeitando:
+"Infelizmente não posso aprovar essa aqui. Tem uma marca d'água do TikTok bem visível no meio do vídeo que compromete completamente a qualidade do post. Precisa ser reprocessado antes de publicar. ❌"
+"""
+
+        model_obj = get_gemini_model("flash")
+        print(f"🧠 Enviando para Gemini (flash) para revisão de publicação...")
+        
+        response_gemini = await client.generate_content(prompt, files=[temp_file.name], model=model_obj)
+        
+        publish_data = extract_json_from_text(response_gemini.text)
+        if publish_data is None:
+            return JSONResponse(content={"raw_content": response_gemini.text, "error": "Failed to parse JSON"}, status_code=200)
+
+        # Enviar mensagens no Discord
+        try:
+            import urllib.parse
+            # 1) Mensagem da Amanda para o canal dela (ID 3)
+            target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
+                "mensagem": publish_data.get("publish_message", ""),
+                "id": discord_id
+            })
+            requests.get(
+                "https://proxy.onrecurve.com/",
+                params={"quest": target_url},
+                timeout=5
+            )
+            
+            # 2) Aviso final pro Painel de Sistema (ID 0)
+            is_published = publish_data.get("published", False)
+            needs_verification = publish_data.get("superior_needs_verification", False)
+            
+            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"
+            
+            sys_end_msg = f"{status_emoji} **{agent_name}** {status_text} da postagem #{record_id}."
+            if final_content_url:
+                sys_end_msg += f"\n\n📎 {final_content_url}"
+
+            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
+            )
+        except Exception as e:
+            print(f"⚠️ Erro ao enviar log para o Discord: {e}")
+
+        # Atualizar no Supabase
+        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)
+        }
+        res_patch = requests.patch(update_url, headers=headers, json=patch_payload, timeout=10)
+        if not res_patch.ok:
+            print(f"⚠️ Erro ao atualizar Supabase: {res_patch.text}")
+
+        return {
+            "success": True, 
+            "record_id": record_id, 
+            "publish_data": publish_data
+        }
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Erro interno: {str(e)}")
+    finally:
+        if temp_file and os.path.exists(temp_file.name): os.unlink(temp_file.name)
+
+
 # ==========================================
 # GROQ ENDPOINTS / SUBTITLES
 # ==========================================