mirror of
https://github.com/bigchaindb/bigchaindb.git
synced 2024-10-13 13:34:05 +00:00
7e33f2bd52
* Allow AssetLinks to be used in place of Assets in the Transaction Model and enforce `Transaction.transfer()` to only take an AssetLink * Remove AssetLink's inheritance from Asset * Remove id from the Asset model * Fix get_txids_by_asset_id query for rethinkdb after removing asset's uuid Because `CREATE` transactions don't have an asset that contains an id anymore, one way to find all the transactions related to an asset is to query the database twice: once for the `CREATE` transaction and another for the `TRANSFER` transactions. * Add TODO notice for vote test utils to be fixtures * Update asset model documentation to reflect usage of transaction id * Fix outdated asset description in transaction schema
181 lines
6.4 KiB
Python
181 lines
6.4 KiB
Python
import builtins
|
|
import json
|
|
|
|
import pytest
|
|
from bigchaindb.common import crypto
|
|
|
|
|
|
TX_ENDPOINT = '/api/v1/transactions/'
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_get_transaction_endpoint(b, client, user_pk):
|
|
input_tx = b.get_owned_ids(user_pk).pop()
|
|
tx = b.get_transaction(input_tx.txid)
|
|
res = client.get(TX_ENDPOINT + tx.id)
|
|
assert tx.to_dict() == res.json
|
|
assert res.status_code == 200
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_get_transaction_returns_404_if_not_found(client):
|
|
res = client.get(TX_ENDPOINT + '123')
|
|
assert res.status_code == 404
|
|
|
|
res = client.get(TX_ENDPOINT + '123/')
|
|
assert res.status_code == 404
|
|
|
|
|
|
@pytest.mark.usefixtures('setup_database')
|
|
def test_post_create_transaction_endpoint(b, client):
|
|
from bigchaindb.models import Transaction
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
|
|
tx = Transaction.create([user_pub], [([user_pub], 1)])
|
|
tx = tx.sign([user_priv])
|
|
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(tx.to_dict()))
|
|
assert res.json['fulfillments'][0]['owners_before'][0] == user_pub
|
|
assert res.json['conditions'][0]['owners_after'][0] == user_pub
|
|
|
|
|
|
def test_post_create_transaction_with_invalid_id(b, client):
|
|
from bigchaindb.common.exceptions import InvalidHash
|
|
from bigchaindb.models import Transaction
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
|
|
tx = Transaction.create([user_pub], [([user_pub], 1)])
|
|
tx = tx.sign([user_priv]).to_dict()
|
|
tx['id'] = 'abcd' * 16
|
|
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(tx))
|
|
assert res.status_code == 400
|
|
err_msg = ("The transaction's id '{}' isn't equal to "
|
|
"the hash of its body, i.e. it's not valid.").format(tx['id'])
|
|
assert res.json['message'] == (
|
|
'Invalid transaction ({}): {}'.format(InvalidHash.__name__, err_msg))
|
|
|
|
|
|
def test_post_create_transaction_with_invalid_signature(b, client):
|
|
from bigchaindb.common.exceptions import InvalidSignature
|
|
from bigchaindb.models import Transaction
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
|
|
tx = Transaction.create([user_pub], [([user_pub], 1)])
|
|
tx = tx.sign([user_priv]).to_dict()
|
|
tx['fulfillments'][0]['fulfillment'] = 'cf:0:0'
|
|
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(tx))
|
|
assert res.status_code == 400
|
|
assert res.json['message'] == (
|
|
"Invalid transaction ({}): Fulfillment URI "
|
|
"couldn't been parsed".format(InvalidSignature.__name__))
|
|
|
|
|
|
def test_post_create_transaction_with_invalid_structure(client):
|
|
res = client.post(TX_ENDPOINT, data='{}')
|
|
assert res.status_code == 400
|
|
|
|
|
|
def test_post_create_transaction_with_invalid_schema(client):
|
|
from bigchaindb.models import Transaction
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
tx = Transaction.create(
|
|
[user_pub], [([user_pub], 1)]).sign([user_priv]).to_dict()
|
|
del tx['version']
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(tx))
|
|
assert res.status_code == 400
|
|
assert res.json['message'] == (
|
|
"Invalid transaction schema: 'version' is a required property")
|
|
|
|
|
|
@pytest.mark.parametrize('exc,msg', (
|
|
('AmountError', 'Do the math again!'),
|
|
('DoubleSpend', 'Nope! It is gone now!'),
|
|
('InvalidHash', 'Do not smoke that!'),
|
|
('InvalidSignature', 'Falsche Unterschrift!'),
|
|
('OperationError', 'Create and transfer!'),
|
|
('TransactionDoesNotExist', 'Hallucinations?'),
|
|
('TransactionOwnerError', 'Not yours!'),
|
|
('TransactionNotInValidBlock', 'Wait, maybe?'),
|
|
('ValueError', '?'),
|
|
))
|
|
def test_post_invalid_transaction(client, exc, msg, monkeypatch):
|
|
from bigchaindb.common import exceptions
|
|
try:
|
|
exc_cls = getattr(exceptions, exc)
|
|
except AttributeError:
|
|
exc_cls = getattr(builtins, 'ValueError')
|
|
|
|
def mock_validation(self_, tx):
|
|
raise exc_cls(msg)
|
|
|
|
monkeypatch.setattr(
|
|
'bigchaindb.Bigchain.validate_transaction', mock_validation)
|
|
monkeypatch.setattr(
|
|
'bigchaindb.models.Transaction.from_dict', lambda tx: None)
|
|
res = client.post(TX_ENDPOINT, data=json.dumps({}))
|
|
assert res.status_code == 400
|
|
assert (res.json['message'] ==
|
|
'Invalid transaction ({}): {}'.format(exc, msg))
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_post_transfer_transaction_endpoint(b, client, user_pk, user_sk):
|
|
sk, pk = crypto.generate_key_pair()
|
|
from bigchaindb.models import Transaction
|
|
from bigchaindb.common.transaction import AssetLink
|
|
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
|
|
input_valid = b.get_owned_ids(user_pk).pop()
|
|
create_tx = b.get_transaction(input_valid.txid)
|
|
transfer_tx = Transaction.transfer(create_tx.to_inputs(),
|
|
[([user_pub], 1)],
|
|
AssetLink(create_tx.id))
|
|
transfer_tx = transfer_tx.sign([user_sk])
|
|
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(transfer_tx.to_dict()))
|
|
|
|
assert res.json['fulfillments'][0]['owners_before'][0] == user_pk
|
|
assert res.json['conditions'][0]['owners_after'][0] == user_pub
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_post_invalid_transfer_transaction_returns_400(b, client, user_pk, user_sk):
|
|
from bigchaindb.models import Transaction
|
|
from bigchaindb.common.transaction import AssetLink
|
|
|
|
user_priv, user_pub = crypto.generate_key_pair()
|
|
|
|
input_valid = b.get_owned_ids(user_pk).pop()
|
|
create_tx = b.get_transaction(input_valid.txid)
|
|
transfer_tx = Transaction.transfer(create_tx.to_inputs(),
|
|
[([user_pub], 1)],
|
|
AssetLink(create_tx.id))
|
|
|
|
res = client.post(TX_ENDPOINT, data=json.dumps(transfer_tx.to_dict()))
|
|
assert res.status_code == 400
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_get_transaction_status_endpoint(b, client, user_pk):
|
|
input_tx = b.get_owned_ids(user_pk).pop()
|
|
tx, status = b.get_transaction(input_tx.txid, include_status=True)
|
|
res = client.get(TX_ENDPOINT + input_tx.txid + "/status")
|
|
assert status == res.json['status']
|
|
assert res.status_code == 200
|
|
|
|
res = client.get(TX_ENDPOINT + input_tx.txid + "/status/")
|
|
assert status == res.json['status']
|
|
assert res.status_code == 200
|
|
|
|
|
|
@pytest.mark.usefixtures('inputs')
|
|
def test_get_transaction_status_returns_404_if_not_found(client):
|
|
res = client.get(TX_ENDPOINT + '123' + "/status")
|
|
assert res.status_code == 404
|
|
|
|
res = client.get(TX_ENDPOINT + '123' + "/status/")
|
|
assert res.status_code == 404
|