chore: bump hak package version (#176)

Signed-off-by: skurzyp-blockydevs <stanislaw.kurzyp@blockydevs.com>

Author: skurzyp-blockydevs

python/hedera_agent_kit/mcp/toolkit.py

@@ -1,14 +1,15 @@
-from typing import Any, List
+from typing import Any
 from mcp.server.fastmcp import FastMCP
 from hiero_sdk_python import Client
 from hedera_agent_kit.shared.api import HederaAgentAPI
 from hedera_agent_kit.shared.configuration import Configuration
 from hedera_agent_kit.shared.tool_discovery import ToolDiscovery
 
+
 class HederaMCPToolkit:
     def __init__(self, client: Client, configuration: Configuration):
         self.server = FastMCP("Hedera Agent Kit", dependencies=["hedera-agent-kit"])
-        
+
         context = configuration.context
         tool_discovery = ToolDiscovery.create_from_configuration(configuration)
         all_tools = tool_discovery.get_all_tools(context, configuration)
@@ -21,7 +22,11 @@ def _register_tool(self, tool):
         @self.server.tool(name=tool.method, description=tool.description)
         async def handler(**kwargs: Any) -> str:
             params = kwargs
-            if "kwargs" in kwargs and len(kwargs) == 1 and isinstance(kwargs["kwargs"], dict):
+            if (
+                "kwargs" in kwargs
+                and len(kwargs) == 1
+                and isinstance(kwargs["kwargs"], dict)
+            ):
                 params = kwargs["kwargs"]
             result = await self._hedera_agent_kit.run(tool.method, params)
             return str(result)

python/hedera_agent_kit/plugins/core_consensus_query_plugin/get_topic_messages_query.py

@@ -42,17 +42,17 @@ def get_topic_messages_query_prompt(context: Context = {}) -> str:
     context_snippet: str = PromptGenerator.get_context_snippet(context)
     usage_instructions: str = PromptGenerator.get_parameter_usage_instructions()
 
-    return f"""  
-{context_snippet}  
+    return f"""
+{context_snippet}
 
-This tool will return the messages for a given Hedera topic.  
+This tool will return the messages for a given Hedera topic.
 
-Parameters:  
-- topic_id (str, required): The topic ID to query  
-- start_time (datetime, optional): The start datetime to query. If set, the messages will be returned after this datetime  
-- end_time (datetime, optional): The end datetime to query. If set, the messages will be returned before this datetime  
+Parameters:
+- topic_id (str, required): The topic ID to query
+- start_time (datetime, optional): The start datetime to query. If set, the messages will be returned after this datetime
+- end_time (datetime, optional): The end datetime to query. If set, the messages will be returned before this datetime
 - limit: (Optional) Max number of messages to return. Defaults to 100. Max value is 100.
-{usage_instructions}  
+{usage_instructions}
 
 Note: When limit is set, the most recent messages up to the limit will be returned within the specified time range.
 """
@@ -73,16 +73,15 @@ def post_process(messages: List[Dict[str, Any]], topic_id: str) -> str:
     for message in messages:
         content = message.get("message", "")
         consensus_timestamp = message.get("consensus_timestamp", "N/A")
-        messages_text_list.append(
-            f"{content} - posted at: {consensus_timestamp}\n"
-        )
+        messages_text_list.append(f"{content} - posted at: {consensus_timestamp}\n")
 
     messages_text = "".join(messages_text_list)
 
-    return f"""Messages for topic {topic_id}:  
-  --- Messages ---  {messages_text}  
+    return f"""Messages for topic {topic_id}:
+  --- Messages ---  {messages_text}
   """
 
+
 async def get_topic_messages_query(
     client: Client,
     context: Context,

python/hedera_agent_kit/shared/hedera_utils/mirrornode/hedera_mirrornode_decoders.py

@@ -1,14 +1,12 @@
 """Mirrornode message decoding utilities."""
 
 import base64
-from typing import List, Any, Dict, Union
+from typing import List, Any, Dict
 
 from .types import TopicMessage
 
 
-def decode_base64_messages(
-        messages: List[TopicMessage]
-) -> List[Dict[str, Any]]:
+def decode_base64_messages(messages: List[TopicMessage]) -> List[Dict[str, Any]]:
     """Decode base64 message content to UTF-8 human-readable strings.
 
     Args:

python/hedera_agent_kit/shared/hedera_utils/mirrornode/hedera_mirrornode_service_default_impl.py

@@ -1,5 +1,4 @@
 import asyncio
-import base64
 from decimal import Decimal
 from typing import Optional, Any, Dict, List, Coroutine
 
@@ -134,12 +133,11 @@ async def get_topic_messages(
             if query_params.get("upperTimestamp")
             else ""
         )
-        
+
         limit = query_params.get("limit", 100)
-        encoding = query_params.get("encoding", "base64")
         # Request at most 100 messages per page (Mirror Node max)
         page_limit = min(limit, 100)
-        
+
         url: str = (
             f"{self.base_url}/topics/{query_params['topic_id']}/messages?{lower}{upper}&order=desc&limit={page_limit}"
         )
@@ -154,9 +152,9 @@ async def get_topic_messages(
             batch = data.get("messages", [])
             if not batch:
                 break
-                
+
             messages.extend(batch)
-            
+
             # effective_limit cancellation
             if len(messages) >= limit:
                 break

python/hedera_agent_kit/shared/hedera_utils/mirrornode/hedera_mirrornode_utils.py

@@ -23,4 +23,3 @@ def get_mirrornode_service(
     if mirrornode_service is not None:
         return mirrornode_service
     return HederaMirrornodeServiceDefaultImpl(ledger_id)
-

python/hedera_agent_kit/shared/parameter_schemas/token_schema.py

@@ -151,7 +151,8 @@ class NftTransfer(BaseModelWithArbitraryTypes):
 
 class TransferNonFungibleTokenParameters(OptionalScheduledTransactionParams):
     source_account_id: Annotated[
-        Optional[str], Field(description="Account ID of the token owner (defaults to operator).")
+        Optional[str],
+        Field(description="Account ID of the token owner (defaults to operator)."),
     ] = None
     token_id: Annotated[str, Field(description="The NFT token ID.")]
     recipients: Annotated[

python/hedera_agent_kit/shared/strategies/tx_mode_strategy.py

@@ -8,12 +8,12 @@
 from __future__ import annotations
 
 from abc import ABC, abstractmethod
-from typing import Any, Callable, Optional, cast
+from typing import Any, Callable, Optional
 
 from hiero_sdk_python import (
     Client,
     TransactionReceipt,
-    ResponseCode, TopicDeleteTransaction,
+    ResponseCode,
 )
 from hiero_sdk_python.hapi.services.response_code_pb2 import ResponseCodeEnum
 from hiero_sdk_python.transaction.transaction import Transaction
@@ -101,10 +101,13 @@ async def handle(
         # Create a raw response object
         raw_transaction_response = RawTransactionResponse(
             status=ResponseCode(receipt.status).name,
-            account_id=getattr(receipt, "account_id", None) or getattr(tx, "account_id", None),
-            token_id=getattr(receipt, "token_id", None) or getattr(tx, "token_id", None),
+            account_id=getattr(receipt, "account_id", None)
+            or getattr(tx, "account_id", None),
+            token_id=getattr(receipt, "token_id", None)
+            or getattr(tx, "token_id", None),
             transaction_id=getattr(receipt, "transaction_id", None),
-            topic_id=getattr(receipt, "topic_id", None) or getattr(tx, "topic_id", None),
+            topic_id=getattr(receipt, "topic_id", None)
+            or getattr(tx, "topic_id", None),
             schedule_id=getattr(receipt, "schedule_id", None),
             factory_contract_id=None,
             # In the case of tools like create_erc20 or create_er721, the sdk returns the id of factory contract.