JourneyPoint / journeypoint / app / api / routes / forum.py
forum.py
Raw
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