From cc30393cee208a64e9e71bcc102a2d81c445b540 Mon Sep 17 00:00:00 2001 From: Andrew Morgan Date: Fri, 19 Nov 2021 18:37:02 +0000 Subject: [PATCH] _handle_to_device -> _get_to_device_messages --- synapse/handlers/appservice.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py index 88806bb78c..816b51e682 100644 --- a/synapse/handlers/appservice.py +++ b/synapse/handlers/appservice.py @@ -321,8 +321,12 @@ class ApplicationServicesHandler: elif stream_key == "to_device_key": # Retrieve a list of to-device message events, as well as the # maximum stream token of the messages we were able to retrieve. - events = await self._handle_to_device(service, new_token, users) - self.scheduler.submit_ephemeral_events_for_as(service, events) + to_device_messages = await self._get_to_device_messages( + service, new_token, users + ) + self.scheduler.submit_ephemeral_events_for_as( + service, to_device_messages + ) # Persist the latest handled stream token for this appservice await self.store.set_type_stream_id_for_appservice( @@ -462,7 +466,7 @@ class ApplicationServicesHandler: return events - async def _handle_to_device( + async def _get_to_device_messages( self, service: ApplicationService, new_token: int,