Update routes/subscription.py

routes/subscription.py

@@ -880,13 +880,17 @@ async def create_price(
         new_price_id = price.id
         logger.info(f"✅ New price created: {new_price_id}")
 
-        # 🔹 7. Se já houver um price_id, cancelar assinaturas ativas ao final do período
+        # 🔹 7. Se já houver um price_id, cancelar e modificar assinaturas ativas com o novo preço
         if existing_price_id:
             subscriptions = stripe.Subscription.list(status="active")
             for sub in subscriptions.auto_paging_iter():
                 if sub["items"]["data"][0]["price"]["id"] == existing_price_id:
-                    stripe.Subscription.modify(sub.id, cancel_at_period_end=True)
-                    logger.info(f"🔹 Subscription {sub.id} set to cancel at period end.")
+                    # Atualiza o price_id antes de cancelar a assinatura
+                    stripe.Subscription.modify(sub.id, items=[{
+                        "id": sub["items"]["data"][0]["id"], 
+                        "price": new_price_id
+                    }], cancel_at_period_end=True)
+                    logger.info(f"🔹 Subscription {sub.id} set to cancel at period end and updated with new price {new_price_id}.")
 
         # 🔹 8. Atualizar Supabase com o novo price_id e valores adicionais
         update_data = {