from fastapi import APIRouter, Depends, HTTPException from sqlalchemy.orm import Session from app.models.forum import ForumMessage from app.schemas.forum import ForumMessageCreate, ForumMessageResponse from app.api.dependencies import get_db from typing import List router = APIRouter() @router.post("/messages", response_model=ForumMessageResponse) def create_message(message: ForumMessageCreate, db: Session = Depends(get_db)): new_message = ForumMessage(**message.dict()) db.add(new_message) db.commit() db.refresh(new_message) return new_message @router.get("/messages", response_model=List[ForumMessageResponse]) def get_messages(db: Session = Depends(get_db)): messages = db.query(ForumMessage).order_by(ForumMessage.created_at.asc()).all() return messages