Update routes/subscription.py

routes/subscription.py

@@ -46,7 +46,7 @@ from fastapi import Header  # Import para pegar headers
 @router.post("/create_price")
 async def create_price(
     data: CreatePriceRequest,
-    user_token: str = Header(None, alias="User-key")  # Pegando o token do Header
+    user_token: str = Header(None, alias="User-key")
 ):
     try:
         if not user_token:
@@ -63,7 +63,7 @@ async def create_price(
         
         supabase_headers = {
             "apikey": SUPABASE_KEY,
-            "Authorization": f"Bearer {user_token}",  # 🔥 Token do usuário
+            "Authorization": f"Bearer {user_token}",
             "Content-Type": "application/json"
         }
 
@@ -76,20 +76,23 @@ async def create_price(
         user = user_data[0]
         price_id = user.get("price_id")  # Pega o price_id salvo
 
-        # 🔹 Se o usuário já tem um price_id salvo, tentar atualizar no Stripe
+        # 🔹 Se o usuário já tem um price_id salvo, tentar buscar no Stripe
+        current_price_valid = False
         if price_id:
             try:
-                price = stripe.Price.modify(
-                    price_id,
-                    active=False  # Desativa o antigo antes de criar um novo
-                )
-                logger.info(f"🔄 Deactivated old price {price_id}")
+                price = stripe.Price.retrieve(price_id)
+                if price.unit_amount == amount:  # Se o preço for igual, podemos reutilizar
+                    current_price_valid = True
+                    logger.info(f"✅ Reusing existing price {price_id} (same amount) for user {user_id}")
+                else:
+                    stripe.Price.modify(price_id, active=False)  # Desativa o antigo
+                    logger.info(f"🔄 Deactivated old price {price_id} (different amount)")
             except stripe.error.InvalidRequestError:
-                logger.warning(f"⚠️ Invalid price_id ({price_id}), creating a new one...")  
+                logger.warning(f"⚠️ Invalid price_id ({price_id}), creating a new one...")
                 price_id = None  # Se for inválido, vamos criar um novo
 
-        # 🔹 Criar um novo preço se não existir um válido
-        if not price_id:
+        # 🔹 Criar um novo preço apenas se necessário
+        if not current_price_valid:
             price = stripe.Price.create(
                 unit_amount=amount,
                 currency="brl",
@@ -97,9 +100,6 @@ async def create_price(
                 product_data={"name": "Custom Subscription Price"}
             )
             logger.info(f"✅ Created new price {price.id} for user {user_id}")
-        else:
-            price = stripe.Price.retrieve(price_id)
-            logger.info(f"✅ Reusing existing price {price.id} for user {user_id}")
 
         # 🔹 Atualizar Supabase com o novo price_id
         update_response = requests.patch(