qa: Expose on-connection to mininode listeners
This commit is contained in:
parent
5b5e4f8330
commit
8650bbb660
1 changed files with 2 additions and 0 deletions
|
@ -1540,6 +1540,7 @@ class NodeConnCB(object):
|
||||||
if conn.ver_send > BIP0031_VERSION:
|
if conn.ver_send > BIP0031_VERSION:
|
||||||
conn.send_message(msg_pong(message.nonce))
|
conn.send_message(msg_pong(message.nonce))
|
||||||
def on_reject(self, conn, message): pass
|
def on_reject(self, conn, message): pass
|
||||||
|
def on_open(self, conn): pass
|
||||||
def on_close(self, conn): pass
|
def on_close(self, conn): pass
|
||||||
def on_mempool(self, conn): pass
|
def on_mempool(self, conn): pass
|
||||||
def on_pong(self, conn, message): pass
|
def on_pong(self, conn, message): pass
|
||||||
|
@ -1657,6 +1658,7 @@ class NodeConn(asyncore.dispatcher):
|
||||||
if self.state != "connected":
|
if self.state != "connected":
|
||||||
self.show_debug_msg("MiniNode: Connected & Listening: \n")
|
self.show_debug_msg("MiniNode: Connected & Listening: \n")
|
||||||
self.state = "connected"
|
self.state = "connected"
|
||||||
|
self.cb.on_open(self)
|
||||||
|
|
||||||
def handle_close(self):
|
def handle_close(self):
|
||||||
self.show_debug_msg("MiniNode: Closing Connection to %s:%d... "
|
self.show_debug_msg("MiniNode: Closing Connection to %s:%d... "
|
||||||
|
|
Loading…
Reference in a new issue