Update routes/subscription.py

routes/subscription.py

@@ -585,22 +585,56 @@ async def stripe_webhook(request: Request):
         elif event_type == "payment_intent.succeeded":
             payment_intent = payload.get("data", {}).get("object", {})
         
-            # 🔹 Pegando os valores do metadado
+            # 🔹 Pegando os valores do metadado - CORRIGIDO
             stylist_id = payment_intent.get("metadata", {}).get("stylist_id")
-            client_id = payment_intent.get("metadata", {}).get("client_id")
-            subscription_id = payment_intent.get("metadata", {}).get("subscription_id")
+            client_id = payment_intent.get("metadata", {}).get("user_id")  # Alterado de client_id para user_id
+            invoice_id = payment_intent.get("invoice")  # Obtendo o ID da fatura
             payment_id = payment_intent.get("id")  # Payment ID
             amount_received = payment_intent.get("amount_received", 0)  # Valor recebido (em centavos)
+            stylist_stripe_id = payment_intent.get("metadata", {}).get("stylist_stripe_id")
         
-            if not all([stylist_id, client_id, subscription_id, payment_id]):
+            if not all([stylist_id, client_id, payment_id]):
                 logger.error("❌ Faltando dados essenciais no metadado do Payment Intent.")
                 return {"status": "error", "message": "Missing essential metadata."}
+                
+            # Obter subscription_id da fatura
+            subscription_id = None
+            if invoice_id:
+                try:
+                    invoice = stripe.Invoice.retrieve(invoice_id)
+                    subscription_id = invoice.get("subscription")
+                except Exception as e:
+                    logger.error(f"❌ Erro ao obter subscription_id da fatura: {str(e)}")
         
             logger.info(f"🔹 Payment Intent succeeded for subscription {subscription_id}")
             logger.info(f"👤 Client ID: {client_id}")
             logger.info(f"👗 Stylist ID: {stylist_id}")
             logger.info(f"💰 Price: R$ {amount_received / 100:.2f}")
             logger.info(f"💳 Payment ID: {payment_id}")
+            
+            # Criar transferência para a conta conectada do estilista
+            if stylist_stripe_id and amount_received > 0:
+                try:
+                    # Calcular valor do estilista (80%)
+                    stylist_amount = int(amount_received * 0.8)
+                    
+                    # Criar transferência
+                    transfer = stripe.Transfer.create(
+                        amount=stylist_amount,
+                        currency="brl",
+                        destination=stylist_stripe_id,
+                        source_transaction=payment_intent.get("latest_charge"),
+                        description=f"Pagamento de assinatura para {stylist_id}",
+                        metadata={
+                            "stylist_id": stylist_id,
+                            "client_id": client_id,
+                            "payment_intent_id": payment_id,
+                            "subscription_id": subscription_id
+                        }
+                    )
+                    logger.info(f"✅ Transferência criada com sucesso: {transfer.id} - Valor: R$ {stylist_amount / 100:.2f}")
+                except Exception as e:
+                    logger.error(f"❌ Erro ao criar transferência: {str(e)}")
         
             # 🔹 Definindo os cabeçalhos do Supabase
             supabase_headers = {