chore: fix typo issues

Signed-off-by: Manish Dait <daitmanish88@gmail.com>

Author: manishdait

CHANGELOG.md

@@ -7,7 +7,7 @@ This changelog is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.
 ## [Unreleased]
 
 ### Added
-- Add support for chunk message  in `TopicSubmitMessageTransaction`.
+- Support for message chunking  in `TopicSubmitMessageTransaction`.
 
 ## [0.1.9] - 2025-11-26
 

examples/consensus/topic_message_submit_chunked.py

@@ -1,6 +1,6 @@
 """
-uv run examples/topic_message_submit.py
-python examples/topic_message_submit.py
+uv run examples/consensus/topic_message_submit_chunked.py
+python examples/consensus/topic_message_submit_chunked.py
 
 """
 import os
@@ -54,7 +54,7 @@ def setup_client():
 
     print(f"Connecting to Hedera {network_name} network!")
 
-    try :
+    try:
         network = Network(network_name)
         client = Client(network)
 
@@ -83,7 +83,7 @@ def create_topic(client):
         )
         topic_id = topic_receipt.topic_id
 
-        print(f"Topic created: {topic_id}: {topic_id}")
+        print(f"Topic created: {topic_id}")
 
         return topic_id
     except Exception as e:
@@ -97,7 +97,7 @@ def submit_topic_message_transaction(client, topic_id):
     print("\nSubmitting large message...")
     try:
         message_receipt = (
-        TopicMessageSubmitTransaction()
+            TopicMessageSubmitTransaction()
             .set_topic_id(topic_id)
             .set_message(BIG_CONTENT)
             .freeze_with(client)
@@ -110,7 +110,7 @@ def submit_topic_message_transaction(client, topic_id):
 
         print(f"Message submitted (status={ResponseCode(message_receipt.status)}, txId={message_receipt.transaction_id})")
         print(f"Message size:", len(BIG_CONTENT), "bytes")
-        print(f"Message Content: {(BIG_CONTENT[:140] + "...") if len(BIG_CONTENT) > 40 else BIG_CONTENT}")
+        print(f"Message Content: {(BIG_CONTENT[:140] + "...") if len(BIG_CONTENT) > 140 else BIG_CONTENT}")
     except Exception as e:
         print(f"Error: Message submission failed: {str(e)}")
         sys.exit(1)
@@ -123,7 +123,7 @@ def fetch_topic_info(client, topic_id):
 
     try:
         info = TopicInfoQuery().set_topic_id(topic_id).execute(client)
-        print (
+        print(
             f"--- Topic Info ---\n"
             f"TopicId: {topic_id}\n"
             f"Memo: {info.memo}\n"
@@ -149,5 +149,3 @@ def main():
 
 if __name__ == "__main__":
     main()
-
-        

src/hiero_sdk_python/consensus/topic_message_submit_transaction.py

@@ -115,7 +115,7 @@ def set_max_chunks(self, max_chunks: int) -> "TopicMessageSubmitTransaction":
         Set maximum allowed chunks.
 
         Args:
-            mac_chunks (int): The maximum number of chunks allowed.
+            max_chunks (int): The maximum number of chunks allowed.
 
         Returns:
             TopicMessageSubmitTransaction: This transaction instance (for chaining).
@@ -257,9 +257,7 @@ def freeze_with(self, client: "Client") -> "TopicMessageSubmitTransaction":
         if self.transaction_id is None:
             self.transaction_id = client.generate_transaction_id()
 
-        if len(self._transaction_ids) == 0:
-            self._transaction_ids = []
-        
+        if not self._transaction_ids:
             base_timestamp = self.transaction_id.valid_start
 
             for i in range(self.get_required_chunks()):
@@ -310,7 +308,7 @@ def execute(self, client: "Client"):
             response = super().execute(client)
             responses.append(response)
 
-        # Return the first response JS SDK do
+        # Return the first response as the JS SDK does
         return responses[0] if responses else None
 
     def sign(self, private_key: "PrivateKey"):

src/hiero_sdk_python/query/topic_message_query.py

@@ -163,7 +163,6 @@ def run_stream():
 
                 except Exception as e:
                     if subscription_handle.is_cancelled():
-
                         return
 
                     attempt += 1

tests/integration/topic_message_qurey_e2e_test.py renamed to tests/integration/topic_message_query_e2e_test.py

@@ -75,7 +75,8 @@ def on_error_handler(e):
 
     handle = query.subscribe(
         env.client,
-        on_message=get_message,on_error=on_error_handler
+        on_message=get_message,
+        on_error=on_error_handler
     )
 
     message_receipt = (

tests/integration/topic_message_submit_transaction_e2e_test.py

@@ -57,7 +57,7 @@ def test_integration_topic_message_submit_transaction_can_execute(env):
     )
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that no message is submited
+    # Check that no message is submitted
     assert info.sequence_number == 0
 
     message_transaction = TopicMessageSubmitTransaction(
@@ -73,7 +73,7 @@ def test_integration_topic_message_submit_transaction_can_execute(env):
     ), f"Message submission failed with status: {ResponseCode(message_receipt.status).name}"
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that one message is submited
+    # Check that one message is submitted
     assert info.sequence_number == 1
 
     delete_topic(env.client, topic_id)
@@ -121,7 +121,7 @@ def test_integration_topic_message_submit_transaction_with_submit_key(env):
     )
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that no message is submited
+    # Check that no message is  submited
     assert info.sequence_number == 0
 
     message_transaction = TopicMessageSubmitTransaction(
@@ -139,7 +139,7 @@ def test_integration_topic_message_submit_transaction_with_submit_key(env):
     ), f"Message submission failed with status: {ResponseCode(message_receipt.status).name}"
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that one message is submited
+    # Check that one message is  submited
     assert info.sequence_number == 1
 
     delete_topic(env.client, topic_id)
@@ -157,7 +157,7 @@ def test_integration_topic_message_submit_transaction_without_submit_key_fails(e
     )
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that no message is submited
+    # Check that no message is  submited
     assert info.sequence_number == 0
 
     message_transaction = TopicMessageSubmitTransaction(
@@ -257,7 +257,8 @@ def test_integration_scheduled_topic_message_submit_transaction_can_execute_with
         balance.hbars.to_tinybars() == Hbar(3).to_tinybars()
     ), f"Expected balance of 3 Hbar, but got {balance.hbars.to_tinybars()}"
 
-    env.client.set_operator(account.id, account.key)  # Set the operator to the account
+    # Restore the operator to the original account
+    env.client.set_operator(account.id, account.key)
 
     topic_message_submit_fee_limit = (
         CustomFeeLimit().set_payer_id(account.id).add_custom_fee(topic_fee)
@@ -285,7 +286,8 @@ def test_integration_scheduled_topic_message_submit_transaction_can_execute_with
         balance.hbars.to_tinybars() < Hbar(2).to_tinybars()
     ), f"Expected balance of less than 2 Hbar, but got {balance.hbars.to_tinybars()}"
 
-    env.client.set_operator(operator_id, operator_key)  # Set the operator to the account
+    # Restore the operator to the original account
+    env.client.set_operator(operator_id, operator_key)
     delete_topic(env.client, topic_id)
 
 
@@ -301,7 +303,7 @@ def test_integration_topic_message_submit_transaction_fails_if_required_chunk_gr
     )
 
     info = TopicInfoQuery(topic_id=topic_id).execute(env.client)
-    # Check that no message is submited
+    # Check that no message is  submited
     assert info.sequence_number == 0
 
     message_transaction = TopicMessageSubmitTransaction(