Implements HIP-1137 registered node support in the Python SDK.

examples/nodes/registered_node_lifecycle.py

@@ -0,0 +1,142 @@
+"""
+Demonstrates the full lifecycle of a registered node on the Hedera network.
+
+This example shows how to:
+1. Create a registered node with BlockNodeServiceEndpoint and multiple endpoint APIs
+2. Update the registered node's description and service endpoints
+3. Delete the registered node
+
+NOTE: This is a privileged transaction. Regular developers do not have the required
+permissions to manage registered nodes on testnet or mainnet as this operation
+requires special authorization.
+
+This example is provided to demonstrate the API for educational purposes or for use
+in private network deployments where you have the necessary administrative privileges.
+"""
+
+import sys
+
+from dotenv import load_dotenv
+
+from hiero_sdk_python import AccountId, Client, Network, PrivateKey
+from hiero_sdk_python.address_book.block_node_api import BlockNodeApi
+from hiero_sdk_python.address_book.block_node_service_endpoint import BlockNodeServiceEndpoint
+from hiero_sdk_python.address_book.mirror_node_service_endpoint import MirrorNodeServiceEndpoint
+from hiero_sdk_python.exceptions import PrecheckError
+from hiero_sdk_python.nodes.registered_node_create_transaction import RegisteredNodeCreateTransaction
+from hiero_sdk_python.nodes.registered_node_delete_transaction import RegisteredNodeDeleteTransaction
+from hiero_sdk_python.nodes.registered_node_update_transaction import RegisteredNodeUpdateTransaction
+from hiero_sdk_python.response_code import ResponseCode
+
+
+def setup_client():
+    """Initialize and set up the client with operator account."""
+    load_dotenv()
+    network = Network(network="solo")
+    client = Client(network)
+    print(f"Connecting to Hedera {network} network!")
+
+    # Account 0.0.2 is a special administrative account with
+    # elevated privileges for network management operations.
+    # The private key is intentionally public for local development.
+    # Note: This setup only works on solo network and will not work on testnet/mainnet.
+    original_operator_key = PrivateKey.from_string_der(
+        "302e020100300506032b65700422042091132178e72057a1d7528025956fe39b0b847f200ab59b2fdd367017f3087137"
+    )
+    client.set_operator(AccountId(0, 0, 2), original_operator_key)
+
+    return client
+
+
+def registered_node_lifecycle():
+    """Demonstrates create, update, and delete of a registered node."""
+    client = setup_client()
+
+    # Generate an admin key for the registered node
+    admin_key = PrivateKey.generate_ed25519()
+
+    # ── Step 1: Create a registered node ────────────────────────────
+    print("\n--- Creating registered node ---")
+
+    block_endpoint = BlockNodeServiceEndpoint(
+        domain_name="block.example.com",
+        port=443,
+        requires_tls=True,
+        endpoint_apis=[BlockNodeApi.STATUS, BlockNodeApi.SUBSCRIBE_STREAM],
+    )
+
+    try:
+        receipt = (
+            RegisteredNodeCreateTransaction()
+            .set_admin_key(admin_key.public_key())
+            .set_description("Example block node")
+            .set_service_endpoints([block_endpoint])
+            .freeze_with(client)
+            .sign(admin_key)
+            .execute(client)
+        )
+    except (PrecheckError, ValueError) as e:
+        print(f"Registered node creation failed: {e}")
+        sys.exit(1)
+
+    if receipt.status != ResponseCode.SUCCESS:
+        print(f"Registered node creation failed: {ResponseCode(receipt.status).name}")
+        sys.exit(1)
+
+    registered_node_id = receipt.registered_node_id
+    print(f"Registered node created with ID: {registered_node_id}")
+
+    # ── Step 2: Update the registered node ──────────────────────────
+    print("\n--- Updating registered node ---")
+
+    mirror_endpoint = MirrorNodeServiceEndpoint(
+        domain_name="mirror.example.com",
+        port=5600,
+        requires_tls=True,
+    )
+
+    try:
+        receipt = (
+            RegisteredNodeUpdateTransaction()
+            .set_registered_node_id(registered_node_id)
+            .set_description("Updated block + mirror node")
+            .set_service_endpoints([block_endpoint, mirror_endpoint])
+            .freeze_with(client)
+            .sign(admin_key)
+            .execute(client)
+        )
+    except (PrecheckError, ValueError) as e:
+        print(f"Registered node update failed: {e}")
+        sys.exit(1)
+
+    if receipt.status != ResponseCode.SUCCESS:
+        print(f"Registered node update failed: {ResponseCode(receipt.status).name}")
+        sys.exit(1)
+
+    print("Registered node updated successfully")
+
+    # ── Step 3: Delete the registered node ──────────────────────────
+    print("\n--- Deleting registered node ---")
+
+    try:
+        receipt = (
+            RegisteredNodeDeleteTransaction()
+            .set_registered_node_id(registered_node_id)
+            .freeze_with(client)
+            .sign(admin_key)
+            .execute(client)
+        )
+    except (PrecheckError, ValueError) as e:
+        print(f"Registered node deletion failed: {e}")
+        sys.exit(1)
+
+    if receipt.status != ResponseCode.SUCCESS:
+        print(f"Registered node deletion failed: {ResponseCode(receipt.status).name}")
+        sys.exit(1)
+
+    print("Registered node deleted successfully")
+    print("\n--- Registered node lifecycle complete ---")
+
+
+if __name__ == "__main__":
+    registered_node_lifecycle()

generate_proto.py

@@ -34,7 +34,7 @@
 from urllib.parse import urlparse
 
 
-VERSION = "v0.72.1"
+VERSION = "v0.73.0"
 SOURCES = [
     {
         "name": "hedera-protobufs",

src/hiero_sdk_python/__init__.py

@@ -9,8 +9,17 @@
 from .account.account_update_transaction import AccountUpdateTransaction
 
 # Address book
+from .address_book.block_node_api import BlockNodeApi
+from .address_book.block_node_service_endpoint import BlockNodeServiceEndpoint
 from .address_book.endpoint import Endpoint
+from .address_book.general_service_endpoint import GeneralServiceEndpoint
+from .address_book.mirror_node_service_endpoint import MirrorNodeServiceEndpoint
 from .address_book.node_address import NodeAddress
+from .address_book.registered_node import RegisteredNode
+from .address_book.registered_node_address_book import RegisteredNodeAddressBook
+from .address_book.registered_node_address_book_query import RegisteredNodeAddressBookQuery
+from .address_book.registered_service_endpoint import RegisteredServiceEndpoint
+from .address_book.rpc_relay_service_endpoint import RpcRelayServiceEndpoint
 
 # Client and Network
 from .client.client import Client
@@ -77,6 +86,9 @@
 from .nodes.node_create_transaction import NodeCreateTransaction
 from .nodes.node_delete_transaction import NodeDeleteTransaction
 from .nodes.node_update_transaction import NodeUpdateTransaction
+from .nodes.registered_node_create_transaction import RegisteredNodeCreateTransaction
+from .nodes.registered_node_delete_transaction import RegisteredNodeDeleteTransaction
+from .nodes.registered_node_update_transaction import RegisteredNodeUpdateTransaction
 
 # PRNG
 from .prng_transaction import PrngTransaction
@@ -245,8 +257,17 @@
     "TokenInfoQuery",
     "AccountInfoQuery",
     # Address book
+    "BlockNodeApi",
+    "BlockNodeServiceEndpoint",
     "Endpoint",
+    "GeneralServiceEndpoint",
+    "MirrorNodeServiceEndpoint",
     "NodeAddress",
+    "RegisteredNode",
+    "RegisteredNodeAddressBook",
+    "RegisteredNodeAddressBookQuery",
+    "RegisteredServiceEndpoint",
+    "RpcRelayServiceEndpoint",
     # Logger
     "Logger",
     "LogLevel",
@@ -296,6 +317,9 @@
     "NodeCreateTransaction",
     "NodeUpdateTransaction",
     "NodeDeleteTransaction",
+    "RegisteredNodeCreateTransaction",
+    "RegisteredNodeUpdateTransaction",
+    "RegisteredNodeDeleteTransaction",
     # PRNG
     "PrngTransaction",
     # Custom Fees

src/hiero_sdk_python/address_book/block_node_api.py

@@ -0,0 +1,13 @@
+from __future__ import annotations
+
+from enum import IntEnum
+
+
+class BlockNodeApi(IntEnum):
+    """Maps to the BlockNodeApi enum defined inside RegisteredServiceEndpoint.BlockNodeEndpoint."""
+
+    OTHER = 0
+    STATUS = 1
+    PUBLISH = 2
+    SUBSCRIBE_STREAM = 3
+    STATE_PROOF = 4

src/hiero_sdk_python/address_book/block_node_service_endpoint.py

@@ -0,0 +1,49 @@
+from __future__ import annotations
+
+from hiero_sdk_python.address_book.block_node_api import BlockNodeApi
+from hiero_sdk_python.address_book.registered_service_endpoint import RegisteredServiceEndpoint
+from hiero_sdk_python.hapi.services.registered_service_endpoint_pb2 import (
+    RegisteredServiceEndpoint as RegisteredServiceEndpointProto,
+)
+
+
+class BlockNodeServiceEndpoint(RegisteredServiceEndpoint):
+    """A registered service endpoint for a block node."""
+
+    def __init__(
+        self,
+        ip_address: bytes | None = None,
+        domain_name: str | None = None,
+        port: int = 0,
+        requires_tls: bool = False,
+        endpoint_apis: list[BlockNodeApi] | None = None,
+    ) -> None:
+        super().__init__(ip_address=ip_address, domain_name=domain_name, port=port, requires_tls=requires_tls)
+        if endpoint_apis is None or len(endpoint_apis) == 0:
+            raise ValueError("endpoint_apis must be non-empty")
+        self.endpoint_apis: list[BlockNodeApi] = [BlockNodeApi(api) for api in endpoint_apis]
+
+    def _set_endpoint_type(self, proto: RegisteredServiceEndpointProto) -> None:
+        block_node = proto.block_node
+        for api in self.endpoint_apis:
+            block_node.endpoint_api.append(api.value)
+
+    @classmethod
+    def _from_proto_inner(
+        cls,
+        proto: RegisteredServiceEndpointProto,
+        ip_address: bytes | None,
+        domain_name: str | None,
+        port: int,
+        requires_tls: bool,
+    ) -> BlockNodeServiceEndpoint:
+        apis = [BlockNodeApi(v) for v in proto.block_node.endpoint_api]
+        if not apis:
+            apis = [BlockNodeApi.OTHER]
+        return cls(
+            ip_address=ip_address,
+            domain_name=domain_name,
+            port=port,
+            requires_tls=requires_tls,
+            endpoint_apis=apis,
+        )

src/hiero_sdk_python/address_book/general_service_endpoint.py

@@ -0,0 +1,47 @@
+from __future__ import annotations
+
+from hiero_sdk_python.address_book.registered_service_endpoint import RegisteredServiceEndpoint
+from hiero_sdk_python.hapi.services.registered_service_endpoint_pb2 import (
+    RegisteredServiceEndpoint as RegisteredServiceEndpointProto,
+)
+
+
+class GeneralServiceEndpoint(RegisteredServiceEndpoint):
+    """A registered service endpoint for a general service."""
+
+    def __init__(
+        self,
+        ip_address: bytes | None = None,
+        domain_name: str | None = None,
+        port: int = 0,
+        requires_tls: bool = False,
+        description: str | None = None,
+    ) -> None:
+        super().__init__(ip_address=ip_address, domain_name=domain_name, port=port, requires_tls=requires_tls)
+        if description is not None and len(description.encode("utf-8")) > 100:
+            raise ValueError("description must be 100 UTF-8 bytes or fewer")
+        self.description: str | None = description
+
+    def _set_endpoint_type(self, proto: RegisteredServiceEndpointProto) -> None:
+        if self.description is not None:
+            proto.general_service.description = self.description
+        else:
+            proto.general_service.SetInParent()
+
+    @classmethod
+    def _from_proto_inner(
+        cls,
+        proto: RegisteredServiceEndpointProto,
+        ip_address: bytes | None,
+        domain_name: str | None,
+        port: int,
+        requires_tls: bool,
+    ) -> GeneralServiceEndpoint:
+        desc = proto.general_service.description or None
+        return cls(
+            ip_address=ip_address,
+            domain_name=domain_name,
+            port=port,
+            requires_tls=requires_tls,
+            description=desc,
+        )

src/hiero_sdk_python/address_book/mirror_node_service_endpoint.py

@@ -0,0 +1,30 @@
+from __future__ import annotations
+
+from hiero_sdk_python.address_book.registered_service_endpoint import RegisteredServiceEndpoint
+from hiero_sdk_python.hapi.services.registered_service_endpoint_pb2 import (
+    RegisteredServiceEndpoint as RegisteredServiceEndpointProto,
+)
+
+
+class MirrorNodeServiceEndpoint(RegisteredServiceEndpoint):
+    """A registered service endpoint for a mirror node."""
+
+    def _set_endpoint_type(self, proto: RegisteredServiceEndpointProto) -> None:
+        # Accessing the field initializes the oneof to mirror_node
+        proto.mirror_node.SetInParent()
+
+    @classmethod
+    def _from_proto_inner(
+        cls,
+        _proto: RegisteredServiceEndpointProto,
+        ip_address: bytes | None,
+        domain_name: str | None,
+        port: int,
+        requires_tls: bool,
+    ) -> MirrorNodeServiceEndpoint:
+        return cls(
+            ip_address=ip_address,
+            domain_name=domain_name,
+            port=port,
+            requires_tls=requires_tls,
+        )