kaslo/synapse
1
0
Fork 0
Code Wiki Activity

Move stream filter back into AppserviceHandler

Browse Source
This commit is contained in:
Andrew Morgan
2021-11-19 15:21:49 +00:00
committed by Olivier Wilkinson (reivilibre)
parent b9b4b55092
commit 0fe753cc7f
2 changed files with 21 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
synapse/handlers/appservice.py
View File

@@ -220,6 +220,16 @@ class ApplicationServicesHandler:
if not self.notify_appservices:
return
# Notify appservices of updates in ephemeral event streams.
# Only the following streams are currently supported.
if stream_key not in (
"typing_key",
"receipt_key",
"presence_key",
"to_device_key",
):
return
# Assert that new_token is an integer (and not a RoomStreamToken).
# All of the supported streams that this function handles use an
# integer to track progress (rather than a RoomStreamToken - a

28
synapse/notifier.py
View File

@@ -454,23 +454,17 @@ class Notifier:
self.notify_replication()
# Notify appservices of updates in ephemeral event streams.
# Only the following streams are currently supported.
if stream_key in (
"typing_key",
"receipt_key",
"presence_key",
"to_device_key",
):
# Notify appservices.
try:
self.appservice_handler.notify_interested_services_ephemeral(
stream_key,
new_token,
users,
)
except Exception:
logger.exception("Error notifying application services of event")
# Notify appservices.
try:
self.appservice_handler.notify_interested_services_ephemeral(
stream_key,
new_token,
users,
)
except Exception:
logger.exception(
"Error notifying application services of ephemeral event"
)
def on_new_replication_data(self) -> None:
"""Used to inform replication listeners that something has happened