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

improve test_es_sync_utility

Browse source
This commit is contained in:
Jack Robison 2022-06-29 12:39:52 -04:00 committed by Lex Berezhny
parent 6d370b0a12
commit a9a1076362
1 changed files with 17 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -126,12 +126,28 @@ class TestESSync(CommandTestCase):
# stop the es writer and advance the chain by 1, adding a new claim. upon resuming the es writer, it should # stop the es writer and advance the chain by 1, adding a new claim. upon resuming the es writer, it should
# add the new claim # add the new claim
await es_writer.stop() await es_writer.stop()
await self.stream_create(f"stream11", bid='0.001', confirm=False)
stream11 = self.get_claim_id(await self.stream_create(f"stream11", bid='0.001', confirm=False))
current_height = self.conductor.spv_node.writer.height
generate_block_task = asyncio.create_task(self.generate(1)) generate_block_task = asyncio.create_task(self.generate(1))
await self.conductor.spv_node.writer.wait_until_block(current_height + 1)
await es_writer.start() await es_writer.start()
await generate_block_task await generate_block_task
self.assertEqual(11, len(await self.claim_search(order_by=['height']))) self.assertEqual(11, len(await self.claim_search(order_by=['height'])))
# stop/delete es and advance the chain by 1, removing stream11
await es_writer.delete_index()
await es_writer.stop()
server_search_client.clear_caches()
await self.stream_abandon(stream11, confirm=False)
current_height = self.conductor.spv_node.writer.height
generate_block_task = asyncio.create_task(self.generate(1))
await self.conductor.spv_node.writer.wait_until_block(current_height + 1)
await es_writer.start(reindex=True)
await generate_block_task
self.assertEqual(10, len(await self.claim_search(order_by=['height'])))
# # this time we will test a migration from unversioned to v1 # # this time we will test a migration from unversioned to v1
# await db.search_index.sync_client.indices.delete_template(db.search_index.index) # await db.search_index.sync_client.indices.delete_template(db.search_index.index)