backend for queues & minor front tweaks

backend/app/views/queue/api.py

@@ -0,0 +1,41 @@
+from datetime import datetime, timedelta, timezone
+from typing import Annotated, Union
+from sqlalchemy.orm import Session
+
+from fastapi import APIRouter, Depends, HTTPException, status
+from fastapi.security import OAuth2PasswordRequestForm
+
+
+from pydantic import BaseModel
+
+from ...config import jwt_config
+from ...dependencies import get_db
+from . import schemas
+from . import services
+
+from ..auth import services as auth_services
+from ..auth import schemas as auth_schemas
+
+
+router = APIRouter(
+    prefix="/queue",
+    tags=["queue"],
+    dependencies=[Depends(get_db)],
+    responses={404: {"description": "Not found"}},
+)
+
+
+@router.get("/")
+async def user_queues_list(
+    queues: Annotated[schemas.Queue, Depends(services.get_user_queues)],
+) -> list[schemas.QueueInDb]:
+    return queues
+
+
+@router.post("/")
+async def create_queue(
+    new_queue: schemas.Queue,
+    current_user: Annotated[auth_schemas.User, Depends(auth_services.get_current_user)],
+    db: Annotated[Session, Depends(get_db)],
+) -> schemas.QueueInDb:
+    return services.create_queue(new_queue=new_queue, current_user=current_user, db=db)

backend/app/views/queue/schemas.py

@@ -0,0 +1,27 @@
+from typing import Union
+from pydantic import BaseModel
+from uuid import UUID
+
+
+class ParticipantInfo(BaseModel):
+    total: int
+    remaining: int
+
+
+class Queue(BaseModel):
+    name: str
+    description: Union[str, None] = None
+
+
+class QueueInList(Queue):
+    participants: ParticipantInfo
+
+    class Config:
+        from_attributes = True
+
+
+class QueueInDb(Queue):
+    id: UUID
+
+    class Config:
+        from_attributes = True

backend/app/views/queue/services.py

@@ -0,0 +1,30 @@
+from fastapi import Depends
+from typing import Annotated
+from sqlalchemy.orm import Session
+
+from ...dependencies import get_db
+from ...db import models
+
+from ..auth import services as auth_services
+from ..auth import schemas as auth_schemas
+
+from . import schemas
+
+
+def get_user_queues(
+    current_user: Annotated[auth_schemas.User, Depends(auth_services.get_current_user)]
+) -> list[schemas.QueueInDb]:
+    return [schemas.QueueInDb.model_validate(q) for q in current_user.owns_queues]
+
+
+def create_queue(
+    new_queue: schemas.Queue,
+    current_user: auth_schemas.UserInDB,
+    db: Session,
+) -> schemas.QueueInDb:
+    q = models.Queue(
+        name=new_queue.name, description=new_queue.description, owner_id=current_user.id
+    )
+    db.add(q)
+    db.commit()
+    return schemas.QueueInDb.model_validate(q)