Update routes/subscription.py

routes/subscription.py

@@ -528,12 +528,19 @@ 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
             cancel_status = subscription.get("cancel_at_period_end", False)
         
+            # 🔹 Definir os cabeçalhos do Supabase antes de qualquer uso
+            supabase_headers = {
+                "Authorization": f"Bearer {SUPABASE_KEY}",
+                "apikey": SUPABASE_KEY,
+                "Content-Type": "application/json"
+            }
+        
             # Verifica se a assinatura foi cancelada
             if canceled_at:
                 # Convertendo timestamp para data e horário de Nova York
@@ -549,12 +556,6 @@ async def stripe_webhook(request: Request):
                     "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]:
@@ -567,7 +568,7 @@ async def stripe_webhook(request: Request):
             # Caso a assinatura tenha sido reativada (cancel_at_period_end=False)
             elif not cancel_status:
                 logger.info(f"🔹 Subscription {subscription_id} reactivated.")
-                
+        
                 # Atualizando o status no Supabase para reativado
                 update_url = f"{SUPABASE_URL}/rest/v1/Subscriptions?sub_id=eq.{subscription_id}"
                 update_data = {
@@ -583,7 +584,7 @@ async def stripe_webhook(request: Request):
                 else:
                     logger.error(f"❌ Failed to update subscription: {response_update.status_code} - {response_update.text}")
                     return {"status": "error", "message": "Failed to update subscription."}
-            
+        
             else:
                 logger.info(f"🔹 Subscription {subscription_id} updated, but not canceled or reactivated.")
                 return {"status": "success", "message": "Subscription updated but not canceled or reactivated."}