From a9a1076362d4ff69c8f5e1607f8adc32b2ef99db Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 29 Jun 2022 12:39:52 -0400 Subject: [PATCH] improve test_es_sync_utility --- .../blockchain/test_wallet_server_sessions.py | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/tests/integration/blockchain/test_wallet_server_sessions.py b/tests/integration/blockchain/test_wallet_server_sessions.py index 5cc7b3902..093839e6f 100644 --- a/tests/integration/blockchain/test_wallet_server_sessions.py +++ b/tests/integration/blockchain/test_wallet_server_sessions.py @@ -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 # add the new claim 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)) + await self.conductor.spv_node.writer.wait_until_block(current_height + 1) + await es_writer.start() await generate_block_task 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 # await db.search_index.sync_client.indices.delete_template(db.search_index.index)