feat(cli): initial implementation of cluster commands

Signed-off-by: Lenin Mehedy <lenin.mehedy@swirldslabs.com>

fullstack-network-manager/resources/dev-cluster.yaml

@@ -0,0 +1,7 @@
+kind: Cluster
+apiVersion: kind.x-k8s.io/v1alpha4
+name: fst # this is overridden if CLUSTER_NAME env var is set. Check .env file
+nodes:
+  - role: control-plane
+    labels:
+      fullstack-scheduling.io/role: network

fullstack-network-manager/src/commands/base.mjs

@@ -1,6 +1,7 @@
 "use strict"
 import {exec} from "child_process";
 import * as core from "../core/index.mjs"
+import * as util from "util";
 
 export const BaseCommand = class BaseCommand {
     /**
@@ -93,16 +94,24 @@ export const BaseCommand = class BaseCommand {
      */
     runExec(cmd) {
         return new Promise((resolve, reject) => {
-            exec(cmd, (error, stdout, stderr) => {
+            exec(cmd, (error, stderr, stdout) => {
                 if (error) {
                     reject(error)
                 }
 
+                console.log(stderr)
+                console.log(stdout)
+
                 resolve(stdout)
             })
         })
     }
 
+    showUser(msg, ...args) {
+        console.log(util.format(msg, ...args))
+        this.logger.debug(msg, ...args)
+    }
+
     constructor(opts) {
         if (opts.logger === undefined) throw new Error("logger cannot be null")
 

fullstack-network-manager/src/commands/cluster.mjs

@@ -18,19 +18,48 @@ export const ClusterCommand = class extends BaseCommand {
     /**
      * Create a cluster
      * @param argv
-     * @returns {Promise<void>}
+     * @returns {Promise<boolean>}
      */
     async create(argv) {
-        this.logger.info("creating cluster '%s'", argv.name)
+        let cmd = `kind create cluster -n ${argv.name} --config ${core.constants.RESOURCES_DIR}/dev-cluster.yaml`
+
+        try {
+            this.showUser(`Invoking '${cmd}'...`)
+            let output = await this.runExec(cmd)
+            this.logger.debug(output)
+
+            this.showUser("Created cluster '%s'\n", argv.name)
+            output = await this.runExec(`kubectl cluster-info --context kind-${argv.name}`)
+            this.showUser(output)
+
+            return true
+        } catch (e) {
+            this.logger.error("%s", e)
+            this.showUser(e.message)
+        }
+
+        return false
     }
 
     /**
      * Delete a cluster
      * @param argv
-     * @returns {Promise<void>}
+     * @returns {Promise<boolean>}
      */
     async delete(argv) {
-        this.logger.info("deleting cluster '%s'", argv.name, {name: argv.name})
+        let cmd = `kind delete cluster -n ${argv.name}`
+        try {
+            this.showUser(`Invoking '${cmd}'...`)
+            let output = await this.runExec(cmd)
+            this.showUser(output)
+            this.showUser("Deleted cluster '%s' (if it existed)", argv.name)
+            return true
+        } catch (e) {
+            this.logger.error("%s", e.stack)
+            this.showUser(e.message)
+        }
+
+        return false
     }
 
     /**

fullstack-network-manager/src/core/logging.mjs

@@ -65,7 +65,8 @@ export function NewLogger(level = 'debug')  {
             // - Write all logs with importance level of `info` or less to `combined.log`
             //
             new winston.transports.File({filename: constants.TMP_DIR + "/logs/combined.log"}),
-            new winston.transports.File({filename: constants.TMP_DIR + "/logs/error.log", level: 'error'}),
+            // new winston.transports.File({filename: constants.TMP_DIR + "/logs/error.log", level: 'error'}),
+            // new winston.transports.Console({format: customFormat})
         ],
     });