helper function create user

main.py

@@ -14,7 +14,7 @@ from typing import Optional
 load_dotenv()
 
 SERVER_NAME = "Nexus Authentication Service"
-VERSION = "1.0.4 debug"
+VERSION = "1.0.5 debug"
 
 # Supabase Configuration
 SUPABASE_URL = os.getenv("SUPABASE_URL")
@@ -109,22 +109,43 @@ 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):
+    """
+    Creates a new user in the database.
 
-# Initialize system user
-async def init_system_user():
-    system_user_data = {
-        "user_id": str(uuid.uuid4()),
-        "username": SYSTEM_USER,
-        "password": hash_password(SYSTEM_PASSWORD),
-        "email": None,
+    Args:
+        username: The username of the new user.
+        password: The password of the new user (hashed).
+        email: The email address of the new user (optional).
+
+    Returns:
+        The created user object.
+
+    Raises:
+        HTTPException: 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"
+        )
+
+    user_data = {
+        "user_id": await generate_numeric_user_id(),
+        "username": username,
+        "password": password,
+        "email": email,
         "date_joined": datetime.now(timezone.utc).isoformat(),
-        "access_level": "hush"
+        "access_level": "default",
     }
-    
-    # Check if system user exists
-    existing_user = supabase.table("users").select("*").eq("username", SYSTEM_USER).execute()
-    if not existing_user.data:
-        supabase.table("users").insert(system_user_data).execute()
+
+    inserted_user = supabase.table("users").insert(user_data).execute()
+    return inserted_user.data[0]
+
+# Initialize system user
+async def init_system_user():
+    await create_user(SYSTEM_USER, hash_password(SYSTEM_PASSWORD), None)
 
 
 @root_router.get("/", status_code=status.HTTP_200_OK)
@@ -135,24 +156,20 @@ async def root():
 # Authentication Routes
 @auth_router.post("/signup", status_code=status.HTTP_201_CREATED)
 async def signup(request: SignupRequest):
-    # Check if username exists
-    existing_user = supabase.table("users").select("*").eq("username", request.username).execute()
-    if existing_user.data:
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST, detail="Username already exists"
-        )
+    """
+    Signup route handler.
 
-    user_data = {
-        "user_id": generate_numeric_user_id(),
-        "username": request.username,
-        "password": hash_password(request.password),
-        "email": request.email,
-        "date_joined": datetime.now(timezone.utc).isoformat(),
-        "access_level": "default"
-    }
-    
-    supabase.table("users").insert(user_data).execute()
-    return {"message": "User created successfully"}
+    Uses the create_user helper function to create a new user.
+
+    Args:
+        request: Signup request data.
+
+    Returns:
+        A JSON response with a success message.
+    """
+
+    created_user = await create_user(request.username, hash_password(request.password), request.email)
+    return {"message": "User created successfully", "user": created_user}
 
 from datetime import datetime, timedelta, timezone