|
|
|
|
@@ -23,6 +23,7 @@ from unittest.mock import AsyncMock, Mock
|
|
|
|
|
|
|
|
|
|
import pymacaroons
|
|
|
|
|
|
|
|
|
|
from twisted.internet.address import IPv4Address
|
|
|
|
|
from twisted.internet.testing import MemoryReactor
|
|
|
|
|
|
|
|
|
|
from synapse.api.auth.internal import InternalAuth
|
|
|
|
|
@@ -118,7 +119,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_user_by_access_token = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
requester = self.get_success(self.auth.get_user_by_req(request))
|
|
|
|
|
@@ -137,7 +138,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_user_by_access_token = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "192.168.10.10"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="192.168.10.10", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
requester = self.get_success(self.auth.get_user_by_req(request))
|
|
|
|
|
@@ -156,7 +157,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_user_by_access_token = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "131.111.8.42"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="131.111.8.42", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
f = self.get_failure(
|
|
|
|
|
@@ -209,7 +210,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_user_by_access_token = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.args[b"user_id"] = [masquerading_user_id]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
@@ -231,7 +232,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_user_by_access_token = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.args[b"user_id"] = [masquerading_user_id]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
@@ -261,7 +262,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_device = AsyncMock(return_value={"hidden": False})
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.args[b"user_id"] = [masquerading_user_id]
|
|
|
|
|
request.args[b"org.matrix.msc3202.device_id"] = [masquerading_device_id]
|
|
|
|
|
@@ -296,7 +297,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.get_device = AsyncMock(return_value=None)
|
|
|
|
|
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.args[b"user_id"] = [masquerading_user_id]
|
|
|
|
|
request.args[b"org.matrix.msc3202.device_id"] = [masquerading_device_id]
|
|
|
|
|
@@ -320,7 +321,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.mark_access_token_as_used = AsyncMock(return_value=None)
|
|
|
|
|
self.store.get_user_locked_status = AsyncMock(return_value=False)
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
self.get_success(self.auth.get_user_by_req(request))
|
|
|
|
|
@@ -341,7 +342,7 @@ class AuthTestCase(unittest.HomeserverTestCase):
|
|
|
|
|
self.store.insert_client_ip = AsyncMock(return_value=None)
|
|
|
|
|
self.store.mark_access_token_as_used = AsyncMock(return_value=None)
|
|
|
|
|
request = Mock(args={})
|
|
|
|
|
request.getClientAddress.return_value.host = "127.0.0.1"
|
|
|
|
|
request.getClientAddress.return_value = IPv4Address(type="TCP", host="127.0.0.1", port=12345)
|
|
|
|
|
request.args[b"access_token"] = [self.test_token]
|
|
|
|
|
request.requestHeaders.getRawHeaders = mock_getRawHeaders()
|
|
|
|
|
self.get_success(self.auth.get_user_by_req(request))
|
|
|
|
|
|