diff options
| author | Erik Johnston <erik@matrix.org> | 2020-02-28 11:24:05 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-02-28 11:25:34 +0000 |
| commit | 9ce4e344a808e15a36a2d9ea03b77ebfc6ac7fe2 (patch) | |
| tree | 50df94a33c6d12b1129e89cbf63819f0c570091b /synapse/replication/tcp | |
| parent | Change device lists stream to have one row per id. (diff) | |
| download | synapse-9ce4e344a808e15a36a2d9ea03b77ebfc6ac7fe2.tar.xz | |
Change device list replication to match new semantics.
Instead of sending down batches of user ID/host tuples, send down a row per entity (user ID or host).
Diffstat (limited to 'synapse/replication/tcp')
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index 208e8a667b..7a8b6e9df1 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -94,9 +94,13 @@ PublicRoomsStreamRow = namedtuple( "network_id", # str, optional ), ) -DeviceListsStreamRow = namedtuple( - "DeviceListsStreamRow", ("user_id", "destination") # str # str -) + + +@attr.s +class DeviceListsStreamRow: + entity = attr.ib(type=str) + + ToDeviceStreamRow = namedtuple("ToDeviceStreamRow", ("entity",)) # str TagAccountDataStreamRow = namedtuple( "TagAccountDataStreamRow", ("user_id", "room_id", "data") # str # str # dict @@ -363,7 +367,8 @@ class PublicRoomsStream(Stream): class DeviceListsStream(Stream): - """Someone added/changed/removed a device + """Either a user has updated their devices or a remote server needs to be + told about a device update. """ NAME = "device_lists" |