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

added hash generation to create primary key for abci_chain tuple.

Browse Source
This commit is contained in:
andrei 2022-06-13 15:04:03 +03:00
parent 49f406fd2c
commit feb5ad319b
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -5,6 +5,7 @@
"""Query implementation for Tarantool""" """Query implementation for Tarantool"""
from secrets import token_hex from secrets import token_hex
from hashlib import sha256
from operator import itemgetter from operator import itemgetter
import tarantool.error import tarantool.error
@ -15,6 +16,7 @@ from planetmint.backend.tarantool.connection import TarantoolDBConnection
from planetmint.backend.tarantool.transaction.tools import TransactionCompose, TransactionDecompose from planetmint.backend.tarantool.transaction.tools import TransactionCompose, TransactionDecompose
from json import dumps, loads from json import dumps, loads
register_query = module_dispatch_registrar(query) register_query = module_dispatch_registrar(query)
@ -515,20 +517,25 @@ def get_asset_tokens_for_public_key(connection, asset_id: str,
@register_query(TarantoolDBConnection) @register_query(TarantoolDBConnection)
def store_abci_chain(connection, height: int, chain_id: str, is_synced: bool = True): def store_abci_chain(connection, height: int, chain_id: str, is_synced: bool = True):
connection.run(connection.space("abci_chains").delete(chain_id), only_data=False) hash_id_primarykey = sha256(dumps(obj={"height": height}).encode()).hexdigest()
connection.run(connection.space("abci_chains").insert((height, is_synced, chain_id)), only_data=False) connection.run(
connection.space("abci_chains").upsert((height, is_synced, chain_id, hash_id_primarykey),
op_list=[
('=', 0, height),
('=', 1, is_synced),
('=', 2, chain_id)
]),
only_data=False
)
@register_query(TarantoolDBConnection) @register_query(TarantoolDBConnection)
def delete_abci_chain(connection, height: int): def delete_abci_chain(connection, height: int):
_chains = connection.run( hash_id_primarykey = sha256(dumps(obj={"height": height}).encode()).hexdigest()
connection.space("abci_chains").select(height, index="height_search") connection.run(
connection.space("abci_chains").delete(hash_id_primarykey),
only_data=False
) )
for _chain in _chains:
connection.run(
connection.space("abci_chains").delete(_chain[2]),
only_data=False
)
@register_query(TarantoolDBConnection) @register_query(TarantoolDBConnection)