diff options
| author | Nick Mills-Barrett <nick@beeper.com> | 2022-04-26 20:14:21 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-04-26 20:14:21 +0100 |
| commit | 63ba9ba38b47bc20074e2c83492c4d113cfe21b8 (patch) | |
| tree | f2fea816f03381980f86abec2f5aa0319f76dfce /synapse/handlers/receipts.py | |
| parent | Merge tag 'v1.58.0rc2' into develop (diff) | |
| download | synapse-63ba9ba38b47bc20074e2c83492c4d113cfe21b8.tar.xz | |
Bound ephemeral events by key (#12544)
Co-authored-by: Brad Murray <bradtgmurray@gmail.com> Co-authored-by: Andrew Morgan <andrewm@element.io>
Diffstat (limited to 'synapse/handlers/receipts.py')
| -rw-r--r-- | synapse/handlers/receipts.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/handlers/receipts.py b/synapse/handlers/receipts.py index 6250bb3bdf..cfe860decc 100644 --- a/synapse/handlers/receipts.py +++ b/synapse/handlers/receipts.py @@ -239,13 +239,14 @@ class ReceiptEventSource(EventSource[int, JsonDict]): return events, to_key async def get_new_events_as( - self, from_key: int, service: ApplicationService + self, from_key: int, to_key: int, service: ApplicationService ) -> Tuple[List[JsonDict], int]: """Returns a set of new read receipt events that an appservice may be interested in. Args: from_key: the stream position at which events should be fetched from + to_key: the stream position up to which events should be fetched to service: The appservice which may be interested Returns: @@ -255,7 +256,6 @@ class ReceiptEventSource(EventSource[int, JsonDict]): * The current read receipt stream token. """ from_key = int(from_key) - to_key = self.get_current_key() if from_key == to_key: return [], to_key |