Clean up an indirect reference to the homeserver datastore (#11914)

matrix-org · Feb 7, 2022 · e03dde2 · e03dde2
1 parent 0c4878c
commit e03dde2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/changelog.d/11914.misc b/changelog.d/11914.misc
@@ -0,0 +1 @@
+Various refactors to the typing notifications code.
diff --git a/synapse/handlers/typing.py b/synapse/handlers/typing.py
@@ -446,7 +446,7 @@ def process_replication_rows(
 
 class TypingNotificationEventSource(EventSource[int, JsonDict]):
     def __init__(self, hs: "HomeServer"):
-        self.hs = hs
+        self._main_store = hs.get_datastore()
         self.clock = hs.get_clock()
         # We can't call get_typing_handler here because there's a cycle:
         #
@@ -487,7 +487,7 @@ async def get_new_events_as(
                     continue
 
                 if not await service.matches_user_in_member_list(
-                    room_id, handler.store
+                    room_id, self._main_store
                 ):
                     continue
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		Various refactors to the typing notifications code.