From c6ea345d86d20e016e880b6492bbe31f66641f85 Mon Sep 17 00:00:00 2001
From: Rodolphe Marques <marques.rodolphe@gmail.com>
Date: Mon, 9 Jan 2017 13:49:55 +0100
Subject: [PATCH] Updated mongodb queries to work with new transaction model.

---
 bigchaindb/backend/mongodb/query.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/bigchaindb/backend/mongodb/query.py b/bigchaindb/backend/mongodb/query.py
index fdccda68..4cb82ef6 100644
--- a/bigchaindb/backend/mongodb/query.py
+++ b/bigchaindb/backend/mongodb/query.py
@@ -130,12 +130,12 @@ def get_asset_by_id(conn, asset_id):
 
 
 @register_query(MongoDBConnection)
-def get_spent(conn, transaction_id, condition_id):
+def get_spent(conn, transaction_id, output):
     cursor = conn.db['bigchain'].aggregate([
         {'$unwind': '$block.transactions'},
         {'$match': {
-            'block.transactions.fulfillments.input.txid': transaction_id,
-            'block.transactions.fulfillments.input.cid': condition_id
+            'block.transactions.inputs.fulfills.txid': transaction_id,
+            'block.transactions.inputs.fulfills.output': output
         }}
     ])
     # we need to access some nested fields before returning so lets use a
@@ -148,7 +148,7 @@ def get_owned_ids(conn, owner):
     cursor = conn.db['bigchain'].aggregate([
         {'$unwind': '$block.transactions'},
         {'$match': {
-            'block.transactions.conditions.owners_after': {
+            'block.transactions.outputs.public_keys': {
                 '$elemMatch': {'$eq': owner}
             }
         }}