import "../common/cluster-ipc"; import type http from "http"; import { ipcMain } from "electron"; import { action, autorun, makeObservable, observable, reaction } from "mobx"; import { Singleton } from "../common/utils"; import { ClusterStore, getClusterIdFromHost } from "../common/cluster-store"; import { Cluster } from "./cluster"; import logger from "./logger"; import { apiKubePrefix } from "../common/vars"; import { CatalogEntity, catalogEntityRegistry } from "../common/catalog"; import { KubernetesCluster } from "../common/catalog-entities/kubernetes-cluster"; const clusterOwnerRef = "ClusterManager"; export class ClusterManager extends Singleton { catalogSource = observable.array([]); constructor(public readonly port: number) { super(); makeObservable(this); catalogEntityRegistry.addObservableSource("lens:kubernetes-clusters", this.catalogSource); // auto-init clusters reaction(() => ClusterStore.getInstance().enabledClustersList, (clusters) => { clusters.forEach((cluster) => { if (!cluster.initialized && !cluster.initializing) { logger.info(`[CLUSTER-MANAGER]: init cluster`, cluster.getMeta()); cluster.init(port); } }); }, { fireImmediately: true }); reaction(() => ClusterStore.getInstance().enabledClustersList, (enabledClusters) => { this.updateCatalogSource(enabledClusters); }, { fireImmediately: true }); reaction(() => catalogEntityRegistry.getItemsForApiKind("entity.k8slens.dev/v1alpha1", "KubernetesCluster"), (entities) => { this.syncClustersFromCatalog(entities); }); // auto-stop removed clusters autorun(() => { const removedClusters = Array.from(ClusterStore.getInstance().removedClusters.values()); if (removedClusters.length > 0) { const meta = removedClusters.map(cluster => cluster.getMeta()); logger.info(`[CLUSTER-MANAGER]: removing clusters`, meta); removedClusters.forEach(cluster => cluster.disconnect()); ClusterStore.getInstance().removedClusters.clear(); } }, { delay: 250 }); ipcMain.on("network:offline", () => { this.onNetworkOffline(); }); ipcMain.on("network:online", () => { this.onNetworkOnline(); }); } @action protected updateCatalogSource(clusters: Cluster[]) { this.catalogSource.replace(this.catalogSource.filter(entity => ( clusters.find((cluster) => entity.metadata.uid === cluster.id) ))); for (const cluster of clusters) { if (cluster.ownerRef) { continue; } const entityIndex = this.catalogSource.findIndex((entity) => entity.metadata.uid === cluster.id); const newEntity = catalogEntityFromCluster(cluster); if (entityIndex === -1) { this.catalogSource.push(newEntity); } else { const oldEntity = this.catalogSource[entityIndex]; newEntity.status.phase = cluster.disconnected ? "disconnected" : "connected"; newEntity.status.active = !cluster.disconnected; newEntity.metadata.labels = { ...newEntity.metadata.labels, ...oldEntity.metadata.labels }; this.catalogSource.splice(entityIndex, 1, newEntity); } } } @action syncClustersFromCatalog(entities: KubernetesCluster[]) { for (const entity of entities) { if (entity.metadata.source !== "local") { continue; } const cluster = ClusterStore.getInstance().getById(entity.metadata.uid); if (!cluster) { ClusterStore.getInstance().addCluster({ id: entity.metadata.uid, enabled: true, ownerRef: clusterOwnerRef, preferences: { clusterName: entity.metadata.name }, kubeConfigPath: entity.spec.kubeconfigPath, contextName: entity.spec.kubeconfigContext }); } else { cluster.enabled = true; cluster.ownerRef ||= clusterOwnerRef; cluster.preferences.clusterName = entity.metadata.name; cluster.kubeConfigPath = entity.spec.kubeconfigPath; cluster.contextName = entity.spec.kubeconfigContext; entity.status = { phase: cluster.disconnected ? "disconnected" : "connected", active: !cluster.disconnected }; } } } protected onNetworkOffline() { logger.info("[CLUSTER-MANAGER]: network is offline"); ClusterStore.getInstance().enabledClustersList.forEach((cluster) => { if (!cluster.disconnected) { cluster.online = false; cluster.accessible = false; cluster.refreshConnectionStatus().catch((e) => e); } }); } protected onNetworkOnline() { logger.info("[CLUSTER-MANAGER]: network is online"); ClusterStore.getInstance().enabledClustersList.forEach((cluster) => { if (!cluster.disconnected) { cluster.refreshConnectionStatus().catch((e) => e); } }); } stop() { ClusterStore.getInstance().clusters.forEach((cluster: Cluster) => { cluster.disconnect(); }); } getClusterForRequest(req: http.IncomingMessage): Cluster { let cluster: Cluster = null; // lens-server is connecting to 127.0.0.1:/ if (req.headers.host.startsWith("127.0.0.1")) { const clusterId = req.url.split("/")[1]; cluster = ClusterStore.getInstance().getById(clusterId); if (cluster) { // we need to swap path prefix so that request is proxied to kube api req.url = req.url.replace(`/${clusterId}`, apiKubePrefix); } } else if (req.headers["x-cluster-id"]) { cluster = ClusterStore.getInstance().getById(req.headers["x-cluster-id"].toString()); } else { const clusterId = getClusterIdFromHost(req.headers.host); cluster = ClusterStore.getInstance().getById(clusterId); } return cluster; } } export function catalogEntityFromCluster(cluster: Cluster) { return new KubernetesCluster({ metadata: { uid: cluster.id, name: cluster.name, source: "local", labels: { distro: cluster.distribution, } }, spec: { kubeconfigPath: cluster.kubeConfigPath, kubeconfigContext: cluster.contextName }, status: { phase: cluster.disconnected ? "disconnected" : "connected", reason: "", message: "", active: !cluster.disconnected } }); }