pvbang/nexus/api-builder

from fastapi import APIRouter, Depends, HTTPException, status, Query
from pydantic import BaseModel, Field
from datetime import datetime
router = APIRouter(prefix="/api/v1/posts", tags=["posts"])
class PostCreate(BaseModel):
    title: str = Field(..., min_length=1, max_length=200, example="My First Post")
    content: str = Field(..., min_length=1, example="Hello world!")
    published: bool = Field(default=False)
class PostResponse(PostCreate):
    id: int
    created_at: datetime
    model_config = {"from_attributes": True}
@router.post("/", response_model=PostResponse, status_code=status.HTTP_201_CREATED)
async def create_post(post: PostCreate, db=Depends(get_db)):
    return await post_service.create(db, post)
@router.get("/", response_model=list[PostResponse])
async def list_posts(skip: int = Query(0, ge=0), limit: int = Query(20, le=100)):
    return await post_service.list(db, skip=skip, limit=limit)

from fastapi import Depends, HTTPException, status
from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
from jose import JWTError, jwt
security = HTTPBearer()
async def get_current_user(
    credentials: HTTPAuthorizationCredentials = Depends(security),
    db=Depends(get_db),
) -> User:
    """Validate JWT token and return current user."""
    try:
        payload = jwt.decode(credentials.credentials, SECRET_KEY, algorithms=["HS256"])
        user_id: int = payload.get("sub")
        if user_id is None:
            raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED)
    except JWTError:
        raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED)
    user = await user_service.get_by_id(db, user_id)
    if user is None:
        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND)
    return user