Update routes/subscription.py

routes/subscription.py

@@ -68,23 +68,22 @@ async def stripe_webhook(request: Request):
 
         if event_type == "invoice.payment_succeeded":
             invoice = payload.get("data", {}).get("object", {})
-            amount_paid = invoice.get("amount_paid", 0)  # Valor total pago (em centavos)
 
-            # 🔹 Recuperar metadata corretamente do nível do invoice
+            # 🔹 Verifica metadata na invoice principal
             metadata = invoice.get("metadata", {})
-            stylist_id = metadata.get("stylist_id", "N/A")  # ID do estilista
-            user_id = metadata.get("user_id", "N/A")  # ID do usuário
-
-            # 🔹 Cálculo da divisão
-            stylist_amount = int(amount_paid * 0.8)  # 80% para o estilista
-            platform_amount = int(amount_paid * 0.2)  # 20% para a plataforma
-
-            # 🔹 Logando os valores
-            logger.info(f"✅ Pagamento bem-sucedido! Valor total: R$ {amount_paid / 100:.2f}")
-            logger.info(f"👤 Stylist ID: {stylist_id}")
-            logger.info(f"👥 User ID: {user_id}")
-            logger.info(f"💰 Estilista recebe: R$ {stylist_amount / 100:.2f}")
-            logger.info(f"🏛️ Plataforma fica com: R$ {platform_amount / 100:.2f}")
+
+            # 🔹 Verifica metadata na assinatura associada
+            subscription_metadata = invoice.get("subscription_details", {}).get("metadata", {})
+
+            # 🔹 Verifica metadata dentro dos itens da fatura (invoice.line_items)
+            line_items = invoice.get("lines", {}).get("data", [])
+            line_item_metadata = line_items[0].get("metadata", {}) if line_items else {}
+
+            # 🔹 Agora pegamos os valores
+            stylist_id = metadata.get("stylist_id") or subscription_metadata.get("stylist_id") or line_item_metadata.get("stylist_id")
+            user_id = metadata.get("user_id") or subscription_metadata.get("user_id") or line_item_metadata.get("user_id")
+
+            logger.info(f"✅ Invoice processada! Stylist ID: {stylist_id}, User ID: {user_id}")
 
         return {"status": "success"}