feat: add timeout flag to network destroy command

examples/custom-network-config/Taskfile.yml

@@ -5,12 +5,12 @@ dotenv:
   - .env
 
 env:
-  SOLO_CHART_VERSION: v0.32.0
-  CONSENSUS_NODE_VERSION: v0.54.1
-  SOLO_NAMESPACE: solo-{{ env "USER" | replace "." "-" | trunc 63 }}
+  SOLO_CHART_VERSION: 0.34.0
+  CONSENSUS_NODE_VERSION: v0.56.0
+  SOLO_NAMESPACE: solo-{{ env "USER" | replace "." "-" | trunc 63 | default "test" }}
   SOLO_CLUSTER_SETUP_NAMESPACE: solo-setup
-  SOLO_NETWORK_SIZE: 7
   SOLO_CLUSTER_RELEASE_NAME: solo-cluster-setup
+  SOLO_NETWORK_SIZE: 7
   SOLO_CLUSTER_NAME: solo-cluster
   MIRROR_RELEASE_NAME: mirror
 

src/commands/flags.ts

@@ -22,8 +22,8 @@
 
 /**
  * Set flag from the flag option
  * @param y instance of yargs
  * @param commandFlags a set of command flags
  *
  */
 export function setCommandFlags (y: any, ...commandFlags: CommandFlag[]) {
@@ -319,6 +319,16 @@
   }
 }
 
+export const enableTimeout: CommandFlag = {
+  constName: 'enableTimeout',
+  name: 'enable-timeout',
+  definition: {
+    describe: 'enable time out for running a command',
+    defaultValue: false,
+    type: 'boolean'
+  }
+}
+
 export const tlsClusterIssuerType: CommandFlag = {
   constName: 'tlsClusterIssuerType',
   name: 'tls-cluster-issuer-type',
@@ -842,6 +852,7 @@
   ed25519PrivateKey,
   enableHederaExplorerTls,
   enablePrometheusSvcMonitor,
+  enableTimeout,
   endpointType,
   soloChartVersion,
   generateGossipKeys,

src/commands/network.ts

@@ -228,6 +228,33 @@
     return config
   }
 
+  async destroyTask (ctx: any, task: any) {
+    const self = this
+    task.title = `Uninstalling chart ${constants.SOLO_DEPLOYMENT_CHART}`
+    await self.chartManager.uninstall(ctx.config.namespace, constants.SOLO_DEPLOYMENT_CHART)
+
+    if (ctx.config.deletePvcs) {
+      const pvcs = await self.k8.listPvcsByNamespace(ctx.config.namespace)
+      task.title = `Deleting PVCs in namespace ${ctx.config.namespace}`
+      if (pvcs) {
+        for (const pvc of pvcs) {
+          await self.k8.deletePvc(pvc, ctx.config.namespace)
+        }
+      }
+    }
+
+    if (ctx.config.deleteSecrets) {
+      task.title = `Deleting secrets in namespace ${ctx.config.namespace}`
+      const secrets = await self.k8.listSecretsByNamespace(ctx.config.namespace)
+
+      if (secrets) {
+        for (const secret of secrets) {
+          await self.k8.deleteSecret(secret, ctx.config.namespace)
+        }
+      }
+    }
+  }
+
   /** Run helm install and deploy network components */
   async deploy (argv: any) {
     const self = this
@@ -437,9 +464,12 @@
         deletePvcs: boolean
         deleteSecrets: boolean
         namespace: string
+        enableTimeout: boolean
+        force: boolean
       }
+      checkTimeout: boolean
     }
-
+    let networkDestroySuccess = true
     const tasks = new Listr<Context>([
       {
         title: 'Initialize',
@@ -466,43 +496,35 @@
           ctx.config = {
             deletePvcs: self.configManager.getFlag<boolean>(flags.deletePvcs) as boolean,
             deleteSecrets: self.configManager.getFlag<boolean>(flags.deleteSecrets) as boolean,
-            namespace: self.configManager.getFlag<string>(flags.namespace) as string
+            namespace: self.configManager.getFlag<string>(flags.namespace) as string,
+            enableTimeout: self.configManager.getFlag<boolean>(flags.enableTimeout) as boolean,
+            force: self.configManager.getFlag<boolean>(flags.force) as boolean,
           }
 
           return ListrLease.newAcquireLeaseTask(lease, task)
         }
       },
       {
-        title: `Uninstall chart ${constants.SOLO_DEPLOYMENT_CHART}`,
-        task: async (ctx) => {
-          await self.chartManager.uninstall(ctx.config.namespace, constants.SOLO_DEPLOYMENT_CHART)
-        }
-      },
-      {
-        title: 'Delete PVCs',
-        task: async (ctx) => {
-          const pvcs = await self.k8.listPvcsByNamespace(ctx.config.namespace)
-
-          if (pvcs) {
-            for (const pvc of pvcs) {
-              await self.k8.deletePvc(pvc, ctx.config.namespace)
-            }
-          }
-        },
-        skip: (ctx) => !ctx.config.deletePvcs
-      },
-      {
-        title: 'Delete Secrets',
-        task: async (ctx) => {
-          const secrets = await self.k8.listSecretsByNamespace(ctx.config.namespace)
+        title: 'Running sub-tasks to destroy network',
+        task: async (ctx, task) => {
+          if (ctx.config.enableTimeout) {
+            const timeoutId = setTimeout(() => {
+              const message = `\n\nUnable to finish network destroy in ${constants.NETWORK_DESTROY_WAIT_TIMEOUT} seconds\n\n`
+              self.logger.error(message)
+              self.logger.showUser(chalk.red(message))
+              networkDestroySuccess = false
+              if (ctx.config.deletePvcs && ctx.config.deleteSecrets && ctx.config.force) {
+                self.k8.deleteNamespace(ctx.config.namespace)
+              }
+            }, constants.NETWORK_DESTROY_WAIT_TIMEOUT * 1000)
 
-          if (secrets) {
-            for (const secret of secrets) {
-              await self.k8.deleteSecret(secret, ctx.config.namespace)
-            }
+            await self.destroyTask(ctx, task)
+
+            clearTimeout(timeoutId)
+          } else {
+            await self.destroyTask(ctx, task)
           }
-        },
-        skip: (ctx) => !ctx.config.deleteSecrets
+        }
       }
     ], {
       concurrent: false,
@@ -517,7 +539,7 @@
       await lease.release()
     }
 
-    return true
+    return networkDestroySuccess
   }
 
   /** Run helm upgrade to refresh network components with new settings */
@@ -606,7 +628,8 @@
               flags.deletePvcs,
               flags.deleteSecrets,
               flags.force,
-              flags.namespace
+              flags.namespace,
+              flags.enableTimeout
             ),
             handler: (argv: any) => {
               networkCmd.logger.debug('==== Running \'network destroy\' ===')

src/core/constants.ts

@@ -178,6 +178,7 @@ export const RELAY_PODS_RUNNING_DELAY = +process.env.RELAY_PODS_RUNNING_DELAY ||
 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 NETWORK_DESTROY_WAIT_TIMEOUT = +process.env.NETWORK_DESTROY_WAIT_TIMEOUT || 120
 
 export const DEFAULT_LOCAL_CONFIG_FILE = 'local-config.yaml'
 export const IGNORED_NODE_ACCOUNT_ID = '0.0.0'