Update routes/subscription.py

routes/subscription.py

@@ -534,6 +534,7 @@ async def stripe_webhook(request: Request):
             canceled_at = subscription.get("canceled_at")  # Timestamp do cancelamento
             cancel_status = subscription.get("cancel_at_period_end", False)
         
+            # Verifica se a assinatura foi cancelada
             if canceled_at:
                 # Convertendo timestamp para data e horário de Nova York
                 ny_tz = pytz.timezone("America/New_York")
@@ -541,7 +542,7 @@ async def stripe_webhook(request: Request):
         
                 logger.info(f"🔹 Subscription {subscription_id} canceled at {canceled_date} (New York Time).")
         
-                # 🔹 Atualizando Supabase
+                # Atualizando no Supabase a assinatura como cancelada
                 update_url = f"{SUPABASE_URL}/rest/v1/Subscriptions?sub_id=eq.{subscription_id}"
                 update_data = {
                     "canceled": True,
@@ -562,11 +563,30 @@ 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.")
-                return {"status": "success", "message": "Subscription updated but not canceled."}
         
-        # A partir daqui, o bloco do código pode continuar sem problemas.
+            # 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 = {
+                    "canceled": False,
+                    "canceled_date": None  # Remove a data de cancelamento
+                }
+        
+                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} reactivated and canceled data removed.")
+                    return {"status": "success", "message": "Subscription reactivated and canceled date removed."}
+                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."}
         
         elif event_type == "payment_intent.succeeded":
             payment_intent = payload.get("data", {}).get("object", {})