wip: changing node account ids

Signed-off-by: Ivaylo Nikolov <[email protected]>

Author: ivaylonikolov7

.env.sample

@@ -14,3 +14,7 @@ OPERATOR_KEY="302e020100300506032b6570042204202cc589a6343ff8d05b71edf54f69bff4cd
 #   - previewnet: Connects to the Hedera preview network.
 #   - local-node: Connects to a local Hedera node for development/testing.
 HEDERA_NETWORK="previewnet"
+
+
+NODE_ADMIN_KEY=302e020100300506032b65700422042091132178e72057a1d7528025956fe39b0b847f200ab59b2fdd367017f3087137
+NODE_ADMIN_ID=0.0.2

src/Executable.js

@@ -800,6 +800,33 @@ export default class Executable {
             // Determine by the executing state what we should do
             switch (shouldRetry) {
                 case ExecutionState.Retry:
+                    // Special handling for INVALID_NODE_ACCOUNT_ID: mark node as unusable
+                    // and update network to get latest node account IDs
+                    if (status === Status.InvalidNodeAccountId) {
+                        if (this._logger) {
+                            this._logger.debug(
+                                `[${this._getLogId()}] node with accountId: ${node.accountId.toString()} and proxy IP: ${node.address.toString()} has invalid node account ID, marking as unhealthy and updating network`,
+                            );
+                        }
+
+                        // Mark the node as unusable by increasing its backoff and removing it from the healthy nodes list
+                        client._network.increaseBackoff(node);
+
+                        // Initiate addressbook query and update the client's network
+                        // This will make the SDK client have the latest node account IDs for subsequent transactions
+                        client.updateNetwork().catch((error) => {
+                            if (this._logger) {
+                                const errorMessage =
+                                    error instanceof Error
+                                        ? error.message
+                                        : String(error);
+                                this._logger.trace(
+                                    `failed to update client address book after INVALID_NODE_ACCOUNT_ID: ${errorMessage}`,
+                                );
+                            }
+                        });
+                    }
+
                     await delayForAttempt(
                         isLocalNode,
                         attempt,

src/client/NativeClient.js

@@ -280,7 +280,11 @@ export default class NativeClient extends Client {
             const network = {};
             for (const nodeAddress of addressBook.nodeAddresses) {
                 for (const endpoint of nodeAddress.addresses) {
-                    if (nodeAddress.accountId != null) {
+                    // Exclude nodes with account ID 0.0.0 (removed node account IDs)
+                    if (
+                        nodeAddress.accountId != null &&
+                        nodeAddress.accountId.toString() !== "0.0.0"
+                    ) {
                         network[endpoint.toString()] = nodeAddress.accountId;
                     }
                 }

src/client/Network.js

@@ -65,7 +65,12 @@ export default class Network extends ManagedNetwork {
         for (const nodeAddress of addressBook.nodeAddresses) {
             for (const endpoint of nodeAddress.addresses) {
                 // TODO: We hard code ports too much, should fix
-                if (endpoint.port === port && nodeAddress.accountId != null) {
+                // Exclude nodes with account ID 0.0.0 (removed node account IDs)
+                if (
+                    endpoint.port === port &&
+                    nodeAddress.accountId != null &&
+                    nodeAddress.accountId.toString() !== "0.0.0"
+                ) {
                     network[endpoint.toString()] = nodeAddress.accountId;
                 }
             }

src/client/WebClient.js

@@ -317,7 +317,11 @@ export default class WebClient extends Client {
             const network = {};
             for (const nodeAddress of addressBook.nodeAddresses) {
                 for (const endpoint of nodeAddress.addresses) {
-                    if (nodeAddress.accountId != null) {
+                    // Exclude nodes with account ID 0.0.0 (removed node account IDs)
+                    if (
+                        nodeAddress.accountId != null &&
+                        nodeAddress.accountId.toString() !== "0.0.0"
+                    ) {
                         network[endpoint.toString()] = nodeAddress.accountId;
                     }
                 }

src/transaction/Transaction.js

@@ -1966,6 +1966,7 @@ export default class Transaction extends Executable {
             case Status.Unknown:
             case Status.PlatformTransactionNotCreated:
             case Status.PlatformNotActive:
+            case Status.InvalidNodeAccountId:
                 return [status, ExecutionState.Retry];
             case Status.Ok:
                 return [status, ExecutionState.Finished];