Fix test_ping_pong in test_discovery ethereum#50

konradkonrad · Jan 18, 2017 · 7bce57f · 7bce57f
1 parent d0ee91e
commit 7bce57f
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/devp2p/tests/test_discovery.py b/devp2p/tests/test_discovery.py
@@ -119,16 +119,20 @@ def test_ping_pong():
     alice = NodeDiscoveryMock(host='127.0.0.1', port=1, seed='alice')
     bob = NodeDiscoveryMock(host='127.0.0.2', port=2, seed='bob')
 
+    cmd_id_map = alice.protocol.cmd_id_map
     bob_node = alice.protocol.get_node(bob.protocol.pubkey, bob.address)
     alice.protocol.kademlia.ping(bob_node)
     assert len(NodeDiscoveryMock.messages) == 1
     # inspect message in queue
     msg = NodeDiscoveryMock.messages[0][2]
     remote_pubkey, cmd_id, payload, mdc = bob.protocol.unpack(msg)
     assert cmd_id == alice.protocol.cmd_id_map['ping']
-    bob.poll()  # receives ping, sends pong
-    assert len(NodeDiscoveryMock.messages) == 1
-    alice.poll()  # receives pong
+    # process the ping pong handshake
+    assert bob.poll() == cmd_id_map['ping']  # receives ping, sends pong
+    assert len(NodeDiscoveryMock.messages) == 2
+    assert alice.poll() == cmd_id_map['ping']  # receives ping, sends pong
+    assert bob.poll() == cmd_id_map['pong']  # receives pong
+    assert alice.poll() == cmd_id_map['pong']  # receives pong
     assert len(NodeDiscoveryMock.messages) == 0