Update routes/subscription.py

routes/subscription.py

@@ -38,41 +38,51 @@ class SubscriptionRequest(BaseModel):
     user_id: str  # ID do usuário que está comprando a assinatura
 
 @router.post("/create_price")
-async def create_price(request: Request):  # ✅ Agora é assíncrona
+async def create_price(data: CreatePriceRequest):
     try:
-        data = await request.json()  # ✅ Agora `await` pode ser usado
-        amount = data.get("amount")
-        user_id = data.get("user_id")
+        amount = data.amount  # ✅ Já está em centavos, não multiplica por 100
+        user_id = data.user_id
 
         if not amount or not user_id:
             raise HTTPException(status_code=400, detail="Amount and user_id are required")
 
         # 🔹 Criar o preço no Stripe
         price = stripe.Price.create(
-            unit_amount=int(amount * 100),
+            unit_amount=amount,  # ✅ Sem multiplicação
             currency="brl",
             recurring={"interval": "month"},
             product_data={  
-                "name": "Custom Subscription Price"  # ✅ 'name' pode ser enviado, mas 'description' não
+                "name": "Custom Subscription Price"  
             }
         )
 
+        logger.info(f"✅ Price created successfully: {price.id} for user {user_id}")
+
         # 🔹 Atualizar o usuário no Supabase com o price_id
+        supabase_url = f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}"
+        
+        logger.info(f"🔄 Updating Supabase: {supabase_url}, price_id={price.id}")  # Debug log
+
         response = requests.patch(
-            f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}",
+            supabase_url,
             headers=SUPABASE_HEADERS,
             json={"price_id": price.id}
         )
 
+        logger.info(f"🔹 Supabase response: {response.status_code}, {response.text}")  # Debug log
+
         if response.status_code not in [200, 204]:
-            raise HTTPException(status_code=500, detail="Failed to update Supabase with price_id")
+            raise HTTPException(status_code=500, detail=f"Failed to update Supabase: {response.text}")
 
-        return {"message": "Price created successfully!", "price_id": price.id}
+        return {
+            "message": "Price created successfully!",
+            "price_id": price.id
+        }
 
     except Exception as e:
-        logger.error(f"Error creating price: {e}")
+        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(data: SubscriptionRequest):
     try: