Update routes/subscription.py

routes/subscription.py

@@ -165,6 +165,44 @@ 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":
+            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)
+
+            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."}
+                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.")
+                return {"status": "success", "message": "Subscription updated but not canceled."}
+
     except Exception as e:
         logger.error(f"❌ Erro no webhook: {str(e)}")
         return {"status": "error", "message": str(e)}