diff options
| author | Will Hunt <will@half-shot.uk> | 2020-10-26 14:51:33 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-10-26 15:00:56 +0000 |
| commit | 9e0f5a0ac44678cd8a1dcb82ba7e116f8b554c4d (patch) | |
| tree | 056d2e948a9492ede4df6ef6c8bf57c16e7b54fe /synapse/handlers/appservice.py | |
| parent | Properly handle presence events for application services. (#8656) (diff) | |
| download | synapse-9e0f5a0ac44678cd8a1dcb82ba7e116f8b554c4d.tar.xz | |
Fix get|set_type_stream_id_for_appservice store functions (#8648)
Diffstat (limited to '')
| -rw-r--r-- | synapse/handlers/appservice.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py index fe8cfc9b18..64dea23fc5 100644 --- a/synapse/handlers/appservice.py +++ b/synapse/handlers/appservice.py @@ -203,16 +203,16 @@ class ApplicationServicesHandler: events = await self._handle_receipts(service) if events: self.scheduler.submit_ephemeral_events_for_as(service, events) - await self.store.set_type_stream_id_for_appservice( - service, "read_receipt", new_token - ) + await self.store.set_type_stream_id_for_appservice( + service, "read_receipt", new_token + ) elif stream_key == "presence_key": events = await self._handle_presence(service, users) if events: self.scheduler.submit_ephemeral_events_for_as(service, events) - await self.store.set_type_stream_id_for_appservice( - service, "presence", new_token - ) + await self.store.set_type_stream_id_for_appservice( + service, "presence", new_token + ) async def _handle_typing(self, service: ApplicationService, new_token: int): typing_source = self.event_sources.sources["typing"] |