2018-06-29 15:32:16 +02:00
|
|
|
from bigchaindb.common.exceptions import (InvalidSignature, DoubleSpend,
|
|
|
|
InputDoesNotExist,
|
2016-10-29 16:35:15 +02:00
|
|
|
TransactionNotInValidBlock,
|
2017-03-03 11:36:50 +01:00
|
|
|
AssetIdMismatch, AmountError,
|
2018-06-08 15:50:50 +02:00
|
|
|
DuplicateTransaction)
|
2016-12-22 10:19:21 +01:00
|
|
|
from bigchaindb.common.transaction import Transaction
|
2018-06-29 15:32:16 +02:00
|
|
|
from bigchaindb.common.utils import (validate_txn_obj, validate_key)
|
2016-11-28 19:30:09 +01:00
|
|
|
from bigchaindb.common.schema import validate_transaction_schema
|
2017-11-03 14:07:19 +01:00
|
|
|
from bigchaindb.backend.schema import validate_language_key
|
2016-09-29 10:29:41 +02:00
|
|
|
|
|
|
|
|
|
|
|
class Transaction(Transaction):
|
2018-02-02 14:40:24 +01:00
|
|
|
def validate(self, bigchain, current_transactions=[]):
|
2017-03-14 12:39:57 +01:00
|
|
|
"""Validate transaction spend
|
2016-09-29 10:29:41 +02:00
|
|
|
|
|
|
|
Args:
|
Refactor tendermint directory to project root (#2401)
* Problem: core.py contains an unused class, `Bigchain`
Solution: Remove core.py. Refactor BigchainDB Class to remove inheritance from Bigchain.
* Problem: core.py contains an unused class, `Bigchain`
Solution: Remove core.py. Refactor BigchainDB Class to remove inheritance from Bigchain.
* Fixed flake8 complaint about too many blank lines
* Attempting to fix Sphinx docs. This may result in some redundant commits, as I don't know what I'm doing, and I can't experiment without running the CI...
Sorry in advance!
* Attempting to fix Sphinx docs. This may result in some redundant commits, as I don't know what I'm doing, and I can't experiment without running the CI...
Sorry in advance!
* Updating from master changed BigchainDB.process_post_response to a private method, so I had to align with that.
* Fixed a couple stale references to bigchaindb.Bigchain in docstrings
* Missed a reference to `Bigchain` in a patch call...
* Problem: BigchainDB class should be part of project root
Solution: Removed the /tendermint directory and moved its contents to project root
* Problem: Flake8 complained that imports were not at the top of the file
Solution: Had to play around with the order of imports to avoid cyclic dependencies, but its working and style compliant now
* Problem: Stale reference to /tendermint directory in the index
Solution: Removed the references to /tendermint
* Problem: Flake8 complaining of unused import in __init__.py
Solution: The import is there so I can import App directly from bigchaindb, rather than from bigchaindb.core (which I think improves code readability. I added a # noqa to silence Flake8.
* Problem: Stale references to `bigchaindb.tendermint.BigchainDB` in the rst files cause Sphinx to fail
Solution: Updated the autodoc files to use `bigchaindb.BigchainDB` instead
* Problem: Stale reference to the `tendermint` directory in an @patch in a disabled test
Solution: Updated the @patch for completeness
* Problem: BigchainDB class should be part of project root
Solution: Removed the /tendermint directory and moved its contents to project root
* Problem: Flake8 complained that imports were not at the top of the file
Solution: Had to play around with the order of imports to avoid cyclic dependencies, but its working and style compliant now
* Problem: Stale reference to /tendermint directory in the index
Solution: Removed the references to /tendermint
* Problem: Flake8 complaining of unused import in __init__.py
Solution: The import is there so I can import App directly from bigchaindb, rather than from bigchaindb.core (which I think improves code readability. I added a # noqa to silence Flake8.
* Problem: Stale references to `bigchaindb.tendermint.BigchainDB` in the rst files cause Sphinx to fail
Solution: Updated the autodoc files to use `bigchaindb.BigchainDB` instead
* Problem: Stale reference to the `tendermint` directory in an @patch in a disabled test
Solution: Updated the @patch for completeness
2018-07-25 16:59:25 +02:00
|
|
|
bigchain (BigchainDB): an instantiated bigchaindb.BigchainDB object.
|
2016-09-29 10:29:41 +02:00
|
|
|
|
|
|
|
Returns:
|
|
|
|
The transaction (Transaction) if the transaction is valid else it
|
|
|
|
raises an exception describing the reason why the transaction is
|
|
|
|
invalid.
|
|
|
|
|
|
|
|
Raises:
|
2017-03-03 11:36:50 +01:00
|
|
|
ValidationError: If the transaction is invalid
|
2016-09-29 10:29:41 +02:00
|
|
|
"""
|
|
|
|
input_conditions = []
|
2016-12-22 10:19:21 +01:00
|
|
|
|
2017-11-10 17:53:57 +01:00
|
|
|
if self.operation == Transaction.CREATE:
|
2018-02-02 14:40:24 +01:00
|
|
|
duplicates = any(txn for txn in current_transactions if txn.id == self.id)
|
|
|
|
if bigchain.get_transaction(self.to_dict()['id']) or duplicates:
|
2017-11-10 17:53:57 +01:00
|
|
|
raise DuplicateTransaction('transaction `{}` already exists'
|
|
|
|
.format(self.id))
|
|
|
|
elif self.operation == Transaction.TRANSFER:
|
2016-10-12 10:29:25 +02:00
|
|
|
# store the inputs so that we can check if the asset ids match
|
|
|
|
input_txs = []
|
2016-12-15 13:52:16 +01:00
|
|
|
for input_ in self.inputs:
|
|
|
|
input_txid = input_.fulfills.txid
|
2016-10-10 09:41:49 +02:00
|
|
|
input_tx, status = bigchain.\
|
|
|
|
get_transaction(input_txid, include_status=True)
|
|
|
|
|
2018-02-02 14:40:24 +01:00
|
|
|
if input_tx is None:
|
|
|
|
for ctxn in current_transactions:
|
|
|
|
# assume that the status as valid for previously validated
|
|
|
|
# transactions in current round
|
|
|
|
if ctxn.id == input_txid:
|
|
|
|
input_tx = ctxn
|
|
|
|
status = bigchain.TX_VALID
|
|
|
|
|
2016-09-29 10:29:41 +02:00
|
|
|
if input_tx is None:
|
2017-03-07 13:15:31 +01:00
|
|
|
raise InputDoesNotExist("input `{}` doesn't exist"
|
|
|
|
.format(input_txid))
|
2016-09-29 10:29:41 +02:00
|
|
|
|
2016-10-10 09:41:49 +02:00
|
|
|
if status != bigchain.TX_VALID:
|
2016-10-29 16:35:15 +02:00
|
|
|
raise TransactionNotInValidBlock(
|
2016-10-10 09:41:49 +02:00
|
|
|
'input `{}` does not exist in a valid block'.format(
|
|
|
|
input_txid))
|
|
|
|
|
2018-02-02 14:40:24 +01:00
|
|
|
spent = bigchain.get_spent(input_txid, input_.fulfills.output,
|
|
|
|
current_transactions)
|
2016-09-29 10:29:41 +02:00
|
|
|
if spent and spent.id != self.id:
|
|
|
|
raise DoubleSpend('input `{}` was already spent'
|
|
|
|
.format(input_txid))
|
|
|
|
|
2016-12-15 13:52:16 +01:00
|
|
|
output = input_tx.outputs[input_.fulfills.output]
|
2016-12-15 12:05:02 +01:00
|
|
|
input_conditions.append(output)
|
2016-10-12 10:29:25 +02:00
|
|
|
input_txs.append(input_tx)
|
|
|
|
|
2017-01-26 13:39:06 +01:00
|
|
|
# Validate that all inputs are distinct
|
|
|
|
links = [i.fulfills.to_uri() for i in self.inputs]
|
|
|
|
if len(links) != len(set(links)):
|
|
|
|
raise DoubleSpend('tx "{}" spends inputs twice'.format(self.id))
|
|
|
|
|
2016-10-12 10:29:25 +02:00
|
|
|
# validate asset id
|
2016-12-22 10:19:21 +01:00
|
|
|
asset_id = Transaction.get_asset_id(input_txs)
|
|
|
|
if asset_id != self.asset['id']:
|
2016-11-06 20:00:47 +01:00
|
|
|
raise AssetIdMismatch(('The asset id of the input does not'
|
|
|
|
' match the asset id of the'
|
|
|
|
' transaction'))
|
|
|
|
|
2016-12-22 10:19:21 +01:00
|
|
|
input_amount = sum([input_condition.amount for input_condition in input_conditions])
|
2016-12-22 13:45:02 +01:00
|
|
|
output_amount = sum([output_condition.amount for output_condition in self.outputs])
|
2016-11-11 11:34:20 +01:00
|
|
|
|
2016-11-06 20:00:47 +01:00
|
|
|
if output_amount != input_amount:
|
2016-11-10 11:59:22 +01:00
|
|
|
raise AmountError(('The amount used in the inputs `{}`'
|
2016-11-06 20:00:47 +01:00
|
|
|
' needs to be same as the amount used'
|
|
|
|
' in the outputs `{}`')
|
|
|
|
.format(input_amount, output_amount))
|
|
|
|
|
2016-12-13 13:41:46 +01:00
|
|
|
if not self.inputs_valid(input_conditions):
|
2017-01-17 11:27:42 +01:00
|
|
|
raise InvalidSignature('Transaction signature is invalid.')
|
2016-12-22 10:19:21 +01:00
|
|
|
|
|
|
|
return self
|
2016-09-29 10:29:41 +02:00
|
|
|
|
2017-03-07 12:58:32 +01:00
|
|
|
@classmethod
|
|
|
|
def from_dict(cls, tx_body):
|
2017-11-25 01:04:50 +01:00
|
|
|
super().validate_id(tx_body)
|
2017-03-13 14:25:36 +01:00
|
|
|
validate_transaction_schema(tx_body)
|
2017-11-01 12:56:16 +01:00
|
|
|
validate_txn_obj('asset', tx_body['asset'], 'data', validate_key)
|
|
|
|
validate_txn_obj('metadata', tx_body, 'metadata', validate_key)
|
2017-11-03 14:07:19 +01:00
|
|
|
validate_language_key(tx_body['asset'], 'data')
|
2016-11-28 19:30:09 +01:00
|
|
|
return super().from_dict(tx_body)
|
|
|
|
|
2017-05-10 16:43:52 +02:00
|
|
|
@classmethod
|
2018-01-31 14:42:41 +01:00
|
|
|
def from_db(cls, bigchain, tx_dict_list):
|
2017-11-30 15:04:14 +01:00
|
|
|
"""Helper method that reconstructs a transaction dict that was returned
|
2017-05-11 12:29:08 +02:00
|
|
|
from the database. It checks what asset_id to retrieve, retrieves the
|
|
|
|
asset from the asset table and reconstructs the transaction.
|
|
|
|
|
|
|
|
Args:
|
Refactor tendermint directory to project root (#2401)
* Problem: core.py contains an unused class, `Bigchain`
Solution: Remove core.py. Refactor BigchainDB Class to remove inheritance from Bigchain.
* Problem: core.py contains an unused class, `Bigchain`
Solution: Remove core.py. Refactor BigchainDB Class to remove inheritance from Bigchain.
* Fixed flake8 complaint about too many blank lines
* Attempting to fix Sphinx docs. This may result in some redundant commits, as I don't know what I'm doing, and I can't experiment without running the CI...
Sorry in advance!
* Attempting to fix Sphinx docs. This may result in some redundant commits, as I don't know what I'm doing, and I can't experiment without running the CI...
Sorry in advance!
* Updating from master changed BigchainDB.process_post_response to a private method, so I had to align with that.
* Fixed a couple stale references to bigchaindb.Bigchain in docstrings
* Missed a reference to `Bigchain` in a patch call...
* Problem: BigchainDB class should be part of project root
Solution: Removed the /tendermint directory and moved its contents to project root
* Problem: Flake8 complained that imports were not at the top of the file
Solution: Had to play around with the order of imports to avoid cyclic dependencies, but its working and style compliant now
* Problem: Stale reference to /tendermint directory in the index
Solution: Removed the references to /tendermint
* Problem: Flake8 complaining of unused import in __init__.py
Solution: The import is there so I can import App directly from bigchaindb, rather than from bigchaindb.core (which I think improves code readability. I added a # noqa to silence Flake8.
* Problem: Stale references to `bigchaindb.tendermint.BigchainDB` in the rst files cause Sphinx to fail
Solution: Updated the autodoc files to use `bigchaindb.BigchainDB` instead
* Problem: Stale reference to the `tendermint` directory in an @patch in a disabled test
Solution: Updated the @patch for completeness
* Problem: BigchainDB class should be part of project root
Solution: Removed the /tendermint directory and moved its contents to project root
* Problem: Flake8 complained that imports were not at the top of the file
Solution: Had to play around with the order of imports to avoid cyclic dependencies, but its working and style compliant now
* Problem: Stale reference to /tendermint directory in the index
Solution: Removed the references to /tendermint
* Problem: Flake8 complaining of unused import in __init__.py
Solution: The import is there so I can import App directly from bigchaindb, rather than from bigchaindb.core (which I think improves code readability. I added a # noqa to silence Flake8.
* Problem: Stale references to `bigchaindb.tendermint.BigchainDB` in the rst files cause Sphinx to fail
Solution: Updated the autodoc files to use `bigchaindb.BigchainDB` instead
* Problem: Stale reference to the `tendermint` directory in an @patch in a disabled test
Solution: Updated the @patch for completeness
2018-07-25 16:59:25 +02:00
|
|
|
bigchain (:class:`~bigchaindb.BigchainDB`): An instance
|
2018-07-10 17:34:51 +02:00
|
|
|
of BigchainDB used to perform database queries.
|
2018-01-31 14:42:41 +01:00
|
|
|
tx_dict_list (:list:`dict` or :obj:`dict`): The transaction dict or
|
|
|
|
list of transaction dict as returned from the database.
|
2017-05-11 12:29:08 +02:00
|
|
|
|
|
|
|
Returns:
|
|
|
|
:class:`~Transaction`
|
|
|
|
|
|
|
|
"""
|
2018-01-31 14:42:41 +01:00
|
|
|
return_list = True
|
|
|
|
if isinstance(tx_dict_list, dict):
|
|
|
|
tx_dict_list = [tx_dict_list]
|
|
|
|
return_list = False
|
|
|
|
|
|
|
|
tx_map = {}
|
|
|
|
tx_ids = []
|
|
|
|
for tx in tx_dict_list:
|
|
|
|
tx.update({'metadata': None})
|
|
|
|
tx_map[tx['id']] = tx
|
2018-03-16 16:19:12 +01:00
|
|
|
if tx['operation'] == Transaction.CREATE:
|
2018-01-31 14:42:41 +01:00
|
|
|
tx_ids.append(tx['id'])
|
|
|
|
|
|
|
|
assets = list(bigchain.get_assets(tx_ids))
|
|
|
|
for asset in assets:
|
|
|
|
tx = tx_map[asset['id']]
|
2017-05-24 12:38:34 +02:00
|
|
|
del asset['id']
|
2018-01-31 14:42:41 +01:00
|
|
|
tx.update({'asset': asset})
|
|
|
|
|
|
|
|
tx_ids = list(tx_map.keys())
|
|
|
|
metadata_list = list(bigchain.get_metadata(tx_ids))
|
|
|
|
for metadata in metadata_list:
|
|
|
|
tx = tx_map[metadata['id']]
|
|
|
|
tx.update({'metadata': metadata.get('metadata')})
|
|
|
|
|
|
|
|
if return_list:
|
|
|
|
tx_list = []
|
|
|
|
for tx_id, tx in tx_map.items():
|
|
|
|
tx_list.append(cls.from_dict(tx))
|
|
|
|
return tx_list
|
|
|
|
else:
|
|
|
|
tx = list(tx_map.values())[0]
|
|
|
|
return cls.from_dict(tx)
|
2017-05-10 16:43:52 +02:00
|
|
|
|
2016-09-29 10:29:41 +02:00
|
|
|
|
2017-05-22 12:41:15 +02:00
|
|
|
class FastTransaction:
|
2017-11-30 15:04:14 +01:00
|
|
|
"""A minimal wrapper around a transaction dictionary. This is useful for
|
2017-05-22 12:41:15 +02:00
|
|
|
when validation is not required but a routine expects something that looks
|
|
|
|
like a transaction, for example during block creation.
|
|
|
|
|
|
|
|
Note: immutability could also be provided
|
|
|
|
"""
|
2017-11-30 15:04:14 +01:00
|
|
|
|
2017-05-22 12:41:15 +02:00
|
|
|
def __init__(self, tx_dict):
|
|
|
|
self.data = tx_dict
|
|
|
|
|
|
|
|
@property
|
|
|
|
def id(self):
|
|
|
|
return self.data['id']
|
|
|
|
|
|
|
|
def to_dict(self):
|
|
|
|
return self.data
|