feat: added unit and integration test for chuck message

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

Author: manishdait

examples/topic_message_submit_chunked.py renamed to examples/consensus/topic_message_submit_chunked.py

@@ -103,11 +103,13 @@ def of_many(cls, responses: List[mirror_proto.ConsensusTopicResponse]) -> "Topic
         chunks: List[TopicMessageChunk] = []
         total_size: int = 0
         transaction_id: Optional[str] = None
-
+        
         for r in sorted_responses:
             c = TopicMessageChunk(r)
             chunks.append(c)
+            
             total_size += len(r.message)
+            
 
             if (
                     transaction_id is None
@@ -116,11 +118,13 @@ def of_many(cls, responses: List[mirror_proto.ConsensusTopicResponse]) -> "Topic
             ):
                 tx_id = r.chunkInfo.initialTransactionID
                 transaction_id = (
-                    f"{tx_id.shardNum}.{tx_id.realmNum}.{tx_id.accountNum}-"
+                    f"{tx_id.accountID.shardNum, '0'}.{tx_id.accountID.realmNum, '0'}.{tx_id.accountID.accountNum}-"
                     f"{tx_id.transactionValidStart.seconds}.{tx_id.transactionValidStart.nanos}"
                 )
+                print(transaction_id)
 
         contents = bytearray(total_size)
+        
         offset: int = 0
         for r in sorted_responses:
             end = offset + len(r.message)

src/hiero_sdk_python/consensus/topic_message.py

@@ -289,7 +289,6 @@ def execute(self, client: "Client"):
         print(self.get_required_chunks())
 
         for chunk_index in range(self.get_required_chunks()):
-            print(chunk_index)
             self._current_index = chunk_index
 
             if self._transaction_ids and chunk_index < len(self._transaction_ids):

src/hiero_sdk_python/consensus/topic_message_submit_transaction.py

@@ -144,17 +144,21 @@ def run_stream():
                             continue
 
                         initial_tx_id = response.chunkInfo.initialTransactionID
-                        tx_id_str = (f"{initial_tx_id.shardNum}."
-                                     f"{initial_tx_id.realmNum}."
-                                     f"{initial_tx_id.accountNum}-"
+                        tx_id_str = (f"{initial_tx_id.accountID.shardNum or '0'}."
+                                     f"{initial_tx_id.accountID.realmNum or '0'}."
+                                     f"{initial_tx_id.accountID.accountNum}-"
                                      f"{initial_tx_id.transactionValidStart.seconds}."
                                      f"{initial_tx_id.transactionValidStart.nanos}")
+                        
                         if tx_id_str not in pending_chunks:
                             pending_chunks[tx_id_str] = []
+                        
                         pending_chunks[tx_id_str].append(response)
 
-                        if len(pending_chunks[tx_id_str]) == response.chunkInfo.total:
-                            chunk_list = pending_chunks.pop(tx_id_str)
+                        if len(pending_chunks) == response.chunkInfo.total:
+                            chunk_list =  [resp for chunk_list in pending_chunks.values() for resp in chunk_list]
+                            pending_chunks.clear() 
+
                             msg_obj = TopicMessage.of_many(chunk_list)
                             on_message(msg_obj)
 
@@ -164,6 +168,7 @@ def run_stream():
 
                 except Exception as e:
                     if subscription_handle.is_cancelled():
+
                         return
 
                     attempt += 1