# Entity: Message ```python from fastapi import APIRouter, Depends, HTTPException, status from sqlalchemy.orm import Session from typing import List from core.database import get_db from core.models.message import Message from core.schemas.message import MessageSchema, MessageCreate router = APIRouter() @router.get("/messages", status_code=200, response_model=List[MessageSchema]) async def get_user_messages( user_id: int, db: Session = Depends(get_db) ): messages = db.query(Message).filter( (Message.sender_id == user_id) | (Message.receiver_id == user_id) ).order_by(Message.created_at.desc()).all() return messages ```