diff --git a/src/sakia/tests/conftest.py b/src/sakia/tests/conftest.py index 07cd5f3332031cbe15785053fb0994621fea0dfc..917c07443a4c651608a2ab9c4fef776c30f5b79a 100644 --- a/src/sakia/tests/conftest.py +++ b/src/sakia/tests/conftest.py @@ -40,7 +40,7 @@ def meta_repo(): meta_repo = SakiaDatabase(con, ConnectionsRepo(con), IdentitiesRepo(con), BlockchainsRepo(con), CertificationsRepo(con), TransactionsRepo(con), - NodesRepo(con), SourcesRepo(con)) + NodesRepo(con), SourcesRepo(con), DividendsRepo(con)) meta_repo.prepare() meta_repo.upgrade_database() return meta_repo diff --git a/src/sakia/tests/technical/test_transactions_service.py b/src/sakia/tests/technical/test_transactions_service.py index dfbdfbcdead2728acbc331b0e07ed3d840bd2f19..54d1edcab0fba05c8867bbffb0bf83e422903d95 100644 --- a/src/sakia/tests/technical/test_transactions_service.py +++ b/src/sakia/tests/technical/test_transactions_service.py @@ -37,3 +37,21 @@ async def test_receive_tx(application_with_one_connection, fake_server, bob, ali assert len(tx_before_send) + 1 == len(tx_after_parse) await fake_server.close() + + +@pytest.mark.asyncio +async def test_issue_dividend(application_with_one_connection, fake_server, bob): + dividends_before_send = application_with_one_connection.transactions_services[fake_server.forge.currency].dividends(bob.key.pubkey) + fake_server.forge.forge_block() + fake_server.forge.generate_dividend() + fake_server.forge.forge_block() + fake_server.forge.forge_block() + fake_server.forge.generate_dividend() + fake_server.forge.forge_block() + fake_server.forge.forge_block() + new_blocks = fake_server.forge.blocks[-5:] + application_with_one_connection.transactions_services[fake_server.forge.currency].handle_new_blocks(new_blocks) + dividends_after_parse = application_with_one_connection.transactions_services[fake_server.forge.currency].dividends(bob.key.pubkey) + assert len(dividends_before_send) + 2 == len(dividends_after_parse) + await fake_server.close() +