From e05b742b01d9d224f9b5e76578cc11c33b610dd1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=A0imon=20Brandner?= Date: Thu, 5 May 2022 09:50:02 +0200 Subject: [PATCH] Update `_on_new_receipts()` to work with MSC2285 changes MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This was missed in https://github.com/matrix-org/synapse/pull/12168 Signed-off-by: Šimon Brandner --- synapse/replication/tcp/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 122892c7bca2..4146b9147368 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -21,7 +21,7 @@ from twisted.internet.protocol import ReconnectingClientFactory from twisted.python.failure import Failure -from synapse.api.constants import EventTypes +from synapse.api.constants import EventTypes, ReceiptTypes from synapse.federation import send_queue from synapse.federation.sender import FederationSender from synapse.logging.context import PreserveLoggingContext, make_deferred_yieldable @@ -402,7 +402,7 @@ async def _on_new_receipts( if not self._is_mine_id(receipt.user_id): continue if ( - receipt.data.get("hidden", False) + receipt.receipt_type == ReceiptTypes.READ_PRIVATE and self._hs.config.experimental.msc2285_enabled ): continue