install openebs and admin console (#1577)

* install openebs

* f

* Make openebs addon install successfully (#1575)

* Install openebs addon

* add metadata and values yaml to addons2 pkg

* add namespace

* Install Admin Console as part of install2 (#1576)

* Install Admin Console as part of install2

* errors wrap

* updates

---------

Co-authored-by: Salah Al Saleh <[email protected]>

Author: marccampbell

cmd/installer/cli/install2.go

@@ -8,10 +8,12 @@ import (
 
 	k0sconfig "github.com/k0sproject/k0s/pkg/apis/k0s/v1beta1"
 	ecv1beta1 "github.com/replicatedhq/embedded-cluster/kinds/apis/v1beta1"
+	"github.com/replicatedhq/embedded-cluster/pkg/addons2"
 	"github.com/replicatedhq/embedded-cluster/pkg/configutils"
 	"github.com/replicatedhq/embedded-cluster/pkg/helpers"
 	"github.com/replicatedhq/embedded-cluster/pkg/k0s"
 	"github.com/replicatedhq/embedded-cluster/pkg/metrics"
+	"github.com/replicatedhq/embedded-cluster/pkg/netutils"
 	"github.com/replicatedhq/embedded-cluster/pkg/preflights"
 	"github.com/replicatedhq/embedded-cluster/pkg/prompts"
 	"github.com/replicatedhq/embedded-cluster/pkg/release"
@@ -183,14 +185,33 @@ func runInstall2(cmd *cobra.Command, args []string, name string, flags Install2C
 		return err
 	}
 
-	fmt.Printf("%#v\n", clusterConfig)
+	logrus.Debugf("installing addons")
+	if err := addons2.InstallAddons(cmd.Context(), addons2.InstallOptions{
+		ClusterConfig:    clusterConfig,
+		AdminConsolePwd:  flags.adminConsolePassword,
+		License:          flags.license,
+		LicenseFile:      flags.licenseFile,
+		AirgapBundle:     flags.airgapBundle,
+		Proxy:            flags.proxy,
+		PrivateCAs:       flags.privateCAs,
+		ConfigValuesFile: flags.configValues,
+		NetworkInterface: flags.networkInterface,
+	}); err != nil {
+		metrics.ReportApplyFinished(cmd.Context(), "", flags.license, err)
+		return err
+	}
 
 	logrus.Debugf("installing manager")
 	if err := installAndEnableManager(); err != nil {
 		metrics.ReportApplyFinished(cmd.Context(), "", flags.license, err)
 		return err
 	}
 
+	if err := printSuccessMessage(flags.license, flags.networkInterface); err != nil {
+		metrics.ReportApplyFinished(cmd.Context(), "", flags.license, err)
+		return err
+	}
+
 	return nil
 }
 
@@ -336,6 +357,42 @@ func installAndStartCluster(ctx context.Context, networkInterface string, airgap
 		return nil, err
 	}
 
+	// init the kubeconfig
+	os.Setenv("KUBECONFIG", runtimeconfig.PathToKubeConfig())
+
 	loading.Infof("Node installation finished!")
 	return cfg, nil
 }
+
+func printSuccessMessage(license *kotsv1beta1.License, networkInterface string) error {
+	adminConsoleURL := getAdminConsoleURL(networkInterface, runtimeconfig.AdminConsolePort())
+
+	successColor := "\033[32m"
+	colorReset := "\033[0m"
+	var successMessage string
+	if license != nil {
+		successMessage = fmt.Sprintf("Visit the Admin Console to configure and install %s: %s%s%s",
+			license.Spec.AppSlug, successColor, adminConsoleURL, colorReset,
+		)
+	} else {
+		successMessage = fmt.Sprintf("Visit the Admin Console to configure and install your application: %s%s%s",
+			successColor, adminConsoleURL, colorReset,
+		)
+	}
+	logrus.Info(successMessage)
+
+	return nil
+}
+
+func getAdminConsoleURL(networkInterface string, port int) string {
+	ipaddr := runtimeconfig.TryDiscoverPublicIP()
+	if ipaddr == "" {
+		var err error
+		ipaddr, err = netutils.FirstValidAddress(networkInterface)
+		if err != nil {
+			logrus.Errorf("unable to determine node IP address: %v", err)
+			ipaddr = "NODE-IP-ADDRESS"
+		}
+	}
+	return fmt.Sprintf("http://%s:%v", ipaddr, port)
+}

go.mod

@@ -48,6 +48,7 @@ require (
 	helm.sh/helm/v3 v3.16.3
 	k8s.io/api v0.31.3
 	k8s.io/apimachinery v0.31.3
+	k8s.io/cli-runtime v0.31.3
 	k8s.io/client-go v0.31.3
 	k8s.io/kubectl v0.31.3
 	k8s.io/utils v0.0.0-20240921022957-49e7df575cb6
@@ -296,7 +297,6 @@ require (
 	gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect
 	k8s.io/apiserver v0.31.3 // indirect
-	k8s.io/cli-runtime v0.31.3 // indirect
 	k8s.io/component-base v0.31.3 // indirect
 	k8s.io/kubelet v0.31.2 // indirect
 	k8s.io/metrics v0.31.3 // indirect

pkg/addons2/addons.go

@@ -1 +1,67 @@
 package addons2
+
+import (
+	"context"
+
+	k0sconfig "github.com/k0sproject/k0s/pkg/apis/k0s/v1beta1"
+	"github.com/pkg/errors"
+	ecv1beta1 "github.com/replicatedhq/embedded-cluster/kinds/apis/v1beta1"
+	"github.com/replicatedhq/embedded-cluster/pkg/addons2/adminconsole"
+	"github.com/replicatedhq/embedded-cluster/pkg/addons2/openebs"
+	"github.com/replicatedhq/embedded-cluster/pkg/addons2/types"
+	"github.com/replicatedhq/embedded-cluster/pkg/kubeutils"
+	"github.com/replicatedhq/embedded-cluster/pkg/spinner"
+	kotsv1beta1 "github.com/replicatedhq/kotskinds/apis/kots/v1beta1"
+)
+
+type InstallOptions struct {
+	ClusterConfig    *k0sconfig.ClusterConfig
+	AdminConsolePwd  string
+	License          *kotsv1beta1.License
+	LicenseFile      string
+	AirgapBundle     string
+	Proxy            *ecv1beta1.ProxySpec
+	PrivateCAs       []string
+	ConfigValuesFile string
+	NetworkInterface string
+}
+
+// this is a temp function that's much more specific than we actually need it to be
+// this is going to get us to working installs, and we refactor.
+// this is not configurable at all, it's not the way it needs to be in the product
+func InstallAddons(ctx context.Context, opts InstallOptions) error {
+	addsOns := []types.AddOn{
+		&openebs.OpenEBS{},
+		&adminconsole.AdminConsole{
+			Password:         opts.AdminConsolePwd,
+			License:          opts.License,
+			LicenseFile:      opts.LicenseFile,
+			AirgapBundle:     opts.AirgapBundle,
+			Proxy:            opts.Proxy,
+			PrivateCAs:       opts.PrivateCAs,
+			ConfigValuesFile: opts.ConfigValuesFile,
+			NetworkInterface: opts.NetworkInterface,
+		},
+	}
+
+	kcli, err := kubeutils.KubeClient()
+	if err != nil {
+		return errors.Wrap(err, "create kube client")
+	}
+
+	loading := spinner.Start()
+	defer loading.Close()
+
+	for _, addon := range addsOns {
+		loading.Infof("Installing %s addon", addon.Name())
+
+		if err := addon.Prepare(); err != nil {
+			return errors.Wrap(err, "prepare addon")
+		}
+		if err := addon.Install(ctx, kcli, loading); err != nil {
+			return errors.Wrap(err, "install addon")
+		}
+	}
+
+	return nil
+}

pkg/addons2/adminconsole/adminconsole.go

@@ -0,0 +1,55 @@
+package adminconsole
+
+import (
+	_ "embed"
+
+	"github.com/pkg/errors"
+	ecv1beta1 "github.com/replicatedhq/embedded-cluster/kinds/apis/v1beta1"
+	"github.com/replicatedhq/embedded-cluster/pkg/release"
+	"github.com/replicatedhq/embedded-cluster/pkg/runtimeconfig"
+	kotsv1beta1 "github.com/replicatedhq/kotskinds/apis/kots/v1beta1"
+	"gopkg.in/yaml.v3"
+)
+
+type AdminConsole struct {
+	Password         string
+	License          *kotsv1beta1.License
+	LicenseFile      string
+	AirgapBundle     string
+	IsHA             bool
+	Proxy            *ecv1beta1.ProxySpec
+	PrivateCAs       []string
+	ConfigValuesFile string
+	NetworkInterface string
+}
+
+const (
+	releaseName = "admin-console"
+	namespace   = runtimeconfig.KotsadmNamespace
+)
+
+var (
+	//go:embed static/values.tpl.yaml
+	rawvalues []byte
+	// helmValues is the unmarshal version of rawvalues.
+	helmValues map[string]interface{}
+	//go:embed static/metadata.yaml
+	rawmetadata []byte
+	// Metadata is the unmarshal version of rawmetadata.
+	Metadata release.AddonMetadata
+)
+
+func init() {
+	if err := yaml.Unmarshal(rawmetadata, &Metadata); err != nil {
+		panic(errors.Wrap(err, "unmarshal metadata"))
+	}
+	hv, err := release.RenderHelmValues(rawvalues, Metadata)
+	if err != nil {
+		panic(errors.Wrap(err, "unmarshal values"))
+	}
+	helmValues = hv
+}
+
+func (a *AdminConsole) Name() string {
+	return "Admin Console"
+}