Mirroristas/planetmint
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint.git synced 2025-06-11 08:36:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed delete_transactions query

Browse Source 
Signed-off-by: Lorenz Herzberger <lorenzherzberger@gmail.com>
This commit is contained in:
Lorenz Herzberger 2023-04-07 16:38:47 +02:00
parent e627eb899d
commit 6b57b1a4f0
No known key found for this signature in database
GPG Key ID: FA5EE906EB55316A
3 changed files with 9 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
planetmint/backend/tarantool/sync_io/query.py
View File

@ -337,6 +337,7 @@ def delete_transactions(connection, txn_ids: list):
_outputs = get_outputs_by_tx_id(connection, _id)
for x in range(len(_outputs)):
connection.connect().call("delete_output", (_outputs[x].id))
connection.connect().delete(TARANT_TABLE_UTXOS, (_id,_outputs[x].index), index="utxo_by_transaction_id_and_output_index")
for _id in txn_ids:
connection.connect().delete(TARANT_TABLE_TRANSACTION, _id)
connection.connect().delete(TARANT_TABLE_GOVERNANCE, _id)

33
tests/tendermint/test_fastquery.py
View File

@ -89,11 +89,7 @@ def test_filter_unspent_outputs(b, user_pk, user_sk, test_models):
}
def test_outputs_query_key_order(b, user_pk, user_sk, user2_pk, user2_sk, test_models, test_validator):
from planetmint import backend
from planetmint.backend.connection import Connection
from planetmint.backend import query
def test_outputs_query_key_order(b, user_pk, user_sk, user2_pk, test_validator):
tx1 = Create.generate([user_pk], [([user_pk], 3), ([user_pk], 2), ([user_pk], 1)]).sign([user_sk])
b.models.store_bulk_transactions([tx1])
@ -101,34 +97,21 @@ def test_outputs_query_key_order(b, user_pk, user_sk, user2_pk, user2_sk, test_m
tx2 = Transfer.generate([inputs[1]], [([user2_pk], 2)], [tx1.id]).sign([user_sk])
assert test_validator.validate_transaction(tx2)
tx2_dict = tx2.to_dict()
fulfills = tx2_dict["inputs"][0]["fulfills"]
tx2_dict["inputs"][0]["fulfills"] = {
"transaction_id": fulfills["transaction_id"],
"output_index": fulfills["output_index"],
}
backend.query.store_transactions(test_models.connection, [tx2_dict])
b.models.store_bulk_transactions([tx2])
outputs = test_models.get_outputs_filtered(user_pk, spent=False)
outputs = b.models.get_outputs_filtered(user_pk, spent=False)
assert len(outputs) == 2
outputs = test_models.get_outputs_filtered(user2_pk, spent=False)
outputs = b.models.get_outputs_filtered(user2_pk, spent=False)
assert len(outputs) == 1
# clean the transaction, metdata and asset collection
connection = Connection()
query.delete_transactions(test_models.connection, txn_ids=[tx1.id, tx2.id])
b.models.delete_transactions([tx1.id, tx2.id])
b.models.store_bulk_transactions([tx1])
tx2_dict = tx2.to_dict()
tx2_dict["inputs"][0]["fulfills"] = {
"output_index": fulfills["output_index"],
"transaction_id": fulfills["transaction_id"],
}
b.models.store_bulk_transactions([tx1, tx2])
backend.query.store_transactions(test_models.connection, [tx2_dict])
outputs = test_models.get_outputs_filtered(user_pk, spent=False)
outputs = b.models.get_outputs_filtered(user_pk, spent=False)
assert len(outputs) == 2
outputs = test_models.get_outputs_filtered(user2_pk, spent=False)
outputs = b.models.get_outputs_filtered(user2_pk, spent=False)
assert len(outputs) == 1

1
tests/utils.py
View File

@ -10,7 +10,6 @@ import random
from functools import singledispatch
from planetmint import backend
from planetmint.backend.localmongodb.connection import LocalMongoDBConnection
from planetmint.backend.tarantool.sync_io.connection import TarantoolDBConnection
from planetmint.backend.schema import TABLES