application.go

package actions

import (
	"fmt"
	"github.com/AlexsJones/gravitywell/configuration"
	"github.com/AlexsJones/gravitywell/kinds"
	"github.com/AlexsJones/gravitywell/shared"
	"github.com/AlexsJones/gravitywell/vcs"
	logger "github.com/sirupsen/logrus"
	"gopkg.in/yaml.v2"
	"io/ioutil"
	"strings"
)

func ApplicationProcessor(commandFlag configuration.CommandFlag,
	opt configuration.Options, clusterName string, application kinds.Application) {

	executeDeployment(application, opt, clusterName, commandFlag)
}

func loadActionList(path string) kinds.ActionList {

	logger.Info(fmt.Sprintf("Loading %s", path))
	bytes, err := ioutil.ReadFile(path)
	if err != nil {
		logger.Error(err)
	}
	appc := kinds.ActionList{}
	err = yaml.Unmarshal(bytes, &appc)
	if err != nil {
		logger.Error(err)
	}
	return appc
}
func selectAndExecute(execute kinds.Execute, deployment kinds.Application, opt configuration.Options,
	clusterName string, commandFlag configuration.CommandFlag, repoName string) {

	if execute.Kind == "" {
		fmt.Printf(shared.PrettyPrint(deployment))
		logger.Fatalf(fmt.Sprintf("kind missing from execute block: (Check file indentation)[%s][%s]",
			deployment.VCS.Git, clusterName))
	}

	if execute.Configuration == nil {
		logger.Fatal("Configuration is missing within Execute block")
	}

	switch strings.ToLower(execute.Kind) {
	case "shell":
		ExecuteShellAction(execute, opt, repoName)

	case "kubernetes":
		ExecuteKubernetesAction(execute, clusterName, deployment, commandFlag, opt, repoName)

	case "runactionlist":
		tp, ok := execute.Configuration["Path"]
		if !ok {
			logger.Error("Could not find RunActionList Path")
			return
		}
		al := loadActionList(tp)

		executeActionList(al, deployment, opt, clusterName, commandFlag, repoName)
	}

}

func executeActionList(actionList kinds.ActionList, deployment kinds.Application, opt configuration.Options,
	clusterName string, commandFlag configuration.CommandFlag, remoteVCSRepoName string) {
	for _, a := range actionList.Executions {

		selectAndExecute(a, deployment, opt, clusterName, commandFlag, remoteVCSRepoName)
	}
}

func executeDeployment(deployment kinds.Application, opt configuration.Options,
	clusterName string, commandFlag configuration.CommandFlag) {
	logger.Info(fmt.Sprintf("Loading deployment %s\n", deployment.Name))

	remoteVCSRepoName, err := vcs.FetchRepo(deployment.VCS.Git, deployment.VCS.GitReference, opt)
	if err != nil {
		logger.Error(err.Error())

		return
	}

	executeActionList(deployment.ActionList, deployment, opt, clusterName, commandFlag, remoteVCSRepoName)
}