diff --git a/synapse/visibility.py b/synapse/visibility.py index d064950eb5..78d33f278b 100644 --- a/synapse/visibility.py +++ b/synapse/visibility.py @@ -48,7 +48,13 @@ from synapse.logging.opentracing import trace from synapse.storage.controllers import StorageControllers from synapse.storage.databases.main import DataStore from synapse.synapse_rust.events import event_visible_to_server -from synapse.types import RetentionPolicy, StateMap, StrCollection, get_domain_from_id, UserID +from synapse.types import ( + RetentionPolicy, + StateMap, + StrCollection, + UserID, + get_domain_from_id, +) from synapse.types.state import StateFilter from synapse.util import Clock @@ -108,7 +114,9 @@ async def filter_events_for_client( # Filter out events that have been soft failed so that we don't relay them # to clients, unless they're a server admin. events_before_filtering = events - if filter_send_to_client and await storage.main.is_server_admin(UserID.from_string(user_id)): + if filter_send_to_client and await storage.main.is_server_admin( + UserID.from_string(user_id) + ): events = events_before_filtering else: events = [e for e in events if not e.internal_metadata.is_soft_failed()]