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

spending transactions fix

Browse Source
This commit is contained in:
andrei 2022-02-14 12:15:19 +02:00
parent 280a8f8030
commit c1dd754722
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -158,7 +158,7 @@ def get_assets(assets_ids: list, space):
@register_query(LocalMongoDBConnection) @register_query(LocalMongoDBConnection)
def get_spent(fullfil_transaction_id: str, fullfil_output_index: str, connection): def get_spent(fullfil_transaction_id: str, fullfil_output_index: str, connection):
space = connection.space("inputs") space = connection.space("inputs")
_inputs = space.select([fullfil_transaction_id, fullfil_output_index], index="spent_search") _inputs = space.select([fullfil_transaction_id, str(fullfil_output_index)], index="spent_search")
_inputs = _inputs.data _inputs = _inputs.data
_transactions = _group_transaction_by_ids(txids=[inp[0] for inp in _inputs], connection=connection) _transactions = _group_transaction_by_ids(txids=[inp[0] for inp in _inputs], connection=connection)
return _transactions return _transactions
@ -257,18 +257,14 @@ def get_owned_ids(connection, owner: str): # TODO To make a test
@register_query(LocalMongoDBConnection) @register_query(LocalMongoDBConnection)
def get_spending_transactions(inputs, connection): # TODO can be duplicate transaction objects, to verify somehow def get_spending_transactions(inputs, connection):
transaction_ids = [i['transaction_id'] for i in inputs]
output_indexes = [i['output_index'] for i in inputs]
_transactions = [] _transactions = []
for i in range(0, len(transaction_ids)): for inp in inputs:
ts_id = transaction_ids[i] _trans_list = get_spent(fullfil_transaction_id=inp["transaction_id"],
ot_id = output_indexes[i] fullfil_output_index=inp["output_index"],
connection=connection)
_trans_object = get_spent(fullfil_transaction_id=ts_id, fullfil_output_index=ot_id, connection=connection) _transactions.extend(_trans_list)
_transactions.extend(_trans_object)
return _transactions return _transactions