From f807c7291f72db6894747258e439ad662a1bf56e Mon Sep 17 00:00:00 2001 From: Will Hunt Date: Wed, 30 Sep 2020 12:55:57 +0100 Subject: Add basic support for device list updates --- synapse/notifier.py | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) (limited to 'synapse/notifier.py') diff --git a/synapse/notifier.py b/synapse/notifier.py index b6b231c15d..7396fe96c5 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -329,9 +329,16 @@ class Notifier: except Exception: logger.exception("Error notifying application services of event") - async def _notify_app_services_ephemeral(self, stream_key: str, new_token: Union[int, RoomStreamToken], users: Collection[UserID] = []): + async def _notify_app_services_ephemeral( + self, + stream_key: str, + new_token: Union[int, RoomStreamToken], + users: Collection[UserID] = [], + ): try: - await self.appservice_handler.notify_interested_services_ephemeral(stream_key, new_token, users) + await self.appservice_handler.notify_interested_services_ephemeral( + stream_key, new_token, users + ) except Exception: logger.exception("Error notifying application services of event") @@ -375,7 +382,11 @@ class Notifier: # Notify appservices run_as_background_process( - "_notify_app_services_ephemeral", self._notify_app_services_ephemeral, stream_key, new_token, users, + "_notify_app_services_ephemeral", + self._notify_app_services_ephemeral, + stream_key, + new_token, + users, ) def on_new_replication_data(self) -> None: -- cgit 1.5.1