diff --git a/bigchaindb/tendermint/event_stream.py b/bigchaindb/tendermint/event_stream.py index 2191924b..9a597026 100644 --- a/bigchaindb/tendermint/event_stream.py +++ b/bigchaindb/tendermint/event_stream.py @@ -50,7 +50,7 @@ def process_event(event_queue, event, stream_id): # Only push non empty blocks if block_txs: block_txs = [decode_transaction_base64(txn) for txn in block_txs] - new_block = {'id': str(block_id), 'transactions': block_txs} + new_block = {'height': block_id, 'transactions': block_txs} event = Event(EventTypes.BLOCK_VALID, new_block) event_queue.put(event) diff --git a/tests/tendermint/test_event_stream.py b/tests/tendermint/test_event_stream.py index a3f3467d..02145bbf 100644 --- a/tests/tendermint/test_event_stream.py +++ b/tests/tendermint/test_event_stream.py @@ -35,6 +35,8 @@ def test_process_event_new_block(): event_queue = Queue() process_event(event_queue, event, 'test_stream_id') assert not event_queue.empty() + block = event_queue.get() + assert isinstance(block.data['height'], int) def test_process_event_empty_block():