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

test initial header sync separately

Browse source
This commit is contained in:
Victor Shyba 2019-10-08 21:45:47 -03:00 committed by Lex Berezhny
parent 320f5cebc7
commit 27631a1746
1 changed files with 16 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
torba/tests/client_tests/integration/test_network.py
View file

@ -74,6 +74,22 @@ class ReconnectTests(IntegrationTestCase):
with self.assertRaises(asyncio.TimeoutError):
await asyncio.wait_for(switch_event, timeout=1)
async def test_direct_sync(self):
await self.ledger.stop()
initial_height = self.ledger.headers.height
await self.blockchain.generate(100)
while self.conductor.spv_node.server.bp.height < initial_height + 100:
print(self.conductor.spv_node.server.bp.height)
await asyncio.sleep(0.1)
self.assertEqual(initial_height, self.ledger.headers.height)
# locks header processing so we make sure we are the only ones modifying it
async with self.ledger._header_processing_lock:
await self.ledger.headers.open()
await self.ledger.network.start()
await self.ledger.network.on_connected.first
await self.ledger.initial_headers_sync()
self.assertEqual(initial_height + 100, self.ledger.headers.height)
async def test_connection_drop_still_receives_events_after_reconnected(self):
address1 = await self.account.receiving.get_or_create_usable_address()
# disconnect and send a new tx, should reconnect and get it