mirror of
https://github.com/bigchaindb/bigchaindb.git
synced 2024-10-13 13:34:05 +00:00
69 lines
1.9 KiB
Python
69 lines
1.9 KiB
Python
import time
|
|
import pytest
|
|
|
|
from bigchaindb import Bigchain
|
|
|
|
|
|
@pytest.fixture
|
|
def inputs(user_pk):
|
|
from bigchaindb.models import Transaction
|
|
|
|
b = Bigchain()
|
|
|
|
# create blocks with transactions for `USER` to spend
|
|
for block in range(4):
|
|
transactions = [
|
|
Transaction.create(
|
|
[b.me], [([user_pk], 1)],
|
|
metadata={'i': i})
|
|
.sign([b.me_private])
|
|
for i in range(10)
|
|
]
|
|
block = b.create_block(transactions)
|
|
b.write_block(block, durability='hard')
|
|
|
|
|
|
@pytest.mark.usefixtures('processes')
|
|
def test_fast_double_create(b, user_pk):
|
|
from bigchaindb.models import Transaction
|
|
from bigchaindb.backend.query import count_blocks
|
|
tx = Transaction.create([b.me], [([user_pk], 1)],
|
|
metadata={'test': 'test'}) \
|
|
.sign([b.me_private])
|
|
|
|
# write everything fast
|
|
b.write_transaction(tx)
|
|
b.write_transaction(tx)
|
|
|
|
time.sleep(2)
|
|
tx_returned = b.get_transaction(tx.id)
|
|
|
|
# test that the tx can be queried
|
|
assert tx_returned == tx
|
|
# test the transaction appears only once
|
|
last_voted_block = b.get_last_voted_block()
|
|
assert len(last_voted_block.transactions) == 1
|
|
assert count_blocks(b.connection) == 2
|
|
|
|
|
|
@pytest.mark.usefixtures('processes')
|
|
def test_double_create(b, user_pk):
|
|
from bigchaindb.models import Transaction
|
|
from bigchaindb.backend.query import count_blocks
|
|
tx = Transaction.create([b.me], [([user_pk], 1)],
|
|
metadata={'test': 'test'}) \
|
|
.sign([b.me_private])
|
|
|
|
b.write_transaction(tx)
|
|
time.sleep(2)
|
|
b.write_transaction(tx)
|
|
time.sleep(2)
|
|
tx_returned = b.get_transaction(tx.id)
|
|
|
|
# test that the tx can be queried
|
|
assert tx_returned == tx
|
|
# test the transaction appears only once
|
|
last_voted_block = b.get_last_voted_block()
|
|
assert len(last_voted_block.transactions) == 1
|
|
assert count_blocks(b.connection) == 2
|