Update DID resolution parsing (#30)

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

Author: AlexanderShenshin

hiero_did_sdk_python/did/hedera_did_resolver.py

@@ -124,8 +124,12 @@ async def resolve(self, did: str) -> DIDResolutionResult:
 
             if not did_document.deactivated:
                 document_meta.update({
-                    "created": datetime.date.fromtimestamp(cast(float, did_document.created)).isoformat(),
-                    "updated": datetime.date.fromtimestamp(cast(float, did_document.updated)).isoformat(),
+                    "created": datetime.date.fromtimestamp(cast(float, did_document.created)).isoformat()
+                    if did_document.created
+                    else None,
+                    "updated": datetime.date.fromtimestamp(cast(float, did_document.updated)).isoformat()
+                    if did_document.updated
+                    else None,
                 })
 
             status = {"deactivated": True} if did_document.deactivated else {}

hiero_did_sdk_python/hcs/hcs_message_transaction.py

@@ -30,7 +30,8 @@ async def execute(self, client: Client):
         message_content = self.message.to_json()
 
         transaction = TopicMessageSubmitTransaction(
-            topic_id=TopicId.from_string(self.topic_id), message=message_content
+            topic_id=TopicId.from_string(self.topic_id),  # pyright: ignore - Hiero SDK seems to have a wrong expected type
+            message=message_content,
         )
 
         if self._transaction_builder:

hiero_did_sdk_python/hcs/hcs_topic_service.py

@@ -57,7 +57,8 @@ async def create_topic(self, topic_options: HcsTopicOptions, signing_keys: list[
 
     async def update_topic(self, topic_id: str, topic_options: HcsTopicOptions, signing_keys: list[PrivateKey]):
         transaction = _set_topic_transaction_options(
-            TopicUpdateTransaction(topic_id=TopicId.from_string(topic_id)), topic_options
+            TopicUpdateTransaction(topic_id=TopicId.from_string(topic_id)),  # pyright: ignore - Hiero SDK seems to have a wrong expected type
+            topic_options,
         ).freeze_with(self._client)
         signed_transaction = await sign_hcs_transaction_async(transaction, signing_keys)
         await execute_hcs_transaction_async(signed_transaction, self._client)

hiero_did_sdk_python/hcs/utils.py

@@ -1,7 +1,7 @@
 import asyncio
-from typing import Any
+from typing import Any, cast
 
-from hiero_sdk_python import Client, PrivateKey, TransactionReceipt
+from hiero_sdk_python import Client, PrivateKey, ResponseCode, TransactionReceipt
 from hiero_sdk_python.query.query import Query
 from hiero_sdk_python.transaction.transaction import Transaction
 
@@ -22,10 +22,22 @@ def sign_transaction():
 async def execute_hcs_transaction_async(transaction: Transaction, client: Client) -> TransactionReceipt:
     execution_task = asyncio.create_task(asyncio.to_thread(lambda: transaction.execute(client)))
     await execution_task
-    return execution_task.result()
+    receipt = cast(TransactionReceipt, execution_task.result())
+
+    # We need additional validation since Hiero SDK Python do not catch error statuses in some cases (in recent versions)
+    if receipt.status != ResponseCode.SUCCESS:
+        error_reason = ResponseCode.get_name(receipt.status) if receipt.status else "Response code is empty"
+        raise Exception(f"Error retrieving transaction receipt: {error_reason}")
+
+    return receipt
 
 
 async def execute_hcs_query_async(query: Query, client: Client) -> Any:
-    query_task = asyncio.create_task(asyncio.to_thread(lambda: query.execute(client)))
+    # Hiero Python SDK removed 'execute' method from 'Query' base class
+    # It looks non-optimal for public API and there is actually no 'Query' subclasses that do not implement 'execute'
+    # It makes sense to use simple runtime check until this problem is addressed
+    if not query.execute:  # pyright: ignore [reportAttributeAccessIssue]
+        raise Exception("Query instance do not implement 'execute' method")
+    query_task = asyncio.create_task(asyncio.to_thread(lambda: query.execute(client)))  # pyright: ignore [reportAttributeAccessIssue]
     await query_task
     return query_task.result()