fix repsponse eventOut

This commit is contained in:
2025-09-04 21:38:50 +02:00
parent 96aeb56195
commit 028adb6160
2 changed files with 59 additions and 9 deletions

View File

@@ -23,7 +23,7 @@ class Event(BaseModel):
disabled_at: datetime | None = None disabled_at: datetime | None = None
class EventOut(BaseModel): class EventOut(BaseModel):
id: ObjectIdField = None id: str | None = None
name: str name: str
place: str place: str
description: str description: str
@@ -35,6 +35,23 @@ class EventOut(BaseModel):
end_date: datetime | None = None end_date: datetime | None = None
tags: list[str] = [] tags: list[str] = []
@classmethod
def from_mongo(cls, event: Event) -> "EventOut":
return cls(
id=str(event.id) if event.id else None,
name=event.name,
place=event.place,
description=event.description,
imgUrl=event.imgUrl,
link=event.link,
ticket=event.ticket,
status=event.status,
start_date=event.start_date,
end_date=event.end_date,
tags=event.tags,
)
class EventIn(BaseModel): class EventIn(BaseModel):
name: str name: str
place: str place: str

View File

@@ -63,9 +63,10 @@ def build_text_filter(item):
@router.get("/events", tags=["events"], response_model=list[events.EventOut]) @router.get("/events", tags=["events"], response_model=list[events.EventOutWithInterested])
async def read_events( async def read_events(
authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))],
user: users.User = Depends(users_token.get_current_user), # 👈 récupère lutilisateur courant
skip: int = 0, skip: int = 0,
limit: int = 20, limit: int = 20,
id_event: str | None = None, id_event: str | None = None,
@@ -127,7 +128,9 @@ async def read_events(
event_repository = events.EventRepository(database=database.database) event_repository = events.EventRepository(database=database.database)
list_events = [] list_events = []
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip, sort=[("start_date", 1)]): for event_index in event_repository.find_by(object_search, limit=limit, skip=skip, sort=[("start_date", 1)]):
event = events.EventOut( interested_users = event_index.interested_users
is_interested = ObjectId(user.id) in interested_users
event = events.EventOutWithInterested(
id=event_index.id, id=event_index.id,
tags=event_index.tags, tags=event_index.tags,
imgUrl=event_index.imgUrl, imgUrl=event_index.imgUrl,
@@ -138,16 +141,19 @@ async def read_events(
start_date=event_index.start_date, start_date=event_index.start_date,
end_date=event_index.end_date, end_date=event_index.end_date,
ticket=event_index.ticket, ticket=event_index.ticket,
link=event_index.link link=event_index.link,
interested=is_interested,
interested_count=len(interested_users)
) )
list_events.append(event) list_events.append(event)
return list_events return list_events
@router.get("/events/search", tags=["events"], response_model=list[events.EventOut]) @router.get("/events/search", tags=["events"], response_model=list[events.EventOutWithInterested])
async def search_events( async def search_events(
authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))],
user: users.User = Depends(users_token.get_current_user), # 👈 récupère lutilisateur courant
skip: int = 0, skip: int = 0,
limit: int = 20, limit: int = 20,
item: Union[str, None] = None, item: Union[str, None] = None,
@@ -203,7 +209,9 @@ async def search_events(
event_repository = events.EventRepository(database=database.database) event_repository = events.EventRepository(database=database.database)
list_events = [] list_events = []
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip, sort=[("start_date", 1)]): for event_index in event_repository.find_by(object_search, limit=limit, skip=skip, sort=[("start_date", 1)]):
event = events.EventOut( interested_users = event_index.interested_users
is_interested = ObjectId(user.id) in interested_users
event = events.EventOutWithInterested(
id=event_index.id, id=event_index.id,
tags=event_index.tags, tags=event_index.tags,
imgUrl=event_index.imgUrl, imgUrl=event_index.imgUrl,
@@ -214,7 +222,9 @@ async def search_events(
start_date=event_index.start_date, start_date=event_index.start_date,
end_date=event_index.end_date, end_date=event_index.end_date,
link=event_index.link, link=event_index.link,
ticket=event_index.ticket ticket=event_index.ticket,
interested=is_interested,
interested_count=len(interested_users)
) )
list_events.append(event) list_events.append(event)
@@ -243,7 +253,7 @@ async def read_events_count(authorize: Annotated[bool, Depends(permissions_check
return response return response
@router.get("/events/{item_id}", tags=["events"], response_model=events.Event) @router.get("/events/{item_id}", tags=["events"], response_model=events.EventOut)
async def read_events_id(item_id : str, authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))]): async def read_events_id(item_id : str, authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))]):
event_repository = events.EventRepository(database=database.database) event_repository = events.EventRepository(database=database.database)
event = event_repository.find_one_by_id(ObjectId(item_id)) event = event_repository.find_one_by_id(ObjectId(item_id))
@@ -442,4 +452,27 @@ async def patch_events_id(item_id : str, authorize: Annotated[bool, Depends(perm
event_repository.save(event) event_repository.save(event)
content = {"message": "event is enabled"} content = {"message": "event is enabled"}
response = JSONResponse(content=content) response = JSONResponse(content=content)
return response return response
@router.post("/events/{event_id}/interest", tags=["events"])
async def toggle_interest(event_id: str, user: users.User = Depends(users_token.get_current_user)):
event_repository = events.EventRepository(database=database.database)
event = event_repository.find_one_by_id(ObjectId(event_id))
if not event:
raise HTTPException(status_code=404, detail="Event not found")
interested_users = event.interested_users
user_obj_id = ObjectId(user.id)
if user_obj_id in interested_users:
# Retirer lutilisateur
interested_users.remove(user_obj_id)
else:
# Ajouter lutilisateur
interested_users.append(user_obj_id)
event.interested_users = interested_users
event_repository.save(event)
return {"event_id": event_id, "interested": user_obj_id in interested_users, "interested_count": len(interested_users)}