wiring

Signed-off-by: instamenta <[email protected]>

Author: instamenta

src/commands/network.ts

@@ -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/models/genesisNetworkDataConstructor.js';
 
 export interface NetworkDeployConfigClass {
   applicationEnv: string;
@@ -61,7 +62,7 @@ export interface NetworkDeployConfigClass {
   grpcWebTlsCertificatePath: string;
   grpcTlsKeyPath: string;
   grpcWebTlsKeyPath: string;
-  genesisNetworkJson: string;
+  genesisNetworkData: GenesisNetworkDataConstructor;
   getUnusedConfigs: () => string[];
   haproxyIps: string;
   envoyIps: string;
@@ -135,16 +136,16 @@ export class NetworkCommand extends BaseCommand {
     config: {
       chartDirectory?: string;
       app?: string;
-      nodeAliases?: string[];
+      nodeAliases: string[];
       debugNodeAlias?: NodeAlias;
       enablePrometheusSvcMonitor?: boolean;
       releaseTag?: string;
       persistentVolumeClaims?: string;
       valuesFile?: string;
       haproxyIpsParsed?: Record<NodeAlias, IP>;
       envoyIpsParsed?: Record<NodeAlias, IP>;
-      genesisNetworkJson?: string;
-    } = {},
+      genesisNetworkData: GenesisNetworkDataConstructor;
+    }
   ) {
     let valuesArg = config.chartDirectory
       ? `-f ${path.join(config.chartDirectory, 'solo-deployment', 'values.yaml')}`
@@ -162,7 +163,7 @@ 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);
     }
@@ -179,7 +180,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}"`;
@@ -188,7 +189,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}"`;
@@ -199,7 +200,7 @@ export class NetworkCommand extends BaseCommand {
       valuesArg += this.prepareValuesFiles(config.valuesFile);
     }
 
-    valuesArg += `--set "hedera.configMaps.genesisNetworkJson=${config.genesisNetworkJson}"`
+    valuesArg += `--set "hedera.configMaps.genesisNetworkJson=${config.genesisNetworkData.toJSON()}"`
 
     this.logger.debug('Prepared helm chart values', {valuesArg});
     return valuesArg;
@@ -261,7 +262,7 @@ export class NetworkCommand extends BaseCommand {
       constants.SOLO_DEPLOYMENT_CHART,
     );
 
-    config.genesisNetworkJson = this.prepareGenesisNetworkJson(config)
+    config.genesisNetworkData = new GenesisNetworkDataConstructor(config.nodeAliases);
 
     config.valuesArg = await this.prepareValuesArg(config);
 

src/core/models/genesisNetworkDataConstructor.ts

@@ -21,12 +21,12 @@ import {KeyManager} from '../key_manager.js';
 
 import crypto from 'node:crypto';
 import {PrivateKey} from '@hashgraph/sdk';
-import {constants} from '../index.js';
+import * as constants from '../constants.js';
 
 export class GenesisNetworkDataConstructor {
   public readonly nodes: Record<NodeAlias, GenesisNetworkNodeDataWrapper>;
 
-  constructor (public readonly nodeAliases: NodeAliases) {
+  public constructor (public readonly nodeAliases: NodeAliases) {
     this.nodeAliases.forEach(nodeAlias => {
       this.nodes[nodeAlias] = new GenesisNetworkNodeDataWrapper(Templates.nodeIdFromNodeAlias(nodeAlias))
 
@@ -39,7 +39,7 @@ export class GenesisNetworkDataConstructor {
    * @param keyManager
    * @param keysDir - !!! config.keysDir !!!
    */
-  async load (keyManager: KeyManager, keysDir: string) {
+  public async load (keyManager: KeyManager, keysDir: string) {
     await Promise.all(this.nodeAliases.map(async nodeAlias => {
       const nodeKeys = await keyManager.loadSigningKey(nodeAlias, keysDir);
 
@@ -54,4 +54,8 @@ export class GenesisNetworkDataConstructor {
       this.nodes[nodeAlias].grpcCertificateHash = hash;
     }))
   }
+
+  public toJSON (): string {
+    return JSON.stringify(this.nodes);
+  }
 }

src/core/profile_manager.ts

@@ -171,7 +171,7 @@ export class ProfileManager {
     }
   }
 
-  resourcesForConsensusPod(profile: any, nodeAliases: NodeAliases, yamlRoot: object): object {
+  resourcesForConsensusPod(profile: any, nodeAliases: NodeAliases, yamlRoot: object, genesisNetworkData: GenesisNetworkDataConstructor): object {
     if (!profile) throw new MissingArgumentError('profile is required');
 
     const accountMap = getNodeAccountMap(nodeAliases);
@@ -198,6 +198,7 @@ export class ProfileManager {
       this.configManager.getFlag(flags.releaseTag),
       this.configManager.getFlag(flags.app),
       this.configManager.getFlag(flags.chainId),
+      genesisNetworkData
     );
 
     for (const flag of flags.nodeConfigFileFlags.values()) {
@@ -301,9 +302,10 @@ export class ProfileManager {
   /**
    * Prepare a values file for Solo Helm chart
    * @param profileName resource profile name
+   * @param genesisNetworkData
    * @returns return the full path to the values file
    */
-  prepareValuesForSoloChart(profileName: string) {
+  prepareValuesForSoloChart(profileName: string, genesisNetworkData: GenesisNetworkDataConstructor) {
     if (!profileName) throw new MissingArgumentError('profileName is required');
     const profile = this.getProfile(profileName);
 
@@ -312,7 +314,7 @@ export class ProfileManager {
 
     // generate the YAML
     const yamlRoot = {};
-    this.resourcesForConsensusPod(profile, nodeAliases, yamlRoot);
+    this.resourcesForConsensusPod(profile, nodeAliases, yamlRoot, genesisNetworkData);
     this.resourcesForHaProxyPod(profile, yamlRoot);
     this.resourcesForEnvoyProxyPod(profile, yamlRoot);
     this.resourcesForMinioTenantPod(profile, yamlRoot);