mirror of
https://github.com/bigchaindb/bigchaindb.git
synced 2024-10-13 13:34:05 +00:00
50b0b3cef2
* Adjust imports to bigchaindb_common * Adjust get_spent function signature * Adjust block serialization * Fix BigchainApi Test * Fix TestTransactionValidation tests * Fix TestBlockValidation tests * WIP: TestMultipleInputs * Adjust tests to tx-model interface changes - Fix old tests - Fix tests in TestMultipleInputs class * Remove fulfillment message tests * Fix TransactionMalleability tests * Remove Cryptoconditions tests * Remove create_transaction * Remove signing logic * Remove consensus plugin * Fix block_creation pipeline * Fix election pipeline * Replace some util functions with bdb_common ones - timestamp ==> gen_timestamp - serialize. * Implement Block model * Simplify function signatures for vote functions Change parameter interface for the following functions: - has_previous_vote - verify_vote_signature - block_election_status so that they take a block's id and voters instead of a fake block. * Integrate Block and Transaction model * Fix leftover tests and cleanup conftest * Add bigchaindb-common to install_requires * Delete transactions after block is written (#609) * delete transactions after block is written * cleanup transaction_exists * check for duplicate transactions * delete invalid tx from backlog * test duplicate transaction * Remove dead code * Test processes.py * Test invalid tx in on server * Fix tests for core.py * Fix models tests * Test commands main fn * Add final coverage to vote pipeline * Add more tests to voting pipeline * Remove consensus plugin docs and misc * Post rebase fixes * Fix rebase mess * Remove extra blank line * Improve docstring * Remove comment handled in bigchaindb/cryptoconditions#27; see https://github.com/bigchaindb/cryptoconditions/issues/27 * Fix block serialization in block creation * Add signed_ prefix to transfer_tx * Improve docs * Add library documentation page on pipelines * PR feedback for models.py * Impr. readability of get_last_voted_block * Use dict comprehension * Add docker-compose file to build and serve docs locally for development purposes * Change private_key for signing_key * Improve docstrings * Remove consensus docs * Document new consensus module * Create different transactions for the block * Cleanup variable names in block.py * Create different transactions for the block * Cleanup variable names in block.py
140 lines
3.7 KiB
Python
140 lines
3.7 KiB
Python
import queue
|
|
from unittest.mock import patch, call
|
|
|
|
import pytest
|
|
|
|
|
|
@pytest.fixture
|
|
def mock_queue(monkeypatch):
|
|
|
|
class MockQueue:
|
|
items = []
|
|
|
|
def get(self, timeout=None):
|
|
try:
|
|
return self.items.pop()
|
|
except IndexError:
|
|
if timeout:
|
|
raise queue.Empty()
|
|
raise
|
|
|
|
def put(self, item):
|
|
self.items.append(item)
|
|
|
|
mockqueue = MockQueue()
|
|
|
|
monkeypatch.setattr('queue.Queue', lambda: mockqueue)
|
|
return mockqueue
|
|
|
|
|
|
def test_empty_pool_is_populated_with_instances(mock_queue):
|
|
from bigchaindb import util
|
|
|
|
pool = util.pool(lambda: 'hello', 4)
|
|
|
|
assert len(mock_queue.items) == 0
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 1
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 2
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 3
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 4
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 4
|
|
|
|
|
|
def test_pool_blocks_if_no_instances_available(mock_queue):
|
|
from bigchaindb import util
|
|
|
|
pool = util.pool(lambda: 'hello', 4)
|
|
|
|
assert len(mock_queue.items) == 0
|
|
|
|
# We need to manually trigger the `__enter__` method so the context
|
|
# manager will "hang" and not return the resource to the pool
|
|
assert pool().__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
assert pool().__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
assert pool().__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
# We need to keep a reference of the last context manager so we can
|
|
# manually release the resource
|
|
last = pool()
|
|
assert last.__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
# This would block using `queue.Queue` but since we mocked it it will
|
|
# just raise a IndexError because it's trying to pop from an empty list.
|
|
with pytest.raises(IndexError):
|
|
assert pool().__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
# Release the last resource
|
|
last.__exit__(None, None, None)
|
|
assert len(mock_queue.items) == 1
|
|
|
|
assert pool().__enter__() == 'hello'
|
|
assert len(mock_queue.items) == 0
|
|
|
|
|
|
def test_pool_raises_empty_exception_when_timeout(mock_queue):
|
|
from bigchaindb import util
|
|
|
|
pool = util.pool(lambda: 'hello', 1, timeout=1)
|
|
|
|
assert len(mock_queue.items) == 0
|
|
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
assert len(mock_queue.items) == 1
|
|
|
|
# take the only resource available
|
|
assert pool().__enter__() == 'hello'
|
|
|
|
with pytest.raises(queue.Empty):
|
|
with pool() as instance:
|
|
assert instance == 'hello'
|
|
|
|
|
|
@patch('multiprocessing.Process')
|
|
def test_process_group_instantiates_and_start_processes(mock_process):
|
|
from bigchaindb.util import ProcessGroup
|
|
|
|
def noop():
|
|
pass
|
|
|
|
concurrency = 10
|
|
|
|
pg = ProcessGroup(concurrency=concurrency, group='test_group', target=noop)
|
|
pg.start()
|
|
|
|
mock_process.assert_has_calls([call(group='test_group', target=noop,
|
|
name=None, args=(), kwargs={},
|
|
daemon=None)
|
|
for i in range(concurrency)], any_order=True)
|
|
|
|
for process in pg.processes:
|
|
process.start.assert_called_with()
|
|
|
|
|
|
def test_is_genesis_block_returns_true_if_genesis(b):
|
|
from bigchaindb.util import is_genesis_block
|
|
genesis_block = b.prepare_genesis_block()
|
|
assert is_genesis_block(genesis_block)
|