Update routes/subscription.py

routes/subscription.py

@@ -246,6 +246,11 @@ async def stripe_webhook(request: Request):
         session = event["data"]["object"]
         payment_intent_id = session.get("payment_intent")
 
+        # Verifica se o payment_intent existe
+        if not payment_intent_id:
+            logger.error("⚠️ No PaymentIntent ID found in session.")
+            raise HTTPException(status_code=400, detail="PaymentIntent ID missing in session.")
+
         try:
             # Recupera o PaymentIntent associado à sessão
             payment_intent = stripe.PaymentIntent.retrieve(payment_intent_id)
@@ -265,10 +270,37 @@ async def stripe_webhook(request: Request):
         stylist_share = int(amount * 0.8)  # 80% para o estilista
         platform_share = amount - stylist_share  # 20% para a plataforma
 
-        # Aqui, o pagamento já foi transferido para o estilista, então não há mais necessidade de fazer uma transferência manual
+        # Logando os valores
         logger.info(f"💸 Payment of R${amount / 100:.2f} BRL received for stylist {stylist_id}.")
         logger.info(f"💸 Stylist share: R${stylist_share / 100:.2f} BRL, Platform share: R${platform_share / 100:.2f} BRL.")
 
+        # Realizando a transferência para o estilista
+        try:
+            # Transfere os fundos para o estilista (Stripe Connect)
+            transfer = stripe.Transfer.create(
+                amount=stylist_share,  # Montante para o estilista (80%)
+                currency="brl",  # Moeda
+                destination=stylist_id,  # Conta do estilista
+                description="Payment for styling service"
+            )
+            logger.info(f"💸 Transfer to stylist {stylist_id} successful: R${stylist_share / 100:.2f} BRL.")
+        except Exception as e:
+            logger.error(f"⚠️ Error transferring funds to stylist: {e}")
+            raise HTTPException(status_code=500, detail="Error transferring funds to stylist.")
+
+        # Você também pode transferir a parte da plataforma, se necessário
+        try:
+            transfer_platform = stripe.Transfer.create(
+                amount=platform_share,  # Montante para a plataforma (20%)
+                currency="brl",  # Moeda
+                destination="your_platform_stripe_account_id",  # Substitua com sua conta Stripe da plataforma
+                description="Platform share"
+            )
+            logger.info(f"💸 Transfer to platform successful: R${platform_share / 100:.2f} BRL.")
+        except Exception as e:
+            logger.error(f"⚠️ Error transferring funds to platform: {e}")
+            raise HTTPException(status_code=500, detail="Error transferring funds to platform.")
+
         # Aqui você pode atualizar seu banco de dados com as informações do pagamento
         # Exemplo de atualização do banco com o valor e o status do pagamento
         # update_payment_status(user_id, stylist_id, amount, stylist_share, platform_share)