// SPDX-License-Identifier: Apache-2.0

import fs from 'node:fs';
import * as Base64 from 'js-base64';
import * as constants from './constants.js';
import {IGNORED_NODE_ACCOUNT_ID} from './constants.js';
import {
  AccountCreateTransaction,
  AccountId,
  type AccountInfo,
  AccountInfoQuery,
  AccountUpdateTransaction,
  Client,
  FileContentsQuery,
  FileId,
  Hbar,
  HbarUnit,
  type Key,
  KeyList,
  Logger,
  LogLevel,
  Long,
  PrivateKey,
  Status,
  TransferTransaction,
} from '@hiero-ledger/sdk';
import {MissingArgumentError} from './errors/missing-argument-error.js';
import {ResourceNotFoundError} from './errors/resource-not-found-error.js';
import {SoloError} from './errors/solo-error.js';
import {Templates} from './templates.js';
import {type NetworkNodeServices} from './network-node-services.js';

import {type SoloLogger} from './logging/solo-logger.js';
import {type K8Factory} from '../integration/kube/k8-factory.js';
import {
  type AccountIdWithKeyPairObject,
  type ClusterReferenceName,
  type Context,
  type Optional,
} from '../types/index.js';
import {type NodeAlias, type NodeAliases, type NodeId, type SdkNetworkEndpoint} from '../types/aliases.js';
import {type PodName} from '../integration/kube/resources/pod/pod-name.js';
import {entityId, sleep} from './helpers.js';
import {Duration} from './time/duration.js';
import {inject, injectable} from 'tsyringe-neo';
import {patchInject} from './dependency-injection/container-helper.js';
import {type NamespaceName} from '../types/namespace/namespace-name.js';
import {PodReference} from '../integration/kube/resources/pod/pod-reference.js';
import {SecretType} from '../integration/kube/resources/secret/secret-type.js';
import {type Pod} from '../integration/kube/resources/pod/pod.js';
import {InjectTokens} from './dependency-injection/inject-tokens.js';
import {type ClusterReferences, type DeploymentName, Realm, Shard} from './../types/index.js';
import {type Service} from '../integration/kube/resources/service/service.js';
import {SoloService} from './model/solo-service.js';
import {PathEx} from '../business/utils/path-ex.js';
import {type NodeServiceMapping} from '../types/mappings/node-service-mapping.js';
import {type ConsensusNode} from './model/consensus-node.js';
import {NetworkNodeServicesBuilder} from './network-node-services-builder.js';
import {LocalConfigRuntimeState} from '../business/runtime-state/config/local/local-config-runtime-state.js';
import {type RemoteConfigRuntimeStateApi} from '../business/runtime-state/api/remote-config-runtime-state-api.js';
import {Secret} from '../integration/kube/resources/secret/secret.js';
import {Address} from '../business/address/address.js';
import {Numbers} from '../business/utils/numbers.js';

// TODO - revisit and remove once we complete the cutover to BN and no longer need MN to pull from CN.
// This should remove this dependency on @hiero-ledger/proto
import {proto} from '@hiero-ledger/proto';
import * as crypto from 'node:crypto';
import {X509Certificate} from 'node:crypto';

const REASON_FAILED_TO_GET_KEYS: string = 'failed to get keys for accountId';
const REASON_SKIPPED: string = 'skipped since it does not have a genesis key';
const REASON_FAILED_TO_UPDATE_ACCOUNT: string = 'failed to update account keys';
const REASON_FAILED_TO_CREATE_K8S_S_KEY: string = 'failed to create k8s scrt key';
const FULFILLED: string = 'fulfilled';
const REJECTED: string = 'rejected';

@injectable()
export class AccountManager {
  private _portForwards: number[];
  private _forcePortForward: boolean = false;
  public _nodeClient: Optional<Client>;

  public constructor(
    @inject(InjectTokens.SoloLogger) private readonly logger?: SoloLogger,
    @inject(InjectTokens.K8Factory) private readonly k8Factory?: K8Factory,
    @inject(InjectTokens.RemoteConfigRuntimeState) private readonly remoteConfig?: RemoteConfigRuntimeStateApi,
    @inject(InjectTokens.LocalConfigRuntimeState) private readonly localConfig?: LocalConfigRuntimeState,
  ) {
    this.logger = patchInject(logger, InjectTokens.SoloLogger, this.constructor.name);
    this.k8Factory = patchInject(k8Factory, InjectTokens.K8Factory, this.constructor.name);
    this.remoteConfig = patchInject(remoteConfig, InjectTokens.RemoteConfigRuntimeState, this.constructor.name);
    this.localConfig = patchInject(localConfig, InjectTokens.LocalConfigRuntimeState, this.constructor.name);

    this._portForwards = [];
    this._nodeClient = null;
  }

  /**
   * Gets the account keys from the Kubernetes secret from which it is stored
   * @param accountId - the account ID for which we want its keys
   * @param namespace - the namespace storing the secret
   */
  public async getAccountKeysFromSecret(
    accountId: string,
    namespace: NamespaceName,
  ): Promise<AccountIdWithKeyPairObject> {
    const contexts: Context[] = this.remoteConfig.getContexts();

    for (const context of contexts) {
      try {
        const secrets: Secret[] = await this.k8Factory
          .getK8(context)
          .secrets()
          .list(namespace, [Templates.renderAccountKeySecretLabelSelector(accountId)]);

        if (secrets.length > 0) {
          const secret: Secret = secrets[0];
          return {
            accountId: secret.labels['solo.hedera.com/account-id'],
            privateKey: Base64.decode(secret.data.privateKey),
            publicKey: Base64.decode(secret.data.publicKey),
          };
        }
      } catch (error) {
        if (!(error instanceof ResourceNotFoundError)) {
          throw error;
        }
      }
    }

    // if it isn't in the secrets we can load genesis key
    return {
      accountId,
      privateKey: constants.GENESIS_KEY,
      publicKey: PrivateKey.fromStringED25519(constants.GENESIS_KEY).publicKey.toString(),
    };
  }

  /**
   * Gets the treasury account private key from Kubernetes secret if it exists, else
   * returns the Genesis private key, then will return an AccountInfo object with the
   * accountId, ed25519PrivateKey, publicKey
   * @param namespace - the namespace that the secret is in
   * @param deploymentName
   */
  public async getTreasuryAccountKeys(
    namespace: NamespaceName,
    deploymentName: DeploymentName,
  ): Promise<AccountIdWithKeyPairObject> {
    // check to see if the treasure account is in the secrets
    return await this.getAccountKeysFromSecret(this.getTreasuryAccountId(deploymentName).toString(), namespace);
  }

  /**
   * batch up the accounts into sets to be processed
   * @param [accountRange]
   * @returns an array of arrays of numbers representing the accounts to update
   */
  public batchAccounts(accountRange: number[][] = constants.SYSTEM_ACCOUNTS): number[][] {
    const batchSize: number = constants.ACCOUNT_UPDATE_BATCH_SIZE as number;
    const batchSets: number[][] = [];

    let currentBatch: number[] = [];
    for (const [start, end] of accountRange) {
      let batchCounter: number = start;
      for (let index: number = start; index <= end; index++) {
        currentBatch.push(index);
        batchCounter++;

        if (batchCounter % batchSize === 0) {
          batchSets.push(currentBatch);
          currentBatch = [];
          batchCounter = 0;
        }
      }
    }

    if (currentBatch.length > 0) {
      batchSets.push(currentBatch);
    }

    batchSets.push([constants.TREASURY_ACCOUNT]);

    return batchSets;
  }

  /** stops and closes the port forwards and the _nodeClient */
  public async close(): Promise<void> {
    this._nodeClient?.close();
    if (this._portForwards) {
      for (const srv of this._portForwards) {
        await this.k8Factory.default().pods().readByReference(null).stopPortForward(srv);
      }
    }

    this._nodeClient = null;
    this._portForwards = [];
    this.logger.debug('node client and port forwards have been closed');
  }

  /**
   * loads and initializes the Node Client
   * @param namespace - the namespace of the network
   * @param clusterReferences - the cluster references
   * @param [deployment] - k8 deployment name
   * @param [forcePortForward] - whether to force the port forward
   */
  public async loadNodeClient(
    namespace: NamespaceName,
    clusterReferences: ClusterReferences,
    deployment: DeploymentName,
    forcePortForward?: boolean,
  ): Promise<Client> {
    try {
      this.logger.debug(
        `loading node client: [!this._nodeClient=${!this._nodeClient}, this._nodeClient.isClientShutDown=${this._nodeClient?.isClientShutDown}]`,
      );
      if (!this._nodeClient || this._nodeClient?.isClientShutDown) {
        this.logger.debug(
          `refreshing node client: [!this._nodeClient=${!this._nodeClient}, this._nodeClient.isClientShutDown=${this._nodeClient?.isClientShutDown}]`,
        );
        await this.refreshNodeClient(namespace, clusterReferences, undefined, deployment, forcePortForward);
      } else {
        try {
          if (!constants.SKIP_NODE_PING) {
            await this._nodeClient.ping(this._nodeClient.operatorAccountId);
          }
        } catch {
          this.logger.debug('node client ping failed, refreshing node client');
          await this.refreshNodeClient(namespace, clusterReferences, undefined, deployment, forcePortForward);
        }
      }

      return this._nodeClient!;
    } catch (error) {
      const message: string = `failed to load node client: ${error.message}`;
      throw new SoloError(message, error);
    }
  }

  /**
   * loads and initializes the Node Client, throws a SoloError if anything fails
   * @param namespace - the namespace of the network
   * @param clusterReferences - the cluster references
   * @param skipNodeAlias - the node alias to skip
   * @param deployment - the deployment name
   * @param [forcePortForward] - whether to force the port forward
   */
  public async refreshNodeClient(
    namespace: NamespaceName,
    clusterReferences: ClusterReferences,
    skipNodeAlias: NodeAlias,
    deployment: DeploymentName,
    forcePortForward?: boolean,
  ): Promise<Client> {
    try {
      await this.close();
      if (forcePortForward !== undefined) {
        this._forcePortForward = forcePortForward;
      }

      const treasuryAccountInfo: AccountIdWithKeyPairObject = await this.getTreasuryAccountKeys(namespace, deployment);
      const networkNodeServicesMap: Map<NodeAlias, NetworkNodeServices> = await this.getNodeServiceMap(
        namespace,
        clusterReferences,
        deployment,
      );

      this._nodeClient = await this._getNodeClient(
        namespace,
        networkNodeServicesMap,
        treasuryAccountInfo.accountId,
        treasuryAccountInfo.privateKey,
        skipNodeAlias,
      );

      this.logger.debug('node client has been refreshed');
      return this._nodeClient;
    } catch (error) {
      const message: string = `failed to refresh node client: ${error.message}`;
      throw new SoloError(message, error);
    }
  }

  /**
   * if the load balancer IP is not set, then we should use the local host port forward
   * @param networkNodeServices
   * @returns whether to use the local host port forward
   */
  private shouldUseLocalHostPortForward(networkNodeServices: NetworkNodeServices): boolean {
    return this._forcePortForward || !networkNodeServices.haProxyLoadBalancerIp;
  }

  /**
   * Returns a node client that can be used to make calls against
   * @param namespace - the namespace for which the node client resides
   * @param networkNodeServicesMap - a map of the service objects that proxy the nodes
   * @param operatorId - the account id of the operator of the transactions
   * @param operatorKey - the private key of the operator of the transactions
   * @param skipNodeAlias - the node alias to skip
   * @returns a node client that can be used to call transactions
   */
  public async _getNodeClient(
    namespace: NamespaceName,
    networkNodeServicesMap: NodeServiceMapping,
    operatorId: string,
    operatorKey: string,
    skipNodeAlias: string,
  ): Promise<Client> {
    let nodes: Record<SdkNetworkEndpoint, AccountId> = {};
    const configureNodeAccessPromiseArray: Promise<Record<SdkNetworkEndpoint, AccountId>>[] = [];

    try {
      let localPort: number = constants.LOCAL_NODE_START_PORT;

      for (const networkNodeService of networkNodeServicesMap.values()) {
        if (
          networkNodeService.accountId !== IGNORED_NODE_ACCOUNT_ID &&
          networkNodeService.nodeAlias !== skipNodeAlias
        ) {
          configureNodeAccessPromiseArray.push(
            this.configureNodeAccess(networkNodeService, localPort, networkNodeServicesMap.size),
          );
          localPort++;
        }
      }
      this.logger.debug(`configuring node access for ${configureNodeAccessPromiseArray.length} nodes`);

      await Promise.allSettled(configureNodeAccessPromiseArray).then((results): void => {
        for (const result of results) {
          switch (result.status) {
            case REJECTED: {
              throw new SoloError(`failed to configure node access: ${(result as PromiseRejectedResult).reason}`);
            }
            case FULFILLED: {
              nodes = {...nodes, ...(result as PromiseFulfilledResult<Record<NodeAlias, AccountId>>).value};
              break;
            }
          }
        }
      });
      this.logger.debug(`configured node access for ${Object.keys(nodes).length} nodes`);

      let formattedNetworkConnection: string = '';
      for (const key of Object.keys(nodes)) {
        formattedNetworkConnection += `${key}:${nodes[key]}, `;
      }
      this.logger.info(`creating client from network configuration: [${formattedNetworkConnection}]`);

      // scheduleNetworkUpdate is set to false, because the ports 50212/50211 are hardcoded in JS SDK that will not work
      // when running locally or in a pipeline
      this._nodeClient = Client.fromConfig({network: nodes, scheduleNetworkUpdate: false});
      this._nodeClient.setOperator(operatorId, operatorKey);
      this._nodeClient.setLogger(new Logger(LogLevel.Trace, PathEx.join(constants.SOLO_LOGS_DIR, 'hashgraph-sdk.log')));
      this._nodeClient.setMaxAttempts(constants.NODE_CLIENT_MAX_ATTEMPTS as number);
      this._nodeClient.setMinBackoff(constants.NODE_CLIENT_MIN_BACKOFF as number);
      this._nodeClient.setMaxBackoff(constants.NODE_CLIENT_MAX_BACKOFF as number);
      this._nodeClient.setRequestTimeout(constants.NODE_CLIENT_REQUEST_TIMEOUT as number);
      this._nodeClient.setMaxQueryPayment(new Hbar(constants.NODE_CLIENT_MAX_QUERY_PAYMENT));

      // ping the node client to ensure it is working
      if (!constants.SKIP_NODE_PING) {
        await this._nodeClient.ping(AccountId.fromString(operatorId));
      }

      return this._nodeClient;
    } catch (error) {
      throw new SoloError(`failed to setup node client: ${error.message}`, error);
    }
  }

  private async configureNodeAccess(
    networkNodeService: NetworkNodeServices,
    localPort: number,
    totalNodes: number,
  ): Promise<Record<SdkNetworkEndpoint, AccountId>> {
    this.logger.debug(`configuring node access for node: ${networkNodeService.nodeAlias}`);

    const port: number = +networkNodeService.haProxyGrpcPort;
    const accountId: AccountId = AccountId.fromString(networkNodeService.accountId as string);

    try {
      // if the load balancer IP is set, then we should use that and avoid the local host port forward
      if (!this.shouldUseLocalHostPortForward(networkNodeService)) {
        const host: string = networkNodeService.haProxyLoadBalancerIp as string;
        const endpoint: SdkNetworkEndpoint = `${host}:${port}`;
        this.logger.debug(`using load balancer IP: ${endpoint}`);

        try {
          const object: Record<SdkNetworkEndpoint, AccountId> = {[endpoint]: accountId};
          await this.sdkPingNetworkNode(object, accountId);
          this.logger.debug(`successfully pinged network node: ${endpoint}`);

          return object;
        } catch {
          // if the connection fails, then we should use the local host port forward
        }
      }
      // if the load balancer IP is not set or the test connection fails, then we should use the local host port forward
      const host: string = '127.0.0.1';
      const endpoint: SdkNetworkEndpoint = `${host}:${localPort}`;

      if (this._portForwards.length < totalNodes) {
        const portForward: number = await this.k8Factory
          .getK8(networkNodeService.context)
          .pods()
          .readByReference(PodReference.of(networkNodeService.namespace, networkNodeService.haProxyPodName))
          .portForward(localPort, port);
        this._portForwards.push(portForward);
        this.logger.debug(`using local host port forward: ${host}:${portForward}`);
      }

      const object: Record<SdkNetworkEndpoint, AccountId> = {[endpoint]: accountId};

      await this.testNodeClientConnection(object, accountId);

      return object;
    } catch (error) {
      throw new SoloError(`failed to configure node access: ${error.message}`, error);
    }
  }

  /**
   * pings the network node to ensure that the connection is working
   * @param object - the object containing the network node endpoint and account id
   * @param accountId - the account id to ping
   * @throws {@link SoloError} if the ping fails
   */
  private async testNodeClientConnection(
    object: Record<SdkNetworkEndpoint, AccountId>,
    accountId: AccountId,
  ): Promise<void> {
    const maxRetries: number = constants.NODE_CLIENT_SDK_PING_MAX_RETRIES;
    const sleepInterval: number = constants.NODE_CLIENT_SDK_PING_RETRY_INTERVAL;

    let currentRetry: number = 0;
    let success: boolean = false;

    try {
      while (!success && currentRetry < maxRetries) {
        try {
          this.logger.debug(
            `attempting to sdk ping network node: ${Object.keys(object)[0]}, attempt: ${currentRetry}, of ${maxRetries}`,
          );
          await this.sdkPingNetworkNode(object, accountId);
          success = true;

          return;
        } catch (error) {
          this.logger.error(`failed to sdk ping network node: ${Object.keys(object)[0]}, ${error.message}`);
          currentRetry++;
          await sleep(Duration.ofMillis(sleepInterval));
        }
      }
    } catch (error) {
      const message: string = `failed testing node client connection for network node: ${Object.keys(object)[0]}, after ${maxRetries} retries: ${error.message}`;
      throw new SoloError(message, error);
    }

    if (currentRetry >= maxRetries) {
      throw new SoloError(`failed to sdk ping network node: ${Object.keys(object)[0]}, after ${maxRetries} retries`);
    }

    return;
  }

  /**
   * Gets a Map of the Hedera node services and the attributes needed, throws a SoloError if anything fails
   * @param namespace - the namespace of the solo network deployment
   * @param clusterReferences - the cluster references to use for the services
   * @param deployment - the deployment to use
   * @returns a map of the network node services
   */
  public async getNodeServiceMap(
    namespace: NamespaceName,
    clusterReferences: ClusterReferences,
    deployment: DeploymentName,
  ): Promise<NodeServiceMapping> {
    const labelSelector: string = 'solo.hedera.com/node-name';

    const serviceBuilderMap: Map<NodeAlias, NetworkNodeServicesBuilder> = new Map();

    try {
      const services: SoloService[] = [];
      for (const [clusterReference, context] of clusterReferences) {
        const serviceList: Service[] = await this.k8Factory.getK8(context).services().list(namespace, [labelSelector]);
        services.push(
          ...serviceList.map(
            (service): SoloService => SoloService.getFromK8Service(service, clusterReference, context, deployment),
          ),
        );
      }

      // retrieve the list of services and build custom objects for the attributes we need
      for (const service of services) {
        let nodeId: NodeId;
        const clusterReference: ClusterReferenceName = service.clusterReference;

        let serviceBuilder: NetworkNodeServicesBuilder = new NetworkNodeServicesBuilder(
          service.metadata.labels['solo.hedera.com/node-name'] as NodeAlias,
        );

        if (serviceBuilderMap.has(serviceBuilder.key())) {
          serviceBuilder = serviceBuilderMap.get(serviceBuilder.key()) as NetworkNodeServicesBuilder;
        } else {
          serviceBuilder = new NetworkNodeServicesBuilder(
            service.metadata.labels['solo.hedera.com/node-name'] as NodeAlias,
          );
          serviceBuilder.withNamespace(namespace);
          serviceBuilder.withClusterRef(clusterReference);
          serviceBuilder.withContext(clusterReferences.get(clusterReference));
          serviceBuilder.withDeployment(deployment);
        }

        const serviceType: string = service.metadata.labels['solo.hedera.com/type'];
        switch (serviceType) {
          // solo.hedera.com/type: envoy-proxy-svc
          case 'envoy-proxy-svc': {
            serviceBuilder
              .withEnvoyProxyName(service.metadata.name)
              .withEnvoyProxyClusterIp(service.spec.clusterIP)
              .withEnvoyProxyLoadBalancerIp(
                service.status.loadBalancer.ingress ? service.status.loadBalancer.ingress[0].ip : undefined,
              )
              .withEnvoyProxyGrpcWebPort(
                service.spec!.ports!.find((port): boolean => port.name === 'hedera-grpc-web').port,
              );
            break;
          }
          // solo.hedera.com/type: haproxy-svc
          case 'haproxy-svc': {
            serviceBuilder
              .withHaProxyAppSelector(service.spec!.selector!.app)
              .withHaProxyName(service.metadata!.name)
              .withHaProxyClusterIp(service.spec!.clusterIP)
              .withHaProxyLoadBalancerIp(
                service.status.loadBalancer.ingress ? service.status.loadBalancer.ingress[0].ip : undefined,
              )
              .withHaProxyGrpcPort(
                service.spec!.ports!.find((port): boolean => port.name === 'non-tls-grpc-client-port').port,
              )
              .withHaProxyGrpcsPort(
                service.spec!.ports!.find((port): boolean => port.name === 'tls-grpc-client-port').port,
              );
            break;
          }
          // solo.hedera.com/type: network-node-svc
          case 'network-node-svc': {
            if (
              service.metadata!.labels!['solo.hedera.com/node-id'] !== '' &&
              Numbers.isNumeric(service.metadata!.labels!['solo.hedera.com/node-id'])
            ) {
              nodeId = +service.metadata!.labels!['solo.hedera.com/node-id'];
            } else {
              nodeId =
                +`${Templates.nodeIdFromNodeAlias(service.metadata.labels['solo.hedera.com/node-name'] as NodeAlias)}`;
              this.logger.warn(
                `received an incorrect node id of ${service.metadata!.labels!['solo.hedera.com/node-id']} for ` +
                  `${service.metadata.labels['solo.hedera.com/node-name']}`,
              );
            }

            serviceBuilder
              .withAccountId(service.metadata!.labels!['solo.hedera.com/account-id'])
              .withNodeServiceName(service.metadata.name)
              .withNodeServiceClusterIp(service.spec!.clusterIP)
              .withNodeServiceLoadBalancerIp(
                service.status.loadBalancer.ingress ? service.status.loadBalancer.ingress[0].ip : undefined,
              )
              .withNodeServiceGossipPort(service.spec!.ports!.find((port): boolean => port.name === 'gossip').port)
              .withNodeServiceGrpcPort(service.spec!.ports!.find((port): boolean => port.name === 'grpc-non-tls').port)
              .withNodeServiceGrpcsPort(service.spec!.ports!.find((port): boolean => port.name === 'grpc-tls').port);

            if (typeof nodeId === 'number') {
              serviceBuilder.withNodeId(+nodeId);
            }
            break;
          }
        }
        const consensusNode: ConsensusNode = this.remoteConfig
          .getConsensusNodes()
          .find((node): boolean => node.name === serviceBuilder.nodeAlias);

        const address: Address = await Address.getExternalAddress(
          consensusNode,
          this.k8Factory.getK8(serviceBuilder.context),
          0,
        );
        serviceBuilder.withExternalAddress(address.hostString());
        serviceBuilderMap.set(serviceBuilder.key(), serviceBuilder);
      }

      // get the pod name for the service to use with portForward if needed
      for (const serviceBuilder of serviceBuilderMap.values()) {
        const podList: Pod[] = await this.k8Factory
          .getK8(serviceBuilder.context)
          .pods()
          .list(namespace, [`app=${serviceBuilder.haProxyAppSelector}`]);
        serviceBuilder.withHaProxyPodName(podList[0].podReference.name);
      }

      for (const [_, context] of clusterReferences) {
        // get the pod name of the network node
        const pods: Pod[] = await this.k8Factory
          .getK8(context)
          .pods()
          .list(namespace, ['solo.hedera.com/type=network-node']);
        for (const pod of pods) {
          if (!pod.labels?.hasOwnProperty('solo.hedera.com/node-name')) {
            continue;
          }
          const podName: PodName = pod.podReference.name;
          const nodeAlias: NodeAlias = pod.labels!['solo.hedera.com/node-name'] as NodeAlias;
          const serviceBuilder: NetworkNodeServicesBuilder = serviceBuilderMap.get(
            nodeAlias,
          ) as NetworkNodeServicesBuilder;
          serviceBuilder.withNodePodName(podName);
        }
      }

      const serviceMap: Map<NodeAlias, NetworkNodeServices> = new Map();
      for (const networkNodeServicesBuilder of serviceBuilderMap.values()) {
        serviceMap.set(networkNodeServicesBuilder.key(), networkNodeServicesBuilder.build());
      }

      this.logger.debug('node services have been loaded');
      return serviceMap;
    } catch (error) {
      throw new SoloError(`failed to get node services: ${error.message}`, error);
    }
  }

  /**
   * updates a set of special accounts keys with a newly generated key and stores them in a Kubernetes secret
   * @param namespace the namespace of the nodes network
   * @param currentSet - the accounts to update
   * @param updateSecrets - whether to delete the secret prior to creating a new secret
   * @param resultTracker - an object to keep track of the results from the accounts that are being updated
   * @param deploymentName - the deployment name
   * @returns the updated resultTracker object
   */
  public async updateSpecialAccountsKeys(
    namespace: NamespaceName,
    currentSet: number[],
    updateSecrets: boolean,
    resultTracker: {
      skippedCount: number;
      rejectedCount: number;
      fulfilledCount: number;
    },
    deploymentName: DeploymentName,
  ): Promise<{skippedCount: number; rejectedCount: number; fulfilledCount: number}> {
    const genesisKey: PrivateKey = PrivateKey.fromStringED25519(constants.OPERATOR_KEY);
    const accountUpdatePromiseArray: any[] = [];

    for (const accountNumber of currentSet) {
      accountUpdatePromiseArray.push(
        this.updateAccountKeys(
          namespace,
          this.getAccountIdByNumber(deploymentName, accountNumber),
          genesisKey,
          updateSecrets,
        ),
      );
    }

    await Promise.allSettled(accountUpdatePromiseArray).then((results): void => {
      for (const result of results) {
        // @ts-expect-error - TS2339: to avoid type mismatch
        switch (result.value.status) {
          case REJECTED: {
            // @ts-expect-error - TS2339: to avoid type mismatch
            if (result.value.reason === REASON_SKIPPED) {
              resultTracker.skippedCount++;
            } else {
              // @ts-expect-error - TS2339: to avoid type mismatch
              this.logger.error(`REJECT: ${result.value.reason}: ${result.value.value}`);
              resultTracker.rejectedCount++;
            }
            break;
          }
          case FULFILLED: {
            resultTracker.fulfilledCount++;
            break;
          }
        }
      }
    });

    this.logger.debug(
      `Current counts: [fulfilled: ${resultTracker.fulfilledCount}, ` +
        `skipped: ${resultTracker.skippedCount}, ` +
        `rejected: ${resultTracker.rejectedCount}]`,
    );

    return resultTracker;
  }

  /**
   * update the account keys for a given account and store its new key in a Kubernetes secret
   * @param namespace - the namespace of the nodes network
   * @param accountId - the account that will get its keys updated
   * @param genesisKey - the genesis key to compare against
   * @param updateSecrets - whether to delete the secret before creating a new secret
   * @returns the result of the call
   */
  public async updateAccountKeys(
    namespace: NamespaceName,
    accountId: AccountId,
    genesisKey: PrivateKey,
    updateSecrets: boolean,
  ): Promise<{value: string; status: string} | {reason: string; value: string; status: string}> {
    let keys: Key[];
    try {
      keys = await this.getAccountKeys(accountId);
    } catch (error) {
      if (error instanceof MissingArgumentError) {
        throw error;
      }
      this.logger.error(
        `failed to get keys for accountId ${accountId.toString()}, e: ${error.toString()}\n  ${error.stack}`,
      );
      return {
        status: REJECTED,
        reason: REASON_FAILED_TO_GET_KEYS,
        value: accountId.toString(),
      };
    }

    if (!keys || !keys[0]) {
      return {
        status: REJECTED,
        reason: REASON_FAILED_TO_GET_KEYS,
        value: accountId.toString(),
      };
    }

    if (constants.GENESIS_PUBLIC_KEY.toString() !== keys[0].toString()) {
      this.logger.debug(`account ${accountId.toString()} can be skipped since it does not have a genesis key`);
      return {
        status: REJECTED,
        reason: REASON_SKIPPED,
        value: accountId.toString(),
      };
    }

    this.logger.debug(`updating account ${accountId.toString()} since it is using the genesis key`);

    const newPrivateKey: PrivateKey = PrivateKey.generateED25519();
    try {
      await this.createOrReplaceAccountKeySecret(newPrivateKey, accountId, updateSecrets, namespace);
    } catch (error) {
      this.logger.error(error.message, error);
      return {
        status: REJECTED,
        reason: REASON_FAILED_TO_CREATE_K8S_S_KEY,
        value: accountId.toString(),
      };
    }

    try {
      if (!(await this.sendAccountKeyUpdate(accountId, newPrivateKey, genesisKey))) {
        this.logger.error(`failed to update account keys for accountId ${accountId.toString()}`);
        return {
          status: REJECTED,
          reason: REASON_FAILED_TO_UPDATE_ACCOUNT,
          value: accountId.toString(),
        };
      }
    } catch (error) {
      this.logger.error(`failed to update account keys for accountId ${accountId.toString()}, e: ${error.toString()}`);
      return {
        status: REJECTED,
        reason: REASON_FAILED_TO_UPDATE_ACCOUNT,
        value: accountId.toString(),
      };
    }

    return {
      status: FULFILLED,
      value: accountId.toString(),
    };
  }

  /**
   * creates or replaces the Kubernetes secret for the account key
   * @param privateKey - the private key to store in the secret
   * @param accountId - the account id for which to create the secret
   * @param updateSecrets - whether to replace the secret if it exists
   * @param namespace - the namespace in which to create the secret
   */
  public async createOrReplaceAccountKeySecret(
    privateKey: PrivateKey,
    accountId: AccountId,
    updateSecrets: boolean,
    namespace: NamespaceName,
  ): Promise<void> {
    const data: {privateKey: string; publicKey: string} = {
      privateKey: Base64.encode(privateKey.toString()),
      publicKey: Base64.encode(privateKey.publicKey.toString()),
    };

    try {
      const contexts: Context[] = this.remoteConfig.getContexts();
      for (const context of contexts) {
        const secretName: string = Templates.renderAccountKeySecretName(accountId);
        const secretLabels: {'solo.hedera.com/account-id': string} =
          Templates.renderAccountKeySecretLabelObject(accountId);
        const secretType: SecretType.OPAQUE = SecretType.OPAQUE;

        const createdOrUpdated: boolean = await (updateSecrets
          ? this.k8Factory.getK8(context).secrets().replace(namespace, secretName, secretType, data, secretLabels)
          : this.k8Factory.getK8(context).secrets().create(namespace, secretName, secretType, data, secretLabels));

        if (!createdOrUpdated) {
          throw new SoloError(`failed to create secret for accountId ${accountId.toString()}`);
        }
      }
    } catch (error) {
      throw new SoloError(
        `failed to create secret for accountId ${accountId.toString()}, e: ${error.toString()}`,
        error,
      );
    }
  }

  /**
   * gets the account info from Hedera network
   * @param accountId - the account
   * @returns the private key of the account
   */
  public async accountInfoQuery(accountId: AccountId | string): Promise<AccountInfo> {
    if (!this._nodeClient) {
      throw new MissingArgumentError('node client is not initialized');
    }

    return await new AccountInfoQuery()
      .setAccountId(accountId)
      .setMaxAttempts(3)
      .setMaxBackoff(1000)
      .execute(this._nodeClient);
  }

  /**
   * gets the account private and public key from the Kubernetes secret from which it is stored
   * @param accountId - the account
   * @returns the private key of the account
   */
  public async getAccountKeys(accountId: AccountId | string): Promise<Key[]> {
    const accountInfo = await this.accountInfoQuery(accountId);

    let keys: Key[] = [];
    if (accountInfo.key instanceof KeyList) {
      keys = accountInfo.key.toArray();
    } else {
      keys.push(accountInfo.key);
    }

    return keys;
  }

  /**
   * send an account key update transaction to the network of nodes
   * @param accountId - the account that will get its keys updated
   * @param newPrivateKey - the new private key
   * @param oldPrivateKey - the genesis key that is the current key
   * @returns whether the update was successful
   */
  async sendAccountKeyUpdate(
    accountId: AccountId | string,
    newPrivateKey: PrivateKey | string,
    oldPrivateKey: PrivateKey | string,
  ): Promise<boolean> {
    if (typeof newPrivateKey === 'string') {
      newPrivateKey = PrivateKey.fromStringED25519(newPrivateKey);
    }

    if (typeof oldPrivateKey === 'string') {
      oldPrivateKey = PrivateKey.fromStringED25519(oldPrivateKey);
    }

    // Create the transaction to update the key on the account
    const transaction: any = new AccountUpdateTransaction()
      .setAccountId(accountId)
      .setKey(newPrivateKey.publicKey)
      .freezeWith(this._nodeClient);

    // Sign the transaction with the old key and new key
    let signedTransaction: any = await transaction.sign(oldPrivateKey);
    signedTransaction = await signedTransaction.sign(newPrivateKey);

    // SIgn the transaction with the client operator private key and submit to a Hedera network
    const txResponse: any = await signedTransaction.execute(this._nodeClient);

    // Request the receipt of the transaction
    const receipt: any = await txResponse.getReceipt(this._nodeClient);

    return receipt.status === Status.Success;
  }

  /**
   * creates a new Hedera account
   * @param namespace - the namespace to store the Kubernetes key secret into
   * @param privateKey - the private key of type PrivateKey
   * @param amount - the amount of HBAR to add to the account
   * @param [setAlias] - whether to set the alias of the account to the public key, requires the ed25519PrivateKey supplied to be ECDSA
   * @param context
   * @returns a custom object with the account information in it
   */
  async createNewAccount(
    namespace: NamespaceName,
    privateKey: PrivateKey,
    amount: number,
    setAlias: boolean = false,
    context: string,
  ): Promise<{accountId: string; privateKey: string; publicKey: string; balance: number; accountAlias?: string}> {
    const newAccountTransaction: any = new AccountCreateTransaction()
      .setKey(privateKey)
      .setInitialBalance(Hbar.from(amount, HbarUnit.Hbar));

    if (setAlias) {
      newAccountTransaction.setAlias(privateKey.publicKey.toEvmAddress());
    }

    const newAccountResponse: any = await newAccountTransaction.execute(this._nodeClient);

    // Get the new account ID
    const transactionReceipt: any = await newAccountResponse.getReceipt(this._nodeClient);
    const accountInfo: {
      accountId: string;
      privateKey: string;
      publicKey: string;
      balance: number;
      accountAlias?: string;
    } = {
      accountId: transactionReceipt.accountId!.toString(),
      privateKey: privateKey.toString(),
      publicKey: privateKey.publicKey.toString(),
      balance: amount,
    };

    // add the account alias if setAlias is true
    if (setAlias) {
      const accountId: string = accountInfo.accountId;
      const realm: any = transactionReceipt.accountId!.realm;
      const shard: any = transactionReceipt.accountId!.shard;
      const accountInfoQueryResult = await this.accountInfoQuery(accountId);
      accountInfo.accountAlias = entityId(shard, realm, accountInfoQueryResult.contractAccountId);
    }

    try {
      const accountSecretCreated: boolean = await this.k8Factory
        .getK8(context)
        .secrets()
        .createOrReplace(
          namespace,
          Templates.renderAccountKeySecretName(accountInfo.accountId),
          SecretType.OPAQUE,
          {
            privateKey: Base64.encode(accountInfo.privateKey),
            publicKey: Base64.encode(accountInfo.publicKey),
          },
          Templates.renderAccountKeySecretLabelObject(accountInfo.accountId),
        );

      if (!accountSecretCreated) {
        this.logger.error(
          `new account created [accountId=${accountInfo.accountId}, amount=${amount} HBAR, publicKey=${accountInfo.publicKey}, privateKey=${accountInfo.privateKey}] but failed to create secret in Kubernetes`,
        );

        throw new SoloError(
          `failed to create secret for accountId ${accountInfo.accountId.toString()}, keys were sent to log file`,
        );
      }
    } catch (error) {
      if (error instanceof SoloError) {
        throw error;
      }
      throw new SoloError(
        `failed to create secret for accountId ${accountInfo.accountId.toString()}, e: ${error.toString()}`,
        error,
      );
    }

    return accountInfo;
  }

  /**
   * transfer the specified amount of HBAR from one account to another
   * @param fromAccountId - the account to pull the HBAR from
   * @param toAccountId - the account to put the HBAR
   * @param hbarAmount - the amount of HBAR
   * @returns if the transaction was successfully posted
   */
  async transferAmount(
    fromAccountId: AccountId | string,
    toAccountId: AccountId | string,
    hbarAmount: number,
  ): Promise<boolean> {
    try {
      const transaction: any = new TransferTransaction()
        .addHbarTransfer(fromAccountId, new Hbar(-1 * hbarAmount))
        .addHbarTransfer(toAccountId, new Hbar(hbarAmount))
        .freezeWith(this._nodeClient);

      const txResponse: any = await transaction.execute(this._nodeClient);

      const receipt: any = await txResponse.getReceipt(this._nodeClient);

      this.logger.debug(
        `The transfer from account ${fromAccountId} to account ${toAccountId} for amount ${hbarAmount} was ${receipt.status.toString()} `,
      );

      return receipt.status === Status.Success;
    } catch (error) {
      throw new SoloError(`transfer amount failed with an error: ${error.toString()}`, error);
    }
  }

  /**
   * Fetch and prepare address book as a base64 string
   */
  async prepareAddressBookBase64(
    namespace: NamespaceName,
    clusterReferences: ClusterReferences,
    deployment: DeploymentName,
    operatorId: string,
    operatorKey: string,
    forcePortForward: boolean,
  ): Promise<string> {
    // fetch AddressBook
    await this.loadNodeClient(namespace, clusterReferences, deployment, forcePortForward);
    const client = this._nodeClient;

    if (operatorId && operatorKey) {
      client.setOperator(operatorId, operatorKey);
    }

    const realm: Realm = this.localConfig.configuration.realmForDeployment(deployment);
    const shard: Shard = this.localConfig.configuration.shardForDeployment(deployment);
    const query: FileContentsQuery = new FileContentsQuery().setFileId(
      new FileId(shard, realm, FileId.ADDRESS_BOOK.num),
    );
    return Buffer.from(await query.execute(client)).toString('base64');
  }

  public async getFileContents(
    namespace: NamespaceName,
    fileNumber: number,
    clusterReferences: ClusterReferences,
    deployment?: DeploymentName,
    forcePortForward?: boolean,
  ): Promise<string> {
    await this.loadNodeClient(namespace, clusterReferences, deployment, forcePortForward);
    const client = this._nodeClient;
    const realm: number | Long = this.localConfig.configuration.realmForDeployment(deployment);
    const shard: number | Long = this.localConfig.configuration.shardForDeployment(deployment);
    const fileId: any = FileId.fromString(entityId(shard, realm, fileNumber));
    const queryFees: any = new FileContentsQuery().setFileId(fileId);
    return Buffer.from(await queryFees.execute(client)).toString('hex');
  }

  /**
   * Build and prepare address book as a base64 string by reading gossip signing keys from the
   * local keys directory and node topology from RemoteConfig.
   * This method does not require Kubernetes services or secrets to exist yet, making it suitable
   * for use during simultaneous consensus node + mirror node deployment.
   * @param keysDirectory - path to the directory containing gossip key PEM files (e.g. ~/.solo/cache/keys)
   * @param deployment - deployment name, used to derive per-node account IDs
   */
  public async buildAddressBookBase64(keysDirectory: string, deployment: DeploymentName): Promise<string> {
    const consensusNodes: ConsensusNode[] = this.remoteConfig.getConsensusNodes();
    const nodeAliases: NodeAlias[] = consensusNodes.map((node: ConsensusNode): NodeAlias => node.name);
    const accountMap: Map<NodeAlias, string> = this.getNodeAccountMap(nodeAliases, deployment);

    const nodeAddresses: proto.INodeAddress[] = [];

    for (const consensusNode of consensusNodes) {
      const nodeAlias: NodeAlias = consensusNode.name;
      const accountIdString: string | undefined = accountMap.get(nodeAlias);
      if (!accountIdString || accountIdString === IGNORED_NODE_ACCOUNT_ID) {
        continue;
      }

      const accountId: AccountId = AccountId.fromString(accountIdString);

      // Use the pre-computed FQDN from ConsensusNode — always a cluster-internal domain name.
      const serviceEndpoint: proto.IServiceEndpoint = {
        domainName: consensusNode.fullyQualifiedDomainName,
        port: constants.GRPC_PORT,
      };

      // Read the gossip signing certificate from the local keys directory.
      // The mirror node importer uses the embedded public key to verify record file signatures.
      let rsaPubKeyHex: string | undefined;
      try {
        const pemFilePath: string = PathEx.join(keysDirectory, Templates.renderGossipPemPublicKeyFile(nodeAlias));
        const pemData: string = fs.readFileSync(pemFilePath, 'utf8');
        const cert: X509Certificate = new crypto.X509Certificate(pemData);
        const derBuffer: Buffer = cert.publicKey.export({type: 'spki', format: 'der'}) as Buffer;
        rsaPubKeyHex = derBuffer.toString('hex');
      } catch (error) {
        this.logger.warn(
          `Could not read gossip signing key for ${nodeAlias} from ${keysDirectory}: ${error.message}. ` +
            'Address book entry will have no RSA_PubKey; mirror node importer may fail signature verification.',
        );
      }

      nodeAddresses.push({
        nodeId: Long.fromNumber(consensusNode.nodeId),
        nodeAccountId: {
          shardNum: Long.fromNumber(Number(accountId.shard)),
          realmNum: Long.fromNumber(Number(accountId.realm)),
          accountNum: Long.fromNumber(Number(accountId.num)),
        },
        RSA_PubKey: rsaPubKeyHex,
        serviceEndpoint: [serviceEndpoint],
        description: nodeAlias,
      });
    }

    this.logger.debug(`Built local address book with ${nodeAddresses.length} nodes for deployment ${deployment}`);

    const addressBookBytes: Uint8Array = proto.NodeAddressBook.encode({nodeAddress: nodeAddresses}).finish();
    return Buffer.from(addressBookBytes).toString('base64');
  }

  /**
   * Pings the network node with a grpc call to ensure it is working, throws a SoloError if the ping fails
   * @param obj - the network node object where the key is the network endpoint and the value is the account id
   * @param accountId - the account id to ping
   * @throws {@link SoloError} if the ping fails
   */
  private async sdkPingNetworkNode(object: Record<SdkNetworkEndpoint, AccountId>, accountId: AccountId): Promise<void> {
    let nodeClient: Client;
    try {
      nodeClient = Client.fromConfig({network: object, scheduleNetworkUpdate: false});
      this.logger.debug(`sdk pinging network node: ${Object.keys(object)[0]}`);

      if (!constants.SKIP_NODE_PING) {
        await nodeClient.ping(accountId);
      }
      this.logger.debug(`sdk ping successful for network node: ${Object.keys(object)[0]}`);

      return;
    } catch (error) {
      throw new SoloError(`failed to sdk ping network node: ${Object.keys(object)[0]} ${error.message}`, error);
    } finally {
      if (nodeClient) {
        try {
          nodeClient.close();
        } catch {
          // continue if nodeClient.close() fails
        }
      }
    }
  }

  public getAccountIdByNumber(deployment: DeploymentName, number: number | Long): AccountId {
    const realm: number | Long = this.localConfig.configuration.realmForDeployment(deployment);
    const shard: number | Long = this.localConfig.configuration.shardForDeployment(deployment);
    return AccountId.fromString(entityId(shard, realm, number));
  }

  public getOperatorAccountId(deployment: DeploymentName): AccountId {
    return this.getAccountIdByNumber(deployment, Number.parseInt(constants.DEFAULT_OPERATOR_ID_NUMBER.toString()));
  }

  public getFreezeAccountId(deployment: DeploymentName): AccountId {
    return this.getAccountIdByNumber(deployment, Number.parseInt(constants.DEFAULT_FREEZE_ID_NUMBER.toString()));
  }

  public getTreasuryAccountId(deployment: DeploymentName): AccountId {
    return this.getAccountIdByNumber(deployment, constants.DEFAULT_TREASURY_ID_NUMBER);
  }

  public getStartAccountId(deployment: DeploymentName): AccountId {
    return this.getAccountIdByNumber(deployment, Number.parseInt(constants.DEFAULT_START_ID_NUMBER.toString()));
  }

  /**
   * Create a map of node aliases to account IDs
   * @param nodeAliases
   * @param deploymentName
   * @returns the map of node IDs to account IDs
   */
  public getNodeAccountMap(nodeAliases: NodeAliases, deploymentName: DeploymentName): Map<NodeAlias, string> {
    const accountMap: Map<NodeAlias, string> = new Map<NodeAlias, string>();
    const realm: Realm = this.localConfig.configuration.realmForDeployment(deploymentName);
    const shard: Shard = this.localConfig.configuration.shardForDeployment(deploymentName);
    const firstAccountId: AccountId = this.getStartAccountId(deploymentName);

    for (const nodeAlias of nodeAliases) {
      const nodeAccount: string = entityId(
        shard,
        realm,
        Long.fromNumber(Templates.nodeIdFromNodeAlias(nodeAlias)).add(firstAccountId.num),
      );
      accountMap.set(nodeAlias, nodeAccount);
    }
    return accountMap;
  }
}