Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

check its broadcasted and use a retriable call

Browse source
This commit is contained in:
Victor Shyba 2020-02-21 17:25:12 -03:00
parent 5c613934ca
commit 1086a3297f
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbry/wallet/usage_payment.py
View file

@ -29,7 +29,7 @@ class WalletServerPayer:
async def pay(self): async def pay(self):
while self.running: while self.running:
await asyncio.sleep(self.payment_period) await asyncio.sleep(self.payment_period)
features = await self.ledger.network.get_server_features() features = await self.ledger.network.retriable_call(self.ledger.network.get_server_features)
address = features['payment_address'] address = features['payment_address']
amount = str(features['daily_fee']) amount = str(features['daily_fee'])
if not address or not amount: if not address or not amount:

3
tests/integration/blockchain/test_wallet_server_sessions.py
View file

@ -67,7 +67,7 @@ class TestUsagePayment(CommandTestCase):
await wallet_pay_service.stop() await wallet_pay_service.stop()
await wallet_pay_service.start(ledger=self.ledger, wallet=self.wallet) await wallet_pay_service.start(ledger=self.ledger, wallet=self.wallet)
address = (await self.account.receiving.get_addresses(limit=1, only_usable=True))[0] address = await self.blockchain.get_raw_change_address()
_, history = await self.ledger.get_local_status_and_history(address) _, history = await self.ledger.get_local_status_and_history(address)
self.assertEqual(history, []) self.assertEqual(history, [])
@ -91,5 +91,6 @@ class TestUsagePayment(CommandTestCase):
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=3) tx = await asyncio.wait_for(wallet_pay_service.on_payment.first, timeout=3)
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)