Support "solo" network name

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

Author: AlexanderShenshin

.github/workflows/main.yml

@@ -45,7 +45,7 @@ jobs:
 
       - name: Prepare Hiero Solo
         id: solo
-        uses: hiero-ledger/hiero-solo-action@35efe2334bffb73298716402a5c688321ec29260
+        uses: AlexanderShenshin/hiero-solo-action@v0.0.4-dev
         with:
           installMirrorNode: true
 

hiero_did_sdk_python/did/did_syntax.py

@@ -8,6 +8,7 @@
 HEDERA_NETWORK_MAINNET = "mainnet"
 HEDERA_NETWORK_TESTNET = "testnet"
 HEDERA_NETWORK_PREVIEWNET = "previewnet"
+HEDERA_NETWORK_SOLO = "solo"
 
 HEDERA_DID_METHOD = "hedera"
 

hiero_did_sdk_python/did/utils.py

@@ -9,6 +9,7 @@
     HEDERA_DID_METHOD,
     HEDERA_NETWORK_MAINNET,
     HEDERA_NETWORK_PREVIEWNET,
+    HEDERA_NETWORK_SOLO,
     HEDERA_NETWORK_TESTNET,
 )
 
@@ -94,6 +95,7 @@ def parse_identifier(identifier: str) -> ParsedIdentifier:
             network_name != HEDERA_NETWORK_MAINNET
             and network_name != HEDERA_NETWORK_TESTNET
             and network_name != HEDERA_NETWORK_PREVIEWNET
+            and network_name != HEDERA_NETWORK_SOLO
         ):
             raise DidException("DID string is invalid. Invalid Hedera network.", DidErrorCode.INVALID_NETWORK)
 

hiero_did_sdk_python/hcs/hcs_message_resolver.py

@@ -10,7 +10,7 @@
 from .hcs_message_envelope import HcsMessageEnvelope
 from .hcs_topic_listener import HcsTopicListener
 
-DEFAULT_TIMEOUT_SECONDS = float(5)
+DEFAULT_TIMEOUT_SECONDS = float(10)
 
 TOPIC_UNSUBSCRIBED_ERROR = "CANCELLED: unsubscribe"
 

hiero_did_sdk_python/hcs/hcs_topic_listener.py

@@ -1,5 +1,6 @@
 import logging
 from collections.abc import Callable
+from datetime import timedelta
 from typing import cast
 
 from hiero_sdk_python import Client, Timestamp, TopicId, TopicMessageQuery
@@ -28,15 +29,15 @@ def __init__(
         self._query = (
             TopicMessageQuery(topic_id=TopicId.from_string(topic_id), start_time=Timestamp(0, 0).to_date())
             .set_max_backoff(2.0)
-            .set_max_attempts(5)
+            .set_max_attempts(10)
         )
 
     def set_start_time(self, start_time: Timestamp):
-        self._query.set_start_time(start_time.to_date())
+        self._query.set_start_time(start_time.to_date() - timedelta(minutes=120))
         return self
 
     def set_end_time(self, end_time: Timestamp):
-        self._query.set_end_time(end_time.to_date())
+        self._query.set_end_time(end_time.to_date() + timedelta(minutes=120))
         return self
 
     def set_limit(self, limit: int):

tests/integration/conftest.py

@@ -14,12 +14,12 @@
         "You can obtain them by creating developer account on https://portal.hedera.com/"
     )
 
+NETWORK: str = os.environ.get("NETWORK") or "testnet"
+
 OPERATOR_KEY = PrivateKey.from_string(OPERATOR_KEY_DER)
 
 OPERATOR_KEY_TYPE = get_key_type(OPERATOR_KEY)
 
-NETWORK = os.environ.get("NETWORK") or "testnet"
-
 
 @pytest.fixture(scope="class")
 def client():

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(5)
+        await asyncio.sleep(10)
 
         # 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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         print("Resolving revocation list states...")
 

tests/integration/test_hcs_file_service.py

@@ -10,7 +10,7 @@
 from .conftest import OPERATOR_KEY_DER
 
 
-@pytest.mark.flaky(retries=3, delay=1)
+# @pytest.mark.flaky(retries=3, delay=1)
 @pytest.mark.asyncio(loop_scope="session")
 class TestHcsFileService:
     @pytest.mark.parametrize(
@@ -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(5)
+        await asyncio.sleep(10)
 
         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_hcs_topic_service.py

@@ -6,7 +6,7 @@
 from .conftest import OPERATOR_KEY
 
 
-@pytest.mark.flaky(retries=3, delay=1)
+# @pytest.mark.flaky(retries=3, delay=1)
 @pytest.mark.asyncio(loop_scope="session")
 class TestHcsTopicService:
     async def test_creates_and_updates_hcs_topic(self, client: Client):

tests/integration/test_hedera_anoncreds_registry.py

@@ -32,9 +32,9 @@
 from hiero_did_sdk_python.anoncreds.utils import AnonCredsObjectType, parse_anoncreds_identifier
 from hiero_did_sdk_python.hcs import HcsMessageResolver
 
-from .conftest import OPERATOR_KEY_DER
+from .conftest import NETWORK, OPERATOR_KEY_DER
 
-ISSUER_ID = "did:hedera:testnet:zvAQyPeUecGck2EsxcsihxhAB6jZurFrBbj2gC7CNkS5o_0.0.5063027"
+ISSUER_ID = f"did:hedera:{NETWORK}:zvAQyPeUecGck2EsxcsihxhAB6jZurFrBbj2gC7CNkS5o_0.0.5063027"
 
 MOCK_SCHEMA_PARAMS = {
     "name": "mock-schema",
@@ -69,7 +69,7 @@
 ACCUM_2 = "mock-accum-2"
 
 
-@pytest.mark.flaky(retries=3, delay=1)
+# @pytest.mark.flaky(retries=3, delay=1)
 @pytest.mark.asyncio(loop_scope="session")
 class TestHederaAnonCredsRegistry:
     async def test_creates_anoncreds_schema(self, client: Client, Something):
@@ -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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         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(5)
+        await asyncio.sleep(10)
 
         entries_messages = await HcsMessageResolver(rev_reg_entries_topic_id, HcsRevRegEntryMessage).execute(client)