Update routes/subscription.py

routes/subscription.py

@@ -41,47 +41,54 @@ class CreatePriceRequest(BaseModel):
     amount: int  # Valor em centavos (ex: 2500 para R$25,00)
     user_id: str  # ID do usuário que está criando o preço
 
+from fastapi import Header  # Import para pegar headers
+
 @router.post("/create_price")
-async def create_price(data: CreatePriceRequest):
+async def create_price(
+    data: CreatePriceRequest,
+    user_token: str = Header(None, alias="User-key")  # Pegando o token do Header
+):
     try:
-        amount = data.amount  # ✅ Já está em centavos, não multiplica por 100
+        if not user_token:
+            raise HTTPException(status_code=401, detail="Missing User-key header")
+
+        amount = data.amount
         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
+        # 🔹 Criar preço no Stripe
         price = stripe.Price.create(
-            unit_amount=amount,  # ✅ Sem multiplicação
+            unit_amount=amount,
             currency="brl",
             recurring={"interval": "month"},
-            product_data={  
-                "name": "Custom Subscription Price"  
-            }
+            product_data={"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
+        # 🔹 Atualizar Supabase com price_id, autenticando com User-key
         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
+        supabase_headers = {
+            "apikey": SUPABASE_KEY,
+            "Authorization": f"Bearer {user_token}",  # 🔥 Passando token do usuário
+            "Content-Type": "application/json"
+        }
 
         response = requests.patch(
             supabase_url,
-            headers=SUPABASE_HEADERS,
+            headers=supabase_headers,
             json={"price_id": price.id}
         )
 
-        logger.info(f"🔹 Supabase response: {response.status_code}, {response.text}")  # Debug log
+        logger.info(f"🔹 Supabase response: {response.status_code}, {response.text}")
 
         if response.status_code not in [200, 204]:
             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}")