Update routes/hello.py

routes/hello.py

@@ -58,7 +58,7 @@ def verify_token(user_token: str) -> str:
 @router.post("/create_customer")
 def create_customer(
     data: CreateCustomerRequest, 
-    user_token: str = Header(None, alias="User-key")  # 🔹 Pegando do "User-key"
+    user_token: str = Header(None, alias="User-key")
 ):
     try:
         if not user_token:
@@ -69,17 +69,25 @@ def create_customer(
         logger.info(f"🔹 User verified. user_id: {user_id}")
 
         # 🔹 Verificar se já existe um cliente com o mesmo e-mail no Stripe
-        existing_customers = stripe.Customer.list(email=data.email, limit=1)
+        logger.info(f"🔹 Checking if email {data.email} already exists in Stripe...")
 
+        existing_customers = stripe.Customer.list(email=data.email, limit=1)
         if existing_customers.data:
             error_message = f"Customer with email {data.email} already exists."
             logger.warning(f"⚠️ {error_message}")
             raise HTTPException(status_code=400, detail=error_message)
 
-        # 🔹 Verificar se já existe um cliente com o mesmo telefone
-        existing_customers_by_phone = stripe.Customer.list(phone=data.phone, limit=1)
+        # 🔹 Logar telefone antes da requisição
+        logger.info(f"🔹 Checking if phone {data.phone} already exists in Stripe...")
+
+        # 🔹 Buscar todos os clientes e filtrar manualmente pelo telefone (porque o Stripe não suporta busca direta)
+        all_customers = stripe.Customer.list(limit=100)  # Pegamos até 100 clientes para otimizar
+        existing_customer_by_phone = next(
+            (customer for customer in all_customers.auto_paging_iter() if customer.phone == data.phone), 
+            None
+        )
 
-        if existing_customers_by_phone.data:
+        if existing_customer_by_phone:
             error_message = f"Customer with phone {data.phone} already exists."
             logger.warning(f"⚠️ {error_message}")
             raise HTTPException(status_code=400, detail=error_message)
@@ -103,21 +111,17 @@ def create_customer(
         update_data = {"stripe_id": stripe_id}
 
         update_headers = {
-            "Authorization": f"Bearer {user_token}",  # 🔹 Token do usuário
-            "apikey": SUPABASE_KEY,  # 🔹 API Key do Supabase
+            "Authorization": f"Bearer {user_token}",
+            "apikey": SUPABASE_KEY,
             "Content-Type": "application/json"
         }
 
-        # 🔹 Corrigindo o nome da tabela (User com "U" maiúsculo)
         supabase_url = f"{SUPABASE_URL}/rest/v1/User?id=eq.{user_id}"
 
         response = requests.patch(supabase_url, headers=update_headers, json=update_data)
-        
-        # 🔹 Logando a resposta para debug
         logger.info(f"🔹 Supabase PATCH response: {response.status_code} - {response.text}")
 
         if response.status_code not in [200, 204]:
-            # 🚨 Se a atualização falhar, deletamos o cliente do Stripe!
             logger.warning(f"⚠️ Rolling back: Deleting Stripe customer {stripe_id} due to Supabase failure.")
             stripe.Customer.delete(stripe_id)
             error_message = f"Error updating Supabase: {response.text}"
@@ -125,7 +129,7 @@ def create_customer(
 
         logger.info(f"✅ Successfully updated user {user_id} with stripe_id {stripe_id}")
         return {"customer_id": stripe_id}
-    
+
     except HTTPException as http_err:
         raise http_err  # Já estruturamos o erro corretamente acima, então só propagamos.