Update routers/instagram.py

routers/instagram.py

@@ -1,5 +1,6 @@
 import os
 import httpx
+import socket
 from typing import Dict, Optional, Tuple
 from fastapi import APIRouter, HTTPException
 from pydantic import BaseModel
@@ -7,7 +8,7 @@ from pydantic import BaseModel
 router = APIRouter()
 
 # 📱 Instagram API Config
-INSTAGRAM_API_BASE = "https://graph.instagram.com/v23.0"
+INSTAGRAM_API_BASE = "https://graph.instagram.com"  # Removido v23.0 para testar
 INSTAGRAM_PAGE_ID = "17841464166934843"  # Seu Page ID
 INSTAGRAM_TOKEN = os.getenv("INSTAGRAM_ACCESS_TOKEN")
 
@@ -28,6 +29,28 @@ class PublishResponse(BaseModel):
     comment_posted: bool = False
     comment_id: Optional[str] = None
 
+# 🔍 Função para testar conectividade
+async def test_connectivity():
+    """Testa a conectividade básica com a API do Instagram"""
+    try:
+        # Teste 1: Resolução DNS
+        print("🔍 Testando resolução DNS...")
+        socket.gethostbyname("graph.instagram.com")
+        print("✅ DNS resolvido com sucesso")
+        
+        # Teste 2: Conexão HTTP
+        print("🔍 Testando conectividade HTTP...")
+        async with httpx.AsyncClient(timeout=10.0) as client:
+            response = await client.get("https://graph.instagram.com")
+            print(f"✅ Conectividade OK - Status: {response.status_code}")
+            
+    except socket.gaierror as e:
+        print(f"❌ Erro de DNS: {e}")
+        raise HTTPException(status_code=502, detail=f"Erro de resolução DNS: {e}")
+    except Exception as e:
+        print(f"❌ Erro de conectividade: {e}")
+        raise HTTPException(status_code=502, detail=f"Erro de conectividade: {e}")
+
 def clean_html_tags(text: str) -> str:
     """
     Remove todas as tags HTML.
@@ -118,12 +141,12 @@ async def post_comment(client: httpx.AsyncClient, post_id: str, comment_text: st
     try:
         comment_url = f"{INSTAGRAM_API_BASE}/{post_id}/comments"
         headers = {
-            "Content-Type": "application/json",
-            "Authorization": f"Bearer {INSTAGRAM_TOKEN}"
+            "Content-Type": "application/json"
         }
         
         comment_payload = {
-            "message": comment_text
+            "message": comment_text,
+            "access_token": INSTAGRAM_TOKEN
         }
         
         print(f"💬 Postando comentário no post {post_id}")
@@ -157,36 +180,49 @@ async def publish_instagram_post(post: InstagramPost) -> PublishResponse:
     3. Se necessário, posta o resto do texto como comentário
     """
     
-    async with httpx.AsyncClient(timeout=30.0) as client:
+    # 🔍 Testa conectividade antes de prosseguir
+    await test_connectivity()
+    
+    # Configuração do cliente HTTP com mais opções
+    client_config = httpx.AsyncClient(
+        timeout=httpx.Timeout(30.0, connect=10.0),
+        follow_redirects=True,
+        verify=True,  # Verifica certificados SSL
+        limits=httpx.Limits(max_connections=10, max_keepalive_connections=5)
+    )
+    
+    async with client_config as client:
         try:
             # 📝 Processa o texto da caption
             main_caption, remaining_text = format_text_for_instagram(post.caption) if post.caption else ("", None)
             
             # 🎯 ETAPA 1: Criar o media container
-            media_payload = {
-                "image_url": post.image_url
+            # Usando parâmetros de query ao invés de JSON body (como no curl que funcionou)
+            media_params = {
+                "image_url": post.image_url,
+                "access_token": INSTAGRAM_TOKEN
             }
             
             # Adiciona caption processada se fornecida
             if main_caption:
-                media_payload["caption"] = main_caption
+                media_params["caption"] = main_caption
             
             media_url = f"{INSTAGRAM_API_BASE}/{INSTAGRAM_PAGE_ID}/media"
-            headers = {
-                "Content-Type": "application/json",
-                "Authorization": f"Bearer {INSTAGRAM_TOKEN}"
-            }
             
             print(f"📤 Criando media container para: {post.image_url}")
+            print(f"🔗 URL: {media_url}")
             if remaining_text:
                 print(f"✂️ Texto cortado - será postado comentário com {len(remaining_text)} caracteres")
             
+            # Usando POST com parâmetros de query (igual ao curl)
             media_response = await client.post(
-                media_url, 
-                headers=headers, 
-                json=media_payload
+                media_url,
+                params=media_params  # Mudança aqui: usando params ao invés de json
             )
             
+            print(f"📊 Status da resposta: {media_response.status_code}")
+            print(f"📊 Headers da resposta: {dict(media_response.headers)}")
+            
             if media_response.status_code != 200:
                 error_detail = media_response.text
                 print(f"❌ Erro ao criar media container: {error_detail}")
@@ -207,17 +243,17 @@ async def publish_instagram_post(post: InstagramPost) -> PublishResponse:
             print(f"✅ Media container criado com ID: {media_id}")
             
             # 🎯 ETAPA 2: Publicar o post
-            publish_payload = {
-                "creation_id": media_id
+            publish_params = {
+                "creation_id": media_id,
+                "access_token": INSTAGRAM_TOKEN
             }
             
             publish_url = f"{INSTAGRAM_API_BASE}/{INSTAGRAM_PAGE_ID}/media_publish"
             
             print(f"📤 Publicando post com creation_id: {media_id}")
             publish_response = await client.post(
-                publish_url, 
-                headers=headers, 
-                json=publish_payload
+                publish_url,
+                params=publish_params  # Usando params também aqui
             )
             
             if publish_response.status_code != 200:
@@ -236,8 +272,12 @@ async def publish_instagram_post(post: InstagramPost) -> PublishResponse:
             if post_id:
                 try:
                     # Query para obter o permalink do post
-                    post_details_url = f"{INSTAGRAM_API_BASE}/{post_id}?fields=permalink"
-                    details_response = await client.get(post_details_url, headers=headers)
+                    post_details_params = {
+                        "fields": "permalink",
+                        "access_token": INSTAGRAM_TOKEN
+                    }
+                    post_details_url = f"{INSTAGRAM_API_BASE}/{post_id}"
+                    details_response = await client.get(post_details_url, params=post_details_params)
                     
                     if details_response.status_code == 200:
                         details_data = details_response.json()
@@ -291,4 +331,16 @@ async def publish_instagram_post(post: InstagramPost) -> PublishResponse:
             raise HTTPException(
                 status_code=500, 
                 detail=f"Erro interno do servidor: {str(e)}"
-            )
+            )
+
+# 🔍 Endpoint para testar conectividade
+@router.get("/test-connection")
+async def test_connection():
+    """Endpoint para testar a conectividade com a API do Instagram"""
+    try:
+        await test_connectivity()
+        return {"status": "success", "message": "Conectividade OK"}
+    except HTTPException as e:
+        raise e
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Erro no teste: {str(e)}")