feat: add CLI base construct and validation command

Author: saitho

.gitignore

@@ -0,0 +1,2 @@
+cli
+.stackhead-cli.yml

README.md

@@ -0,0 +1,14 @@
+# StackHead CLI
+
+## Configuration file
+
+.stackhead-cli.yml in current directory or $HOME
+```yaml
+---
+ansible:
+  collection_path: /my/collection/path # optional
+software:
+  webserver: nginx
+  container: docker
+
+```

ansible/collection.go

@@ -0,0 +1,55 @@
+package ansible
+
+import (
+	"fmt"
+	"os"
+	"path/filepath"
+	"strings"
+
+	homedir "github.com/mitchellh/go-homedir"
+	"github.com/spf13/viper"
+)
+
+func GetCollectionDirs() ([]string, error) {
+	var customCollectionPath = viper.GetString("ansible.collection_path")
+	if customCollectionPath != "" {
+		absPath, err := filepath.Abs(customCollectionPath)
+		if err != nil {
+			return nil, err
+		}
+		return []string{absPath}, nil
+	}
+
+	homeDir, err := homedir.Dir()
+	if err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	}
+
+	var pathEnv = os.Getenv("COLLECTIONS_PATHS")
+	var pathList []string
+	if pathEnv == "" {
+		pathList = []string{homeDir + "/.ansible/collections/ansible_collections"}
+	} else {
+		pathList = strings.Split(pathEnv, ":")
+		if len(pathList) == 0 {
+			pathList = []string{homeDir + "/.ansible/collections/ansible_collections"}
+		}
+	}
+	return pathList, nil
+}
+
+func GetStackHeadCollectionLocation() (string, error) {
+	collectionDirs, err := GetCollectionDirs()
+	if err != nil {
+		return "", err
+	}
+	// Look for Ansible directory
+	for _, singlePath := range collectionDirs {
+		var installPath = filepath.Join(singlePath, "getstackhead", "stackhead")
+		if _, err := os.Stat(installPath); !os.IsNotExist(err) {
+			return installPath, nil
+		}
+	}
+	return "", fmt.Errorf("unable to find StackHead Ansible collection ")
+}

commands/init.go

@@ -0,0 +1,20 @@
+package commands
+
+import (
+	"github.com/spf13/cobra"
+
+	"github.com/getstackhead/stackhead/cli/commands/init"
+	"github.com/getstackhead/stackhead/cli/routines"
+)
+
+var Init = &cobra.Command{
+	Use:   "init",
+	Short: "Install StackHead dependencies according to configuration file",
+	Long: `init will install all required dependencies according to configuration file.
+If no configuration file exists, it will start a wizard to create one.`,
+	Run: func(cmd *cobra.Command, args []string) {
+
+		routines.RunTask(commands_init.InstallCollection...)
+		routines.RunTask(commands_init.InstallModules...)
+	},
+}

commands/init/install_collection.go

@@ -0,0 +1,46 @@
+package commands_init
+
+import (
+	"sync"
+
+	"github.com/getstackhead/stackhead/cli/ansible"
+	"github.com/getstackhead/stackhead/cli/routines"
+)
+
+func installCollection() error {
+	return routines.ExecAnsibleGalaxy(
+		"collection", "install", "git+https://github.com/getstackhead/stackhead.git",
+	)
+}
+
+func installCollectionDependencies() error {
+	collectionDir, err := ansible.GetStackHeadCollectionLocation()
+	if err != nil {
+		return err
+	}
+	return routines.ExecAnsibleGalaxy(
+		"install",
+		"-r", collectionDir+"/requirements/requirements.yml",
+	)
+}
+
+var InstallCollection = []routines.TaskOption{
+	routines.Text("Installing StackHead Ansible collection"),
+	routines.Execute(func(wg *sync.WaitGroup, result chan routines.TaskResult) {
+		defer wg.Done()
+
+		err := installCollection()
+		if err == nil {
+			err = installCollectionDependencies()
+		}
+
+		taskResult := routines.TaskResult{
+			Error: err != nil,
+		}
+		if err != nil {
+			taskResult.Message = err.Error()
+		}
+
+		result <- taskResult
+	}),
+}

commands/init/install_modules.go

@@ -0,0 +1,88 @@
+package commands_init
+
+import (
+	"fmt"
+	"github.com/spf13/viper"
+	"strings"
+	"sync"
+
+	"github.com/getstackhead/stackhead/cli/routines"
+	"github.com/getstackhead/stackhead/cli/stackhead"
+)
+
+func collectModules() []string {
+	var modules []string
+	var err error
+
+	var webserver = viper.GetString("modules.webserver")
+	if len(webserver) == 0 {
+		webserver = "getstackhead.stackhead_webserver_nginx"
+	}
+	webserver, err = stackhead.AutoCompleteModuleName(webserver, stackhead.ModuleWebserver)
+	if err != nil {
+		// error
+	}
+	modules = append(modules, webserver)
+
+	var container = viper.GetString("modules.container")
+	if len(container) == 0 {
+		container = "getstackhead.stackhead_container_docker"
+	}
+	container, err = stackhead.AutoCompleteModuleName(container, stackhead.ModuleContainer)
+	if err != nil {
+		// error
+	}
+
+	modules = append(modules, container)
+	return modules
+}
+
+func installStackHeadModules() error {
+	var modules = collectModules()
+
+	var wg sync.WaitGroup
+	wg.Add(len(modules))
+	allErrorsChan := make(chan routines.TaskResult, len(modules))
+	for _, moduleName := range modules {
+		go func(name string) {
+			defer wg.Done()
+			err := routines.ExecAnsibleGalaxy("install", name)
+			if err != nil {
+				allErrorsChan <- routines.TaskResult{
+					Name:    name,
+					Message: err.Error(),
+					Error:   true,
+				}
+			}
+		}(moduleName)
+	}
+	wg.Wait()
+	close(allErrorsChan)
+
+	if len(allErrorsChan) > 0 {
+		var readableErrors []string
+		for err := range allErrorsChan {
+			readableErrors = append(readableErrors, fmt.Sprintf("- %s: %s ", err.Name, err.Message))
+		}
+		return fmt.Errorf("The following errors occurred while installing StackHead modules:\n%s", strings.Join(readableErrors, "\n"))
+	}
+	return nil
+}
+
+var InstallModules = []routines.TaskOption{
+	routines.Text("Installing StackHead modules"),
+	routines.Execute(func(wg *sync.WaitGroup, result chan routines.TaskResult) {
+		defer wg.Done()
+
+		err := installStackHeadModules()
+
+		taskResult := routines.TaskResult{
+			Error: err != nil,
+		}
+		if err != nil {
+			taskResult.Message = err.Error()
+		}
+
+		result <- taskResult
+	}),
+}

commands/validate.go

@@ -0,0 +1,35 @@
+package commands
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/spf13/cobra"
+
+	"github.com/getstackhead/stackhead/cli/jsonschema"
+)
+
+var Validate = &cobra.Command{
+	Use:   "validate [path to project definition file]",
+	Short: "Validate a project definition file",
+	Long:  `validate is used to make sure your project definition file meets the StackHead project definition syntax.`,
+	Args:  cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		result, err := jsonschema.ValidateFile(args[0])
+
+		if err != nil {
+			panic(err.Error())
+		}
+
+		errorMessage := jsonschema.ShouldValidate(result)
+		if len(errorMessage) == 0 {
+			_, err = fmt.Fprintln(os.Stdout, "The project definition is valid")
+		} else {
+			_, err = fmt.Fprintln(os.Stderr, errorMessage)
+			os.Exit(1)
+		}
+		if err != nil {
+			panic(err.Error())
+		}
+	},
+}

go.mod

@@ -0,0 +1,13 @@
+module github.com/getstackhead/stackhead/cli
+
+go 1.13
+
+require (
+	github.com/briandowns/spinner v1.11.1
+	github.com/ghodss/yaml v1.0.0
+	github.com/mitchellh/go-homedir v1.1.0
+	github.com/smartystreets/goconvey v1.6.4
+	github.com/spf13/cobra v1.0.0
+	github.com/spf13/viper v1.7.1
+	github.com/xeipuuv/gojsonschema v1.2.0
+)