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