From 516084bf58c5e65b9c1c8ad3b1a2a17e0b09a0ac Mon Sep 17 00:00:00 2001 From: andrei Date: Thu, 17 Feb 2022 17:38:05 +0200 Subject: [PATCH] get_metadata test function pass --- planetmint/backend/tarantool/query.py | 2 +- tests/backend/tarantool/test_queries.py | 15 ++++++++------- 2 files changed, 9 insertions(+), 8 deletions(-) diff --git a/planetmint/backend/tarantool/query.py b/planetmint/backend/tarantool/query.py index 8dc9db3..7923df8 100644 --- a/planetmint/backend/tarantool/query.py +++ b/planetmint/backend/tarantool/query.py @@ -116,7 +116,7 @@ def get_transactions(transactions_ids: list, connection): def store_metadatas(metadata: list, connection): space = connection.space("meta_data") for meta in metadata: - space.insert((meta["id"], meta["data"])) + space.insert((meta["id"], meta["data"] if not "metadata" in meta else meta["metadata"])) # @register_query(LocalMongoDBConnection) diff --git a/tests/backend/tarantool/test_queries.py b/tests/backend/tarantool/test_queries.py index e943afd..794717d 100644 --- a/tests/backend/tarantool/test_queries.py +++ b/tests/backend/tarantool/test_queries.py @@ -194,19 +194,20 @@ def test_write_metadata(): def test_get_metadata(): - from planetmint.backend import connect, query - conn = connect() + from planetmint.backend import connect + from planetmint.backend.tarantool import query + conn = connect().get_connection() metadata = [ - {'id': 1, 'metadata': None}, - {'id': 2, 'metadata': {'key': 'value'}}, - {'id': 3, 'metadata': '3'}, + {'id': "dd86682db39e4b424df0eec1413cfad65488fd48712097c5d865ca8e8e059b64", 'metadata': None}, + {'id': "55a2303e3bcd653e4b5bd7118d39c0e2d48ee2f18e22fbcf64e906439bdeb45d", 'metadata': {'key': 'value'}}, ] - conn.db.metadata.insert_many(deepcopy(metadata), ordered=False) + # conn.db.metadata.insert_many(deepcopy(metadata), ordered=False) + query.store_metadatas(connection=conn, metadata=metadata) for meta in metadata: - assert query.get_metadata(conn, [meta['id']]) + assert query.get_metadata(connection=conn, transaction_ids=[meta["id"]]) def test_get_owned_ids(signed_create_tx, user_pk):