From eb3b260cf5e19f9faf642be6251a4364a7d88a9e Mon Sep 17 00:00:00 2001 From: Sebastian Malton Date: Mon, 20 Jun 2022 14:46:20 -0400 Subject: [PATCH] Add behaviours for clsuter status screen Signed-off-by: Sebastian Malton --- .../cluster/connection-status.test.ts | 149 ++++++++++++++---- 1 file changed, 121 insertions(+), 28 deletions(-) diff --git a/src/features/cluster/connection-status.test.ts b/src/features/cluster/connection-status.test.ts index 50ecf67891..9b6ae357d4 100644 --- a/src/features/cluster/connection-status.test.ts +++ b/src/features/cluster/connection-status.test.ts @@ -8,6 +8,7 @@ import type { ClusterStore } from "../../common/cluster-store/cluster-store"; import clusterStoreInjectable from "../../common/cluster-store/cluster-store.injectable"; import type { ClusterId } from "../../common/cluster-types"; import type { Cluster } from "../../common/cluster/cluster"; +import type { NavigateToClusterView } from "../../common/front-end-routing/routes/cluster-view/navigate-to-cluster-view.injectable"; import navigateToClusterViewInjectable from "../../common/front-end-routing/routes/cluster-view/navigate-to-cluster-view.injectable"; import type { ReadFileSync } from "../../common/fs/read-file-sync.injectable"; import readFileSyncInjectable from "../../common/fs/read-file-sync.injectable"; @@ -19,8 +20,10 @@ describe("cluster connection status", () => { let clusterStore: ClusterStore; let clusters: Map; let cluster: Cluster; + let cluster2: Cluster; let applicationBuilder: ApplicationBuilder; let result: RenderResult; + let navigateToClusterView: NavigateToClusterView; beforeEach(async () => { applicationBuilder = getApplicationBuilder(); @@ -36,13 +39,22 @@ describe("cluster connection status", () => { server: "https://192.168.64.3:8443", }, }], - contexts: [{ - context: { - cluster: "minikube", - user: "minikube", + contexts: [ + { + context: { + cluster: "minikube", + user: "minikube", + }, + name: "minikube", }, - name: "minikube", - }], + { + context: { + cluster: "minikube", + user: "minikube", + }, + name: "minikube-2", + }, + ], users: [{ name: "minikube", }], @@ -53,32 +65,47 @@ describe("cluster connection status", () => { applicationBuilder.dis.rendererDi.override(readFileSyncInjectable, () => readFileSyncMock); - clusterStore = ({ - clusters, - get clustersList() { - return [...clusters.values()]; - }, - getById: (id) => clusters.get(id), - }) as ClusterStore; + applicationBuilder.beforeRender(() => { + clusterStore = ({ + clusters, + get clustersList() { + return [...clusters.values()]; + }, + getById: (id) => clusters.get(id), + }) as ClusterStore; - applicationBuilder.dis.mainDi.override(clusterStoreInjectable, () => clusterStore); - applicationBuilder.dis.rendererDi.override(clusterStoreInjectable, () => clusterStore); + applicationBuilder.dis.mainDi.override(clusterStoreInjectable, () => clusterStore); + applicationBuilder.dis.rendererDi.override(clusterStoreInjectable, () => clusterStore); - result = await applicationBuilder.render(); + navigateToClusterView = applicationBuilder.dis.rendererDi.inject(navigateToClusterViewInjectable); - const createCluster = applicationBuilder.dis.rendererDi.inject(createClusterInjectable); + const createCluster = applicationBuilder.dis.rendererDi.inject(createClusterInjectable); - cluster = createCluster({ - contextName: "minikube", - id: "some-cluster-id", - kubeConfigPath: "/some/file/path", - }, { - clusterServerUrl: "https://localhost:1234", + cluster = createCluster({ + contextName: "minikube", + id: "some-cluster-id", + kubeConfigPath: "/some/file/path", + }, { + clusterServerUrl: "https://localhost:1234", + }); + cluster.activate = jest.fn(); // override for test + + cluster2 = createCluster({ + contextName: "minikube-2", + id: "some-cluster-id", + kubeConfigPath: "/some/file/path", + }, { + clusterServerUrl: "https://localhost:1234", + }); + cluster2.activate = jest.fn(); // override for test + + clusters = new Map([ + [cluster.id, cluster], + [cluster2.id, cluster2], + ]); }); - clusters = new Map(); - - clusters.set(cluster.id, cluster); + result = await applicationBuilder.render(); }); it("renders", () => { @@ -87,8 +114,6 @@ describe("cluster connection status", () => { describe("when navigating to cluster connection", () => { beforeEach(() => { - const navigateToClusterView = applicationBuilder.dis.rendererDi.inject(navigateToClusterViewInjectable); - navigateToClusterView(cluster.id); }); @@ -99,5 +124,73 @@ describe("cluster connection status", () => { it("shows cluster status screen", () => { expect(result.queryByTestId("cluster-status")).not.toBeNull(); }); + + describe("when a connection update has been broadcast for first cluster", () => { + beforeEach(() => { + cluster.broadcastConnectUpdate("some-connection-update"); + }); + + it("shows connection update", async () => { + await result.findByText("some-connection-update"); + }); + + describe("when navigating to a different cluster", () => { + beforeEach(() => { + navigateToClusterView(cluster2.id); + }); + + it("renders", () => { + expect(result.baseElement).toMatchSnapshot(); + }); + + it("shows cluster status screen", () => { + expect(result.queryByTestId("cluster-status")).not.toBeNull(); + }); + + it("does not show connection update for first cluster", () => { + expect(result.queryByText("some-connection-update")).toBeNull(); + }); + + describe("when connection update has been broadcast for second cluster", () => { + beforeEach(() => { + cluster2.broadcastConnectUpdate("some-different-connection-update"); + }); + + it("shows connection update", async () => { + await result.findByText("some-different-connection-update"); + }); + + describe("when navigating back to first cluster", () => { + beforeEach(() => { + navigateToClusterView(cluster.id); + }); + + it("shows conncection update for first cluster", async () => { + await result.findByText("some-connection-update"); + }); + + describe("when second cluster connects", () => { + beforeEach(() => { + cluster2.disconnected = false; + }); + + it("shows conncection update for first cluster", async () => { + await result.findByText("some-connection-update"); + }); + + describe("when second cluster disconnects", () => { + beforeEach(() => { + cluster2.disconnected = false; + }); + + it("shows conncection update for first cluster", async () => { + await result.findByText("some-connection-update"); + }); + }); + }); + }); + }); + }); + }); }); });