AlexsJones/gravitywell

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)
}