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."}
 
-        if event_type == "customer.subscription.updated":
+        elif 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,6 +351,42 @@ 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":
+            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
+            emergency_sub_data = {
+                "sub_id": subscription_id,
+                "stylist_id": stylist_id,
+                "client_id": client_id,
+                "price": amount_paid  # Preço em centavos
+            }
+
+            # 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,
+                headers=supabase_headers,
+                json=emergency_sub_data
+            )
+
+            if response_emergency_sub.status_code == 201:
+                logger.info(f"✅ Emergency subscription 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."
+            }
+
     except Exception as e:
         logger.error(f"❌ Erro no webhook: {str(e)}")
         return {"status": "error", "message": str(e)}