forked from LBRYCommunity/lbry-sdk
listen for wallet pay service payment earlier in test
This commit is contained in:
parent
8545ab880b
commit
e2ffd24d51
1 changed files with 2 additions and 1 deletions
|
@ -78,11 +78,12 @@ class TestUsagePayment(CommandTestCase):
|
||||||
await node.stop(False)
|
await node.stop(False)
|
||||||
await node.start(self.blockchain, extraconf={"PAYMENT_ADDRESS": address, "DAILY_FEE": "1.0"})
|
await node.start(self.blockchain, extraconf={"PAYMENT_ADDRESS": address, "DAILY_FEE": "1.0"})
|
||||||
self.daemon.jsonrpc_settings_set('lbryum_servers', [f"{node.hostname}:{node.port}"])
|
self.daemon.jsonrpc_settings_set('lbryum_servers', [f"{node.hostname}:{node.port}"])
|
||||||
|
next_payment = wallet_pay_service.on_payment.first
|
||||||
await self.daemon.jsonrpc_wallet_reconnect()
|
await self.daemon.jsonrpc_wallet_reconnect()
|
||||||
features = await self.ledger.network.get_server_features()
|
features = await self.ledger.network.get_server_features()
|
||||||
self.assertEqual(features["payment_address"], address)
|
self.assertEqual(features["payment_address"], address)
|
||||||
self.assertEqual(features["daily_fee"], "1.0")
|
self.assertEqual(features["daily_fee"], "1.0")
|
||||||
tx = await asyncio.wait_for(wallet_pay_service.on_payment.first, timeout=8)
|
tx = await asyncio.wait_for(next_payment, timeout=8)
|
||||||
self.assertIsNotNone(await self.blockchain.get_raw_transaction(tx.id)) # verify its broadcasted
|
self.assertIsNotNone(await self.blockchain.get_raw_transaction(tx.id)) # verify its broadcasted
|
||||||
self.assertEqual(tx.outputs[0].amount, 100000000)
|
self.assertEqual(tx.outputs[0].amount, 100000000)
|
||||||
self.assertEqual(tx.outputs[0].get_address(self.ledger), address)
|
self.assertEqual(tx.outputs[0].get_address(self.ledger), address)
|
||||||
|
|
Loading…
Reference in a new issue