Update routes/users.py

routes/users.py

@@ -216,7 +216,86 @@ async def update_user(
     except Exception as e:
         logger.error(f"❌ Erro ao atualizar usuário: {str(e)}")
         raise HTTPException(status_code=500, detail="Erro interno do servidor")
-        
+
+@router.delete("/admin/delete-feed")
+async def delete_feed(
+    feed_id: int = Query(..., description="ID do feed a ser deletado"),
+    user_token: str = Header(None, alias="User-key")
+):
+    """
+    Deleta um feed, seus portfolios relacionados e as imagens no bucket.
+    """
+    try:
+        await verify_admin_token(user_token)
+
+        headers = SUPABASE_ROLE_HEADERS.copy()
+        headers["Accept"] = "application/json"
+
+        async with aiohttp.ClientSession() as session:
+            # Buscar o feed pelo ID
+            feed_query = f"{SUPABASE_URL}/rest/v1/Feeds?select=portfolios&limit=1&id=eq.{feed_id}"
+            async with session.get(feed_query, headers=headers) as feed_response:
+                if feed_response.status != 200:
+                    raise HTTPException(status_code=feed_response.status, detail="Erro ao buscar feed")
+                
+                feed_data = await feed_response.json()
+                if not feed_data:
+                    raise HTTPException(status_code=404, detail="Feed não encontrado")
+                
+                portfolio_ids = feed_data[0].get("portfolios", [])
+                if not isinstance(portfolio_ids, list):
+                    import json
+                    portfolio_ids = json.loads(portfolio_ids)  # Caso venha como string JSON
+
+            # Buscar os portfolios para pegar os URLs das imagens
+            image_urls = []
+            if portfolio_ids:
+                ids_str = ",".join([str(pid) for pid in portfolio_ids])
+                portfolio_query = f"{SUPABASE_URL}/rest/v1/Portfolio?select=id,image_url&id=in.({ids_str})"
+                async with session.get(portfolio_query, headers=headers) as portfolio_response:
+                    if portfolio_response.status == 200:
+                        portfolio_data = await portfolio_response.json()
+                        image_urls = [item["image_url"] for item in portfolio_data if "image_url" in item]
+
+            # Deletar os portfolios
+            if portfolio_ids:
+                delete_portfolios_url = f"{SUPABASE_URL}/rest/v1/Portfolio?id=in.({','.join(map(str, portfolio_ids))})"
+                async with session.delete(delete_portfolios_url, headers=headers) as delete_response:
+                    if delete_response.status != 204:
+                        raise HTTPException(status_code=delete_response.status, detail="Erro ao deletar portfolios")
+
+            # Deletar imagens do bucket Supabase Storage
+            async def delete_image_from_storage(image_url: str):
+                from urllib.parse import urlparse
+                path = urlparse(image_url).path
+                # Extraindo bucket e key
+                parts = path.strip("/").split("/")
+                if len(parts) < 3:
+                    return
+                bucket_id = parts[1]
+                file_key = "/".join(parts[2:])
+                delete_url = f"{SUPABASE_URL}/storage/v1/object/{bucket_id}/{file_key}"
+                async with session.delete(delete_url, headers=headers) as delete_img_response:
+                    if delete_img_response.status not in (200, 204):
+                        logger.warning(f"❌ Falha ao deletar imagem: {file_key}")
+
+            await asyncio.gather(*[delete_image_from_storage(url) for url in image_urls])
+
+            # Deletar o feed
+            delete_feed_url = f"{SUPABASE_URL}/rest/v1/Feeds?id=eq.{feed_id}"
+            async with session.delete(delete_feed_url, headers=headers) as delete_feed_response:
+                if delete_feed_response.status != 204:
+                    raise HTTPException(status_code=delete_feed_response.status, detail="Erro ao deletar feed")
+
+        logger.info(f"✅ Feed {feed_id} e portfolios relacionados deletados com sucesso.")
+        return {"message": f"Feed {feed_id} e portfolios deletados com sucesso."}
+
+    except HTTPException as he:
+        raise he
+    except Exception as e:
+        logger.error(f"❌ Erro ao deletar feed: {str(e)}")
+        raise HTTPException(status_code=500, detail="Erro interno do servidor")
+
 @router.get("/admin/user")
 async def get_user_name(
     user_id: str = Query(..., description="ID do usuário"),