2323
2424import pymacaroons
2525
26+ from twisted .internet .address import IPv4Address
2627from twisted .internet .testing import MemoryReactor
2728
2829from synapse .api .auth .internal import InternalAuth
@@ -118,7 +119,7 @@ def test_get_user_by_req_appservice_valid_token(self) -> None:
118119 self .store .get_user_by_access_token = AsyncMock (return_value = None )
119120
120121 request = Mock (args = {})
121- request .getClientAddress .return_value . host = " 127.0.0.1"
122+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
122123 request .args [b"access_token" ] = [self .test_token ]
123124 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
124125 requester = self .get_success (self .auth .get_user_by_req (request ))
@@ -137,7 +138,7 @@ def test_get_user_by_req_appservice_valid_token_good_ip(self) -> None:
137138 self .store .get_user_by_access_token = AsyncMock (return_value = None )
138139
139140 request = Mock (args = {})
140- request .getClientAddress .return_value . host = " 192.168.10.10"
141+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 192.168.10.10", port = 12345 )
141142 request .args [b"access_token" ] = [self .test_token ]
142143 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
143144 requester = self .get_success (self .auth .get_user_by_req (request ))
@@ -156,7 +157,7 @@ def test_get_user_by_req_appservice_valid_token_bad_ip(self) -> None:
156157 self .store .get_user_by_access_token = AsyncMock (return_value = None )
157158
158159 request = Mock (args = {})
159- request .getClientAddress .return_value . host = " 131.111.8.42"
160+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 131.111.8.42", port = 12345 )
160161 request .args [b"access_token" ] = [self .test_token ]
161162 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
162163 f = self .get_failure (
@@ -209,7 +210,7 @@ class FakeUserInfo:
209210 self .store .get_user_by_access_token = AsyncMock (return_value = None )
210211
211212 request = Mock (args = {})
212- request .getClientAddress .return_value . host = " 127.0.0.1"
213+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
213214 request .args [b"access_token" ] = [self .test_token ]
214215 request .args [b"user_id" ] = [masquerading_user_id ]
215216 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
@@ -231,7 +232,7 @@ def test_get_user_by_req_appservice_valid_token_bad_user_id(self) -> None:
231232 self .store .get_user_by_access_token = AsyncMock (return_value = None )
232233
233234 request = Mock (args = {})
234- request .getClientAddress .return_value . host = " 127.0.0.1"
235+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
235236 request .args [b"access_token" ] = [self .test_token ]
236237 request .args [b"user_id" ] = [masquerading_user_id ]
237238 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
@@ -261,7 +262,7 @@ def test_get_user_by_req_appservice_valid_token_valid_device_id(self) -> None:
261262 self .store .get_device = AsyncMock (return_value = {"hidden" : False })
262263
263264 request = Mock (args = {})
264- request .getClientAddress .return_value . host = " 127.0.0.1"
265+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
265266 request .args [b"access_token" ] = [self .test_token ]
266267 request .args [b"user_id" ] = [masquerading_user_id ]
267268 request .args [b"org.matrix.msc3202.device_id" ] = [masquerading_device_id ]
@@ -296,7 +297,7 @@ def test_get_user_by_req_appservice_valid_token_invalid_device_id(self) -> None:
296297 self .store .get_device = AsyncMock (return_value = None )
297298
298299 request = Mock (args = {})
299- request .getClientAddress .return_value . host = " 127.0.0.1"
300+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
300301 request .args [b"access_token" ] = [self .test_token ]
301302 request .args [b"user_id" ] = [masquerading_user_id ]
302303 request .args [b"org.matrix.msc3202.device_id" ] = [masquerading_device_id ]
@@ -320,7 +321,7 @@ def test_get_user_by_req__puppeted_token__not_tracking_puppeted_mau(self) -> Non
320321 self .store .mark_access_token_as_used = AsyncMock (return_value = None )
321322 self .store .get_user_locked_status = AsyncMock (return_value = False )
322323 request = Mock (args = {})
323- request .getClientAddress .return_value . host = " 127.0.0.1"
324+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
324325 request .args [b"access_token" ] = [self .test_token ]
325326 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
326327 self .get_success (self .auth .get_user_by_req (request ))
@@ -341,7 +342,7 @@ def test_get_user_by_req__puppeted_token__tracking_puppeted_mau(self) -> None:
341342 self .store .insert_client_ip = AsyncMock (return_value = None )
342343 self .store .mark_access_token_as_used = AsyncMock (return_value = None )
343344 request = Mock (args = {})
344- request .getClientAddress .return_value . host = " 127.0.0.1"
345+ request .getClientAddress .return_value = IPv4Address ( type = "TCP" , host = " 127.0.0.1", port = 12345 )
345346 request .args [b"access_token" ] = [self .test_token ]
346347 request .requestHeaders .getRawHeaders = mock_getRawHeaders ()
347348 self .get_success (self .auth .get_user_by_req (request ))
0 commit comments