Update routes/subscription.py

routes/subscription.py

@@ -318,29 +318,29 @@ async def stripe_webhook(request: Request):
             subscription_id = subscription.get("id")
             canceled_at = subscription.get("canceled_at")  # Timestamp do cancelamento
             cancel_status = subscription.get("cancel_at_period_end", False)
-
+        
             if canceled_at:
                 # Convertendo timestamp para data e horário de Nova York
                 ny_tz = pytz.timezone("America/New_York")
                 canceled_date = datetime.fromtimestamp(canceled_at, ny_tz).isoformat()
-
+        
                 logger.info(f"🔹 Subscription {subscription_id} canceled at {canceled_date} (New York Time).")
-
+        
                 # 🔹 Atualizando Supabase
                 update_url = f"{SUPABASE_URL}/rest/v1/Subscriptions?sub_id=eq.{subscription_id}"
                 update_data = {
                     "canceled": True,
                     "canceled_date": canceled_date
                 }
-
+        
                 supabase_headers = {
                     "Authorization": f"Bearer {SUPABASE_KEY}",
                     "apikey": SUPABASE_KEY,
                     "Content-Type": "application/json"
                 }
-
+        
                 response_update = requests.patch(update_url, headers=supabase_headers, json=update_data)
-
+        
                 if response_update.status_code in [200, 204]:
                     logger.info(f"✅ Subscription {subscription_id} updated with canceled date.")
                     return {"status": "success", "message": "Subscription updated with cancellation date."}
@@ -350,25 +350,27 @@ async def stripe_webhook(request: Request):
             else:
                 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":
+        
+        # A partir daqui, o bloco do código pode continuar sem problemas.
+        
+        elif event_type == "payment_intent.succeeded":
             payment_intent = payload.get("data", {}).get("object", {})
-            
+        
             # 🔹 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,  # Subscription ID
@@ -376,19 +378,19 @@ async def stripe_webhook(request: Request):
                 "client_id": client_id,      # Client ID
                 "price": amount_received     # Price in cents
             }
-
+        
             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 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"