add-cluster page -- part 1

Signed-off-by: Roman <ixrock@gmail.com>

src/main/cluster-manager.ts

@@ -9,7 +9,7 @@ import { ClusterId, ClusterModel, clusterStore } from "../common/cluster-store"
 import { handleMessages } from "../common/ipc";
 import { ClusterIpcMessage } from "../common/ipc-messages";
 import { tracker } from "../common/tracker";
-import { validateConfig } from "./k8s";
+import { validateConfig } from "../common/kube-helpers";
 import { Cluster } from "./cluster"
 import { FeatureInstallRequest } from "./feature";
 import logger from "./logger"

src/main/cluster.ts

@@ -8,7 +8,7 @@ import { ContextHandler } from "./context-handler"
 import { AuthorizationV1Api, CoreV1Api, KubeConfig, V1ResourceAttributes } from "@kubernetes/client-node"
 import { Kubectl } from "./kubectl";
 import { KubeconfigManager } from "./kubeconfig-manager"
-import { getNodeWarningConditions, loadConfig, podHasIssues } from "./k8s"
+import { getNodeWarningConditions, loadConfig, podHasIssues } from "../common/kube-helpers"
 import { getFeatures, installFeature, uninstallFeature, upgradeFeature } from "./feature-manager";
 import request, { RequestPromiseOptions } from "request-promise-native"
 import logger from "./logger"

src/main/k8s.ts

@@ -1,138 +0,0 @@
-import { KubeConfig, V1Node, V1Pod } from "@kubernetes/client-node"
-import path from "path"
-import os from "os"
-import yaml from "js-yaml"
-import logger from "./logger";
-
-function resolveTilde(filePath: string) {
-  if (filePath[0] === "~" && (filePath[1] === "/" || filePath.length === 1)) {
-    return filePath.replace("~", os.homedir());
-  }
-  return filePath;
-}
-
-export function loadConfig(pathOrContent?: string): KubeConfig {
-  const kc = new KubeConfig();
-  if (path.isAbsolute(pathOrContent)) {
-    kc.loadFromFile(resolveTilde(pathOrContent));
-  } else {
-    kc.loadFromString(pathOrContent);
-  }
-  return kc
-}
-
-/**
- * KubeConfig is valid when there's at least one of each defined:
- * - User
- * - Cluster
- * - Context
- * @param config KubeConfig to check
- */
-export function validateConfig(config: KubeConfig | string): KubeConfig {
-  if (typeof config == "string") {
-    config = loadConfig(config);
-  }
-  logger.debug(`validating kube config: ${JSON.stringify(config)}`)
-  if (!config.users || config.users.length == 0) {
-    throw new Error("No users provided in config")
-  }
-  if (!config.clusters || config.clusters.length == 0) {
-    throw new Error("No clusters provided in config")
-  }
-  if (!config.contexts || config.contexts.length == 0) {
-    throw new Error("No contexts provided in config")
-  }
-
-  return config
-}
-
-/**
- * Breaks kube config into several configs. Each context as it own KubeConfig object
- */
-export function splitConfig(kubeConfig: KubeConfig): KubeConfig[] {
-  const configs: KubeConfig[] = []
-  if (!kubeConfig.contexts) {
-    return configs;
-  }
-  kubeConfig.contexts.forEach(ctx => {
-    const kc = new KubeConfig();
-    kc.clusters = [kubeConfig.getCluster(ctx.cluster)].filter(n => n);
-    kc.users = [kubeConfig.getUser(ctx.user)].filter(n => n)
-    kc.contexts = [kubeConfig.getContextObject(ctx.name)].filter(n => n)
-    kc.setCurrentContext(ctx.name);
-
-    configs.push(kc);
-  });
-  return configs;
-}
-
-export function dumpConfigYaml(kubeConfig: Partial<KubeConfig>): string {
-  const config = {
-    apiVersion: "v1",
-    kind: "Config",
-    preferences: {},
-    'current-context': kubeConfig.currentContext,
-    clusters: kubeConfig.clusters.map(cluster => {
-      return {
-        name: cluster.name,
-        cluster: {
-          'certificate-authority-data': cluster.caData,
-          'certificate-authority': cluster.caFile,
-          server: cluster.server,
-          'insecure-skip-tls-verify': cluster.skipTLSVerify
-        }
-      }
-    }),
-    contexts: kubeConfig.contexts.map(context => {
-      return {
-        name: context.name,
-        context: {
-          cluster: context.cluster,
-          user: context.user,
-          namespace: context.namespace
-        }
-      }
-    }),
-    users: kubeConfig.users.map(user => {
-      return {
-        name: user.name,
-        user: {
-          'client-certificate-data': user.certData,
-          'client-certificate': user.certFile,
-          'client-key-data': user.keyData,
-          'client-key': user.keyFile,
-          'auth-provider': user.authProvider,
-          exec: user.exec,
-          token: user.token,
-          username: user.username,
-          password: user.password
-        }
-      }
-    })
-  }
-
-  logger.debug("Dumping KubeConfig:", config);
-  // skipInvalid: true makes dump ignore undefined values
-  return yaml.safeDump(config, { skipInvalid: true });
-}
-
-export function podHasIssues(pod: V1Pod) {
-  // Logic adapted from dashboard
-  const notReady = !!pod.status.conditions.find(condition => {
-    return condition.type == "Ready" && condition.status !== "True"
-  });
-
-  return (
-    notReady ||
-    pod.status.phase !== "Running" ||
-    pod.spec.priority > 500000 // We're interested in high prio pods events regardless of their running status
-  )
-}
-
-// Logic adapted from dashboard
-// see: https://github.com/kontena/kontena-k8s-dashboard/blob/7d8f9cb678cc817a22dd1886c5e79415b212b9bf/client/api/endpoints/nodes.api.ts#L147
-export function getNodeWarningConditions(node: V1Node) {
-  return node.status.conditions.filter(c =>
-    c.status.toLowerCase() === "true" && c.type !== "Ready" && c.type !== "HostUpgrades"
-  )
-}

src/main/kubeconfig-manager.ts

@@ -4,7 +4,7 @@ import type { ContextHandler } from "./context-handler";
 import { app } from "electron"
 import path from "path"
 import fs from "fs-extra"
-import { dumpConfigYaml, loadConfig } from "./k8s"
+import { dumpConfigYaml, loadConfig } from "../common/kube-helpers"
 import logger from "./logger"
 
 export class KubeconfigManager {