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

Revert "get_tx_by_payload_hash checks block status (no tests)"

Browse Source 
This reverts commit bb0bb9a1b4f686e2cb042427de1aeb06a002fc14.
This commit is contained in:
ryan 2016-05-23 10:20:33 +02:00
parent 5bc66a28c1
commit 1b10d11a2c
1 changed files with 51 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

110
bigchaindb/core.py
View File

@ -175,6 +175,52 @@ class Bigchain(object):
else:
return None
def search_block_election_on_index(self, value, index):
"""Retrieves block election information given a secondary index and value
Args:
value: a value to search (e.g. transaction id string, payload hash string)
index (str): name of a secondary index, e.g. 'transaction_id'
Returns:
A list of blocks with with only election information
"""
# First, get information on all blocks which contain this transaction
response = r.table('bigchain').get_all(value, index=index)\
.pluck('votes', 'id', {'block': ['voters']}).run(self.conn)
return list(response)
def get_blocks_status_containing_tx(self, txid):
"""Retrieves block ids and statuses related to a transaction
Transactions may occur in multiple blocks, but no more than one valid block.
Args:
txid (str): transaction id of the transaction to query
Returns:
A dict of blocks containing the transaction, e.g. {block_id_1: 'valid', block_id_2: 'invalid' ...}, or None
"""
# First, get information on all blocks which contain this transaction
blocks = self.search_block_election_on_index(txid, 'transaction_id')
if blocks:
# Determine the election status of each block
validity = {block['id']: self.block_election_status(block) for block in blocks}
# If there are multiple valid blocks with this transaction, something has gone wrong
if list(validity.values()).count('valid') > 1:
raise Exception('Transaction {tx} is present in multiple valid blocks: {block_ids}'
.format(tx=txid,
block_ids=str([block for block in validity if validity[block] == 'valid'])))
return validity
else:
return None
def get_tx_by_payload_hash(self, payload_hash):
"""Retrieves transactions related to a digital asset.
@ -193,20 +239,12 @@ class Bigchain(object):
returns an empty list `[]`
"""
# First, get information on all blocks which contain this hash
blocks = self.search_block_election_on_index(payload_hash, 'payload_hash')
if blocks:
validity = {block['id']: self.block_election_status(block) for block in blocks}
cursor = r.table('bigchain') \
.get_all(payload_hash, index='payload_hash') \
.run(self.conn)
# disregard invalid blocks
validity = {_id: status for _id, status in validity.items() if status != 'invalid'}
cursor = r.table('bigchain').get_all(*list(validity.keys()))\
.get_all(payload_hash, index='payload_hash')\
.run(self.conn)
return list(cursor)
else:
return []
transactions = list(cursor)
return transactions
def get_spent(self, tx_input):
"""Check if a `txid` was already used as an input.
@ -296,52 +334,6 @@ class Bigchain(object):
return owned
def search_block_election_on_index(self, value, index):
"""Retrieves block election information given a secondary index and value
Args:
value: a value to search (e.g. transaction id string, payload hash string)
index (str): name of a secondary index, e.g. 'transaction_id'
Returns:
A list of blocks with with only election information
"""
# First, get information on all blocks which contain this transaction
response = r.table('bigchain').get_all(value, index=index)\
.pluck('votes', 'id', {'block': ['voters']}).run(self.conn)
return list(response)
def get_blocks_status_containing_tx(self, txid):
"""Retrieves block ids and statuses related to a transaction
Transactions may occur in multiple blocks, but no more than one valid block.
Args:
txid (str): transaction id of the transaction to query
Returns:
A dict of blocks containing the transaction, e.g. {block_id_1: 'valid', block_id_2: 'invalid' ...}, or None
"""
# First, get information on all blocks which contain this transaction
blocks = self.search_block_election_on_index(txid, 'transaction_id')
if blocks:
# Determine the election status of each block
validity = {block['id']: self.block_election_status(block) for block in blocks}
# If there are multiple valid blocks with this transaction, something has gone wrong
if list(validity.values()).count('valid') > 1:
raise Exception('Transaction {tx} is present in multiple valid blocks: {block_ids}'
.format(tx=txid,
block_ids=str([block for block in validity if validity[block] == 'valid'])))
return validity
else:
return None
def validate_transaction(self, transaction):
"""Validate a transaction.