Update routes/subscription.py

routes/subscription.py

@@ -61,13 +61,42 @@ def create_checkout_session(data: SubscriptionRequest):
 async def stripe_webhook(request: Request):
     payload = await request.body()
     headers = dict(request.headers)
+    event = None
+    try:
+        event = stripe.Event.construct_from(
+            json.loads(payload), stripe.api_key
+        )
+    except Exception as e:
+        logger.error(f"⚠️ Erro ao processar webhook: {e}")
+        raise HTTPException(status_code=400, detail="Webhook error")
 
-    logger.info("🔹 Webhook recebido!")
-    logger.info(f"🔹 Headers: {headers}")
-    logger.info(f"🔹 Corpo: {payload.decode('utf-8')}")
-
-    return {"status": "Webhook recebido com sucesso!"}
+    logger.info(f"🔹 Evento recebido: {event['type']}")
+    
+    if event["type"] == "invoice.payment_succeeded":
+        invoice = event["data"]["object"]
+        estilista_id = invoice.get("metadata", {}).get("estilista_id")
+        amount = invoice["amount_paid"]
+        estilista_share = int(amount * 0.8)  # 80% para o estilista
+        platform_share = amount - estilista_share  # 20% para a plataforma
+        
+        logger.info(f"Pagamento confirmado: {amount / 100:.2f} BRL")
+        logger.info(f"Estilista {estilista_id} receberá: {estilista_share / 100:.2f} BRL")
+        logger.info(f"Plataforma receberá: {platform_share / 100:.2f} BRL")
+        
+        # Transferir os fundos automaticamente
+        try:
+            transfer = stripe.Transfer.create(
+                amount=estilista_share,
+                currency="brl",
+                destination=estilista_id,  # Conta conectada do estilista
+                description="Pagamento de assinatura"
+            )
+            logger.info(f"Transferência bem-sucedida: {transfer.id}")
+        except Exception as e:
+            logger.error(f"Erro na transferência: {e}")
     
+    return {"status": "Webhook processado com sucesso!"}
+
 ### 4. CANCELAR ASSINATURA ###
 @router.post("/cancel_subscription")
 def cancel_subscription(data: CancelSubscriptionRequest):