kanister_app.go

// Copyright (c) arkade author(s) 2022. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

package apps

import (
	"fmt"
	"log"

	"github.com/alexellis/arkade/pkg"
	"github.com/alexellis/arkade/pkg/apps"
	"github.com/alexellis/arkade/pkg/config"
	"github.com/alexellis/arkade/pkg/k8s"
	"github.com/alexellis/arkade/pkg/types"
	"github.com/spf13/cobra"
)

// MakeInstallKanister to be removed when k10 sponsored app
// expires.
func MakeInstallKanister() *cobra.Command {
	var kanisterApp = &cobra.Command{
		Use:          "kanister",
		Short:        "Install kanister for application-level data management",
		Long:         "Install kanister, an extensible open-source framework for application-level data management on Kubernetes",
		Example:      "arkade install kanister",
		SilenceUsage: true,
	}

	kanisterApp.Flags().StringP("namespace", "n", "default", "The namespace to install kanister (default: default")
	kanisterApp.Flags().Bool("update-repo", true, "Update the helm repo")
	kanisterApp.Flags().StringArray("set", []string{}, "Use custom flags or override existing flags \n(example --set image.tag=0.69.0)")

	kanisterApp.RunE = func(command *cobra.Command, args []string) error {
		kubeConfigPath, _ := command.Flags().GetString("kubeconfig")
		log.Println(kubeConfigPath)
		namespace, _ := kanisterApp.Flags().GetString("namespace")

		updateRepo, _ := kanisterApp.Flags().GetBool("update-repo")

		overrides := map[string]string{}

		customFlags, _ := command.Flags().GetStringArray("set")

		if err := config.MergeFlags(overrides, customFlags); err != nil {
			return err
		}

		arch := k8s.GetNodeArchitecture()
		fmt.Printf("Node architecture: %q\n", arch)

		if arch != IntelArch {
			return fmt.Errorf(OnlyIntelArch)
		}

		kanisterOptions := types.DefaultInstallOptions().
			WithNamespace(namespace).
			WithHelmRepo("kanister/kanister-operator").
			WithHelmURL("https://charts.kanister.io/").
			WithHelmUpdateRepo(updateRepo).
			WithOverrides(overrides).
			WithKubeconfigPath(kubeConfigPath)

		_, err := apps.MakeInstallChart(kanisterOptions)
		if err != nil {
			return err
		}

		println(KanisterInstallMsg)
		return nil
	}

	return kanisterApp
}

const KanisterInfoMsg = `# Get started with kanister here:
# https://kanister.io/

# See kanister docs here
# https://docs.kanister.io/install.html

# Download the Kanister CLI:

arkade get kanctl

# Once deployed use kanctl to create an S3 compliant kanister profile

kanctl create profile s3compliant --bucket $S3_BUCKET \
  --access-key $AWS_ACCESS_KEY_ID \
  --secret-key $AWS_SECRET_ACCESS_KEY \
  --region <region> \
  --namespace kanister

`

const KanisterInstallMsg = `=======================================================================
= kanister has been installed.                                   =
=======================================================================` +
	"\n\n" + KanisterInfoMsg + "\n\n" + pkg.SupportMessageShort