Update routes/subscription.py

routes/subscription.py

@@ -60,6 +60,38 @@ def verify_token(user_token: str) -> str:
     else:
         raise HTTPException(status_code=401, detail="Invalid or expired token")
 
+@router.post("/webhook")
+async def stripe_webhook(request: Request):
+    try:
+        payload = await request.json()
+
+        event_type = payload.get("type")
+        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 do checkout
+            metadata = invoice.get("lines", {}).get("data", [])[0].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}")
+
+        return {"status": "success"}
+
+    except Exception as e:
+        logger.error(f"❌ Erro no webhook: {str(e)}")
+        return {"status": "error", "message": str(e)}
+        
 @router.post("/create_price")
 async def create_price(
     data: CreatePriceRequest,
@@ -139,31 +171,6 @@ async def create_price(
     except Exception as e:
         logger.error(f"❌ Error creating/updating price: {e}")
         raise HTTPException(status_code=500, detail="Error creating/updating price.")
-
-@router.post("/webhook")
-async def stripe_webhook(request: Request):
-    try:
-        payload = await request.json()
-
-        event_type = payload.get("type")
-        if event_type == "invoice.payment_succeeded":
-            invoice = payload.get("data", {}).get("object", {})
-            amount_paid = invoice.get("amount_paid", 0)  # Valor total pago (em centavos)
-
-            # Cálculo de 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"💰 Estilista recebe: R$ {stylist_amount / 100:.2f}")
-            logger.info(f"🏛️ Plataforma fica com: R$ {platform_amount / 100:.2f}")
-
-        return {"status": "success"}
-
-    except Exception as e:
-        logger.error(f"❌ Erro no webhook: {str(e)}")
-        return {"status": "error", "message": str(e)}
         
 @router.post("/create_checkout_session")
 def create_checkout_session(