Update routes/subscription.py

routes/subscription.py

@@ -205,23 +205,29 @@ async def create_price(
         user_avatar = user.get("avatar", None)  # 🔹 Recuperar a URL do avatar do usuário, se existir
         logger.info(f"🔹 Existing price_id: {existing_price_id}, user_name: {user_name}, user_avatar: {user_avatar}")
 
-        # 🔹 5. Criar novo preço no Stripe com nome e imagem baseados no usuário
-        price_name = f"{user_name} - {amount} BRL"  # 🔹 Nome formatado para o preço
-        price_data = {
-            "unit_amount": amount,
-            "currency": "brl",
-            "recurring": {"interval": "month"},
-            "product_data": {"name": price_name}
+        # 🔹 5. Criar produto no Stripe com nome e imagem baseados no usuário
+        product_data = {
+            "name": f"{user_name} - {amount} BRL",  # Nome do produto
         }
         
-        if user_avatar:  # 🔹 Verificar se o avatar existe e adicionar a imagem
-            price_data["product_data"]["images"] = [user_avatar]
-
-        price = stripe.Price.create(**price_data)
+        if user_avatar:  # Verificar se o avatar existe e adicionar a imagem
+            product_data["images"] = [user_avatar]
+
+        product = stripe.Product.create(**product_data)
+        product_id = product.id
+        logger.info(f"✅ New product created: {product_id}")
+
+        # 🔹 6. Criar novo preço no Stripe associado ao produto
+        price = stripe.Price.create(
+            unit_amount=amount,
+            currency="brl",
+            recurring={"interval": "month"},
+            product=product_id  # Associando o preço ao produto
+        )
         new_price_id = price.id
         logger.info(f"✅ New price created: {new_price_id}")
 
-        # 🔹 6. Se já houver um price_id, cancelar assinaturas ativas ao final do período
+        # 🔹 7. Se já houver um price_id, cancelar assinaturas ativas ao final do período
         if existing_price_id:
             subscriptions = stripe.Subscription.list(status="active")
             for sub in subscriptions.auto_paging_iter():
@@ -229,7 +235,7 @@ async def create_price(
                     stripe.Subscription.modify(sub.id, cancel_at_period_end=True)
                     logger.info(f"🔹 Subscription {sub.id} set to cancel at period end.")
 
-        # 🔹 7. Atualizar Supabase com o novo price_id e valores adicionais
+        # 🔹 8. Atualizar Supabase com o novo price_id e valores adicionais
         update_data = {
             "price_id": new_price_id,  # Novo price_id
             "price": amount,  # Atualizando o valor de 'price'