mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-12-18 06:14:21 -05:00
Comment
This commit is contained in:
parent
54a79c1d37
commit
832e9c52ca
@ -282,6 +282,8 @@ class RoomMemberStore(SQLBaseStore):
|
|||||||
|
|
||||||
@cachedInlineCallbacks(max_entries=50000, cache_context=True, iterable=True)
|
@cachedInlineCallbacks(max_entries=50000, cache_context=True, iterable=True)
|
||||||
def get_users_who_share_room_with_user(self, user_id, cache_context):
|
def get_users_who_share_room_with_user(self, user_id, cache_context):
|
||||||
|
"""Returns the set of users who share a room with `user_id`
|
||||||
|
"""
|
||||||
rooms = yield self.get_rooms_for_user(
|
rooms = yield self.get_rooms_for_user(
|
||||||
user_id, on_invalidate=cache_context.invalidate,
|
user_id, on_invalidate=cache_context.invalidate,
|
||||||
)
|
)
|
||||||
@ -291,7 +293,6 @@ class RoomMemberStore(SQLBaseStore):
|
|||||||
user_ids = yield self.get_users_in_room(
|
user_ids = yield self.get_users_in_room(
|
||||||
room.room_id, on_invalidate=cache_context.invalidate,
|
room.room_id, on_invalidate=cache_context.invalidate,
|
||||||
)
|
)
|
||||||
logger.info("Users in room: %r %r", room.room_id, user_ids)
|
|
||||||
user_who_share_room.update(user_ids)
|
user_who_share_room.update(user_ids)
|
||||||
|
|
||||||
defer.returnValue(user_who_share_room)
|
defer.returnValue(user_who_share_room)
|
||||||
|
Loading…
Reference in New Issue
Block a user