✨ Support calling provider plugins.

.gitignore

@@ -17,5 +17,6 @@ temp
 # build and release
 dist
 csmctl
+csmctl-docker
 tmp/
 releases/

Makefile

@@ -46,6 +46,7 @@ export GOBIN := $(abspath $(TOOLS_BIN_DIR))
 .PHONY: build
 build: # build the csmctl binary
 	go build -o csmctl main.go
+	go build -o csmctl-docker csmctldocker/csmctldocker_main.go
 
 .PHONY: lint-golang
 lint-golang: ## Lint Golang codebase

csmctldocker/csmctldocker_main.go

@@ -0,0 +1,48 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	csmctlclusterstack "github.com/SovereignCloudStack/csmctl/pkg/clusterstack"
+)
+
+const provider = "docker"
+
+func usage() {
+	fmt.Printf(`%s create-node-images cluster-stack-directory cluster-stack-release-directory
+This command is a csmctl plugin.
+
+https://github.com/SovereignCloudStack/csmctl
+`, os.Args[0])
+}
+
+func main() {
+	if len(os.Args) != 4 {
+		usage()
+		os.Exit(1)
+	}
+	if os.Args[1] != "create-node-images" {
+		usage()
+		os.Exit(1)
+	}
+	clusterStackPath := os.Args[2]
+	config, err := csmctlclusterstack.GetCsmctlConfig(clusterStackPath)
+	if err != nil {
+		fmt.Println(err.Error())
+		os.Exit(1)
+	}
+	if config.Config.Provider.Type != provider {
+		fmt.Printf("Wrong provider in %s. Expected %s\n", clusterStackPath, provider)
+		os.Exit(1)
+	}
+	releaseDir := os.Args[3]
+	_, err = os.Stat(releaseDir)
+	if err != nil {
+		fmt.Println(err.Error())
+		os.Exit(1)
+	}
+	fmt.Printf("clusterStackPath: %s\n", clusterStackPath)
+	fmt.Printf("releaseDir: %s\n", releaseDir)
+	fmt.Println(".... pretending to do heavy work (creating node images) ...")
+}

pkg/cmd/create.go

@@ -27,6 +27,7 @@
 	"github.com/SovereignCloudStack/csmctl/pkg/git"
 	"github.com/SovereignCloudStack/csmctl/pkg/github"
 	"github.com/SovereignCloudStack/csmctl/pkg/hash"
+	"github.com/SovereignCloudStack/csmctl/pkg/providerplugin"
 	"github.com/SovereignCloudStack/csmctl/pkg/template"
 	"github.com/spf13/cobra"
 	"gopkg.in/yaml.v3"
@@ -64,7 +65,8 @@
 Supported modes are - stable, alpha, beta, hash
 
 note - Hash mode takes the last hash of the git commit.`,
-	RunE: createAction,
+	RunE:         createAction,
+	SilenceUsage: true,
 }
 
 func init() {
@@ -86,6 +88,11 @@
 		return fmt.Errorf("failed to get config: %w", err)
 	}
 
+	_, err = providerplugin.CheckProviderExecutable(config)
+	if err != nil {
+		return err
+	}
+
 	// Skip downloading github release for the hash mode.
 	// var latestRepoRelease *string
 	if mode == hashMode {
@@ -109,7 +116,7 @@
 			clusterStackReleaseDir: csrDirName,
 			currentHash:            currentHash,
 		}
-		if err := create.buildPackerAndGenerateRelease(); err != nil {
+		if err := create.buildNodeImagesAndGenerateRelease(); err != nil {
 			return fmt.Errorf("failed to build packer and generate release: %w", err)
 		}
 		return nil
@@ -150,7 +157,7 @@
 		clusterStackReleaseDir: csrDirName,
 		currentHash:            currentHash,
 	}
-	if err := create.buildPackerAndGenerateRelease(); err != nil {
+	if err := create.buildNodeImagesAndGenerateRelease(); err != nil {
 		return fmt.Errorf("failed to build packer and generate release: %w", err)
 	}
 
@@ -255,10 +262,10 @@
 	return metadata, nil
 }
 
-func (c *CreateOptions) buildPackerAndGenerateRelease() error {
+func (c *CreateOptions) buildNodeImagesAndGenerateRelease() error {
 	// Release directory name
 	releaseDirectory := filepath.Join(outputDirectory, c.clusterStackReleaseDir)
-
+	fmt.Printf("Creating output in %s\n", releaseDirectory)
 	// Write the current hash
 	hashJSONData, err := json.MarshalIndent(c.currentHash, "", "  ")
 	if err != nil {
@@ -287,5 +294,5 @@
 		return fmt.Errorf("failed to create package: %w", err)
 	}
 
-	return nil
+	return providerplugin.CreateNodeImages(c.config, c.clusterStackPath, releaseDirectory)
 }

pkg/providerplugin/providerplugin.go

@@ -0,0 +1,40 @@
+package providerplugin
+
+import (
+	"fmt"
+	"os"
+	"os/exec"
+	"path/filepath"
+
+	"github.com/SovereignCloudStack/csmctl/pkg/clusterstack"
+)
+
+func CheckProviderExecutable(config *clusterstack.CsmctlConfig) (path string, err error) {
+	pluginName := "csmctl-" + config.Config.Provider.Type
+	_, err = os.Stat(pluginName)
+	if err == nil {
+		path, err := filepath.Abs(pluginName)
+		if err != nil {
+			return "", err
+		}
+		return path, err
+	}
+	path, err = exec.LookPath(pluginName)
+	if err != nil {
+		return "", fmt.Errorf("could not find plugin %s in $PATH or current working directory", pluginName)
+	}
+	return path, nil
+}
+
+func CreateNodeImages(config *clusterstack.CsmctlConfig, clusterStackPath string, clusterStackReleaseDir string) error {
+	path, err := CheckProviderExecutable(config)
+	if err != nil {
+		return err
+	}
+	args := []string{"create-node-images", clusterStackPath, clusterStackReleaseDir}
+	fmt.Printf("Calling Provider Plugin: %s\n", path)
+	cmd := exec.Command(path, args...)
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+	return cmd.Run()
+}