feat: add user model and registration endpoint

This commit is contained in:
Indiana
2026-07-20 15:14:31 +00:00
parent 9e69c622c9
commit cfffc7ff59
9 changed files with 147 additions and 7 deletions

View File

@@ -1,6 +1,21 @@
from contextlib import asynccontextmanager
from fastapi import FastAPI from fastapi import FastAPI
app = FastAPI(title="Quantumancy") import app.models # noqa: F401 — registers models on Base.metadata before create_all
from app.db import Base, engine
from app.routes.auth import router as auth_router
@asynccontextmanager
async def lifespan(app: FastAPI):
async with engine.begin() as conn:
await conn.run_sync(Base.metadata.create_all)
yield
app = FastAPI(title="Quantumancy", lifespan=lifespan)
app.include_router(auth_router)
@app.get("/healthz") @app.get("/healthz")

View File

@@ -0,0 +1,3 @@
from app.models.user import User
__all__ = ["User"]

View File

@@ -0,0 +1,19 @@
import uuid
from datetime import datetime, timezone
from sqlalchemy import DateTime, String
from sqlalchemy.orm import Mapped, mapped_column
from app.db import Base
class User(Base):
__tablename__ = "users"
id: Mapped[uuid.UUID] = mapped_column(primary_key=True, default=uuid.uuid4)
username: Mapped[str] = mapped_column(String(32), unique=True, index=True)
password_hash: Mapped[str] = mapped_column(String(255))
email: Mapped[str | None] = mapped_column(String(255), nullable=True)
created_at: Mapped[datetime] = mapped_column(
DateTime(timezone=True), default=lambda: datetime.now(timezone.utc)
)

View File

View File

@@ -0,0 +1,27 @@
from fastapi import APIRouter, Depends, HTTPException, status
from sqlalchemy import select
from sqlalchemy.ext.asyncio import AsyncSession
from app.db import get_db
from app.models.user import User
from app.schemas import RegisterRequest, UserOut
from app.security import hash_password
router = APIRouter(prefix="/auth", tags=["auth"])
@router.post("/register", response_model=UserOut, status_code=status.HTTP_201_CREATED)
async def register(payload: RegisterRequest, db: AsyncSession = Depends(get_db)):
existing = await db.scalar(select(User).where(User.username == payload.username))
if existing is not None:
raise HTTPException(status_code=status.HTTP_409_CONFLICT, detail="username taken")
user = User(
username=payload.username,
password_hash=hash_password(payload.password),
email=payload.email,
)
db.add(user)
await db.commit()
await db.refresh(user)
return user

17
backend/app/schemas.py Normal file
View File

@@ -0,0 +1,17 @@
import uuid
from pydantic import BaseModel, Field
class RegisterRequest(BaseModel):
username: str = Field(min_length=3, max_length=32)
password: str = Field(min_length=8, max_length=128)
email: str | None = None
class UserOut(BaseModel):
id: uuid.UUID
username: str
class Config:
from_attributes = True

15
backend/app/security.py Normal file
View File

@@ -0,0 +1,15 @@
from argon2 import PasswordHasher
from argon2.exceptions import VerifyMismatchError
_hasher = PasswordHasher()
def hash_password(password: str) -> str:
return _hasher.hash(password)
def verify_password(password: str, password_hash: str) -> bool:
try:
return _hasher.verify(password_hash, password)
except VerifyMismatchError:
return False

View File

@@ -1,8 +1,31 @@
import os import pytest_asyncio
from httpx import ASGITransport, AsyncClient
from sqlalchemy.ext.asyncio import async_sessionmaker
from app.db import Base, engine, get_db
from app.main import app
TestSessionLocal = async_sessionmaker(engine, expire_on_commit=False)
def pytest_configure(config): @pytest_asyncio.fixture(autouse=True)
"""Set up minimal environment variables for tests before any imports.""" async def _reset_db():
os.environ.setdefault("DATABASE_URL", "postgresql+asyncpg://test:test@localhost/test") async with engine.begin() as conn:
os.environ.setdefault("OLLAMA_BASE_URL", "http://localhost:11434") await conn.run_sync(Base.metadata.drop_all)
os.environ.setdefault("SESSION_SECRET", "test-secret-key") await conn.run_sync(Base.metadata.create_all)
yield
async def _override_get_db():
async with TestSessionLocal() as session:
yield session
app.dependency_overrides[get_db] = _override_get_db
@pytest_asyncio.fixture
async def client():
transport = ASGITransport(app=app)
async with AsyncClient(transport=transport, base_url="http://test") as ac:
yield ac

View File

@@ -0,0 +1,21 @@
import pytest
@pytest.mark.asyncio
async def test_register_creates_user(client):
response = await client.post(
"/auth/register",
json={"username": "medium1", "password": "spookyspooky"},
)
assert response.status_code == 201
body = response.json()
assert body["username"] == "medium1"
assert "id" in body
assert "password" not in body
@pytest.mark.asyncio
async def test_register_duplicate_username_rejected(client):
await client.post("/auth/register", json={"username": "medium1", "password": "spookyspooky"})
response = await client.post("/auth/register", json={"username": "medium1", "password": "anotherpass"})
assert response.status_code == 409