varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Apply PR feedback:

Browse Source 
Check that node is in mesh peer's mesh after subscribe
This commit is contained in:
NIC619
2019-07-23 16:45:54 +08:00
parent 042e0ac916
commit c0a3af69e0
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
tests/pubsub/test_gossipsub.py
View File

@ -63,8 +63,10 @@ async def test_join():
for i in hosts_indices: for i in hosts_indices:
if i in subscribed_peer_indices: if i in subscribed_peer_indices:
assert str(libp2p_hosts[i].get_id()) in gossipsubs[central_node_index].mesh[topic] assert str(libp2p_hosts[i].get_id()) in gossipsubs[central_node_index].mesh[topic]
assert str(libp2p_hosts[central_node_index].get_id()) in gossipsubs[i].mesh[topic]
else: else:
assert str(libp2p_hosts[i].get_id()) not in gossipsubs[central_node_index].mesh[topic] assert str(libp2p_hosts[i].get_id()) not in gossipsubs[central_node_index].mesh[topic]
assert str(libp2p_hosts[central_node_index].get_id()) not in gossipsubs[i].mesh[topic]
await cleanup() await cleanup()