summary refs log tree commit diff
path: root/synapse/handlers/appservice.py
diff options
context:
space:
mode:
authorWill Hunt <will@half-shot.uk>2020-10-26 14:51:33 +0000
committerGitHub <noreply@github.com>2020-10-26 10:51:33 -0400
commite8dbbcb64c2725933a5bcefeeeaff9efbd0c2261 (patch)
tree9c3bef157f00a5460691c6dd6037d1fba97834ce /synapse/handlers/appservice.py
parentCorrect the package name in OpenID Connect install instructions (#8634) (diff)
downloadsynapse-e8dbbcb64c2725933a5bcefeeeaff9efbd0c2261.tar.xz
Fix get|set_type_stream_id_for_appservice store functions (#8648)
Diffstat (limited to 'synapse/handlers/appservice.py')
-rw-r--r--synapse/handlers/appservice.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py
index 7826387e53..03e9ec4d4e 100644
--- a/synapse/handlers/appservice.py
+++ b/synapse/handlers/appservice.py
@@ -236,16 +236,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"]