hiero-ledger
diff --git a/‎.madgerc
Lines changed: 7 additions & 0 deletions b/‎.madgerc
Lines changed: 7 additions & 0 deletions
diff --git a/‎examples/performance-tuning/README.md b/‎examples/performance-tuning/README.md
diff --git a/‎src/commands/flags.ts
Lines changed: 2 additions & 0 deletions b/‎src/commands/flags.ts
Lines changed: 2 additions & 0 deletions
diff --git a/‎src/commands/network.ts
Lines changed: 33 additions & 22 deletions b/‎src/commands/network.ts
Lines changed: 33 additions & 22 deletions
diff --git a/‎src/commands/node/configs.ts
Lines changed: 2 additions & 2 deletions b/‎src/commands/node/configs.ts
Lines changed: 2 additions & 2 deletions
diff --git a/‎src/commands/node/tasks.ts
Lines changed: 2 additions & 1 deletion b/‎src/commands/node/tasks.ts
Lines changed: 2 additions & 1 deletion
diff --git a/‎src/core/constants.ts
Lines changed: 1 addition & 0 deletions b/‎src/core/constants.ts
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/core/genesis_network_models/genesis_network_data_constructor.ts
Lines changed: 86 additions & 0 deletions b/‎src/core/genesis_network_models/genesis_network_data_constructor.ts
Lines changed: 86 additions & 0 deletions
diff --git a/‎src/core/genesis_network_models/genesis_network_node_data_wrapper.ts
Lines changed: 69 additions & 0 deletions b/‎src/core/genesis_network_models/genesis_network_node_data_wrapper.ts
Lines changed: 69 additions & 0 deletions
diff --git a/‎src/core/helpers.ts
Lines changed: 5 additions & 5 deletions b/‎src/core/helpers.ts
Lines changed: 5 additions & 5 deletions
@@ -0,0 +1,7 @@
+{
+  "detectiveOptions": {
+    "ts": {
+      "skipTypeImports": true
+    }
+  }
+}
@@ -1645,6 +1645,7 @@ export class Flags {
     Flags.envoyIps,
     Flags.generateEcdsaKey,
     Flags.generateGossipKeys,
+    Flags.generateEcdsaKey,
     Flags.generateTlsKeys,
     Flags.gossipEndpoints,
     Flags.gossipPrivateKey,
@@ -1665,6 +1666,7 @@ export class Flags {
     Flags.namespace,
     Flags.newAccountNumber,
     Flags.newAdminKey,
+    Flags.createAmount,
     Flags.nodeAlias,
     Flags.nodeAliasesUnparsed,
     Flags.operatorId,
 
@@ -38,6 +38,7 @@ import {ConsensusNodeComponent} from '../core/config/remote/components/consensus
 import {ConsensusNodeStates} from '../core/config/remote/enumerations.js';
 import {EnvoyProxyComponent} from '../core/config/remote/components/envoy_proxy_component.js';
 import {HaProxyComponent} from '../core/config/remote/components/ha_proxy_component.js';
+import {GenesisNetworkDataConstructor} from '../core/genesis_network_models/genesis_network_data_constructor.js';
 
 export interface NetworkDeployConfigClass {
   applicationEnv: string;
@@ -61,6 +62,7 @@ export interface NetworkDeployConfigClass {
   grpcWebTlsCertificatePath: string;
   grpcTlsKeyPath: string;
   grpcWebTlsKeyPath: string;
+  genesisNetworkData: GenesisNetworkDataConstructor;
   getUnusedConfigs: () => string[];
   haproxyIps: string;
   envoyIps: string;
@@ -130,20 +132,19 @@ export class NetworkCommand extends BaseCommand {
     ];
   }
 
-  async prepareValuesArg(
-    config: {
-      chartDirectory?: string;
-      app?: string;
-      nodeAliases?: string[];
-      debugNodeAlias?: NodeAlias;
-      enablePrometheusSvcMonitor?: boolean;
-      releaseTag?: string;
-      persistentVolumeClaims?: string;
-      valuesFile?: string;
-      haproxyIpsParsed?: Record<NodeAlias, IP>;
-      envoyIpsParsed?: Record<NodeAlias, IP>;
-    } = {},
-  ) {
+  async prepareValuesArg(config: {
+    chartDirectory?: string;
+    app?: string;
+    nodeAliases: string[];
+    debugNodeAlias?: NodeAlias;
+    enablePrometheusSvcMonitor?: boolean;
+    releaseTag?: string;
+    persistentVolumeClaims?: string;
+    valuesFile?: string;
+    haproxyIpsParsed?: Record<NodeAlias, IP>;
+    envoyIpsParsed?: Record<NodeAlias, IP>;
+    genesisNetworkData: GenesisNetworkDataConstructor;
+  }) {
     let valuesArg = config.chartDirectory
       ? `-f ${path.join(config.chartDirectory, 'solo-deployment', 'values.yaml')}`
       : '';
@@ -160,7 +161,10 @@ export class NetworkCommand extends BaseCommand {
     }
 
     const profileName = this.configManager.getFlag<string>(flags.profileName) as string;
-    this.profileValuesFile = await this.profileManager.prepareValuesForSoloChart(profileName);
+    this.profileValuesFile = await this.profileManager.prepareValuesForSoloChart(
+      profileName,
+      config.genesisNetworkData,
+    );
     if (this.profileValuesFile) {
       valuesArg += this.prepareValuesFiles(this.profileValuesFile);
     }
@@ -172,7 +176,7 @@ export class NetworkCommand extends BaseCommand {
 
     // Iterate over each node and set static IPs for HAProxy
     if (config.haproxyIpsParsed) {
-      config.nodeAliases?.forEach((nodeAlias, index) => {
+      config.nodeAliases.forEach((nodeAlias, index) => {
         const ip = config.haproxyIpsParsed?.[nodeAlias];
 
         if (ip) valuesArg += ` --set "hedera.nodes[${index}].haproxyStaticIP=${ip}"`;
@@ -181,7 +185,7 @@ export class NetworkCommand extends BaseCommand {
 
     // Iterate over each node and set static IPs for Envoy Proxy
     if (config.envoyIpsParsed) {
-      config.nodeAliases?.forEach((nodeAlias, index) => {
+      config.nodeAliases.forEach((nodeAlias, index) => {
         const ip = config.envoyIpsParsed?.[nodeAlias];
 
         if (ip) valuesArg += ` --set "hedera.nodes[${index}].envoyProxyStaticIP=${ip}"`;
@@ -253,13 +257,19 @@ export class NetworkCommand extends BaseCommand {
       constants.SOLO_DEPLOYMENT_CHART,
     );
 
-    config.valuesArg = await this.prepareValuesArg(config);
-
     // compute other config parameters
     config.keysDir = path.join(validatePath(config.cacheDir), 'keys');
     config.stagingDir = Templates.renderStagingDir(config.cacheDir, config.releaseTag);
     config.stagingKeysDir = path.join(validatePath(config.stagingDir), 'keys');
 
+    config.genesisNetworkData = await GenesisNetworkDataConstructor.initialize(
+      config.nodeAliases,
+      this.keyManager,
+      config.keysDir,
+    );
+
+    config.valuesArg = await this.prepareValuesArg(config);
+
     if (!(await this.k8.hasNamespace(config.namespace))) {
       await this.k8.createNamespace(config.namespace);
     }
@@ -341,7 +351,7 @@ export class NetworkCommand extends BaseCommand {
         },
         {
           title: 'Check if cluster setup chart is installed',
-          task: async (ctx, task) => {
+          task: async () => {
             const isChartInstalled = await this.chartManager.isChartInstalled('', constants.SOLO_CLUSTER_SETUP_CHART);
             if (!isChartInstalled) {
               throw new SoloError(
@@ -386,7 +396,7 @@ export class NetworkCommand extends BaseCommand {
           task: (ctx, parentTask) => {
             const config = ctx.config;
 
-            // set up the sub-tasks
+            // set up the subtasks
             return parentTask.newListr(self.platformInstaller.copyNodeKeys(config.stagingDir, config.nodeAliases), {
               concurrent: true,
               rendererOptions: constants.LISTR_DEFAULT_RENDERER_OPTION,
@@ -502,7 +512,7 @@ export class NetworkCommand extends BaseCommand {
                 ),
             });
 
-            // set up the sub-tasks
+            // set up the subtasks
             return task.newListr(subTasks, {
               concurrent: false, // no need to run concurrently since if one node is up, the rest should be up by then
               rendererOptions: {
@@ -754,6 +764,7 @@ export class NetworkCommand extends BaseCommand {
       },
     };
   }
+
   /** Adds the consensus node, envoy and haproxy components to remote config.  */
   public addNodesAndProxies(): ListrTask<any, any, any> {
     return {
 
@@ -24,8 +24,8 @@ import path from 'path';
 import fs from 'fs';
 import {validatePath} from '../../core/helpers.js';
 import {Flags as flags} from '../flags.js';
-import {type NodeAlias, type NodeAliases, type PodName} from '../../types/aliases.js';
-import {type NetworkNodeServices} from '../../core/network_node_services.js';
+import type {NodeAlias, NodeAliases, PodName} from '../../types/aliases.js';
+import type {NetworkNodeServices} from '../../core/network_node_services.js';
 
 export const PREPARE_UPGRADE_CONFIGS_NAME = 'prepareUpgradeConfig';
 export const DOWNLOAD_GENERATED_FILES_CONFIGS_NAME = 'downloadGeneratedFilesConfig';
 
@@ -455,6 +455,7 @@ export class NodeCommandTasks {
    */
   _generateGossipKeys(generateMultiple: boolean) {
     const self = this;
+
     return new Task(
       'Generate gossip keys',
       (ctx: any, task: ListrTaskWrapper<any, any, any>) => {
@@ -701,7 +702,7 @@ export class NodeCommandTasks {
           config.stagingDir,
         );
 
-        // if directory data/upgrade/current/data/keys does not exist then use data/upgrade/current
+        // if directory data/upgrade/current/data/keys does not exist, then use data/upgrade/current
         let keyDir = `${constants.HEDERA_HAPI_PATH}/data/upgrade/current/data/keys`;
         if (!(await self.k8.hasDir(nodeFullyQualifiedPodName, constants.ROOT_CONTAINER, keyDir))) {
           keyDir = `${constants.HEDERA_HAPI_PATH}/data/upgrade/current`;
 
@@ -196,6 +196,7 @@ export const RELAY_PODS_RUNNING_MAX_ATTEMPTS = +process.env.RELAY_PODS_RUNNING_M
 export const RELAY_PODS_RUNNING_DELAY = +process.env.RELAY_PODS_RUNNING_DELAY || 1_000;
 export const RELAY_PODS_READY_MAX_ATTEMPTS = +process.env.RELAY_PODS_READY_MAX_ATTEMPTS || 100;
 export const RELAY_PODS_READY_DELAY = +process.env.RELAY_PODS_READY_DELAY || 1_000;
+export const GRPC_PORT = +process.env.GRPC_PORT || 50_211;
 
 export const NETWORK_DESTROY_WAIT_TIMEOUT = +process.env.NETWORK_DESTROY_WAIT_TIMEOUT || 120;
 
 
@@ -0,0 +1,86 @@
+/**
+ * Copyright (C) 2024 Hedera Hashgraph, LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the ""License"");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an ""AS IS"" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+import crypto from 'node:crypto';
+import {PrivateKey} from '@hashgraph/sdk';
+import {Templates} from '../templates.js';
+import {GenesisNetworkNodeDataWrapper} from './genesis_network_node_data_wrapper.js';
+import * as x509 from '@peculiar/x509';
+import * as constants from '../constants.js';
+
+import type {KeyManager} from '../key_manager.js';
+import type {ToJSON} from '../../types/index.js';
+import type {JsonString, NodeAlias, NodeAliases} from '../../types/aliases.js';
+
+/**
+ * Used to construct the nodes data and convert them to JSON
+ */
+export class GenesisNetworkDataConstructor implements ToJSON {
+  public readonly nodes: Record<NodeAlias, GenesisNetworkNodeDataWrapper> = {};
+
+  private constructor(
+    private readonly nodeAliases: NodeAliases,
+    private readonly keyManager: KeyManager,
+    private readonly keysDir: string,
+  ) {
+    nodeAliases.forEach((nodeAlias, nodeId) => {
+      // TODO: get nodeId from label in pod.
+      const adminPrivateKey = PrivateKey.fromStringED25519(constants.GENESIS_KEY);
+      const adminPubKey = adminPrivateKey.publicKey;
+
+      this.nodes[nodeAlias] = new GenesisNetworkNodeDataWrapper(nodeId, adminPubKey, nodeAlias);
+    });
+  }
+
+  public static async initialize(
+    nodeAliases: NodeAliases,
+    keyManager: KeyManager,
+    keysDir: string,
+  ): Promise<GenesisNetworkDataConstructor> {
+    const instance = new GenesisNetworkDataConstructor(nodeAliases, keyManager, keysDir);
+
+    await instance.load();
+
+    return instance;
+  }
+
+  /**
+   * Loads the gossipCaCertificate and grpcCertificateHash
+   */
+  private async load() {
+    await Promise.all(
+      this.nodeAliases.map(async nodeAlias => {
+        const nodeKeys = await this.keyManager.loadSigningKey(nodeAlias, this.keysDir);
+
+        //* Convert the certificate to PEM format
+        const certPem = nodeKeys.certificate.toString();
+
+        //* Assign the PEM certificate
+        this.nodes[nodeAlias].gossipCaCertificate = nodeKeys.certificate.toString('base64');
+
+        //* Decode the PEM to DER format
+        const tlsCertDer = new Uint8Array(x509.PemConverter.decode(certPem)[0]);
+
+        //* Generate the SHA-384 hash
+        this.nodes[nodeAlias].grpcCertificateHash = crypto.createHash('sha384').update(tlsCertDer).digest('base64');
+      }),
+    );
+  }
+
+  public toJSON(): JsonString {
+    return JSON.stringify({nodeMetadata: Object.values(this.nodes).map(node => node.toObject())});
+  }
+}
@@ -0,0 +1,69 @@
+/**
+ * Copyright (C) 2024 Hedera Hashgraph, LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the ""License"");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an ""AS IS"" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+import type {AccountId, PublicKey} from '@hashgraph/sdk';
+import type {GenesisNetworkNodeStructure, ServiceEndpoint, ToObject} from '../../types/index.js';
+
+export class GenesisNetworkNodeDataWrapper
+  implements GenesisNetworkNodeStructure, ToObject<{node: GenesisNetworkNodeStructure}>
+{
+  public accountId: AccountId;
+  public gossipEndpoint: ServiceEndpoint[] = [];
+  public serviceEndpoint: ServiceEndpoint[] = [];
+  public gossipCaCertificate: string;
+  public grpcCertificateHash: string;
+  public weight: number;
+  public readonly deleted = false;
+
+  constructor(
+    public readonly nodeId: number,
+    public readonly adminKey: PublicKey,
+    public readonly description: string,
+  ) {}
+
+  /**
+   * @param domainName - a fully qualified domain name
+   * @param port
+   */
+  public addServiceEndpoint(domainName: string, port: number): void {
+    this.serviceEndpoint.push({domainName, port, ipAddressV4: ''});
+  }
+
+  /**
+   * @param domainName - a fully qualified domain name
+   * @param port
+   */
+  public addGossipEndpoint(domainName: string, port: number): void {
+    this.gossipEndpoint.push({domainName, port, ipAddressV4: ''});
+  }
+
+  public toObject() {
+    return {
+      node: {
+        nodeId: this.nodeId,
+        accountId: this.accountId,
+        description: this.description,
+        gossipEndpoint: this.gossipEndpoint,
+        serviceEndpoint: this.serviceEndpoint,
+        gossipCaCertificate: this.gossipCaCertificate,
+        grpcCertificateHash: this.grpcCertificateHash,
+        weight: this.weight,
+        deleted: this.deleted,
+        adminKey: this.adminKey,
+      },
+    };
+  }
+}
@@ -27,6 +27,7 @@ import {type NodeAlias, type NodeAliases} from '../types/aliases.js';
 import {type CommandFlag} from '../types/flag_types.js';
 import {type SoloLogger} from './logging.js';
 import {type Duration} from './time/duration.js';
+import {type NodeAddConfigClass} from '../commands/node/configs.js';
 
 export function sleep(duration: Duration) {
   return new Promise<void>(resolve => {
@@ -241,13 +242,14 @@ export function addDebugOptions(valuesArg: string, debugNodeAlias: NodeAlias, in
 export function addSaveContextParser(ctx: any) {
   const exportedCtx = {} as Record<string, string>;
 
-  const config = /** @type {NodeAddConfigClass} **/ ctx.config;
+  const config = ctx.config as NodeAddConfigClass;
   const exportedFields = ['tlsCertHash', 'upgradeZipHash', 'newNode'];
 
   exportedCtx.signingCertDer = ctx.signingCertDer.toString();
   exportedCtx.gossipEndpoints = ctx.gossipEndpoints.map((ep: any) => `${ep.getDomainName}:${ep.getPort}`);
   exportedCtx.grpcServiceEndpoints = ctx.grpcServiceEndpoints.map((ep: any) => `${ep.getDomainName}:${ep.getPort}`);
   exportedCtx.adminKey = ctx.adminKey.toString();
+  // @ts-ignore
   exportedCtx.existingNodeAliases = config.existingNodeAliases;
 
   for (const prop of exportedFields) {
@@ -308,16 +310,14 @@ export function prepareEndpoints(endpointType: string, endpoints: string[], defa
     if (endpointType.toUpperCase() === constants.ENDPOINT_TYPE_IP) {
       ret.push(
         new ServiceEndpoint({
-          // @ts-ignore
-          port,
+          port: +port,
           ipAddressV4: parseIpAddressToUint8Array(url),
         }),
       );
     } else {
       ret.push(
         new ServiceEndpoint({
-          // @ts-ignore
-          port,
+          port: +port,
           domainName: url,
         }),
       );
-Original file line number
+Diff line change
@@ @@ -0,0 +1,7 @@ @@
 +{
 +  "detectiveOptions": {
 +    "ts": {
 +      "skipTypeImports": true
 +    }
 +  }
 +}