|
8 | 8 | import requests
|
9 | 9 | import responses
|
10 | 10 | from eth_utils import decode_hex, encode_hex, to_canonical_address, to_normalized_address
|
| 11 | +from flask_restful.representations import json |
11 | 12 | from matrix_client.errors import MatrixRequestError
|
12 | 13 | from matrix_client.user import User
|
13 | 14 |
|
14 | 15 | import raiden.network.transport.matrix.client
|
15 | 16 | import raiden.network.transport.matrix.utils
|
| 17 | +from raiden.constants import ServerListType |
16 | 18 | from raiden.exceptions import TransportError
|
17 | 19 | from raiden.messages.synchronization import Processed
|
18 | 20 | from raiden.messages.transfers import RevealSecret
|
|
28 | 30 | )
|
29 | 31 | from raiden.tests.utils.factories import make_secret, make_signature, make_signer
|
30 | 32 | from raiden.tests.utils.transport import ignore_member_join, ignore_messages
|
| 33 | +from raiden.utils.cli import get_matrix_servers |
31 | 34 | from raiden.utils.signer import recover
|
32 | 35 | from raiden.utils.typing import MessageID
|
33 | 36 |
|
@@ -291,3 +294,26 @@ def test_message_ack_timing_keeper():
|
291 | 294 | report = matk.generate_report()
|
292 | 295 | assert len(report) == 1
|
293 | 296 | assert report == [0.05]
|
| 297 | + |
| 298 | + |
| 299 | +def test_get_matrix_servers(requests_responses: responses.RequestsMock): |
| 300 | + server_list_content = { |
| 301 | + "active_servers": ["http://server1", "http://server2"], |
| 302 | + "all_servers": ["http://server3", "http://server4"], |
| 303 | + } |
| 304 | + requests_responses.add(responses.GET, "http://server-list", json.dumps(server_list_content)) |
| 305 | + |
| 306 | + active_servers_default = get_matrix_servers("http://server-list") |
| 307 | + active_servers_explicit = get_matrix_servers( |
| 308 | + "http://server-list", server_list_type=ServerListType.ACTIVE_SERVERS |
| 309 | + ) |
| 310 | + |
| 311 | + assert ( |
| 312 | + active_servers_default == active_servers_explicit == server_list_content["active_servers"] |
| 313 | + ) |
| 314 | + |
| 315 | + all_servers = get_matrix_servers( |
| 316 | + "http://server-list", server_list_type=ServerListType.ALL_SERVERS |
| 317 | + ) |
| 318 | + |
| 319 | + assert all_servers == server_list_content["all_servers"] |
0 commit comments