@@ -1,9 +1,26 @@
-from fastapi import APIRouter
-
+from fastapi import APIRouter, Depends
+from sqlmodel import Session
 
+from api.db import get_session
+from .models import ChatMessagePayload, ChatMessage
 router = APIRouter()
 
 # /api/chats/
 @router.get("/")
 def chat_health():
-return {"status": "ok"}
+return {"status": "ok"}
+
+
+# HTTP POST -> payload = {"message": "Hello world"} -> {"message": "hello world", "id": 1}
+@router.post("/", response_model=ChatMessage)
+def chat_create_message(
+payload:ChatMessagePayload,
+session: Session = Depends(get_session)
+):
+data = payload.model_dump() # pydantic -> dict
+obj = ChatMessage.model_validate(data)
+session.add(obj)
+session.commit()
+session.refresh(obj) # ensure id/primary key added to the obj instance
+# ready to store in the database
+return obj

@@ -12,6 +12,7 @@
 engine = sqlmodel.create_engine(DATABASE_URL)
 
 # database models
+# does not create db migrations
 def init_db():
 print("creating database tables...")
 SQLModel.metadata.create_all(engine)