diff --git a/backend/app/routers/listeners.py b/backend/app/routers/listeners.py index a1179fdc5..06a98367d 100644 --- a/backend/app/routers/listeners.py +++ b/backend/app/routers/listeners.py @@ -265,7 +265,7 @@ async def search_listeners( Or( EventListenerDB.access == None, EventListenerDB.access.owner == user_id, - In(EventListenerDB.access.users, user_id), + EventListenerDB.access.users == user_id, In(EventListenerDB.access.groups, user_groups), ) ) @@ -274,7 +274,7 @@ async def search_listeners( Or( EventListenerDB.access == None, EventListenerDB.access.owner == user_id, - In(EventListenerDB.access.users, user_id), + EventListenerDB.access.users == user_id, In(EventListenerDB.access.groups, user_groups), EventListenerDB.access.datasets == PydanticObjectId(dataset_id), ) @@ -422,7 +422,7 @@ async def get_listeners( Or( EventListenerDB.access == None, EventListenerDB.access.owner == user_id, - In(EventListenerDB.access.users, user_id), + EventListenerDB.access.users == user_id, In(EventListenerDB.access.groups, user_groups), ) ) @@ -431,7 +431,7 @@ async def get_listeners( Or( EventListenerDB.access == None, EventListenerDB.access.owner == user_id, - In(EventListenerDB.access.users, user_id), + EventListenerDB.access.users == user_id, In(EventListenerDB.access.groups, user_groups), EventListenerDB.access.datasets == PydanticObjectId(dataset_id), )