Update routes/subscription.py

routes/subscription.py

@@ -313,7 +313,7 @@ async def stripe_webhook(request: Request):
                 logger.error(f"❌ Failed to update subscription: {response_update.status_code} - {response_update.text}")
                 return {"status": "error", "message": "Failed to update subscription."}
 
-        elif event_type == "customer.subscription.updated":
+        if event_type == "customer.subscription.updated":
             subscription = payload.get("data", {}).get("object", {})
             subscription_id = subscription.get("id")
             canceled_at = subscription.get("canceled_at")  # Timestamp do cancelamento
@@ -351,25 +351,32 @@ async def stripe_webhook(request: Request):
                 logger.info(f"🔹 Subscription {subscription_id} updated, but not canceled.")
                 return {"status": "success", "message": "Subscription updated but not canceled."}
 
-        elif event_type == "payment_intent.succeeded":
+                elif event_type == "payment_intent.succeeded":
             payment_intent = payload.get("data", {}).get("object", {})
-            metadata = payment_intent.get("metadata", {})
-
-            # 🔹 Capturando os dados do metadado
-            stylist_id = metadata.get("stylist_id")
-            subscription_id = metadata.get("subscription_id")
-            client_id = metadata.get("client_id")
-            amount_paid = payment_intent.get("amount_received", 0)  # Valor pago
-
-            # 🔹 Criando a nova linha na tabela Emergency_sub
+            
+            # 🔹 Pegando os valores do metadado
+            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")
+            amount_received = payment_intent.get("amount_received", 0)  # Valor recebido (em centavos)
+
+            if not all([stylist_id, client_id, subscription_id]):
+                logger.error("❌ Faltando dados essenciais no metadado do Payment Intent.")
+                return {"status": "error", "message": "Missing essential metadata."}
+
+            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}")
+
+            # 🔹 Inserir dados na tabela Emergency_sub no Supabase
             emergency_sub_data = {
-                "sub_id": subscription_id,
-                "stylist_id": stylist_id,
-                "client_id": client_id,
-                "price": amount_paid  # Preço em centavos
+                "sub_id": subscription_id,  # Subscription ID
+                "stylist_id": stylist_id,    # Stylist ID
+                "client_id": client_id,      # Client ID
+                "price": amount_received     # Price in cents
             }
 
-            # Inserir dados na tabela Emergency_sub no Supabase
             emergency_sub_url = f"{SUPABASE_URL}/rest/v1/Emergency_sub"
             response_emergency_sub = requests.post(
                 emergency_sub_url,
@@ -378,13 +385,13 @@ async def stripe_webhook(request: Request):
             )
 
             if response_emergency_sub.status_code == 201:
-                logger.info(f"✅ Emergency subscription added successfully for client {client_id}")
+                logger.info(f"✅ Emergency subscription data added successfully for client {client_id}")
             else:
                 logger.error(f"❌ Failed to add emergency subscription: {response_emergency_sub.status_code} - {response_emergency_sub.text}")
 
             return {
                 "status": "success",
-                "message": "Emergency subscription added successfully."
+                "message": "Emergency subscription added successfully"
             }
 
     except Exception as e: