Skip to content

Commit e9dfa9b

Browse files
committed
[tests] Move version message sending from NodeConn to NodeConnCB
This commit moves the logic that sends a version message on connection from NodeConn to NodeConnCB. NodeConn should not be aware of the semantics or meaning of the P2P payloads.
1 parent dad596f commit e9dfa9b

File tree

1 file changed

+14
-11
lines changed

1 file changed

+14
-11
lines changed

test/functional/test_framework/mininode.py

Lines changed: 14 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ class NodeConn(asyncore.dispatcher):
7575
def __init__(self):
7676
super().__init__(map=mininode_socket_map)
7777

78-
def peer_connect(self, dstaddr, dstport, net="regtest", services=NODE_NETWORK|NODE_WITNESS, send_version=True):
78+
def peer_connect(self, dstaddr, dstport, net="regtest"):
7979
self.dstaddr = dstaddr
8080
self.dstport = dstport
8181
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
@@ -86,16 +86,6 @@ def peer_connect(self, dstaddr, dstport, net="regtest", services=NODE_NETWORK|NO
8686
self.network = net
8787
self.disconnect = False
8888

89-
if send_version:
90-
# stuff version msg into sendbuf
91-
vt = msg_version()
92-
vt.nServices = services
93-
vt.addrTo.ip = self.dstaddr
94-
vt.addrTo.port = self.dstport
95-
vt.addrFrom.ip = "0.0.0.0"
96-
vt.addrFrom.port = 0
97-
self.send_message(vt, True)
98-
9989
logger.info('Connecting to Bitcoin Node: %s:%d' % (self.dstaddr, self.dstport))
10090

10191
try:
@@ -279,6 +269,19 @@ def __init__(self):
279269
# The network services received from the peer
280270
self.nServices = 0
281271

272+
def peer_connect(self, *args, services=NODE_NETWORK|NODE_WITNESS, send_version=True, **kwargs):
273+
super().peer_connect(*args, **kwargs)
274+
275+
if send_version:
276+
# Send a version msg
277+
vt = msg_version()
278+
vt.nServices = services
279+
vt.addrTo.ip = self.dstaddr
280+
vt.addrTo.port = self.dstport
281+
vt.addrFrom.ip = "0.0.0.0"
282+
vt.addrFrom.port = 0
283+
self.send_message(vt, True)
284+
282285
# Message receiving methods
283286

284287
def on_message(self, message):

0 commit comments

Comments
 (0)