AlexsJones/gravitywell

package actions

import (
    "fmt"
    "github.com/AlexsJones/gravitywell/configuration"
    "github.com/AlexsJones/gravitywell/kinds"
    "github.com/AlexsJones/gravitywell/platform"
    logger "github.com/sirupsen/logrus"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    "os"
    "path"
    "path/filepath"
    "strconv"
)

func clientForCluster(clusterName string) (*rest.Config, kubernetes.Interface) {
    logger.Info(fmt.Sprintf("\n\nSwitching to cluster: %s\n\n", clusterName))
    restclient, k8siface, err := platform.GetKubeClient(clusterName)
    if err != nil {
        logger.Error(err.Error())
        os.Exit(1)
    }
    return restclient, k8siface
}

func ExecuteKubernetesAction(action kinds.Execute, clusterName string,
    deployment kinds.Application,
    commandFlag configuration.CommandFlag, opt configuration.Options, repoName string) {
    var deploymentPath = "."
    shouldAwaitDeployment := false
    if tp, ok := action.Configuration["Path"]; ok && tp != "" {
        deploymentPath = tp
    }
    if tp, ok := action.Configuration["AwaitDeployment"]; ok && tp != "" {
        b, err := strconv.ParseBool(tp)
        if err != nil {
            logger.Error(err.Error())
        }
        shouldAwaitDeployment = b
    }

    fileList := []string{}
    err := filepath.Walk(path.Join(opt.TempVCSPath,
        repoName, deploymentPath),
        func(path string, f os.FileInfo, err error) error {
            if err != nil {
                return err
            }
            if f.IsDir() {
                logger.Info("Ignoring directory %s", fmt.Sprintf(path))
                return nil
            }
            fileList = append(fileList, path)
            return nil
        })
    if err != nil {
        logger.Fatal(err.Error())
    }

    _, k8siface := clientForCluster(clusterName)
    err = platform.GenerateDeploymentPlan(
        k8siface, fileList,
        deployment.Namespace, opt, commandFlag, shouldAwaitDeployment)
    if err != nil {
        logger.Error(err.Error())
    }
    //---------------------------------
}