def connectionMade(self):
self.send_version(
- version=70002,
+ version=60011,
services=1,
time=int(time.time()),
addr_to=dict(
if hasattr(self.factory, 'gotConnection'):
self.factory.gotConnection(self)
- self.pinger = deferral.RobustLoopingCall(self.send_ping)
+ self.pinger = deferral.RobustLoopingCall(self.send_ping, nonce=1234)
self.pinger.start(30)
message_inv = pack.ComposedType([
('block', bitcoin_data.block_type),
])
def handle_block(self, block):
- block_hash = bitcoin_data.hash256(bitcoin_data.block_header_type.pack(block['header']))
+ block_hash = bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(block['header']))
self.get_block.got_response(block_hash, block)
self.get_block_header.got_response(block_hash, block['header'])
def handle_headers(self, headers):
for header in headers:
header = header['header']
- self.get_block_header.got_response(bitcoin_data.hash256(bitcoin_data.block_header_type.pack(header)), header)
+ self.get_block_header.got_response(bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(header)), header)
self.factory.new_headers.happened([header['header'] for header in headers])
- message_ping = pack.ComposedType([])
- def handle_ping(self):
+ message_ping = pack.ComposedType([
+ ('nonce', pack.IntType(64)),
+ ])
+ def handle_ping(self, nonce):
+ self.send_pong(nonce=nonce)
+
+ message_pong = pack.ComposedType([
+ ('nonce', pack.IntType(64)),
+ ])
+ def handle_pong(self, nonce):
pass
message_alert = pack.ComposedType([