RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-01 23:39:45 +04:00
parent 93a9ef8c70
commit 2b36708b7d
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pybtc/connector.py
View File

@ -329,6 +329,7 @@ class Connector:
if not self.active or not self.active_block.done() or self.last_block_height >= block["height"]: if not self.active or not self.active_block.done() or self.last_block_height >= block["height"]:
return return
self.active_block = asyncio.Future() self.active_block = asyncio.Future()
block["height"] = self.last_block_height + 1
self.log.debug("Block %s %s" % (block["height"], block["hash"])) self.log.debug("Block %s %s" % (block["height"], block["hash"]))
bt = time.time() bt = time.time()
self.cache_loading = True if self.last_block_height < self.app_block_height_on_start else False self.cache_loading = True if self.last_block_height < self.app_block_height_on_start else False
@ -844,9 +845,10 @@ def get_stream(stream):
return stream return stream
def decode_block_tx(block): def decode_block_tx(block, height):
s = get_stream(block) s = get_stream(block)
b = dict() b = dict()
b["height"] = height
b["version"] = unpack("<L", s.read(4))[0] b["version"] = unpack("<L", s.read(4))[0]
b["versionHex"] = pack(">L", b["version"]).hex() b["versionHex"] = pack(">L", b["version"]).hex()
b["previousBlockHash"] = rh2s(s.read(32)) b["previousBlockHash"] = rh2s(s.read(32))