dynatrace.go

package dynatrace

import (
	"fmt"
	"os"

	"github.com/openshift/osdctl/cmd/promote/utils"
	"github.com/spf13/cobra"
)

type promoteDynatraceOptions struct {
	list bool

	appInterfaceProvidedPath   string
	gitHash                    string
	component                  string
	terraform                  bool
	module                     string
	dynatraceConfigCheckoutDir string
}

// NewCmdDynatrace implements the promote command to promote services/operators
func NewCmdDynatrace() *cobra.Command {
	ops := &promoteDynatraceOptions{}
	promoteDynatraceCmd := &cobra.Command{
		Use:               "dynatrace",
		Short:             "Utilities to promote dynatrace",
		Args:              cobra.NoArgs,
		DisableAutoGenTag: true,
		Long: `Promote Dynatrace components or terraform modules.

DYNATRACE COMPONENTS:
  Components are defined in app-interface under:
    data/services/osd-operators/cicd/saas/saas-dynatrace/

  Each component maps to a specific path within the dynatrace-config repository.
  When promoting a component, only changes to that component's path are included
  in the promotion diff.

  Please run 'osdctl promote dynatrace --list' to check available dynatrace components for promotion & their corresponding paths.

TERRAFORM MODULES:
  Modules are defined in the dynatrace-config repository under:
    terraform/modules/

  Promoting a module updates configs in:
    terraform/redhat-aws/sd-sre/`,
		Example: `
		# List all Dynatrace components available for promotion
		osdctl promote dynatrace --list

		# Promote a dynatrace component
		osdctl promote dynatrace --component <component> --gitHash <git-hash>

		# List all dynatrace-config modules available for promotion
		osdctl promote dynatrace --terraform --list

		# Promote a dynatrace module
		osdctl promote dynatrace --terraform --module=<module-name>`,

		RunE: func(cmd *cobra.Command, args []string) error {

			if ops.terraform {
				dynatraceConfig := DynatraceConfigPromotion(ops.dynatraceConfigCheckoutDir)
				if ops.list {
					ops.validateSaasFlow()
					if ops.component != "" || ops.gitHash != "" || ops.module != "" {
						fmt.Printf("Error: Please provide correct parameters \n\n")
						fmt.Printf("Please run 'osdctl promote dynatrace --terraform --list' to check available dynatrace-config modules for promotion.\n\n")
						cmd.Help()
						os.Exit(1)
					}
					_ = listDynatraceModuleNames(dynatraceConfig)
					os.Exit(0)
				} else {
					if ops.module == "" {
						fmt.Printf("Error: Please provide correct parameters \n\n")
						fmt.Printf("Please run 'osdctl promote dynatrace --terraform --module=<module-name>' to check promote dynatrace-config module to latest ref.\n\n")
						cmd.Help()
						os.Exit(1)
					} else if ops.component != "" || ops.gitHash != "" {
						fmt.Printf("Error: Please provide correct parameters \n\n")
						fmt.Printf("Please run 'osdctl promote dynatrace --terraform --module=<module-name>' to check promote dynatrace-config module to latest ref.\n\n")
						cmd.Help()
						os.Exit(1)
					} else {
						err := modulePromotion(dynatraceConfig, ops.module)
						if err != nil {
							fmt.Printf("Error while promoting module: %v\n", err)
							os.Exit(1)
						}
					}
				}
			} else {
				ops.validateSaasFlow()

				appInterfaceClone, err := utils.FindAppInterfaceClone(ops.appInterfaceProvidedPath)
				if err != nil {
					return err
				}

				servicesRegistry, err := utils.NewServicesRegistry(
					appInterfaceClone,
					validateDynatraceServiceFilePath,
					saasDynatraceDir,
				)
				if err != nil {
					return err
				}

				if ops.list {
					if ops.component != "" || ops.gitHash != "" {
						fmt.Printf("Error: --list cannot be used with any other flags\n\n")
						cmd.Help()
						os.Exit(1)
					}
					_ = listServiceIds(servicesRegistry)
					os.Exit(0)
				}

				if ops.component == "" {
					fmt.Printf("Error: Please provide dynatrace component to promote.\n\n")
					fmt.Printf("Please run 'osdctl promote dynatrace --list' to check available dynatrace components for promotion.\n\n")
					cmd.Help()
					os.Exit(1)
				}

				service, err := servicesRegistry.GetService(ops.component)
				if err != nil {
					return err
				}
				err = service.Promote(&utils.DefaultPromoteCallbacks{Service: service}, ops.gitHash)

				if err != nil {
					fmt.Printf("Error while promoting service: %v\n", err)
					os.Exit(1)
				}
			}
			return nil
		},
	}

	promoteDynatraceCmd.Flags().BoolVarP(&ops.list, "list", "l", false, "List all SaaS services/operators")
	promoteDynatraceCmd.Flags().StringVarP(&ops.component, "component", "c", "", "Dynatrace component getting promoted")
	promoteDynatraceCmd.Flags().StringVarP(&ops.gitHash, "gitHash", "g", "", "Git hash of the SaaS service/operator commit getting promoted")
	promoteDynatraceCmd.Flags().StringVarP(&ops.appInterfaceProvidedPath, "appInterfaceDir", "", "", "location of app-interface checkout. Falls back to current working directory")
	promoteDynatraceCmd.Flags().BoolVarP(&ops.terraform, "terraform", "t", false, "deploy dynatrace-config terraform job")
	promoteDynatraceCmd.Flags().StringVarP(&ops.module, "module", "m", "", "module to promote")
	promoteDynatraceCmd.Flags().StringVarP(&ops.dynatraceConfigCheckoutDir, "dynatraceConfigDir", "", "", "location of dynatrace-config checkout. Falls back to current working directory")

	return promoteDynatraceCmd
}

func (o *promoteDynatraceOptions) validateSaasFlow() {
	if o.component == "" && o.gitHash == "" && !o.terraform {
		fmt.Printf("Usage: For dynatrace component, please provide --component and (optional) --gitHash\n")
		fmt.Printf("--component is the name of the component, i.e. dynatrace-dynakube\n")
		fmt.Printf("--gitHash is the target git commit for the dt component, if not specified defaults to HEAD of master\n\n")
		return
	}
}