Add capability to make resource outputs nullable during diff phase

.github/workflows/build_and_deploy.yaml

@@ -135,6 +135,7 @@ jobs:
           './examples/local_exec',
           './examples/remote_exec',
           './examples/certificates',
+          './examples/terraform',
         ]
 
     steps:

.gitignore

@@ -3,4 +3,5 @@ bin/
 dist/
 .vscode
 .envrc
-.terraform
+.terraform
+.terraform.lock.hcl

cmd/dev.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/jumppad-labs/jumppad/cmd/view"
+	"github.com/jumppad-labs/jumppad/pkg/clients"
 	"github.com/jumppad-labs/jumppad/pkg/jumppad"
 	"github.com/jumppad-labs/jumppad/pkg/utils"
 	"github.com/spf13/cobra"
@@ -55,7 +56,11 @@ func newDevCmdFunc(variables *[]string, variablesFile, interval *string, ttyFlag
 			}
 		}
 
-		engine, _, _ = createEngine(v.Logger())
+		engineClients, _ := clients.GenerateClients(v.Logger())
+		engine, _, err := createEngine(v.Logger(), engineClients)
+		if err != nil {
+			return fmt.Errorf("unable to create engine: %s", err)
+		}
 
 		// create the shipyard and sub folders in the users home directory
 		utils.CreateFolders()

cmd/down.go

@@ -3,6 +3,7 @@ package cmd
 import (
 	"os"
 
+	"github.com/jumppad-labs/jumppad/pkg/clients"
 	"github.com/jumppad-labs/jumppad/pkg/clients/connector"
 	"github.com/jumppad-labs/jumppad/pkg/utils"
 	"github.com/spf13/cobra"
@@ -15,25 +16,31 @@ func newDestroyCmd(cc connector.Connector) *cobra.Command {
 		Long:    "Remove all resources in the current state",
 		Example: `jumppad down`,
 		Run: func(cmd *cobra.Command, args []string) {
-			err := engine.Destroy()
+			l := createLogger()
+			engineClients, _ := clients.GenerateClients(l)
+			engine, _, err := createEngine(l, engineClients)
+			if err != nil {
+				l.Error("Unable to create engine", "error", err)
+				return
+			}
+
+			err = engine.Destroy()
 			logger := createLogger()
 
 			if err != nil {
-				logger.Error("Unable to destroy stack", "error", err)
+				l.Error("Unable to destroy stack", "error", err)
 				return
 			}
 
-			// clean up the data folder
-			os.RemoveAll(utils.GetDataFolder("", os.ModePerm))
-
-			// clean up the library folder
-			os.RemoveAll(utils.GetLibraryFolder("", os.ModePerm))
+			// clean up the data folders
+			os.RemoveAll(utils.DataFolder("", os.ModePerm))
+			os.RemoveAll(utils.LibraryFolder("", os.ModePerm))
 
 			// shutdown ingress when we destroy all resources
 			if cc.IsRunning() {
 				err = cc.Stop()
 				if err != nil {
-					logger.Error("Unable to destroy stack", "error", err)
+					logger.Error("Unable to destroy jumppad daemon", "error", err)
 				}
 			}
 		},

cmd/purge.go

@@ -75,15 +75,15 @@ func newPurgeCmdFunc(dt container.Docker, il images.ImageLog, l logger.Logger) f
 			bHasError = true
 		}
 
-		hcp := utils.GetBlueprintLocalFolder("")
+		hcp := utils.BlueprintLocalFolder("")
 		l.Info("Removing cached blueprints", "path", hcp)
 		err = os.RemoveAll(hcp)
 		if err != nil {
 			l.Error("Unable to remove cached blueprints", "error", err)
 			bHasError = true
 		}
 
-		bcp := utils.GetHelmLocalFolder("")
+		bcp := utils.HelmLocalFolder("")
 		l.Info("Removing cached Helm charts", "path", bcp)
 		err = os.RemoveAll(bcp)
 		if err != nil {
@@ -92,22 +92,30 @@ func newPurgeCmdFunc(dt container.Docker, il images.ImageLog, l logger.Logger) f
 		}
 
 		// delete the releases
-		rcp := utils.GetReleasesFolder()
+		rcp := utils.ReleasesFolder()
 		l.Info("Removing cached releases", "path", rcp)
 		err = os.RemoveAll(rcp)
 		if err != nil {
 			l.Error("Unable to remove cached Releases", "error", err)
 			bHasError = true
 		}
 
-		dcp := utils.GetDataFolder("", os.ModePerm)
+		dcp := utils.DataFolder("", os.ModePerm)
 		l.Info("Removing data folders", "path", dcp)
 		err = os.RemoveAll(dcp)
 		if err != nil {
 			l.Error("Unable to remove data folder", "error", err)
 			bHasError = true
 		}
 
+		ccp := utils.DataFolder("", os.ModePerm)
+		l.Info("Removing cache folders", "path", ccp)
+		err = os.RemoveAll(ccp)
+		if err != nil {
+			l.Error("Unable to remove cache folder", "error", err)
+			bHasError = true
+		}
+
 		cp := path.Join(utils.JumppadHome(), "config")
 		l.Info("Removing config", "path", cp)
 		err = os.RemoveAll(cp)

cmd/root.go

@@ -23,65 +23,23 @@ var rootCmd = &cobra.Command{
 	Long:  `Jumppad is a tool that helps you create and run development, demo, and tutorial environments`,
 }
 
-var engine jumppad.Engine
-var l logger.Logger
-var engineClients *clients.Clients
-
 var version string // set by build process
 var date string    // set by build process
 var commit string  // set by build process
 
-func init() {
-
-	var vm gvm.Versions
-
-	// setup dependencies
-	l = createLogger()
-	engine, engineClients, vm = createEngine(l)
-
-	rootCmd.AddCommand(checkCmd)
-	rootCmd.AddCommand(outputCmd)
-	rootCmd.AddCommand(newDevCmd())
-	rootCmd.AddCommand(newEnvCmd(engine))
-	rootCmd.AddCommand(newRunCmd(engine, engineClients.ContainerTasks, engineClients.Getter, engineClients.HTTP, engineClients.Browser, vm, engineClients.Connector, l))
-	rootCmd.AddCommand(newTestCmd())
-	rootCmd.AddCommand(newDestroyCmd(engineClients.Connector))
-	rootCmd.AddCommand(statusCmd)
-	rootCmd.AddCommand(newPurgeCmd(engineClients.Docker, engineClients.ImageLog, l))
-	rootCmd.AddCommand(taintCmd)
-	rootCmd.AddCommand(newVersionCmd(vm))
-	rootCmd.AddCommand(uninstallCmd)
-	rootCmd.AddCommand(newPushCmd(engineClients.ContainerTasks, engineClients.Kubernetes, engineClients.HTTP, engineClients.Nomad, l))
-	rootCmd.AddCommand(newLogCmd(engine, engineClients.Docker, os.Stdout, os.Stderr), completionCmd)
-
-	// add the server commands
-	rootCmd.AddCommand(connectorCmd)
-	connectorCmd.AddCommand(newConnectorRunCommand())
-	connectorCmd.AddCommand(connectorStopCmd)
-	connectorCmd.AddCommand(newConnectorCertCmd())
+func createEngine(l logger.Logger, c *clients.Clients) (jumppad.Engine, gvm.Versions, error) {
 
-	// add the generate command
-	rootCmd.AddCommand(generateCmd)
-	generateCmd.AddCommand(newGenerateReadmeCommand(engine))
-}
-
-func createEngine(l logger.Logger) (jumppad.Engine, *clients.Clients, gvm.Versions) {
-	engineClients, err := clients.GenerateClients(l)
-	if err != nil {
-		return nil, nil, nil
-	}
-
-	providers := config.NewProviders(engineClients)
+	providers := config.NewProviders(c)
 
 	engine, err := jumppad.New(providers, l)
 	if err != nil {
-		panic(err)
+		return nil, nil, err
 	}
 
 	o := gvm.Options{
 		Organization: "jumppad-labs",
 		Repo:         "jumppad",
-		ReleasesPath: utils.GetReleasesFolder(),
+		ReleasesPath: utils.ReleasesFolder(),
 	}
 
 	o.AssetNameFunc = func(version, goos, goarch string) string {
@@ -112,7 +70,7 @@ func createEngine(l logger.Logger) (jumppad.Engine, *clients.Clients, gvm.Versio
 
 	vm := gvm.New(o)
 
-	return engine, engineClients, vm
+	return engine, vm, nil
 }
 
 func createLogger() logger.Logger {
@@ -130,9 +88,52 @@ func Execute(v, c, d string) error {
 	commit = c
 	date = d
 
+	var vm gvm.Versions
+
+	// setup dependencies
+	l := createLogger()
+
+	engineClients, _ := clients.GenerateClients(l)
+
+	// Check the system to see if Docker is running and everything is installed
+	s, err := engineClients.System.Preflight()
+	if err != nil {
+		fmt.Println("")
+		fmt.Println("###### SYSTEM DIAGNOSTICS ######")
+		fmt.Println(s)
+		return err
+	}
+
+	engine, vm, _ := createEngine(l, engineClients)
+
+	rootCmd.AddCommand(checkCmd)
+	rootCmd.AddCommand(outputCmd)
+	rootCmd.AddCommand(newDevCmd())
+	rootCmd.AddCommand(newEnvCmd(engine))
+	rootCmd.AddCommand(newRunCmd(engine, engineClients.ContainerTasks, engineClients.Getter, engineClients.HTTP, engineClients.System, vm, engineClients.Connector, l))
+	rootCmd.AddCommand(newTestCmd())
+	rootCmd.AddCommand(newDestroyCmd(engineClients.Connector))
+	rootCmd.AddCommand(statusCmd)
+	rootCmd.AddCommand(newPurgeCmd(engineClients.Docker, engineClients.ImageLog, l))
+	rootCmd.AddCommand(taintCmd)
+	rootCmd.AddCommand(newVersionCmd(vm))
+	rootCmd.AddCommand(uninstallCmd)
+	rootCmd.AddCommand(newPushCmd(engineClients.ContainerTasks, engineClients.Kubernetes, engineClients.HTTP, engineClients.Nomad, l))
+	rootCmd.AddCommand(newLogCmd(engine, engineClients.Docker, os.Stdout, os.Stderr), completionCmd)
+
+	// add the server commands
+	rootCmd.AddCommand(connectorCmd)
+	connectorCmd.AddCommand(newConnectorRunCommand())
+	connectorCmd.AddCommand(connectorStopCmd)
+	connectorCmd.AddCommand(newConnectorCertCmd())
+
+	// add the generate command
+	rootCmd.AddCommand(generateCmd)
+	generateCmd.AddCommand(newGenerateReadmeCommand(engine))
+
 	rootCmd.SilenceErrors = true
 
-	err := rootCmd.Execute()
+	err = rootCmd.Execute()
 
 	if err != nil {
 		fmt.Println("")