fix cluster upgrade modal not showing intermittently

pkg/api/handlers/types/types.go

@@ -97,6 +97,8 @@ type ResponseCluster struct {
 	RequiresUpgrade bool `json:"requiresUpgrade"`
 	// State represents the current state of the most recently deployed embedded cluster config
 	State string `json:"state,omitempty"`
+	// NumInstallations represents the number of installation objects in the cluster
+	NumInstallations int `json:"numInstallations"`
 }
 
 type GetPendingAppResponse struct {

pkg/embeddedcluster/util.go

@@ -60,6 +60,18 @@ func RequiresUpgrade(ctx context.Context, newcfg embeddedclusterv1beta1.ConfigSp
 
 // GetCurrentInstallation returns the most recent installation object from the cluster.
 func GetCurrentInstallation(ctx context.Context) (*embeddedclusterv1beta1.Installation, error) {
+	installations, err := ListInstallations(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to list installations: %w", err)
+	}
+	latest, err := GetLatestInstallation(ctx, installations)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get latest installation: %w", err)
+	}
+	return latest, nil
+}
+
+func ListInstallations(ctx context.Context) ([]embeddedclusterv1beta1.Installation, error) {
 	clientConfig, err := k8sutil.GetClusterConfig()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get cluster config: %w", err)
@@ -75,14 +87,17 @@ func GetCurrentInstallation(ctx context.Context) (*embeddedclusterv1beta1.Instal
 	if err != nil {
 		return nil, fmt.Errorf("failed to list installations: %w", err)
 	}
-	if len(installationList.Items) == 0 {
+	return installationList.Items, nil
+}
+
+func GetLatestInstallation(ctx context.Context, installations []embeddedclusterv1beta1.Installation) (*embeddedclusterv1beta1.Installation, error) {
+	if len(installations) == 0 {
 		return nil, ErrNoInstallations
 	}
-	items := installationList.Items
-	sort.SliceStable(items, func(i, j int) bool {
-		return items[j].CreationTimestamp.Before(&items[i].CreationTimestamp)
+	sort.SliceStable(installations, func(i, j int) bool {
+		return installations[j].CreationTimestamp.Before(&installations[i].CreationTimestamp)
 	})
-	return &installationList.Items[0], nil
+	return &installations[0], nil
 }
 
 // ClusterConfig will extract the current cluster configuration from the latest installation

pkg/handlers/app.go

@@ -341,11 +341,21 @@ func responseAppFromApp(a *apptypes.App) (*types.ResponseApp, error) {
 				return nil, errors.Wrap(err, "failed to check if cluster requires upgrade")
 			}
 
-			embeddedClusterInstallation, err := embeddedcluster.GetCurrentInstallation(context.TODO())
+			embeddedClusterInstallations, err := embeddedcluster.ListInstallations(context.TODO())
 			if err != nil {
-				return nil, errors.Wrap(err, "failed to get current installation")
+				return nil, errors.Wrap(err, "failed to list installations")
+			}
+
+			cluster.NumInstallations = len(embeddedClusterInstallations)
+
+			latestEmbeddedClusterInstallation, err := embeddedcluster.GetLatestInstallation(context.TODO(), embeddedClusterInstallations)
+			if err != nil {
+				return nil, errors.Wrap(err, "failed to get latest installation")
+			}
+
+			if latestEmbeddedClusterInstallation != nil {
+				cluster.State = string(latestEmbeddedClusterInstallation.Status.State)
 			}
-			cluster.State = string(embeddedClusterInstallation.Status.State)
 		}
 	}
 

web/src/utilities/utilities.js

@@ -672,11 +672,22 @@ export const Utilities = {
     }
   },
 
-  isClusterUpgrading(state) {
-    const normalizedState = this.clusterState(state);
-    return (
-      normalizedState === "Upgrading" || normalizedState === "Upgrading addons"
-    );
+  isClusterUpgrading(cluster) {
+    if (!cluster) {
+      return false;
+    }
+    const normalizedState = this.clusterState(cluster.state);
+    if (normalizedState === "Upgrading" || normalizedState === "Upgrading addons") {
+      return true;
+    }
+
+    if (cluster.numInstallations > 1 && !cluster.state) {
+      // if there multiple installations and no state, assume it's upgrading
+      // as it's possible the downtime begins before a state is reported
+      return true;
+    }
+
+    return false;
   },
 
   isPendingClusterUpgrade(app) {
@@ -696,7 +707,7 @@ export const Utilities = {
     // and the cluster will upgrade or is already upgrading
     return (
       app.downstream?.cluster?.requiresUpgrade ||
-      Utilities.isClusterUpgrading(app.downstream?.cluster?.state)
+      Utilities.isClusterUpgrading(app.downstream?.cluster)
     );
   },