diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-03-04 10:05:39 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-03-04 10:05:39 +0000 |
commit | 2c3548d9d89ed4c8cefd5b18d1b86ff0fc2f52bf (patch) | |
tree | 4d49e024cbdc7affc544fc626589a2d1496420b8 /tests/server.py | |
parent | Fix incorrect log about not persisting duplicate state event. (#4776) (diff) | |
download | synapse-2c3548d9d89ed4c8cefd5b18d1b86ff0fc2f52bf.tar.xz |
Update test_typing to use HomeserverTestCase. (#4771)
Diffstat (limited to 'tests/server.py')
-rw-r--r-- | tests/server.py | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/tests/server.py b/tests/server.py index fc1e76d146..37069afdda 100644 --- a/tests/server.py +++ b/tests/server.py @@ -137,6 +137,7 @@ def make_request( access_token=None, request=SynapseRequest, shorthand=True, + federation_auth_origin=None, ): """ Make a web request using the given method and path, feed it the @@ -150,9 +151,11 @@ def make_request( a dict. shorthand: Whether to try and be helpful and prefix the given URL with the usual REST API path, if it doesn't contain it. + federation_auth_origin (bytes|None): if set to not-None, we will add a fake + Authorization header pretenting to be the given server name. Returns: - A synapse.http.site.SynapseRequest. + Tuple[synapse.http.site.SynapseRequest, channel] """ if not isinstance(method, bytes): method = method.encode('ascii') @@ -184,6 +187,11 @@ def make_request( b"Authorization", b"Bearer " + access_token.encode('ascii') ) + if federation_auth_origin is not None: + req.requestHeaders.addRawHeader( + b"Authorization", b"X-Matrix origin=%s,key=,sig=" % (federation_auth_origin,) + ) + if content: req.requestHeaders.addRawHeader(b"Content-Type", b"application/json") @@ -288,9 +296,6 @@ def setup_test_homeserver(cleanup_func, *args, **kwargs): **kwargs ) - pool.runWithConnection = runWithConnection - pool.runInteraction = runInteraction - class ThreadPool: """ Threadless thread pool. @@ -316,8 +321,12 @@ def setup_test_homeserver(cleanup_func, *args, **kwargs): return d clock.threadpool = ThreadPool() - pool.threadpool = ThreadPool() - pool.running = True + + if pool: + pool.runWithConnection = runWithConnection + pool.runInteraction = runInteraction + pool.threadpool = ThreadPool() + pool.running = True return d |