forked from LBRYCommunity/lbry-sdk
memory address -> bytes
This commit is contained in:
parent
665921b3b1
commit
c4e4e81ac3
1 changed files with 16 additions and 4 deletions
|
@ -38,15 +38,27 @@ def insert_block(block):
|
||||||
|
|
||||||
|
|
||||||
def get_block_headers(first, last=None):
|
def get_block_headers(first, last=None):
|
||||||
|
q = (
|
||||||
|
select(
|
||||||
|
Block.c.height,
|
||||||
|
Block.c.block_hash,
|
||||||
|
Block.c.previous_hash,
|
||||||
|
Block.c.timestamp,
|
||||||
|
)
|
||||||
|
.select_from(Block)
|
||||||
|
)
|
||||||
if last is not None:
|
if last is not None:
|
||||||
query = (
|
query = (
|
||||||
select('*').select_from(Block)
|
q.where(between(Block.c.height, first, last))
|
||||||
.where(between(Block.c.height, first, last))
|
|
||||||
.order_by(Block.c.height)
|
.order_by(Block.c.height)
|
||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
query = select('*').select_from(Block).where(Block.c.height == first)
|
query = q.where(Block.c.height == first)
|
||||||
return context().fetchall(query)
|
rows = context().fetchall(query)
|
||||||
|
for row in rows:
|
||||||
|
row['block_hash'] = bytes(row['block_hash'])
|
||||||
|
row['previous_hash'] = bytes(row['previous_hash'])
|
||||||
|
return rows
|
||||||
|
|
||||||
|
|
||||||
def insert_transaction(block_hash, tx):
|
def insert_transaction(block_hash, tx):
|
||||||
|
|
Loading…
Reference in a new issue