do a reatriable call so the service doesnt die

check its broadcasted
2020-02-21 17:26:31 -03:00 · 2020-02-21 17:26:04 -03:00
2 changed files with 3 additions and 2 deletions
--- a/lbry/wallet/usage_payment.py
+++ b/lbry/wallet/usage_payment.py
@ -29,7 +29,7 @@ class WalletServerPayer:
    async def pay(self):
        while self.running:
            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']
            amount = str(features['daily_fee'])
            if not address or not amount:
--- a/tests/integration/blockchain/test_wallet_server_sessions.py
+++ b/tests/integration/blockchain/test_wallet_server_sessions.py
@ -67,7 +67,7 @@ class TestUsagePayment(CommandTestCase):
        await wallet_pay_service.stop()
        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)
        self.assertEqual(history, [])

@ -91,5 +91,6 @@ class TestUsagePayment(CommandTestCase):
        self.assertEqual(features["payment_address"], address)
        self.assertEqual(features["daily_fee"], "1.0")
        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].get_address(self.ledger), address)
Author	SHA1	Message	Date
Victor Shyba	abfe0be81e	do a reatriable call so the service doesnt die	2020-02-21 17:26:31 -03:00
Victor Shyba	820b7a6753	check its broadcasted	2020-02-21 17:26:04 -03:00