feat: added e2e test for the registeredNodeTx

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

Author: manishdait

sdk/src/main/java/com/hedera/hashgraph/sdk/RegisteredNodeAddressBookQuery.java

@@ -1,3 +1,4 @@
+// SPDX-License-Identifier: Apache-2.0
 package com.hedera.hashgraph.sdk;
 
 import java.util.concurrent.CompletableFuture;

sdk/src/testIntegration/java/com/hedera/hashgraph/sdk/test/integration/RegisteredNodeCreateTransactionIntegrationTest.java

@@ -5,6 +5,7 @@
 
 import com.hedera.hashgraph.sdk.BlockNodeApi;
 import com.hedera.hashgraph.sdk.BlockNodeServiceEndpoint;
+import com.hedera.hashgraph.sdk.MirrorNodeServiceEndpoint;
 import com.hedera.hashgraph.sdk.PrivateKey;
 import com.hedera.hashgraph.sdk.RegisteredNodeCreateTransaction;
 import com.hedera.hashgraph.sdk.RegisteredServiceEndpoint;
@@ -37,4 +38,32 @@ void canCreateRegisteredNode() throws Exception {
             assertThat(receipt.registeredNodeId).isGreaterThan(0);
         }
     }
+
+    @Test
+    @DisplayName("Can create a registered node with multiple service endpoints")
+    void canCreateRegisteredNodeWithMultipleServiceEndpoints() throws Exception {
+        try (var testEnv = new IntegrationTestEnv(1)) {
+            var key = PrivateKey.generateED25519();
+            List<RegisteredServiceEndpoint> serviceEndpoints = List.of(
+                    new BlockNodeServiceEndpoint()
+                            .setDomainName("test.block.com")
+                            .setPort(443)
+                            .setEndpointApi(BlockNodeApi.STATUS),
+                    new MirrorNodeServiceEndpoint()
+                            .setDomainName("test.mirror.com")
+                            .setPort(443));
+
+            var response = new RegisteredNodeCreateTransaction()
+                    .setAdminKey(key)
+                    .setDescription("test description")
+                    .setServiceEndpoints(serviceEndpoints)
+                    .freezeWith(testEnv.client)
+                    .execute(testEnv.client);
+
+            var receipt = response.getReceipt(testEnv.client);
+
+            assertThat(receipt.status).isEqualTo(Status.SUCCESS);
+            assertThat(receipt.registeredNodeId).isGreaterThan(0);
+        }
+    }
 }

sdk/src/testIntegration/java/com/hedera/hashgraph/sdk/test/integration/RegisteredNodeDeleteTransactionIntegrationTest.java

@@ -0,0 +1,49 @@
+// SPDX-License-Identifier: Apache-2.0
+package com.hedera.hashgraph.sdk.test.integration;
+
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+
+import com.hedera.hashgraph.sdk.BlockNodeApi;
+import com.hedera.hashgraph.sdk.BlockNodeServiceEndpoint;
+import com.hedera.hashgraph.sdk.PrivateKey;
+import com.hedera.hashgraph.sdk.RegisteredNodeCreateTransaction;
+import com.hedera.hashgraph.sdk.RegisteredNodeDeleteTransaction;
+import com.hedera.hashgraph.sdk.RegisteredServiceEndpoint;
+import com.hedera.hashgraph.sdk.Status;
+import java.util.List;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class RegisteredNodeDeleteTransactionIntegrationTest {
+    @Test
+    @DisplayName("Can delete a registered node")
+    void canDeleteRegisteredNode() throws Exception {
+        try (var testEnv = new IntegrationTestEnv(1)) {
+            var key = PrivateKey.generateED25519();
+
+            List<RegisteredServiceEndpoint> endpoints = List.of(new BlockNodeServiceEndpoint()
+                    .setDomainName("blocks.example.com")
+                    .setPort(443)
+                    .setEndpointApi(BlockNodeApi.STATUS));
+
+            var createReceipt = new RegisteredNodeCreateTransaction()
+                    .setAdminKey(key)
+                    .setDescription("test node delete")
+                    .setServiceEndpoints(endpoints)
+                    .freezeWith(testEnv.client)
+                    .execute(testEnv.client)
+                    .getReceipt(testEnv.client);
+
+            var nodeId = createReceipt.registeredNodeId;
+
+            var deleteReceipt = new RegisteredNodeDeleteTransaction()
+                    .setRegisteredNodeId(nodeId)
+                    .freezeWith(testEnv.client)
+                    .sign(key)
+                    .execute(testEnv.client)
+                    .getReceipt(testEnv.client);
+
+            assertThat(deleteReceipt.status).isEqualTo(Status.SUCCESS);
+        }
+    }
+}

sdk/src/testIntegration/java/com/hedera/hashgraph/sdk/test/integration/RegisteredNodeUpdateTransactionIntegrationTest.java

@@ -0,0 +1,95 @@
+// SPDX-License-Identifier: Apache-2.0
+package com.hedera.hashgraph.sdk.test.integration;
+
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+
+import com.hedera.hashgraph.sdk.BlockNodeApi;
+import com.hedera.hashgraph.sdk.BlockNodeServiceEndpoint;
+import com.hedera.hashgraph.sdk.PrivateKey;
+import com.hedera.hashgraph.sdk.RegisteredNodeCreateTransaction;
+import com.hedera.hashgraph.sdk.RegisteredNodeUpdateTransaction;
+import com.hedera.hashgraph.sdk.RegisteredServiceEndpoint;
+import com.hedera.hashgraph.sdk.Status;
+import java.util.List;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+public class RegisteredNodeUpdateTransactionIntegrationTest {
+    @Test
+    @DisplayName("Can update registered node endpoints and description")
+    void canUpdateRegisteredNode() throws Exception {
+        try (var testEnv = new IntegrationTestEnv(1)) {
+            var key = PrivateKey.generateED25519();
+
+            List<RegisteredServiceEndpoint> endpoints = List.of(new BlockNodeServiceEndpoint()
+                    .setDomainName("initial.blocks.com")
+                    .setPort(443)
+                    .setEndpointApi(BlockNodeApi.SUBSCRIBE_STREAM));
+
+            var createResponse = new RegisteredNodeCreateTransaction()
+                    .setAdminKey(key)
+                    .setDescription("test initial node")
+                    .setServiceEndpoints(endpoints)
+                    .freezeWith(testEnv.client)
+                    .execute(testEnv.client);
+
+            var createReceipt = createResponse.getReceipt(testEnv.client);
+
+            var nodeId = createReceipt.registeredNodeId;
+
+            List<RegisteredServiceEndpoint> updatedEndpoints = List.of(new BlockNodeServiceEndpoint()
+                    .setDomainName("updated.blocks.com")
+                    .setPort(443)
+                    .setEndpointApi(BlockNodeApi.STATUS));
+
+            var updateResponse = new RegisteredNodeUpdateTransaction()
+                    .setRegisteredNodeId(nodeId)
+                    .setDescription("test updated node")
+                    .setServiceEndpoints(updatedEndpoints)
+                    .freezeWith(testEnv.client)
+                    .sign(key)
+                    .execute(testEnv.client);
+
+            var updateReceipt = updateResponse.getReceipt(testEnv.client);
+
+            assertThat(updateReceipt.status).isEqualTo(Status.SUCCESS);
+        }
+    }
+
+    @Test
+    @DisplayName("Can rotate registered node admin key")
+    void canRotateAdminKey() throws Exception {
+        try (var testEnv = new IntegrationTestEnv(1)) {
+            var oldKey = PrivateKey.generateED25519();
+
+            List<RegisteredServiceEndpoint> endpoints = List.of(new BlockNodeServiceEndpoint()
+                    .setDomainName("blocks.example.com")
+                    .setPort(443)
+                    .setEndpointApi(BlockNodeApi.STATUS));
+
+            var createReceipt = new RegisteredNodeCreateTransaction()
+                    .setAdminKey(oldKey)
+                    .setDescription("test node")
+                    .setServiceEndpoints(endpoints)
+                    .freezeWith(testEnv.client)
+                    .execute(testEnv.client)
+                    .getReceipt(testEnv.client);
+
+            var nodeId = createReceipt.registeredNodeId;
+
+            var newKey = PrivateKey.generateED25519();
+
+            var tx = new RegisteredNodeUpdateTransaction()
+                    .setRegisteredNodeId(nodeId)
+                    .setAdminKey(newKey)
+                    .freezeWith(testEnv.client);
+
+            tx.sign(oldKey);
+            tx.sign(newKey);
+
+            var receipt = tx.execute(testEnv.client).getReceipt(testEnv.client);
+
+            assertThat(receipt.status).isEqualTo(Status.SUCCESS);
+        }
+    }
+}