feat: implement _from_protobuf for all transaction types and fix dispatch map

Signed-off-by: Mounil Kanakhara <mounilkankhara@gmail.com>

Author: Mounil2005

src/hiero_sdk_python/account/account_allowance_approve_transaction.py

@@ -366,3 +366,13 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: An object containing the transaction function to approve allowances.
         """
         return _Method(transaction_func=channel.crypto.approveAllowances, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("cryptoApproveAllowance"):
+            body = transaction_body.cryptoApproveAllowance
+            transaction.hbar_allowances = [HbarAllowance._from_proto(a) for a in body.cryptoAllowances]
+            transaction.token_allowances = [TokenAllowance._from_proto(a) for a in body.tokenAllowances]
+            transaction.nft_allowances = [TokenNftAllowance._from_proto(a) for a in body.nftAllowances]
+        return transaction

src/hiero_sdk_python/account/account_allowance_delete_transaction.py

@@ -131,3 +131,11 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: An object containing the transaction function to delete allowances.
         """
         return _Method(transaction_func=channel.crypto.deleteAllowances, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("cryptoDeleteAllowance"):
+            body = transaction_body.cryptoDeleteAllowance
+            transaction.nft_wipe = [TokenNftAllowance._from_wipe_proto(a) for a in body.nftAllowances]
+        return transaction

src/hiero_sdk_python/account/account_create_transaction.py

@@ -319,7 +319,9 @@ def _build_proto_body(self) -> crypto_create_pb2.CryptoCreateTransactionBody:
             # triggers an INVALID_INITIAL_BALANCE pre-check error instead of a local error.
             initialBalance=ctypes.c_uint64(initial_balance_tinybars).value,
             receiverSigRequired=self.receiver_signature_required,
-            autoRenewPeriod=duration_pb2.Duration(seconds=self.auto_renew_period.seconds),
+            autoRenewPeriod=(
+                duration_pb2.Duration(seconds=self.auto_renew_period.seconds) if self.auto_renew_period else None
+            ),
             memo=self.account_memo,
             max_automatic_token_associations=self.max_automatic_token_associations,
             alias=self.alias.address_bytes if self.alias else None,
@@ -371,3 +373,27 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: An instance of _Method containing the transaction and query functions.
         """
         return _Method(transaction_func=channel.crypto.createAccount, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("cryptoCreateAccount"):
+            body = transaction_body.cryptoCreateAccount
+            if body.HasField("key"):
+                transaction.key = Key.from_proto_key(body.key)
+            transaction.initial_balance = body.initialBalance
+            transaction.receiver_signature_required = body.receiverSigRequired
+            transaction.auto_renew_period = None
+            if body.HasField("autoRenewPeriod"):
+                transaction.auto_renew_period = Duration._from_proto(body.autoRenewPeriod)
+            transaction.account_memo = body.memo if body.memo else None
+            transaction.max_automatic_token_associations = body.max_automatic_token_associations
+            transaction.alias = EvmAddress.from_bytes(body.alias) if body.alias else None
+            transaction.decline_staking_reward = body.decline_reward
+            staked_id = body.WhichOneof("staked_id")
+            if staked_id == "staked_account_id":
+                transaction.staked_account_id = AccountId._from_proto(body.staked_account_id)
+            elif staked_id == "staked_node_id":
+                transaction.staked_node_id = body.staked_node_id
+        return transaction

src/hiero_sdk_python/account/account_delete_transaction.py

@@ -128,3 +128,14 @@ def _get_method(self, channel: _Channel) -> _Method:
                 delete accounts.
         """
         return _Method(transaction_func=channel.crypto.cryptoDelete, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("cryptoDelete"):
+            body = transaction_body.cryptoDelete
+            if body.HasField("deleteAccountID"):
+                transaction.account_id = AccountId._from_proto(body.deleteAccountID)
+            if body.HasField("transferAccountID"):
+                transaction.transfer_account_id = AccountId._from_proto(body.transferAccountID)
+        return transaction

src/hiero_sdk_python/account/account_update_transaction.py

@@ -352,3 +352,31 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: An object containing the transaction function to update an account.
         """
         return _Method(transaction_func=channel.crypto.updateAccount, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):  # noqa: PLR0912
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("cryptoUpdateAccount"):
+            body = transaction_body.cryptoUpdateAccount
+            if body.HasField("accountIDToUpdate"):
+                transaction.account_id = AccountId._from_proto(body.accountIDToUpdate)
+            if body.HasField("key"):
+                transaction.key = Key.from_proto_key(body.key)
+            if body.HasField("autoRenewPeriod"):
+                transaction.auto_renew_period = Duration._from_proto(body.autoRenewPeriod)
+            if body.HasField("memo"):
+                transaction.account_memo = body.memo.value
+            if body.HasField("expirationTime"):
+                transaction.expiration_time = Timestamp._from_protobuf(body.expirationTime)
+            if body.HasField("receiverSigRequiredWrapper"):
+                transaction.receiver_signature_required = body.receiverSigRequiredWrapper.value
+            if body.HasField("max_automatic_token_associations"):
+                transaction.max_automatic_token_associations = body.max_automatic_token_associations.value
+            if body.HasField("decline_reward"):
+                transaction.decline_staking_reward = body.decline_reward.value
+            staked_id = body.WhichOneof("staked_id")
+            if staked_id == "staked_account_id":
+                transaction.staked_account_id = AccountId._from_proto(body.staked_account_id)
+            elif staked_id == "staked_node_id":
+                transaction.staked_node_id = body.staked_node_id
+        return transaction

src/hiero_sdk_python/consensus/topic_create_transaction.py

@@ -278,3 +278,23 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: The method for executing the transaction.
         """
         return _Method(transaction_func=channel.topic.createTopic, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):  # noqa: PLR0912
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("consensusCreateTopic"):
+            body = transaction_body.consensusCreateTopic
+            transaction.memo = body.memo if body.memo else ""
+            if body.HasField("adminKey"):
+                transaction.admin_key = Key.from_proto_key(body.adminKey)
+            if body.HasField("submitKey"):
+                transaction.submit_key = Key.from_proto_key(body.submitKey)
+            if body.HasField("autoRenewPeriod"):
+                transaction.auto_renew_period = Duration._from_proto(body.autoRenewPeriod)
+            if body.HasField("autoRenewAccount"):
+                transaction.auto_renew_account = AccountId._from_proto(body.autoRenewAccount)
+            if body.HasField("fee_schedule_key"):
+                transaction.fee_schedule_key = Key.from_proto_key(body.fee_schedule_key)
+            transaction.custom_fees = [CustomFixedFee._from_topic_fee_proto(f) for f in body.custom_fees]
+            transaction.fee_exempt_keys = [Key.from_proto_key(k) for k in body.fee_exempt_key_list]
+        return transaction

src/hiero_sdk_python/consensus/topic_delete_transaction.py

@@ -94,3 +94,12 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: The method to execute the transaction.
         """
         return _Method(transaction_func=channel.topic.deleteTopic, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("consensusDeleteTopic"):
+            body = transaction_body.consensusDeleteTopic
+            if body.HasField("topicID"):
+                transaction.topic_id = TopicId._from_proto(body.topicID)
+        return transaction

src/hiero_sdk_python/consensus/topic_message_submit_transaction.py

@@ -170,7 +170,7 @@ def _build_proto_body(self) -> consensus_submit_message_pb2.ConsensusSubmitMessa
             ConsensusSubmitMessageTransactionBody: The protobuf body for this transaction.
 
         Raises:
-            ValueError: If required fields (message) are missing.
+            ValueError: If required fields (topic_id, message) are missing.
         """
         if not self.message:
             raise ValueError("Missing required fields: message.")
@@ -233,6 +233,17 @@ def _get_method(self, channel: _Channel) -> _Method:
         """
         return _Method(transaction_func=channel.topic.submitMessage, query_func=None)
 
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("consensusSubmitMessage"):
+            body = transaction_body.consensusSubmitMessage
+            if body.HasField("topicID"):
+                transaction.topic_id = TopicId._from_proto(body.topicID)
+            transaction.message = body.message.decode("utf-8") if body.message else None
+            transaction._total_chunks = transaction.get_required_chunks()
+        return transaction
+
     def sign(self, private_key: PrivateKey) -> TopicMessageSubmitTransaction:
         """
         Signs the transaction using the provided private key.

src/hiero_sdk_python/consensus/topic_update_transaction.py

@@ -33,7 +33,7 @@ def __init__(
         memo: str | None = None,
         admin_key: Key | None = None,
         submit_key: Key | None = None,
-        auto_renew_period: Duration | None = Duration(7890000),
+        auto_renew_period: Duration | None = None,
         auto_renew_account: AccountId | None = None,
         expiration_time: Timestamp | None = None,
         custom_fees: list[CustomFixedFee] | None = None,
@@ -57,7 +57,7 @@ def __init__(
         """
         super().__init__()
         self.topic_id: TopicId | None = topic_id
-        self.memo: str = memo or ""
+        self.memo: str | None = memo
         self.admin_key: Key | None = admin_key
         self.submit_key: Key | None = submit_key
         self.auto_renew_period: Duration | None = auto_renew_period
@@ -312,3 +312,32 @@ def _get_method(self, channel: _Channel) -> _Method:
             _Method: The method to execute the transaction.
         """
         return _Method(transaction_func=channel.topic.updateTopic, query_func=None)
+
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):  # noqa: PLR0912
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("consensusUpdateTopic"):
+            body = transaction_body.consensusUpdateTopic
+            transaction.memo = None
+            transaction.auto_renew_period = None
+            if body.HasField("topicID"):
+                transaction.topic_id = TopicId._from_proto(body.topicID)
+            if body.HasField("memo"):
+                transaction.memo = body.memo.value
+            if body.HasField("adminKey"):
+                transaction.admin_key = Key.from_proto_key(body.adminKey)
+            if body.HasField("submitKey"):
+                transaction.submit_key = Key.from_proto_key(body.submitKey)
+            if body.HasField("autoRenewPeriod"):
+                transaction.auto_renew_period = Duration._from_proto(body.autoRenewPeriod)
+            if body.HasField("autoRenewAccount"):
+                transaction.auto_renew_account = AccountId._from_proto(body.autoRenewAccount)
+            if body.HasField("expirationTime"):
+                transaction.expiration_time = Timestamp._from_protobuf(body.expirationTime)
+            if body.HasField("fee_schedule_key"):
+                transaction.fee_schedule_key = Key.from_proto_key(body.fee_schedule_key)
+            if body.HasField("custom_fees"):
+                transaction.custom_fees = [CustomFixedFee._from_topic_fee_proto(f) for f in body.custom_fees.fees]
+            if body.HasField("fee_exempt_key_list"):
+                transaction.fee_exempt_keys = [Key.from_proto_key(k) for k in body.fee_exempt_key_list.keys]
+        return transaction

src/hiero_sdk_python/contract/contract_create_transaction.py

@@ -10,6 +10,7 @@
 from hiero_sdk_python.contract.contract_function_parameters import (
     ContractFunctionParameters,
 )
+from hiero_sdk_python.crypto.key import Key
 from hiero_sdk_python.crypto.public_key import PublicKey
 from hiero_sdk_python.Duration import Duration
 from hiero_sdk_python.executable import _Method
@@ -387,6 +388,40 @@ def build_scheduled_body(self) -> SchedulableTransactionBody:
         schedulable_body.contractCreateInstance.CopyFrom(contract_create_body)
         return schedulable_body
 
+    @classmethod
+    def _from_protobuf(cls, transaction_body, body_bytes: bytes, sig_map):
+        transaction = super()._from_protobuf(transaction_body, body_bytes, sig_map)
+        if transaction_body.HasField("contractCreateInstance"):
+            body = transaction_body.contractCreateInstance
+            if body.HasField("adminKey"):
+                transaction.admin_key = Key.from_proto_key(body.adminKey)
+            transaction.gas = body.gas
+            transaction.initial_balance = body.initialBalance
+            if body.HasField("proxyAccountID"):
+                transaction.proxy_account_id = AccountId._from_proto(body.proxyAccountID)
+            transaction.auto_renew_period = (
+                Duration._from_proto(body.autoRenewPeriod)
+                if body.HasField("autoRenewPeriod")
+                else Duration(DEFAULT_AUTO_RENEW_PERIOD)
+            )
+            transaction.parameters = body.constructorParameters if body.constructorParameters else None
+            transaction.contract_memo = body.memo if body.memo else None
+            transaction.max_automatic_token_associations = body.max_automatic_token_associations
+            if body.HasField("auto_renew_account_id"):
+                transaction.auto_renew_account_id = AccountId._from_proto(body.auto_renew_account_id)
+            transaction.decline_reward = body.decline_reward
+            initcode_source = body.WhichOneof("initcodeSource")
+            if initcode_source == "fileID":
+                transaction.bytecode_file_id = FileId._from_proto(body.fileID)
+            elif initcode_source == "initcode":
+                transaction.bytecode = body.initcode
+            staked_id = body.WhichOneof("staked_id")
+            if staked_id == "staked_account_id":
+                transaction.staked_account_id = AccountId._from_proto(body.staked_account_id)
+            elif staked_id == "staked_node_id":
+                transaction.staked_node_id = body.staked_node_id
+        return transaction
+
     def _get_method(self, channel: _Channel) -> _Method:
         """
         Gets the method to execute the contract create transaction.