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

Merge pull request #137 from andreitricolici/planetmint-tarantool

Browse Source 
Fixed upsert function and flush_db_tarantool
This commit is contained in:
Lorenz Herzberger 2022-06-09 16:31:43 +02:00 committed by GitHub
commit a5fbc161a9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 18 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
planetmint/backend/schema.py
View File

@ -22,7 +22,7 @@ TABLES = ('transactions', 'blocks', 'assets', 'metadata',
SPACE_NAMES = ("abci_chains", "assets", "blocks", "blocks_tx",
"elections", "meta_data", "pre_commits", "validators",
"transactions", "inputs", "outputs", "keys")
"transactions", "inputs", "outputs", "keys", "utxos")
VALID_LANGUAGES = ('danish', 'dutch', 'english', 'finnish', 'french', 'german',
'hungarian', 'italian', 'norwegian', 'portuguese', 'romanian',

1
planetmint/backend/tarantool/connection.py
View File

@ -62,7 +62,6 @@ class TarantoolDBConnection(Connection):
except tarantool.error.NetworkError as net_error:
raise net_error
def get_connection(self):
return self.conn

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

@ -390,11 +390,11 @@ def store_pre_commit_state(connection, state: dict):
_precommit = connection.run(
connection.space("pre_commits").select([], limit=1)
)
_precommitTuple = (token_hex(8), state["height"], state["transactions"]) if _precommit is None or len(_precommit) == 0 else _precommit[0]
_precommitTuple = (token_hex(8), state["height"], state["transactions"]) if _precommit is None or len(
_precommit) == 0 else _precommit[0]
connection.run(
connection.space("pre_commits").upsert(_precommitTuple,
op_list=[('=', 0, _precommitTuple[0]),
('=', 1, state["height"]),
op_list=[('=', 1, state["height"]),
('=', 2, state["transactions"])],
limit=1),
only_data=False
@ -420,8 +420,7 @@ def store_validator_set(conn, validators_update: dict):
unique_id = token_hex(8) if _validator is None or len(_validator) == 0 else _validator[0][0]
conn.run(
conn.space("validators").upsert((unique_id, validators_update["height"], validators_update["validators"]),
op_list=[('=', 0, unique_id),
('=', 1, validators_update["height"]),
op_list=[('=', 1, validators_update["height"]),
('=', 2, validators_update["validators"])],
limit=1),
only_data=False
@ -444,8 +443,7 @@ def delete_validator_set(connection, height: int):
def store_election(connection, election_id: str, height: int, is_concluded: bool):
connection.run(
connection.space("elections").upsert((election_id, height, is_concluded),
op_list=[('=', 0, election_id),
('=', 1, height),
op_list=[('=', 1, height),
('=', 2, is_concluded)],
limit=1),
only_data=False
@ -517,16 +515,8 @@ def get_asset_tokens_for_public_key(connection, asset_id: str,
@register_query(TarantoolDBConnection)
def store_abci_chain(connection, height: int, chain_id: str, is_synced: bool = True):
_chain = connection.run(connection.space("abci_chains").select(height, index="height_search", limit=1))
_chainTuple = (height, is_synced, chain_id) if _chain is None or len(_chain) == 0 else _chain[0]
connection.run(
connection.space("abci_chains").upsert(_chainTuple,
op_list=[('=', 0, height),
('=', 1, is_synced),
('=', 2, chain_id)],
limit=1),
only_data=False
)
connection.run(connection.space("abci_chains").delete(chain_id), only_data=False)
connection.run(connection.space("abci_chains").insert((height, is_synced, chain_id)), only_data=False)
@register_query(TarantoolDBConnection)

2
tests/tendermint/test_lib.py
View File

@ -522,7 +522,7 @@ def test_get_spent_key_order(b, user_pk, user_sk, user2_pk, user2_sk):
asset=None) \
.sign([user_sk])
b.store_bulk_transactions([tx1])
assert tx1.validate(b)
inputs = tx1.to_inputs()
tx2 = Transfer.generate([inputs[1]], [([user2_pk], 2)], tx1.id).sign([user_sk])
assert tx2.validate(b)

10
tests/utils.py
View File

@ -40,13 +40,15 @@ def flush_tarantool_db(connection, dbname):
if "assets" == s:
connection.run(connection.space(s).delete(_id[1]), only_data=False)
elif s in ["blocks", "abci_chains"]:
connection.run(connection.space(s).delete(_id[2], only_data=False))
connection.run(connection.space(s).delete(_id[2]), only_data=False)
elif s == "inputs":
connection.run(connection.space(s).delete(_id[-2], only_data=False))
connection.run(connection.space(s).delete(_id[-2]), only_data=False)
elif s == "outputs":
connection.run(connection.space(s).delete(_id[-4], only_data=False))
connection.run(connection.space(s).delete(_id[-4]), only_data=False)
elif s == "utxos":
connection.run(connection.space(s).delete([_id[0], _id[1]]), only_data=False)
else:
connection.run(connection.space(s).delete(_id[0], only_data=False))
connection.run(connection.space(s).delete(_id[0]), only_data=False)
def generate_block(planet):