feat: added API and db function for get events for given year

Author: arunPdl02

src/event/crud.py

@@ -1,13 +1,29 @@
 from collections.abc import Sequence
 
-import sqlalchemy
+from sqlalchemy import select, or_, and_, extract
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from event.tables import EventDB
 
+from datetime import datetime, date
+
 
 async def get_all_events(
     db_session: AsyncSession
 ) -> Sequence[EventDB]:
-    events = (await db_session.scalars(sqlalchemy.select(EventDB))).all()
+    events = (await db_session.scalars(select(EventDB))).all()
+    return events
+
+
+async def get_events_for_this_year(
+    db_session: AsyncSession,
+    year: int,
+) -> Sequence[EventDB]:
+    events = (await db_session.scalars(select(EventDB).where
+    (
+        or_(
+            extract('year', EventDB.start_time) == year, 
+            extract('year', EventDB.end_time) == year
+        )
+    ))).all()
     return events

src/event/urls.py

@@ -11,6 +11,7 @@
 )
 from event.tables import EventDB
 from utils.shared_models import DetailModel, SuccessResponse
+from datetime import datetime, date
 
 router = APIRouter(
     prefix="/event",
@@ -31,4 +32,20 @@ async def get_all_events(
 ):
     events_list = await event.crud.get_all_events(db_session)
 
+    return events_list
+
+
+@router.get(
+    "/{year}",
+    description="Get events that start OR end in this year",
+    response_model=list[EventPublic],
+    # responses= {}
+    operation_id="get_events_for_this_year"
+)
+async def get_events_for_this_year(
+    db_session: database.DBSession,
+    year: int,
+):
+    events_list = await event.crud.get_events_for_this_year(db_session, year)
+
     return events_list