From 200531dd96a84e79f84a628041dcbf4c75b860d4 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Wed, 8 Jan 2020 13:09:16 -0300 Subject: [PATCH] wait for tx instead --- lbry/testcase.py | 5 +++++ tests/integration/blockchain/test_wallet_server_sessions.py | 4 +--- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/lbry/testcase.py b/lbry/testcase.py index 2f9989076..39118c953 100644 --- a/lbry/testcase.py +++ b/lbry/testcase.py @@ -253,6 +253,11 @@ class IntegrationTestCase(AsyncioTestCase): lambda e: e.tx.id == txid ) + def on_address_update(self, address): + return self.ledger.on_transaction.where( + lambda e: e.address == address + ) + def on_transaction_address(self, tx, address): return self.ledger.on_transaction.where( lambda e: e.tx.id == tx.id and e.address == address diff --git a/tests/integration/blockchain/test_wallet_server_sessions.py b/tests/integration/blockchain/test_wallet_server_sessions.py index 8b3c0025e..a39ac916f 100644 --- a/tests/integration/blockchain/test_wallet_server_sessions.py +++ b/tests/integration/blockchain/test_wallet_server_sessions.py @@ -77,10 +77,8 @@ class TestUsagePayment(CommandTestCase): self.assertEqual(features["payment_address"], address) self.assertEqual(features["daily_fee"], "1.1") - await asyncio.sleep(1) # fixme: wait on something better - + await self.on_address_update(address) _, history = await self.ledger.get_local_status_and_history(address) - self.assertNotEqual(history, []) txid, nout = history[0] tx_details = await self.daemon.jsonrpc_transaction_show(txid) self.assertEqual(tx_details.outputs[nout].amount, 110000000)