Matrix/synapse
Matrix/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse synced 2024-09-28 17:42:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Fix replication

Browse source
This commit is contained in:
Erik Johnston 2024-06-19 17:27:05 +01:00
parent d05aa3026b
commit 57c5347559
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
synapse/replication/tcp/client.py
View file

@ -155,7 +155,7 @@ class ReplicationDataHandler:
)
await self._pusher_pool.on_new_receipts({row.user_id for row in rows})
elif stream_name == ToDeviceStream.NAME:
entities = [row.user_id for row in rows if not row.hosts_calculated]
entities = [row.entity for row in rows if row.entity.startswith("@")]
if entities:
self.notifier.on_new_event(
StreamKeyType.TO_DEVICE, token, users=entities