simplify validation script
This commit is contained in:
@@ -6,23 +6,18 @@ from electrum.bitcoin import Hash, rev_hex, int_to_hex
|
|||||||
|
|
||||||
"""validate a transaction (SPV)"""
|
"""validate a transaction (SPV)"""
|
||||||
|
|
||||||
|
|
||||||
i = Interface({'server':'ecdsa.org:50002:s'})
|
i = Interface({'server':'ecdsa.org:50002:s'})
|
||||||
i.start()
|
i.start()
|
||||||
|
|
||||||
|
|
||||||
encode = lambda x: x[::-1].encode('hex')
|
encode = lambda x: x[::-1].encode('hex')
|
||||||
decode = lambda x: x.decode('hex')[::-1]
|
decode = lambda x: x.decode('hex')[::-1]
|
||||||
|
|
||||||
|
|
||||||
def merkle_root(merkle_s, target_hash):
|
def do_merkle_root(merkle_s, target_hash):
|
||||||
h = decode(target_hash)
|
h = decode(target_hash)
|
||||||
for item in merkle_s:
|
for item in merkle_s:
|
||||||
is_left = item[0] == 'L'
|
is_left = item[0] == 'L'
|
||||||
if is_left:
|
h = Hash( h + decode(item[1:]) ) if is_left else Hash( decode(item[1:]) + h )
|
||||||
h = Hash( h + decode(item[1:]) )
|
|
||||||
else:
|
|
||||||
h = Hash( decode(item[1:]) + h )
|
|
||||||
return encode(h)
|
return encode(h)
|
||||||
|
|
||||||
|
|
||||||
@@ -37,25 +32,23 @@ def hash_header(res):
|
|||||||
|
|
||||||
|
|
||||||
def verify_tx(tx_hash):
|
def verify_tx(tx_hash):
|
||||||
|
|
||||||
res = i.synchronous_get([ ('blockchain.transaction.get_merkle',[tx_hash]) ])[0]
|
res = i.synchronous_get([ ('blockchain.transaction.get_merkle',[tx_hash]) ])[0]
|
||||||
assert res.get('merkle_root') == merkle_root(res['merkle'], tx_hash)
|
merkle_root = do_merkle_root(res['merkle'], tx_hash)
|
||||||
block_height = res.get('block_height')
|
tx_height = res.get('block_height')
|
||||||
print block_height
|
|
||||||
|
|
||||||
headers_requests = []
|
headers_requests = []
|
||||||
for height in range(block_height-10,block_height+10):
|
for height in range(tx_height-10,tx_height+10):
|
||||||
headers_requests.append( ('blockchain.block.get_header',[height]) )
|
headers_requests.append( ('blockchain.block.get_header',[height]) )
|
||||||
res = i.synchronous_get(headers_requests)
|
headers = i.synchronous_get(headers_requests)
|
||||||
|
|
||||||
_hash = None
|
_hash = None
|
||||||
for header in res:
|
for header in headers:
|
||||||
if _hash: assert _hash == header.get('prev_block_hash')
|
if _hash: assert _hash == header.get('prev_block_hash')
|
||||||
_hash = hash_header(header)
|
_hash = hash_header(header)
|
||||||
print _hash
|
height = header.get('block_height')
|
||||||
if height==block_height:
|
if height==tx_height:
|
||||||
assert header.get('merkle_root') == res.get('merkle_root')
|
assert header.get('merkle_root') == merkle_root
|
||||||
|
print height, _hash, '*'
|
||||||
|
else:
|
||||||
|
print height, _hash
|
||||||
|
|
||||||
try:
|
try:
|
||||||
tx = sys.argv[1]
|
tx = sys.argv[1]
|
||||||
|
|||||||
Reference in New Issue
Block a user