Update routes/subscription.py

routes/subscription.py

@@ -114,21 +114,26 @@ async def update_subscription(
         if not subscription:
             raise HTTPException(status_code=404, detail="Subscription not found.")
 
-        # 🔹 2. Verificar se a assinatura pertence ao usuário (se houver um campo identificador)
-        # Se o modelo de dados do Stripe salvar o user_id no metadata, podemos validar assim:
+        # 🔹 2. Verificar se a assinatura pertence ao usuário (caso esteja salvo no metadata)
         if subscription.get("metadata", {}).get("user_id") != user_id:
             raise HTTPException(status_code=403, detail="You are not authorized to modify this subscription.")
 
-        # 🔹 3. Atualizar a assinatura para o novo preço
+        # 🔹 3. Reativar a assinatura (removendo cancelamento)
+        if subscription.status == "canceled" or subscription.cancel_at_period_end:
+            stripe.Subscription.modify(subscription_id, cancel_at_period_end=False)
+            logger.info(f"✅ Subscription {subscription_id} reactivated.")
+
+        # 🔹 4. Atualizar a assinatura para o novo preço (sem proration)
         updated_subscription = stripe.Subscription.modify(
             subscription_id,
-            items=[{"id": subscription["items"]["data"][0]["id"], "price": new_price_id}]
+            items=[{"id": subscription["items"]["data"][0]["id"], "price": new_price_id}],
+            proration_behavior="none"  # 🔹 Garante que o novo preço só entra na próxima fatura
         )
 
         logger.info(f"✅ Subscription {subscription_id} updated to new price {new_price_id}")
 
         return {
-            "message": "Subscription updated successfully!",
+            "message": "Subscription reactivated and updated successfully!",
             "subscription_id": subscription_id,
             "new_price_id": new_price_id
         }
@@ -140,7 +145,7 @@ async def update_subscription(
     except Exception as e:
         logger.error(f"❌ Error updating subscription: {e}")
         raise HTTPException(status_code=500, detail=f"Error updating subscription: {str(e)}")
-
+        
 @router.post("/sync_emergency_payments")
 async def sync_emergency_payments(request: Request, data: EmergencyPaymentRequest):
     try: