[WIP] front api exchanges

backend/src/forms/forms.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, HTTPException, Depends
+from fastapi import APIRouter, HTTPException, Depends, Query
 import src.messages as messages
 import src.models as models
 from src.database import get_session
@@ -8,29 +8,33 @@ import src.forms.service as service
 router = APIRouter(prefix='/forms')
 
 @router.get('/', response_model=list[models.FormPublic])
-def get_forms(session: Session = Depends(get_session)):
-    return service.get_all(session)
+async def get_forms(
+    seasons: list[str] = Query([]),
+    productors: list[str] = Query([]),
+    session: Session = Depends(get_session)
+):
+    return service.get_all(session, seasons, productors)
 
 @router.get('/{id}', response_model=models.FormPublic)
-def get_forms(id: int, session: Session = Depends(get_session)):
+async def get_forms(id: int, session: Session = Depends(get_session)):
     result = service.get_one(session, id)
     if result is None:
         raise HTTPException(status_code=404, detail=messages.notfound)
     return result
 
 @router.post('/', response_model=models.FormPublic)
-def create_form(form: models.FormCreate, session: Session = Depends(get_session)):
+async def create_form(form: models.FormCreate, session: Session = Depends(get_session)):
     return service.create_one(session, form)
 
 @router.put('/{id}', response_model=models.FormPublic)
-def update_form(id: int, form: models.FormUpdate, session: Session = Depends(get_session)):
+async def update_form(id: int, form: models.FormUpdate, session: Session = Depends(get_session)):
     result = service.update_one(session, id, form)
     if result is None:
         raise HTTPException(status_code=404, detail=messages.notfound)
     return result
 
 @router.delete('/{id}', response_model=models.FormPublic)
-def delete_form(id: int, session: Session = Depends(get_session)):
+async def delete_form(id: int, session: Session = Depends(get_session)):
     result = service.delete_one(session, id)
     if result is None:
         raise HTTPException(status_code=404, detail=messages.notfound)

backend/src/forms/service.py

@@ -1,8 +1,16 @@
 from sqlmodel import Session, select
 import src.models as models
 
-def get_all(session: Session) -> list[models.FormPublic]:
+def get_all(
+    session: Session, 
+    seasons: list[str],
+    productors: list[str]
+) -> list[models.FormPublic]:
     statement = select(models.Form)
+    if len(seasons) > 0:
+        statement = statement.where(models.Form.season.in_(seasons))
+    if len(productors) > 0:
+        statement = statement.join(models.Productor).where(models.Productor.name.in_(productors))
     return session.exec(statement).all()
 
 def get_one(session: Session, form_id: int) -> models.FormPublic: