Update routes/users.py

routes/users.py

@@ -209,13 +209,12 @@ async def get_user_transfer_history(
     user_id: str = Query(..., description="ID do usuário no Supabase")
 ):
     """
-    Retorna o histórico de transferências ou pagamentos associados ao Stripe ID do usuário.
-    Apenas para administradores ou usuários com permissão 'view_users'.
+    Retorna os 10 últimos pagamentos do usuário, com metadados e dados do produto, além do total de cobranças.
     """
     try:
-        # Verifica se o token tem permissão
+        # Verificar permissões
         await verify_token_with_permissions(user_token, "view_users")
-        
+
         # Buscar stripe_id do usuário
         user_url = f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}&select=stripe_id"
         async with aiohttp.ClientSession() as session:
@@ -224,34 +223,51 @@ async def get_user_transfer_history(
                     raise HTTPException(status_code=404, detail="Usuário não encontrado")
                 data = await response.json()
                 if not data or not data[0].get("stripe_id"):
-                    raise HTTPException(status_code=404, detail="Stripe ID não encontrado para o usuário")
+                    raise HTTPException(status_code=404, detail="Stripe ID não encontrado")
                 stripe_id = data[0]["stripe_id"]
+
+        # Buscar todas as cobranças (limite maior para contagem)
+        all_charges = stripe.Charge.list(customer=stripe_id, limit=100, expand=["data.invoice"])
+        total_count = len(all_charges["data"])
         
-        # Buscar pagamentos no Stripe associados ao customer
-        charges = stripe.Charge.list(customer=stripe_id, limit=100)
-        
-        formatted = []
-        for charge in charges.auto_paging_iter():
-            formatted.append({
+        # Selecionar os 10 últimos
+        recent_charges = sorted(all_charges["data"], key=lambda c: c["created"], reverse=True)[:10]
+
+        transfers = []
+        for charge in recent_charges:
+            product_name = None
+            invoice_id = charge.get("invoice")
+
+            # Se houver fatura, tentar obter o nome do produto
+            if invoice_id and isinstance(invoice_id, str):
+                invoice = stripe.Invoice.retrieve(invoice_id, expand=["lines.data.price.product"])
+                if invoice and invoice["lines"]["data"]:
+                    first_line = invoice["lines"]["data"][0]
+                    product = first_line.get("price", {}).get("product")
+                    if isinstance(product, dict):
+                        product_name = product.get("name")
+
+            transfers.append({
                 "id": charge["id"],
-                "amount": charge["amount"] / 100,  # Stripe trabalha em centavos
+                "amount": charge["amount"] / 100,
                 "currency": charge["currency"].upper(),
                 "status": charge["status"],
                 "created_at": datetime.fromtimestamp(charge["created"]).isoformat(),
                 "description": charge.get("description"),
                 "payment_method": charge.get("payment_method_details", {}).get("type"),
                 "receipt_url": charge.get("receipt_url"),
+                "metadata": charge.get("metadata", {}),
+                "product_name": product_name
             })
 
         return {
             "stripe_id": stripe_id,
-            "transfers": formatted,
-            "count": len(formatted)
+            "transfers": transfers,
+            "count": total_count
         }
-    
+
     except HTTPException as he:
         raise he
-    
     except Exception as e:
         logger.error(f"❌ Erro ao obter transferências: {str(e)}")
         raise HTTPException(status_code=500, detail="Erro interno ao consultar o histórico de transferências.")