Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

more mongocalls

Browse Source
This commit is contained in:
ryan 2016-12-02 17:33:37 +01:00 committed by Sylvain Bellemare
parent 4877f5b03a
commit 2152c245ff
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
bigchaindb/backend/mongodb/query.py
View File

@ -37,18 +37,32 @@ def get_transaction_from_block(conn, block_id, tx_id):
'block.transactions.id': tx_id})
@query.get_transaction_from_backlog(MongoDBConnection)
@query.get_transaction_from_backlog.register(MongoDBConnection)
def get_transaction_from_backlog(conn, transaction_id):
return conn.db['backlog'].find_one({'id': transaction_id})
@query.get_blocks_status_from_transaction(MongoDBConnection)
@query.get_blocks_status_from_transaction.register(MongoDBConnection)
def get_blocks_status_from_transaction(conn, transaction_id):
return conn.db['bigchain']\
.find({'block.transactions.id': transaction_id},
projection=['id', 'block.voters'])
@query.get_txids_by_asset_id.register(MongoDBConnection)
def get_txids_by_asset_id(conn, asset_id):
return conn.db['bigchain']\
.find({'block.transactions.asset.id': asset_id},
projection=['id'])
@query.get_asset_by_id.register(MongoDBConnection)
def get_asset_by_id(conn, asset_id):
return conn.db['bigchain']\
.find_one({'block.transactions.asset.id': asset_id},
projection=['block.transactions.asset'])
@query.write_vote.register(MongoDBConnection)
def write_vote(conn, vote):
return conn.db['votes'].insert_one(vote)