Update routes/subscription.py

routes/subscription.py

@@ -71,6 +71,7 @@ def verify_token(user_token: str) -> str:
     else:
         raise HTTPException(status_code=401, detail="Invalid or expired token")
 
+
 @router.post("/subscription_details")
 async def subscription_details(data: SubscriptionRequest):
     try:
@@ -360,9 +361,10 @@ async def stripe_webhook(request: Request):
             stylist_id = payment_intent.get("metadata", {}).get("stylist_id")
             client_id = payment_intent.get("metadata", {}).get("client_id")
             subscription_id = payment_intent.get("metadata", {}).get("subscription_id")
+            payment_id = payment_intent.get("id")  # Payment ID
             amount_received = payment_intent.get("amount_received", 0)  # Valor recebido (em centavos)
         
-            if not all([stylist_id, client_id, subscription_id]):
+            if not all([stylist_id, client_id, subscription_id, payment_id]):
                 logger.error("❌ Faltando dados essenciais no metadado do Payment Intent.")
                 return {"status": "error", "message": "Missing essential metadata."}
         
@@ -370,6 +372,7 @@ async def stripe_webhook(request: Request):
             logger.info(f"👤 Client ID: {client_id}")
             logger.info(f"👗 Stylist ID: {stylist_id}")
             logger.info(f"💰 Price: R$ {amount_received / 100:.2f}")
+            logger.info(f"💳 Payment ID: {payment_id}")
         
             # 🔹 Definindo os cabeçalhos do Supabase
             supabase_headers = {
@@ -378,12 +381,21 @@ async def stripe_webhook(request: Request):
                 "Content-Type": "application/json"
             }
         
+            # 🔹 Verificar se o payment_id já existe na tabela Emergency_sub
+            check_url = f"{SUPABASE_URL}/rest/v1/Emergency_sub?payment_id=eq.{payment_id}"
+            response_check = requests.get(check_url, headers=supabase_headers)
+        
+            if response_check.status_code == 200 and len(response_check.json()) > 0:
+                logger.info(f"❌ Payment ID {payment_id} já existe. Nenhuma nova linha será inserida.")
+                return {"status": "error", "message": "Payment ID already exists."}
+        
             # 🔹 Inserir dados na tabela Emergency_sub no Supabase
             emergency_sub_data = {
                 "sub_id": subscription_id,  # Subscription ID
                 "stylist_id": stylist_id,    # Stylist ID
                 "client_id": client_id,      # Client ID
-                "price": amount_received     # Price in cents
+                "price": amount_received,    # Price in cents
+                "payment_id": payment_id    # Payment ID
             }
         
             emergency_sub_url = f"{SUPABASE_URL}/rest/v1/Emergency_sub"