Reduce data propagation waiting time in integration tests

Signed-off-by: Alexander Shenshin <[email protected]>

Author: AlexanderShenshin

tests/integration/demo.py

@@ -93,7 +93,7 @@ async def test_demo(self, client: Client):
         )
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         # Create Hedera DID resolver instance
         did_resolver = HederaDidResolver(client)
@@ -135,7 +135,7 @@ async def test_demo(self, client: Client):
         )
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         print("Resolving schema object...")
 
@@ -174,7 +174,7 @@ async def test_demo(self, client: Client):
         )
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         print("Resolving credential definition object...")
 
@@ -224,7 +224,7 @@ async def test_demo(self, client: Client):
         )
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         print("Resolving revocation registry definition object...")
 
@@ -257,7 +257,7 @@ async def test_demo(self, client: Client):
         rev_list_timestamp = int(time.time())
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         print(
             f"Revocation list has been registered, initial revocation entry can be found in HCS topic: https://hashscan.io/testnet/topic/{rev_reg_entries_topic_id}"
@@ -281,7 +281,7 @@ async def test_demo(self, client: Client):
         assert rev_list_update_result.revocation_list_state.state == "finished"
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         print("Resolving revocation list states...")
 

tests/integration/test_hcs_file_service.py

@@ -33,7 +33,7 @@ async def test_submit_and_resolve_file(
         topic_id = await service.submit_file(file_payload, OPERATOR_KEY_DER)
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         topic_info = await execute_hcs_query_async(TopicInfoQuery(topic_id=TopicId.from_string(topic_id)), client)
         topic_messages = await HcsMessageResolver(topic_id, HcsFileChunkMessage).execute(client)

tests/integration/test_hedera_anoncreds_registry.py

@@ -92,7 +92,7 @@ async def test_creates_anoncreds_schema(self, client: Client, Something):
         assert parsed_identifier.object_type == AnonCredsObjectType.SCHEMA
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         resolution_result = await registry.get_schema(schema_id)
 
@@ -124,7 +124,7 @@ async def test_creates_anoncreds_cred_def(self, client: Client, Something):
         assert parsed_identifier.object_type == AnonCredsObjectType.PUBLIC_CRED_DEF
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         resolution_result = await registry.get_cred_def(cred_def_id)
 
@@ -159,7 +159,7 @@ async def test_creates_anoncreds_rev_reg_def(self, client: Client, Something):
         assert parsed_identifier.object_type == AnonCredsObjectType.REV_REG
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         resolution_result = await registry.get_rev_reg_def(rev_reg_def_id)
 
@@ -182,7 +182,7 @@ async def test_creates_and_updates_rev_list(self, client: Client, Something):
         assert rev_reg_def_id
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         rev_list = AnonCredsRevList(
             issuer_id=ISSUER_ID,
@@ -205,7 +205,7 @@ async def test_creates_and_updates_rev_list(self, client: Client, Something):
         assert rev_reg_entries_topic_id
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         entries_messages = await HcsMessageResolver(rev_reg_entries_topic_id, HcsRevRegEntryMessage).execute(client)
 
@@ -240,7 +240,7 @@ async def test_creates_and_updates_rev_list(self, client: Client, Something):
         )
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         entries_messages = await HcsMessageResolver(rev_reg_entries_topic_id, HcsRevRegEntryMessage).execute(client)
 

tests/integration/test_hedera_did.py

@@ -159,7 +159,7 @@ async def test_deletes_did_document(self, client: Client):
             assert did.topic_id
 
             # Wait until changes are propagated to Hedera Mirror node
-            await asyncio.sleep(10)
+            await asyncio.sleep(5)
 
             did_document = await did.resolve()
 
@@ -574,7 +574,7 @@ async def test_adds_new_verification_method(self, client: Client):
             )
 
             # Wait until changes are propagated to Hedera Mirror node
-            await asyncio.sleep(10)
+            await asyncio.sleep(5)
 
             did_document = await did.resolve()
 

tests/integration/test_hedera_did_resolver.py

@@ -60,7 +60,7 @@ async def test_returns_success_response(self, client: Client, Something):
         assert did.identifier
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         result = await HederaDidResolver(client).resolve(did.identifier)
 
@@ -106,7 +106,7 @@ async def test_returns_deactivated_document(self, client: Client):
         assert did.identifier
 
         # Wait until changes are propagated to Hedera Mirror node
-        await asyncio.sleep(10)
+        await asyncio.sleep(5)
 
         result = await HederaDidResolver(client).resolve(did.identifier)
 

tests/unit/hcs/hcs_file/test_hcs_file_service.py

@@ -135,7 +135,7 @@ async def test_throws_on_resolving_invalid_topic_id(
         service = HcsFileService(mock_client)
         with pytest.raises(
             Exception,
-            match="Invalid TopicId format. Expected 'shard.realm.num'",
+            match="Invalid topic ID string 'invalid_topic_id'. Expected format 'shard.realm.num'.",
         ):
             await service.resolve_file("invalid_topic_id")
 

tests/unit/hcs/test_hcs_topic_service.py

@@ -17,7 +17,7 @@ def mock_topic_create_transaction(mocker: MockerFixture):
     MockTopicCreateTransaction = mocker.patch("hiero_did_sdk_python.hcs.hcs_topic_service.TopicCreateTransaction")
 
     mock_transaction_response = mocker.MagicMock()
-    mock_transaction_response.topicId.__str__.return_value = MOCK_TOPIC_ID
+    mock_transaction_response.topic_id.__str__.return_value = MOCK_TOPIC_ID
     mock_transaction_response.status = ResponseCode.SUCCESS
 
     mock_topic_create_transaction = MockTopicCreateTransaction.return_value
@@ -33,7 +33,7 @@ def mock_topic_update_transaction(mocker: MockerFixture):
     MockTopicUpdateTransaction = mocker.patch("hiero_did_sdk_python.hcs.hcs_topic_service.TopicUpdateTransaction")
 
     mock_transaction_response = mocker.MagicMock()
-    mock_transaction_response.topicId.__str__.return_value = MOCK_TOPIC_ID
+    mock_transaction_response.topic_id.__str__.return_value = MOCK_TOPIC_ID
     mock_transaction_response.status = ResponseCode.SUCCESS
 
     mock_topic_update_transaction = MockTopicUpdateTransaction.return_value