Compare commits
7 Commits
Author | SHA1 | Date | |
---|---|---|---|
45d4ac30bd | |||
5f24657956 | |||
46b1f80b53 | |||
e5510cc390 | |||
1470d8976e | |||
5e462861e2 | |||
bf47256519 |
@@ -128,7 +128,7 @@ 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)]):
|
||||||
interested_users = getattr(event_index, "interested_users", [])
|
interested_users = event_index.interested_users
|
||||||
is_interested = ObjectId(user.id) in interested_users
|
is_interested = ObjectId(user.id) in interested_users
|
||||||
event = events.EventOutWithInterested(
|
event = events.EventOutWithInterested(
|
||||||
id=event_index.id,
|
id=event_index.id,
|
||||||
@@ -209,7 +209,7 @@ 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)]):
|
||||||
interested_users = getattr(event_index, "interested_users", [])
|
interested_users = event_index.interested_users
|
||||||
is_interested = ObjectId(user.id) in interested_users
|
is_interested = ObjectId(user.id) in interested_users
|
||||||
event = events.EventOutWithInterested(
|
event = events.EventOutWithInterested(
|
||||||
id=event_index.id,
|
id=event_index.id,
|
||||||
@@ -457,12 +457,12 @@ async def patch_events_id(item_id : str, authorize: Annotated[bool, Depends(perm
|
|||||||
@router.post("/events/{event_id}/interest", tags=["events"])
|
@router.post("/events/{event_id}/interest", tags=["events"])
|
||||||
async def toggle_interest(event_id: str, user: users.User = Depends(users_token.get_current_user)):
|
async def toggle_interest(event_id: str, user: users.User = Depends(users_token.get_current_user)):
|
||||||
event_repository = events.EventRepository(database=database.database)
|
event_repository = events.EventRepository(database=database.database)
|
||||||
event = event_repository.get(ObjectId(event_id))
|
event = event_repository.find_one_by_id(ObjectId(event_id))
|
||||||
|
|
||||||
if not event:
|
if not event:
|
||||||
raise HTTPException(status_code=404, detail="Event not found")
|
raise HTTPException(status_code=404, detail="Event not found")
|
||||||
|
|
||||||
interested_users = getattr(event, "interested_users", [])
|
interested_users = event.interested_users
|
||||||
user_obj_id = ObjectId(user.id)
|
user_obj_id = ObjectId(user.id)
|
||||||
|
|
||||||
if user_obj_id in interested_users:
|
if user_obj_id in interested_users:
|
||||||
@@ -471,7 +471,8 @@ async def toggle_interest(event_id: str, user: users.User = Depends(users_token.
|
|||||||
else:
|
else:
|
||||||
# Ajouter l’utilisateur
|
# Ajouter l’utilisateur
|
||||||
interested_users.append(user_obj_id)
|
interested_users.append(user_obj_id)
|
||||||
|
event.interested_users = interested_users
|
||||||
|
|
||||||
event_repository.update({"_id": ObjectId(event_id)}, {"$set": {"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)}
|
return {"event_id": event_id, "interested": user_obj_id in interested_users, "interested_count": len(interested_users)}
|
||||||
|
Reference in New Issue
Block a user