Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Commit

Permalink
Always set the stream position, even when there are no events.
Browse files Browse the repository at this point in the history
  • Loading branch information
@Fizzadar
Fizzadar committed Nov 3, 2021
1 parent 451c31f commit 88d2d5c
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions synapse/handlers/appservice.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -268,10 +268,10 @@ async def _notify_interested_services_ephemeral(
service, events
)

# Persist the latest handled stream token for this appservice
await self.store.set_type_stream_id_for_appservice(
service, "read_receipt", new_token
)
# Persist the latest handled stream token for this appservice
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, new_token)
Expand All @@ -280,10 +280,10 @@ async def _notify_interested_services_ephemeral(
service, events
)

# Persist the latest handled stream token for this appservice
await self.store.set_type_stream_id_for_appservice(
service, "presence", new_token
)
# Persist the latest handled stream token for this appservice
await self.store.set_type_stream_id_for_appservice(
service, "presence", new_token
)

async def _handle_typing(
self, service: ApplicationService, new_token: int
Expand Down

0 comments on commit 88d2d5c

Please sign in to comment.