embedded cluster upgrade modal

Makefile

@@ -68,7 +68,7 @@ gosec:
 
 .PHONY: mock
 mock:
-	go get github.com/golang/mock/[email protected]
+	go install github.com/golang/mock/[email protected]
 	mockgen -source=pkg/store/store_interface.go -destination=pkg/store/mock/mock.go
 	mockgen -source=pkg/handlers/interface.go -destination=pkg/handlers/mock/mock.go
 	mockgen -source=pkg/operator/client/client_interface.go -destination=pkg/operator/client/mock/mock.go

pkg/api/handlers/types/types.go

@@ -91,6 +91,11 @@ type ResponseGitOps struct {
 type ResponseCluster struct {
 	ID   string `json:"id"`
 	Slug string `json:"slug"`
+	// RequiresUpgrade represents whether the embedded cluster config for the current app
+	// version is different from the currently deployed embedded cluster config
+	RequiresUpgrade bool `json:"requiresUpgrade"`
+	// State represents the current state of the most recently deployed embedded cluster config
+	State string `json:"state,omitempty"`
 }
 
 type GetPendingAppResponse struct {

pkg/handlers/app.go

@@ -1,6 +1,7 @@
 package handlers
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"net/http"
@@ -13,8 +14,10 @@ import (
 	downstreamtypes "github.com/replicatedhq/kots/pkg/api/downstream/types"
 	"github.com/replicatedhq/kots/pkg/api/handlers/types"
 	apptypes "github.com/replicatedhq/kots/pkg/app/types"
+	"github.com/replicatedhq/kots/pkg/embeddedcluster"
 	"github.com/replicatedhq/kots/pkg/gitops"
 	"github.com/replicatedhq/kots/pkg/helm"
+	"github.com/replicatedhq/kots/pkg/k8sutil"
 	"github.com/replicatedhq/kots/pkg/kotsutil"
 	"github.com/replicatedhq/kots/pkg/logger"
 	"github.com/replicatedhq/kots/pkg/operator"
@@ -314,6 +317,36 @@ func responseAppFromApp(a *apptypes.App) (*types.ResponseApp, error) {
 		Slug: d.ClusterSlug,
 	}
 
+	clientset, err := k8sutil.GetClientset()
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to get clientset")
+	}
+
+	isEmbeddedCluster, err := embeddedcluster.IsEmbeddedCluster(clientset)
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to check if cluster is embedded")
+	}
+
+	if isEmbeddedCluster {
+		embeddedClusterConfig, err := store.GetStore().GetEmbeddedClusterConfigForVersion(a.ID, a.CurrentSequence)
+		if err != nil {
+			return nil, errors.Wrap(err, "failed to get embedded cluster config")
+		}
+
+		if embeddedClusterConfig != nil {
+			cluster.RequiresUpgrade, err = embeddedcluster.RequiresUpgrade(context.TODO(), embeddedClusterConfig.Spec)
+			if err != nil {
+				return nil, errors.Wrap(err, "failed to check if cluster requires upgrade")
+			}
+
+			embeddedClusterInstallation, err := embeddedcluster.GetCurrentInstallation(context.TODO())
+			if err != nil {
+				return nil, errors.Wrap(err, "failed to get current installation")
+			}
+			cluster.State = string(embeddedClusterInstallation.Status.State)
+		}
+	}
+
 	responseDownstream := types.ResponseDownstream{
 		Name:            d.Name,
 		Links:           links,

pkg/store/kotsstore/version_store.go

@@ -14,6 +14,7 @@ import (
 	"github.com/blang/semver"
 	"github.com/mholt/archiver/v3"
 	"github.com/pkg/errors"
+	embeddedclusterv1beta1 "github.com/replicatedhq/embedded-cluster-operator/api/v1beta1"
 	downstreamtypes "github.com/replicatedhq/kots/pkg/api/downstream/types"
 	versiontypes "github.com/replicatedhq/kots/pkg/api/version/types"
 	apptypes "github.com/replicatedhq/kots/pkg/app/types"
@@ -199,6 +200,37 @@ func (s *KOTSStore) GetTargetKotsVersionForVersion(appID string, sequence int64)
 	return kotsAppSpec.Spec.TargetKotsVersion, nil
 }
 
+func (s *KOTSStore) GetEmbeddedClusterConfigForVersion(appID string, sequence int64) (*embeddedclusterv1beta1.Config, error) {
+	db := persistence.MustGetDBSession()
+	query := `select embeddedcluster_config from app_version where app_id = ? and sequence = ?`
+	rows, err := db.QueryOneParameterized(gorqlite.ParameterizedStatement{
+		Query:     query,
+		Arguments: []interface{}{appID, sequence},
+	})
+	if err != nil {
+		return nil, fmt.Errorf("failed to query: %v: %v", err, rows.Err)
+	}
+	if !rows.Next() {
+		return nil, nil
+	}
+
+	var embeddedClusterSpecStr gorqlite.NullString
+	if err := rows.Scan(&embeddedClusterSpecStr); err != nil {
+		return nil, errors.Wrap(err, "failed to scan")
+	}
+
+	if embeddedClusterSpecStr.String == "" {
+		return nil, nil
+	}
+
+	embeddedClusterConfig, err := kotsutil.LoadEmbeddedClusterConfigFromBytes([]byte(embeddedClusterSpecStr.String))
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to load embedded cluster config from contents")
+	}
+
+	return embeddedClusterConfig, nil
+}
+
 // CreateAppVersion takes an unarchived app, makes an archive and then uploads it
 // to s3 with the appID and sequence specified
 func (s *KOTSStore) CreateAppVersionArchive(appID string, sequence int64, archivePath string) error {

pkg/store/store_interface.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"time"
 
+	embeddedclusterv1beta1 "github.com/replicatedhq/embedded-cluster-operator/api/v1beta1"
 	airgaptypes "github.com/replicatedhq/kots/pkg/airgap/types"
 	downstreamtypes "github.com/replicatedhq/kots/pkg/api/downstream/types"
 	versiontypes "github.com/replicatedhq/kots/pkg/api/version/types"
@@ -199,6 +200,7 @@ type VersionStore interface {
 	GetNextAppSequence(appID string) (int64, error)
 	GetCurrentUpdateCursor(appID string, channelID string) (string, error)
 	HasStrictPreflights(appID string, sequence int64) (bool, error)
+	GetEmbeddedClusterConfigForVersion(appID string, sequence int64) (*embeddedclusterv1beta1.Config, error)
 }
 
 type LicenseStore interface {