Ensure the generated user_id is unique

main.py

@@ -113,7 +113,12 @@ def create_device_token(username: str, user_agent: str) -> str:
 def is_token_expired(expiration_time: datetime) -> bool:
     return datetime.now(timezone.utc) > expiration_time
 
-async def create_user(username: str, password: str, email: Optional[str] = None, access_level   : Optional[str] = None):
+async def create_user(
+    username: str,
+    password: str,
+    email: Optional[str] = None,
+    access_level: Optional[str] = None,
+):
     """
     Creates a new user in the database.
 
@@ -121,6 +126,7 @@ async def create_user(username: str, password: str, email: Optional[str] = None,
         username: The username of the new user.
         password: The password of the new user (hashed).
         email: The email address of the new user (optional).
+        access_level: The access level of the new user (optional).
 
     Returns:
         The created user object.
@@ -129,14 +135,23 @@ async def create_user(username: str, password: str, email: Optional[str] = None,
         HTTPException: If the username already exists.
     """
 
+    # Check if the username already exists
     existing_user = supabase.table("users").select("*").eq("username", username).execute()
     if existing_user.data:
         raise HTTPException(
             status_code=status.HTTP_400_BAD_REQUEST, detail="Username already exists"
         )
 
+    # Ensure the generated user_id is unique
+    while True:
+        user_id = generate_numeric_user_id()
+        existing_user_id = supabase.table("users").select("*").eq("user_id", user_id).execute()
+        if not existing_user_id.data:
+            break
+
+    # Prepare user data
     user_data = {
-        "user_id": generate_numeric_user_id(),
+        "user_id": user_id,
         "username": username,
         "password": password,
         "email": email,
@@ -144,6 +159,7 @@ async def create_user(username: str, password: str, email: Optional[str] = None,
         "access_level": access_level or "default",
     }
 
+    # Insert the user into the database
     inserted_user = supabase.table("users").insert(user_data).execute()
     return inserted_user.data[0]