diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2022-09-23 10:33:28 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-23 14:33:28 +0000 |
| commit | efd108b45d1706526416bc9a6f89463b5ff4506a (patch) | |
| tree | 8924c96286e16acdc51c09c571faaa8f9fd8a13c /synapse/replication/tcp | |
| parent | Send device list updates out to servers in partially joined rooms (#13874) (diff) | |
| download | synapse-efd108b45d1706526416bc9a6f89463b5ff4506a.tar.xz | |
Accept & store thread IDs for receipts (implement MSC3771). (#13782)
Updates the `/receipts` endpoint and receipt EDU handler to parse a `thread_id` from the body and insert it in the database.
Diffstat (limited to 'synapse/replication/tcp')
| -rw-r--r-- | synapse/replication/tcp/client.py | 3 | ||||
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 1 |
2 files changed, 3 insertions, 1 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index cf9cd6833b..b2522f98ca 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -427,7 +427,8 @@ class FederationSenderHandler: receipt.receipt_type, receipt.user_id, [receipt.event_id], - receipt.data, + thread_id=receipt.thread_id, + data=receipt.data, ) await self.federation_sender.send_read_receipt(receipt_info) diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index 398bebeaa6..e01155ad59 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -361,6 +361,7 @@ class ReceiptsStream(Stream): receipt_type: str user_id: str event_id: str + thread_id: Optional[str] data: dict NAME = "receipts" |