Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Commit 7e6d343

Browse files
committed
store argument is no longer optional in is_interested_in_room
1 parent 60a291a commit 7e6d343

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

synapse/appservice/__init__.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -259,8 +259,8 @@ async def is_interested_in_room(
259259
async def is_interested_in_event(
260260
self,
261261
event: EventBase,
262+
store: "DataStore",
262263
cache_context: _CacheContext,
263-
store: Optional["DataStore"] = None,
264264
) -> bool:
265265
"""Check if this service is interested in this event.
266266
@@ -288,10 +288,7 @@ async def is_interested_in_event(
288288
):
289289
return True
290290

291-
# TODO: The store is only optional here to aid testing this function. We should
292-
# instead convert the tests to use HomeServerTestCase in order to get a working
293-
# database instance.
294-
if store is not None and await self.is_interested_in_room(
291+
if await self.is_interested_in_room(
295292
event.room_id, store, on_invalidate=cache_context.invalidate
296293
):
297294
return True

synapse/handlers/appservice.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -769,7 +769,7 @@ async def _get_services_for_event(
769769
# inside of a list comprehension anymore.
770770
interested_list = []
771771
for s in services:
772-
if await s.is_interested_in_event(event, store=self.store):
772+
if await s.is_interested_in_event(event, self.store):
773773
interested_list.append(s)
774774

775775
return interested_list

tests/appservice/test_appservice.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
from synapse.appservice import ApplicationService, Namespace
2020

2121
from tests import unittest
22+
from tests.test_utils import simple_async_mock
2223

2324

2425
def _regex(regex: str, exclusive: bool = True) -> Namespace:
@@ -39,6 +40,8 @@ def setUp(self):
3940
)
4041

4142
self.store = Mock()
43+
self.store.get_aliases_for_room = simple_async_mock(return_value=[])
44+
self.store.get_users_in_room = simple_async_mock(return_value=[])
4245

4346
@defer.inlineCallbacks
4447
def test_regex_user_id_prefix_match(self):
@@ -47,7 +50,7 @@ def test_regex_user_id_prefix_match(self):
4750
self.assertTrue(
4851
(
4952
yield defer.ensureDeferred(
50-
self.service.is_interested_in_event(self.event)
53+
self.service.is_interested_in_event(self.event, self.store)
5154
)
5255
)
5356
)
@@ -59,7 +62,7 @@ def test_regex_user_id_prefix_no_match(self):
5962
self.assertFalse(
6063
(
6164
yield defer.ensureDeferred(
62-
self.service.is_interested_in_event(self.event)
65+
self.service.is_interested_in_event(self.event, self.store)
6366
)
6467
)
6568
)
@@ -73,7 +76,7 @@ def test_regex_room_member_is_checked(self):
7376
self.assertTrue(
7477
(
7578
yield defer.ensureDeferred(
76-
self.service.is_interested_in_event(self.event)
79+
self.service.is_interested_in_event(self.event, self.store)
7780
)
7881
)
7982
)
@@ -102,7 +105,7 @@ def test_regex_room_id_no_match(self):
102105
self.assertFalse(
103106
(
104107
yield defer.ensureDeferred(
105-
self.service.is_interested_in_event(self.event)
108+
self.service.is_interested_in_event(self.event, self.store)
106109
)
107110
)
108111
)
@@ -207,7 +210,7 @@ def test_interested_in_self(self):
207210
self.assertTrue(
208211
(
209212
yield defer.ensureDeferred(
210-
self.service.is_interested_in_event(self.event)
213+
self.service.is_interested_in_event(self.event, self.store)
211214
)
212215
)
213216
)

0 commit comments

Comments
 (0)