Revert "Broadcast cluster's disconnected state before stopping KubeAuthProxy (#4273)" (#4412)

This reverts commit 8081d35f9c.

src/main/__test__/cluster.test.ts

@@ -36,8 +36,6 @@ jest.mock("winston", () => ({
     label: jest.fn(),
     timestamp: jest.fn(),
     printf: jest.fn(),
-    padLevels: jest.fn(),
-    ms: jest.fn(),
   },
   createLogger: jest.fn().mockReturnValue(logger),
   transports: {
@@ -51,31 +49,12 @@ jest.mock("../context-handler");
 jest.mock("request");
 jest.mock("request-promise-native");
 
-jest.mock("electron", () => ({
-  app: {
-    getVersion: () => "99.99.99",
-    getName: () => "lens",
-    setName: jest.fn(),
-    setPath: jest.fn(),
-    getPath: () => "tmp",
-    getLocale: () => "en",
-    setLoginItemSettings: jest.fn(),
-  },
-  ipcMain: {
-    on: jest.fn(),
-    once: jest.fn(),
-    handle: jest.fn(),
-  },
-}));
-
 import { Console } from "console";
 import mockFs from "mock-fs";
-import { AppPaths } from "../../common/app-paths";
 import { Cluster } from "../cluster";
 import { Kubectl } from "../kubectl";
 
 console = new Console(process.stdout, process.stderr); // fix mockFS
-AppPaths.init();
 
 describe("create clusters", () => {
   beforeEach(() => {

src/main/catalog-sources/__test__/kubeconfig-sync.test.ts

@@ -42,7 +42,6 @@ jest.mock("electron", () => ({
   },
   ipcMain: {
     on: jest.fn(),
-    once: jest.fn(),
     handle: jest.fn(),
   },
 }));

src/main/cluster.ts

@@ -34,7 +34,7 @@ import { DetectorRegistry } from "./cluster-detectors/detector-registry";
 import plimit from "p-limit";
 import type { ClusterState, ClusterRefreshOptions, ClusterMetricsResourceType, ClusterId, ClusterMetadata, ClusterModel, ClusterPreferences, ClusterPrometheusPreferences, UpdateClusterModel, KubeAuthUpdate } from "../common/cluster-types";
 import { ClusterMetadataKey, initialNodeShellImage, ClusterStatus } from "../common/cluster-types";
-import { disposer, storedKubeConfigFolder, toJS } from "../common/utils";
+import { storedKubeConfigFolder, toJS } from "../common/utils";
 import type { Response } from "request";
 
 /**
@@ -53,7 +53,7 @@ export class Cluster implements ClusterModel, ClusterState {
    */
   public contextHandler: ContextHandler;
   protected kubeconfigManager: KubeconfigManager;
-  protected eventDisposers = disposer();
+  protected eventDisposers: Function[] = [];
   protected activated = false;
   private resourceAccessStatuses: Map<KubeApiResource, boolean> = new Map();
 
@@ -324,6 +324,15 @@ export class Cluster implements ClusterModel, ClusterState {
     this.getProxyKubeconfig();
   }
 
+  /**
+   * internal
+   */
+  protected unbindEvents() {
+    logger.info(`[CLUSTER]: unbind events`, this.getMeta());
+    this.eventDisposers.forEach(dispose => dispose());
+    this.eventDisposers.length = 0;
+  }
+
   /**
    * @param force force activation
    * @internal
@@ -386,13 +395,8 @@ export class Cluster implements ClusterModel, ClusterState {
    * @internal
    */
   @action disconnect() {
-    logger.info(`[CLUSTER]: disconnecting cluster`, { id: this.id });
-
-    ipcMain.once(`cluster:${this.id}:frame-removed`, () => {
-      this.contextHandler?.stopServer();
-    });
-
-    this.eventDisposers();
+    this.unbindEvents();
+    this.contextHandler?.stopServer();
     this.disconnected = true;
     this.online = false;
     this.accessible = false;
@@ -401,6 +405,7 @@ export class Cluster implements ClusterModel, ClusterState {
     this.allowedNamespaces = [];
     this.resourceAccessStatuses.clear();
     this.pushState();
+    logger.info(`[CLUSTER]: disconnect`, this.getMeta());
   }
 
   /**

src/main/kube-auth-proxy.ts

@@ -129,11 +129,11 @@ export class KubeAuthProxy {
     this.ready = false;
 
     if (this.proxyProcess) {
-      logger.info("[KUBE-AUTH]: stopping local proxy", { clusterId: this.cluster.id });
-      this.proxyProcess.kill();
+      logger.debug("[KUBE-AUTH]: stopping local proxy", this.cluster.getMeta());
       this.proxyProcess.removeAllListeners();
       this.proxyProcess.stderr.removeAllListeners();
       this.proxyProcess.stdout.removeAllListeners();
+      this.proxyProcess.kill();
       this.proxyProcess = null;
     }
   }