Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Some DHT cleanup.

pull/149/head
jMyles 2018-02-19 15:21:06 -08:00
parent bb279fa954
commit 1cdc0cad80
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/network/test_network_actors.py
View File

@ -35,7 +35,7 @@ def test_all_ursulas_know_about_all_other_ursulas(ursulas):
ignorance = [] ignorance = []
for acounter, announcing_ursula in enumerate(blockchain_client._ursulas_on_blockchain): for acounter, announcing_ursula in enumerate(blockchain_client._ursulas_on_blockchain):
for counter, propagating_ursula in enumerate(ursulas): for counter, propagating_ursula in enumerate(ursulas):
if not digest(announcing_ursula) in propagating_ursula.server.storage: if not digest(bytes(announcing_ursula)) in propagating_ursula.server.storage:
ignorance.append((counter, acounter)) ignorance.append((counter, acounter))
if ignorance: if ignorance:
pytest.fail(str(["{} didn't know about {}".format(counter, acounter) for counter, acounter in ignorance])) pytest.fail(str(["{} didn't know about {}".format(counter, acounter) for counter, acounter in ignorance]))
@ -93,9 +93,7 @@ def test_alice_finds_ursula(alice, ursulas):
""" """
ursula_index = 1 ursula_index = 1
all_ursulas = blockchain_client._ursulas_on_blockchain all_ursulas = blockchain_client._ursulas_on_blockchain
getter = alice.server.get(all_ursulas[ursula_index]) value = alice.server.get_now(all_ursulas[ursula_index])
loop = asyncio.get_event_loop()
value = loop.run_until_complete(getter)
header, _signature, _ursula_pubkey_sig, _hrac, interface_info = dht_value_splitter(value, header, _signature, _ursula_pubkey_sig, _hrac, interface_info = dht_value_splitter(value,
return_remainder=True) return_remainder=True)
@ -190,9 +188,7 @@ def test_treaure_map_is_legit(enacted_policy):
""" """
alice = enacted_policy.alice alice = enacted_policy.alice
for ursula_interface_id in enacted_policy.treasure_map: for ursula_interface_id in enacted_policy.treasure_map:
getter = alice.server.get(ursula_interface_id) value = alice.server.get_now(ursula_interface_id)
loop = asyncio.get_event_loop()
value = loop.run_until_complete(getter)
header, signature, ursula_pubkey_sig, hrac, interface_info = dht_value_splitter(value, header, signature, ursula_pubkey_sig, hrac, interface_info = dht_value_splitter(value,
return_remainder=True) return_remainder=True)
assert header == BYTESTRING_IS_URSULA_IFACE_INFO assert header == BYTESTRING_IS_URSULA_IFACE_INFO