mirror of
https://github.com/element-hq/synapse.git
synced 2024-12-14 11:57:44 +00:00
Fix worker handling
This commit is contained in:
parent
f70f44abc7
commit
e53744c737
1 changed files with 3 additions and 2 deletions
|
@ -676,8 +676,9 @@ class GenericWorkerReplicationHandler(ReplicationClientHandler):
|
||||||
elif stream_name == "device_lists":
|
elif stream_name == "device_lists":
|
||||||
all_room_ids = set()
|
all_room_ids = set()
|
||||||
for row in rows:
|
for row in rows:
|
||||||
room_ids = await self.store.get_rooms_for_user(row.user_id)
|
if row.entity.startswith("@"):
|
||||||
all_room_ids.update(room_ids)
|
room_ids = await self.store.get_rooms_for_user(row.entity)
|
||||||
|
all_room_ids.update(room_ids)
|
||||||
self.notifier.on_new_event("device_list_key", token, rooms=all_room_ids)
|
self.notifier.on_new_event("device_list_key", token, rooms=all_room_ids)
|
||||||
elif stream_name == "presence":
|
elif stream_name == "presence":
|
||||||
await self.presence_handler.process_replication_rows(token, rows)
|
await self.presence_handler.process_replication_rows(token, rows)
|
||||||
|
|
Loading…
Reference in a new issue