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

pre_commit_state -> PASSED

Browse Source
This commit is contained in:
andrei 2022-02-21 13:28:17 +02:00
parent 134d608f46
commit 6fdcceefbf
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -391,10 +391,10 @@ def delete_transactions(connection, txn_ids: list):
def store_pre_commit_state(state: dict, connection): def store_pre_commit_state(state: dict, connection):
space = connection.space("pre_commits") space = connection.space("pre_commits")
# precommit = space.select(state["height"], index="height_search", limit=1) _precommit = space.select(state["height"], index="height_search", limit=1)
# unique_id = token_hex(8) if (len(_precommit.data) == 0) else _precommit.data[0][0] unique_id = token_hex(8) if (len(_precommit.data) == 0) else _precommit.data[0][0]
space.upsert((state["commit_id"], state["height"], state["transactions"]), space.upsert((unique_id, state["height"], state["transactions"]),
op_list=[('=', 0, state["id"]), op_list=[('=', 0, unique_id),
('=', 1, state["height"]), ('=', 1, state["height"]),
('=', 2, state["transactions"])], ('=', 2, state["transactions"])],
limit=1) limit=1)

2
tests/backend/tarantool/test_queries.py
View File

@ -434,7 +434,7 @@ def test_store_pre_commit_state(db_context):
query.store_pre_commit_state(connection=conn, state=state) query.store_pre_commit_state(connection=conn, state=state)
commit = query.get_pre_commit_state(connection=conn) commit = query.get_pre_commit_state(connection=conn)
assert len(list(commit)) == 1 assert len([commit]) == 1
# cursor = db_context.conn.db.pre_commit.find({'commit_id': 'test'}, # cursor = db_context.conn.db.pre_commit.find({'commit_id': 'test'},
# projection={'_id': False}) # projection={'_id': False})