Added API Endpoints for Meetings

Author: Prijam-01

backend/app/api/main.py

@@ -1,13 +1,14 @@
 from fastapi import APIRouter
 
-from app.api.routes import items, login, private, users, utils
+from app.api.routes import items, login, meetings, private, users, utils
 from app.core.config import settings
 
 api_router = APIRouter()
 api_router.include_router(login.router)
 api_router.include_router(users.router)
 api_router.include_router(utils.router)
 api_router.include_router(items.router)
+api_router.include_router(meetings.router)
 
 
 if settings.ENVIRONMENT == "local":

backend/app/api/routes/meetings.py

@@ -0,0 +1,95 @@
+from typing import Any
+from uuid import UUID
+
+from fastapi import APIRouter, Depends, HTTPException
+from sqlmodel import Session
+
+from app import crud
+from app.api import deps
+from app.models import (
+    Meeting,
+    MeetingCreate,
+    MeetingUpdate,
+    MeetingPublic,
+    MeetingsPublic,
+)
+
+router = APIRouter(prefix="/meetings", tags=["meetings"])
+
+
+@router.get("", response_model=MeetingsPublic)
+def read_meetings(
+    *,
+    session: Session = Depends(deps.get_session),
+    skip: int = 0,
+    limit: int = 100,
+) -> Any:
+    """
+    Retrieve meetings.
+    """
+    meetings, total = crud.meeting.get_meetings(
+        session=session, skip=skip, limit=limit
+    )
+    return MeetingsPublic(data=meetings, count=total)
+
+
+@router.post("", response_model=MeetingPublic)
+def create_meeting(
+    *,
+    session: Session = Depends(deps.get_session),
+    meeting_in: MeetingCreate,
+) -> Any:
+    """
+    Create new meeting.
+    """
+    meeting = crud.meeting.create_meeting(session=session, meeting_in=meeting_in)
+    return meeting
+
+
+@router.get("/{meeting_id}", response_model=MeetingPublic)
+def read_meeting(
+    *,
+    session: Session = Depends(deps.get_session),
+    meeting_id: UUID,
+) -> Any:
+    """
+    Get meeting by ID.
+    """
+    meeting = crud.meeting.get_meeting(session=session, meeting_id=meeting_id)
+    if not meeting:
+        raise HTTPException(status_code=404, detail="Meeting not found")
+    return meeting
+
+
+@router.put("/{meeting_id}", response_model=MeetingPublic)
+def update_meeting(
+    *,
+    session: Session = Depends(deps.get_session),
+    meeting_id: UUID,
+    meeting_in: MeetingUpdate,
+) -> Any:
+    """
+    Update a meeting.
+    """
+    meeting = crud.meeting.get_meeting(session=session, meeting_id=meeting_id)
+    if not meeting:
+        raise HTTPException(status_code=404, detail="Meeting not found")
+    meeting = crud.meeting.update_meeting(
+        session=session, db_obj=meeting, obj_in=meeting_in
+    )
+    return meeting
+
+
+@router.delete("/{meeting_id}", response_model=MeetingPublic)
+def delete_meeting(
+    *,
+    session: Session = Depends(deps.get_session),
+    meeting_id: UUID,
+) -> Any:
+    """
+    Delete a meeting.
+    """
+    meeting = crud.meeting.delete_meeting(session=session, meeting_id=meeting_id)
+    if not meeting:
+        raise HTTPException(status_code=404, detail="Meeting not found")
+    return meeting

backend/app/crud.py

@@ -1,10 +1,11 @@
 import uuid
 from typing import Any
+from uuid import UUID
 
 from sqlmodel import Session, select
 
 from app.core.security import get_password_hash, verify_password
-from app.models import Item, ItemCreate, User, UserCreate, UserUpdate
+from app.models import Item, ItemCreate, User, UserCreate, UserUpdate, Meeting, MeetingCreate, MeetingUpdate
 
 
 def create_user(*, session: Session, user_create: UserCreate) -> User:
@@ -52,3 +53,43 @@ def create_item(*, session: Session, item_in: ItemCreate, owner_id: uuid.UUID) -
     session.commit()
     session.refresh(db_item)
     return db_item
+
+
+def create_meeting(*, session: Session, meeting_in: MeetingCreate) -> Meeting:
+    db_obj = Meeting.model_validate(meeting_in)
+    session.add(db_obj)
+    session.commit()
+    session.refresh(db_obj)
+    return db_obj
+
+
+def get_meeting(*, session: Session, meeting_id: UUID) -> Meeting | None:
+    return session.get(Meeting, meeting_id)
+
+
+def get_meetings(
+    *, session: Session, skip: int = 0, limit: int = 100
+) -> tuple[list[Meeting], int]:
+    statement = select(Meeting).offset(skip).limit(limit)
+    meetings = session.exec(statement).all()
+    total = session.query(Meeting).count()
+    return meetings, total
+
+
+def update_meeting(
+    *, session: Session, db_obj: Meeting, obj_in: MeetingUpdate
+) -> Meeting:
+    update_data = obj_in.model_dump(exclude_unset=True)
+    db_obj.sqlmodel_update(update_data)
+    session.add(db_obj)
+    session.commit()
+    session.refresh(db_obj)
+    return db_obj
+
+
+def delete_meeting(*, session: Session, meeting_id: UUID) -> Meeting | None:
+    meeting = session.get(Meeting, meeting_id)
+    if meeting:
+        session.delete(meeting)
+        session.commit()
+    return meeting