Initial commit

backend/routers/samples.py

@@ -0,0 +1,64 @@
+from fastapi import APIRouter, Depends, HTTPException
+from sqlalchemy.ext.asyncio import AsyncSession
+from sqlalchemy import select
+
+from database import get_db
+from models import Sample
+from schemas import SampleResponse, SampleCreate, SampleUpdate
+
+router = APIRouter(prefix="/api", tags=["samples"])
+
+
+@router.get("/samples", response_model=list[SampleResponse])
+async def list_samples(db: AsyncSession = Depends(get_db)):
+    result = await db.execute(select(Sample).order_by(Sample.id))
+    return result.scalars().all()
+
+
+@router.get("/samples/{sample_id}", response_model=SampleResponse)
+async def get_sample(sample_id: int, db: AsyncSession = Depends(get_db)):
+    result = await db.execute(select(Sample).where(Sample.id == sample_id))
+    sample = result.scalar_one_or_none()
+    if not sample:
+        raise HTTPException(status_code=404, detail="Sample not found")
+    return sample
+
+
+@router.post("/samples", response_model=SampleResponse, status_code=201)
+async def create_sample(body: SampleCreate, db: AsyncSession = Depends(get_db)):
+    sample = Sample(title=body.title, content=body.content, author=body.author)
+    db.add(sample)
+    await db.commit()
+    await db.refresh(sample)
+    return sample
+
+
+@router.put("/samples/{sample_id}", response_model=SampleResponse)
+async def update_sample(
+    sample_id: int, body: SampleUpdate, db: AsyncSession = Depends(get_db)
+):
+    result = await db.execute(select(Sample).where(Sample.id == sample_id))
+    sample = result.scalar_one_or_none()
+    if not sample:
+        raise HTTPException(status_code=404, detail="Sample not found")
+
+    if body.title is not None:
+        sample.title = body.title
+    if body.content is not None:
+        sample.content = body.content
+    if body.author is not None:
+        sample.author = body.author
+
+    await db.commit()
+    await db.refresh(sample)
+    return sample
+
+
+@router.delete("/samples/{sample_id}", status_code=204)
+async def delete_sample(sample_id: int, db: AsyncSession = Depends(get_db)):
+    result = await db.execute(select(Sample).where(Sample.id == sample_id))
+    sample = result.scalar_one_or_none()
+    if not sample:
+        raise HTTPException(status_code=404, detail="Sample not found")
+    await db.delete(sample)
+    await db.commit()