Mirroristas/planetmint
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint.git synced 2025-11-25 23:15:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test_lib test_update_utxoset passing

Browse Source
This commit is contained in:
andrei 2022-05-05 15:00:53 +03:00
parent a96515ee31
commit bb7f6bc143
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
planetmint/backend/tarantool/query.py
View File

@ -335,16 +335,13 @@ def delete_transactions(connection, txn_ids: list):
for _id in txn_ids: for _id in txn_ids:
assets_space.delete(_id, index="txid_search") assets_space.delete(_id, index="txid_search")
@register_query(TarantoolDB) @register_query(TarantoolDB)
def store_unspent_outputs(connection, *unspent_outputs: list): def store_unspent_outputs(connection, *unspent_outputs: list):
space = connection.space('utxos') space = connection.space('utxos')
if unspent_outputs: if unspent_outputs:
for utxo in unspent_outputs: for utxo in unspent_outputs:
try: space.insert((utxo['transaction_id'], utxo['output_index']))
yield space.insert((utxo['transaction_id'], utxo['output_index']))
except DuplicateKeyError:
# TODO log warning at least
pass
@register_query(TarantoolDB) @register_query(TarantoolDB)
@ -352,7 +349,7 @@ def delete_unspent_outputs(connection, *unspent_outputs: list):
space = connection.space('utxos') space = connection.space('utxos')
if unspent_outputs: if unspent_outputs:
for utxo in unspent_outputs: for utxo in unspent_outputs:
yield space.delete((utxo['transaction_id'], utxo['output_index'])) space.delete((utxo['transaction_id'], utxo['output_index']))
@register_query(TarantoolDB) @register_query(TarantoolDB)
@ -360,6 +357,7 @@ def get_unspent_outputs(connection):
space = connection.space('utxos') space = connection.space('utxos')
return space.select() return space.select()
@register_query(TarantoolDB) @register_query(TarantoolDB)
def store_pre_commit_state(connection, state: dict): def store_pre_commit_state(connection, state: dict):
space = connection.space("pre_commits") space = connection.space("pre_commits")