Update routers/wordpress.py

routers/wordpress.py

@@ -21,13 +21,37 @@ class WPPost(BaseModel):
     content: str
     subhead: Optional[str] = None  # 👈 campo ACF mapeado para "subtitulo"
     image_url: Optional[str] = None
+    author_username: Optional[str] = None  # 👈 novo campo para o username do author
     status: str = "publish"
 
+async def get_user_id_by_username(client: httpx.AsyncClient, username: str) -> Optional[int]:
+    """Busca o ID do usuário pelo username"""
+    try:
+        response = await client.get(f"{WP_URL}/users?search={username}", auth=AUTH)
+        if response.status_code == 200:
+            users = response.json()
+            for user in users:
+                if user.get("slug") == username or user.get("name") == username:
+                    return user.get("id")
+        return None
+    except Exception:
+        return None
+
 @router.post("/wordpress/post")
 async def create_wordpress_post(post: WPPost):
     async with httpx.AsyncClient(timeout=20.0) as client:
         featured_media_id = None
-
+        author_id = None
+        
+        # 👤 Buscar ID do author se username fornecido
+        if post.author_username:
+            author_id = await get_user_id_by_username(client, post.author_username)
+            if not author_id:
+                raise HTTPException(
+                    status_code=404, 
+                    detail=f"Usuário '{post.author_username}' não encontrado"
+                )
+        
         # Upload de imagem se fornecida
         if post.image_url:
             try:
@@ -48,27 +72,31 @@ async def create_wordpress_post(post: WPPost):
                         featured_media_id = upload.json().get("id")
             except Exception:
                 pass  # Ignora erro de imagem para não quebrar o post
-
+        
         # Dados do post
         post_data = {
             "title": post.title,
             "content": post.content,
             "status": post.status
         }
-
+        
         if featured_media_id:
             post_data["featured_media"] = featured_media_id
-
+            
+        # 👤 Adicionar author se encontrado
+        if author_id:
+            post_data["author"] = author_id
+        
         # Campo ACF: subhead → subtitulo
         if post.subhead:
             post_data["subtitulo"] = post.subhead
-
+        
         # Criar post
         response = await client.post(f"{WP_URL}/posts", auth=AUTH, json=post_data)
-
+        
         if response.status_code not in [200, 201]:
             raise HTTPException(status_code=response.status_code, detail=response.text)
-
+        
         result = response.json()
         
         # 🔄 Fallback: Se ACF não foi salvo, tentar novamente
@@ -79,5 +107,5 @@ async def create_wordpress_post(post: WPPost):
                 update_resp = await client.post(f"{WP_URL}/posts/{post_id}", auth=AUTH, json=acf_data)
                 if update_resp.status_code in [200, 201]:
                     result = update_resp.json()
-
+        
         return result