LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-02 02:05:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #4402 from kyuupichan/master

Browse source 
Subscribe to raw headers
This commit is contained in:
ghost43 2018-06-04 17:15:49 +02:00 • committed by GitHub
commit d667c5d46e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/network.py
View file

@ -711,7 +711,7 @@ class Network(util.DaemonThread):
interface.mode = 'default' interface.mode = 'default'
interface.request = None interface.request = None
self.interfaces[server] = interface self.interfaces[server] = interface
self.queue_request('blockchain.headers.subscribe', [], interface) self.queue_request('blockchain.headers.subscribe', [True], interface)
if server == self.default_server: if server == self.default_server:
self.switch_to_interface(server) self.switch_to_interface(server)
#self.notify('interfaces') #self.notify('interfaces')
@ -983,10 +983,9 @@ class Network(util.DaemonThread):
self.stop_network() self.stop_network()
self.on_stop() self.on_stop()
def on_notify_header(self, interface, header): def on_notify_header(self, interface, header_dict):
height = header.get('block_height') header_hex, height = header_dict['hex'], header_dict['height']
if not height: header = blockchain.deserialize_header(bfh(header_hex), height)
return
if height < self.max_checkpoint(): if height < self.max_checkpoint():
self.connection_down(interface.server) self.connection_down(interface.server)
return return

3
scripts/block_headers
View file

@ -21,7 +21,8 @@ if not network.is_connected():
# 2. send the subscription # 2. send the subscription
callback = lambda response: print_msg(json_encode(response.get('result'))) callback = lambda response: print_msg(json_encode(response.get('result')))
network.send([('blockchain.headers.subscribe',[])], callback) network.send([('server.version',["block_headers script", "1.2"])], callback)
network.send([('blockchain.headers.subscribe',[True])], callback)
# 3. wait for results # 3. wait for results
while network.is_connected(): while network.is_connected():

5
scripts/watch_address
View file

@ -2,6 +2,7 @@
import sys import sys
import time import time
from electrum import bitcoin
from electrum import SimpleConfig, Network from electrum import SimpleConfig, Network
from electrum.util import print_msg, json_encode from electrum.util import print_msg, json_encode
@ -11,6 +12,8 @@ except Exception:
print("usage: watch_address <bitcoin_address>") print("usage: watch_address <bitcoin_address>")
sys.exit(1) sys.exit(1)
sh = bitcoin.address_to_scripthash(addr)
# start network # start network
c = SimpleConfig() c = SimpleConfig()
network = Network(c) network = Network(c)
@ -26,7 +29,7 @@ if not network.is_connected():
# 2. send the subscription # 2. send the subscription
callback = lambda response: print_msg(json_encode(response.get('result'))) callback = lambda response: print_msg(json_encode(response.get('result')))
network.send([('blockchain.address.subscribe',[addr])], callback) network.send([('blockchain.scripthash.subscribe',[sh])], callback)
# 3. wait for results # 3. wait for results
while network.is_connected(): while network.is_connected():