Update routes/subscription.py

routes/subscription.py

@@ -81,13 +81,17 @@ async def sync_emergency_payments(request: Request, data: EmergencyPaymentReques
         
         # Passo 2: Validar o token e obter o user_id
         user_id = verify_token(user_token)
+        logger.info(f"User ID from token: {user_id}")
 
         # Passo 3: Buscar o stripe_id associado ao user_id no Supabase
         response = requests.get(
             f"{SUPABASE_URL}/rest/v1/User?user_id=eq.{user_id}",
             headers=SUPABASE_HEADERS
         )
-        
+
+        # Log para verificar a resposta da consulta ao Supabase
+        logger.info(f"Supabase response for user {user_id}: {response.status_code} {response.text}")
+
         if response.status_code != 200 or not response.json():
             raise HTTPException(status_code=404, detail="User not found in database")
         
@@ -103,7 +107,10 @@ async def sync_emergency_payments(request: Request, data: EmergencyPaymentReques
             f"{SUPABASE_URL}/rest/v1/Emergency_sub?client_id=eq.{user_id}&stylist_id=eq.{stylist_id}",
             headers=SUPABASE_HEADERS
         )
-        
+
+        # Log para verificar a resposta da consulta de pagamentos
+        logger.info(f"Supabase response for emergency payments: {response_payments.status_code} {response_payments.text}")
+
         if response_payments.status_code != 200:
             raise HTTPException(status_code=500, detail="Failed to fetch emergency payments")
 
@@ -111,21 +118,17 @@ async def sync_emergency_payments(request: Request, data: EmergencyPaymentReques
         logger.info(f"Found {len(existing_payments)} emergency payments for stylist {stylist_id} and customer {user_id}")
 
         # Passo 5: Verificar os pagamentos e inserir os que faltam
-        # Aqui é onde a lógica de inserção vai ocorrer se o pagamento não for encontrado
-        emergency_sub_data = {
-            "stylist_id": stylist_id,
-            "client_id": user_id,
-            "payment_id": None,  # ID do pagamento, se aplicável
-            "price": 0,  # Valor do pagamento
-            # Adicione outros campos se necessário
-        }
-
-        # Exemplo de lógica de verificação de pagamento (substitua conforme o seu fluxo de dados)
         for payment in existing_payments:
             payment_id = payment.get("payment_id")
             if not payment_id:
                 # Inserir pagamento de emergência que não foi encontrado
-                emergency_sub_data["payment_id"] = payment_id  # Exemplo de dado de pagamento
+                emergency_sub_data = {
+                    "stylist_id": stylist_id,
+                    "client_id": user_id,
+                    "payment_id": payment_id,  # Exemplo de dado de pagamento
+                    "price": 0,  # Valor do pagamento
+                    # Adicione outros campos se necessário
+                }
                 response_insert = requests.post(
                     f"{SUPABASE_URL}/rest/v1/Emergency_sub",
                     headers=SUPABASE_HEADERS,
@@ -135,7 +138,7 @@ async def sync_emergency_payments(request: Request, data: EmergencyPaymentReques
                 if response_insert.status_code == 201:
                     logger.info(f"Payment {payment_id} added successfully")
                 else:
-                    logger.error(f"Failed to add payment {payment_id}: {response_insert.status_code}")
+                    logger.error(f"Failed to add payment {payment_id}: {response_insert.status_code} - {response_insert.text}")
         
         return {"status": "success", "message": "Emergency payments synchronized successfully"}