Update routes/subscription.py

routes/subscription.py

@@ -124,7 +124,6 @@ async def create_price(
         user_id = verify_token(user_token)
 
         amount = data.amount
-
         if not amount:
             raise HTTPException(status_code=400, detail="Amount is required")
 
@@ -139,57 +138,39 @@ async def create_price(
         user = user_data[0]
         existing_price_id = user.get("price_id")
 
-        # 🔹 3. Atualizar ou criar um novo price_id
-        updated_price_id = None
+        # 🔹 3. Criar novo preço no Stripe
+        price = stripe.Price.create(
+            unit_amount=amount,
+            currency="brl",
+            recurring={"interval": "month"},
+            product_data={"name": "Custom Subscription Price"}
+        )
+        new_price_id = price.id
+        logger.info(f"✅ New price created: {new_price_id}")
 
+        # 🔹 4. Se já houver um price_id, cancelar assinaturas ativas ao final do período
         if existing_price_id:
-            try:
-                stripe.Price.modify(
-                    existing_price_id,
-                    unit_amount=amount,
-                    metadata={"updated_at": "now"}
-                )
-                logger.info(f"✅ Price {existing_price_id} updated successfully.")
-                updated_price_id = existing_price_id
-            except stripe.error.InvalidRequestError:
-                logger.warning(f"⚠️ Failed to update price {existing_price_id}, creating a new one instead.")
-
-        if not updated_price_id:
-            price = stripe.Price.create(
-                unit_amount=amount,
-                currency="brl",
-                recurring={"interval": "month"},
-                product_data={"name": "Custom Subscription Price"}
-            )
-            updated_price_id = price.id
-            logger.info(f"✅ New price created: {updated_price_id}")
-
-            # 🔹 4. Pausar assinaturas antigas e desativar o preço antigo
-            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, pause_collection={"behavior": "void"})
-                        logger.info(f"🔹 Subscription {sub.id} paused.")
-
-                stripe.Price.modify(existing_price_id, active=False)
-                logger.info(f"🚫 Price {existing_price_id} deactivated.")
+            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.")
 
         # 🔹 5. Atualizar Supabase com o novo price_id
         update_response = requests.patch(
             supabase_url,
             headers=SUPABASE_HEADERS,
-            json={"price_id": updated_price_id}
+            json={"price_id": new_price_id}
         )
 
         if update_response.status_code not in [200, 204]:
             raise HTTPException(status_code=500, detail=f"Failed to update Supabase: {update_response.text}")
 
-        return {"message": "Price created or updated successfully!", "price_id": updated_price_id}
+        return {"message": "Price created successfully!", "price_id": new_price_id}
 
     except Exception as e:
-        logger.error(f"❌ Error creating/updating price: {e}")
-        raise HTTPException(status_code=500, detail="Error creating/updating price.")
+        logger.error(f"❌ Error creating price: {e}")
+        raise HTTPException(status_code=500, detail="Error creating price.")
         
 @router.post("/create_checkout_session")
 def create_checkout_session(