Add openstack plugin for csctl

Signed-off-by: michal.gubricky <michal.gubricky@dnation.cloud>

Author: michal-gubricky

.builder-image-version.txt

@@ -1 +1 @@
-0.2.4
+0.2.0

.gitignore

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

Makefile

@@ -59,6 +59,7 @@ clean: ## cleans the csctl binary
 .PHONY: build
 build: # build the csctl binary
 	go build -ldflags "$(LDFLAGS)" -o csctl main.go
+	go build -o csctl-openstack csctlopenstack/csctlopenstack_main.go
 
 .PHONY: lint-golang
 lint-golang: ## Lint Golang codebase

csctlopenstack/csctlopenstack_main.go

@@ -0,0 +1,77 @@
+/*
+Copyright 2024 The Kubernetes Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+// Package main provides a dummy plugin for csctl. You can use that code
+// to create a real csctl plugin.
+// You can implement the "create-node-images" command to create node images during
+// a `csclt create` call.
+package main
+
+import (
+	"fmt"
+	"os"
+	"path/filepath"
+
+	csctlclusterstack "github.com/SovereignCloudStack/csctl/pkg/clusterstack"
+)
+
+const provider = "openstack"
+
+func usage() {
+	fmt.Printf(`%s create-node-images cluster-stack-directory cluster-stack-release-directory
+This command is a csctl plugin.
+https://github.com/SovereignCloudStack/csctl
+`, 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 := csctlclusterstack.GetCsctlConfig(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)
+	}
+	if config.Config.Provider.Config.Method == "get" {
+		nodeImageData, err := os.ReadFile(filepath.Join(clusterStackPath, "node-images", "config.yaml"))
+		if err != nil {
+			fmt.Println("failed to read config.yaml: %w", err)
+			os.Exit(1)
+		}
+
+		if err := os.WriteFile(filepath.Join(releaseDir, "node-images.yaml"), nodeImageData, os.FileMode(0o644)); err != nil {
+			fmt.Println("failed to write config.yaml: %w", err)
+			os.Exit(1)
+		}
+	}
+	if config.Config.Provider.Config.Method == "build" {
+		fmt.Println(".... pretending to do heavy work (creating node images) ...")
+	}
+}

pkg/clusterstack/config.go

@@ -37,9 +37,11 @@ type CsctlConfig struct {
 		KubernetesVersion string `yaml:"kubernetesVersion"`
 		ClusterStackName  string `yaml:"clusterStackName"`
 		Provider          struct {
-			Type       string   `yaml:"type"`
-			APIVersion string   `yaml:"apiVersion"`
-			Config     struct{} `yaml:"config"`
+			Type       string `yaml:"type"`
+			APIVersion string `yaml:"apiVersion"`
+			Config     struct {
+				Method string `yaml:"method"`
+			} `yaml:"config"`
 		} `yaml:"provider"`
 	} `yaml:"config"`
 }

pkg/cmd/create.go

@@ -27,6 +27,7 @@ import (
 	"github.com/SovereignCloudStack/csctl/pkg/github"
 	"github.com/SovereignCloudStack/csctl/pkg/github/client"
 	"github.com/SovereignCloudStack/csctl/pkg/hash"
+	"github.com/SovereignCloudStack/csctl/pkg/providerplugin"
 	"github.com/SovereignCloudStack/csctl/pkg/template"
 	"github.com/spf13/cobra"
 	"gopkg.in/yaml.v3"
@@ -109,7 +110,7 @@ func GetCreateOptions(ctx context.Context, clusterStackPath string) (*CreateOpti
 			return nil, fmt.Errorf("failed to create new github client: %w", err)
 		}
 
-		// update the metadata kubernetes version with the csmctl.yaml config
+		// update the metadata kubernetes version with the csctl.yaml config
 		createOption.Metadata.Versions.Kubernetes = config.Config.KubernetesVersion
 
 		latestRepoRelease, err := github.GetLatestReleaseFromRemoteRepository(ctx, mode, &config, gc)
@@ -156,6 +157,16 @@ func createAction(cmd *cobra.Command, args []string) error {
 		return fmt.Errorf("mode is not supported please choose from - stable, hash")
 	}
 
+	// Get csctl config form cluster stacks.
+	config, err := clusterstack.GetCsctlConfig(clusterStackPath)
+	if err != nil {
+		return fmt.Errorf("failed to get config: %w", err)
+	}
+	_, _, err = providerplugin.GetProviderExecutable(&config)
+	if err != nil {
+		return fmt.Errorf("failed to get provider executable: %w", err)
+	}
+
 	createOpts, err := GetCreateOptions(cmd.Context(), clusterStackPath)
 	if err != nil {
 		return fmt.Errorf("failed to create create options: %w", err)
@@ -244,5 +255,5 @@ func (c *CreateOptions) generateRelease() error {
 		return fmt.Errorf("failed to write metadata: %w", err)
 	}
 
-	return nil
+	return providerplugin.CreateNodeImages(&c.Config, c.ClusterStackPath, c.ClusterStackReleaseDir)
 }

pkg/providerplugin/providerplugin.go

@@ -0,0 +1,68 @@
+/*
+Copyright 2024 The Kubernetes Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+// Package providerplugin implements calling the provider specific csctl plugin.
+package providerplugin
+
+import (
+	"fmt"
+	"os"
+	"os/exec"
+	"path/filepath"
+
+	"github.com/SovereignCloudStack/csctl/pkg/clusterstack"
+)
+
+// GetProviderExecutable returns the path to the provider plugin (like "csctl-docker").
+// If there is not "config" for the provider in csctl.yaml, then needed is false and path is the empty string.
+func GetProviderExecutable(config *clusterstack.CsctlConfig) (needed bool, path string, err error) {
+	if config.Config.Provider.Config.Method == "" {
+		return false, "", nil
+	}
+	pluginName := "csctl-" + config.Config.Provider.Type
+	_, err = os.Stat(pluginName)
+	if err == nil {
+		path, err := filepath.Abs(pluginName)
+		if err != nil {
+			return false, "", fmt.Errorf("failed to find a path: %w", err)
+		}
+		return true, path, nil
+	}
+	path, err = exec.LookPath(pluginName)
+	if err != nil {
+		return false, "", fmt.Errorf("could not find plugin %s in $PATH or current working directory", pluginName)
+	}
+	return true, path, nil
+}
+
+// CreateNodeImages calls the provider plugin command to create nodes images.
+func CreateNodeImages(config *clusterstack.CsctlConfig, clusterStackPath, clusterStackReleaseDir string) error {
+	needed, path, err := GetProviderExecutable(config)
+	if err != nil {
+		return err
+	}
+	if !needed {
+		fmt.Printf("No provider specific configuration in csctl.yaml. No need to call a plugin for provider %q\n", config.Config.Provider.Type)
+		return nil
+	}
+	args := []string{"create-node-images", clusterStackPath, clusterStackReleaseDir}
+	fmt.Printf("Calling Provider Plugin: %s\n", path)
+	cmd := exec.Command(path, args...) // #nosec G204
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+
+	if err := cmd.Run(); err != nil {
+		return fmt.Errorf("error executing command: %w", err)
+	}
+	return nil
+}