refactor: embed bootstrap config files

On-behalf-of: @SAP [email protected]
Signed-off-by: Christopher Junk <[email protected]>

Author: christophrj

internal/util.go

@@ -1,8 +1,11 @@
 package internal
 
 import (
+	"embed"
+	"fmt"
 	"io"
 	"os"
+	"path/filepath"
 	"strings"
 	"text/template"
 
@@ -66,3 +69,22 @@ func UnstructuredRef(name string, namespace string, gvk schema.GroupVersionKind)
 	obj.SetGroupVersionKind(gvk)
 	return obj
 }
+
+// MustTmpFileFromEmbedFS creates a temporary file from an embedded file and returns the file path
+func MustTmpFileFromEmbedFS(fs embed.FS, path string) string {
+	data, err := fs.ReadFile(path)
+	if err != nil {
+		panic(err)
+	}
+	file := filepath.Base(path)
+	tmpDir, err := os.MkdirTemp("", fmt.Sprintf("%s-*", file))
+	if err != nil {
+		panic(err)
+	}
+	tmpPath := filepath.Join(tmpDir, file)
+	var userRW os.FileMode = 0o600
+	if err := os.WriteFile(tmpPath, data, userRW); err != nil {
+		panic(err)
+	}
+	return tmpPath
+}

pkg/setup/bootstrap.go

@@ -2,6 +2,8 @@ package setup
 
 import (
 	"context"
+	"embed"
+	"os"
 
 	apimachinerytypes "k8s.io/apimachinery/pkg/types"
 	"k8s.io/klog/v2"
@@ -13,10 +15,14 @@ import (
 	"sigs.k8s.io/e2e-framework/pkg/types"
 	"sigs.k8s.io/e2e-framework/support/kind"
 
+	"github.com/openmcp-project/openmcp-testing/internal"
 	"github.com/openmcp-project/openmcp-testing/pkg/providers"
 	"github.com/openmcp-project/openmcp-testing/pkg/resources"
 )
 
+//go:embed config/*
+var configFS embed.FS
+
 type OpenMCPSetup struct {
 	Namespace        string
 	Operator         OpenMCPOperatorSetup
@@ -36,28 +42,33 @@ type OpenMCPOperatorSetup struct {
 
 // Bootstrap sets up a the minimum set of components of an openMCP installation
 func (s *OpenMCPSetup) Bootstrap(testenv env.Environment) error {
+	kindConfig := internal.MustTmpFileFromEmbedFS(configFS, "config/kind-config.yaml")
+	operatorTemplate := internal.MustTmpFileFromEmbedFS(configFS, "config/operator.yaml.tmpl")
 	platformClusterName := envconf.RandomName("platform", 16)
 	s.Operator.Namespace = s.Namespace
-	testenv.Setup(createPlatformCluster(platformClusterName)).
+	testenv.Setup(createPlatformCluster(platformClusterName, kindConfig)).
 		Setup(envfuncs.CreateNamespace(s.Namespace)).
-		Setup(s.installOpenMCPOperator()).
+		Setup(s.installOpenMCPOperator(operatorTemplate)).
 		Setup(s.installClusterProviders()).
 		Setup(s.loadServiceProviderImages(platformClusterName)).
 		Setup(s.installServiceProviders()).
 		Setup(s.verifyEnvironment()).
-		Finish(s.cleanup()).
+		Finish(s.cleanup(kindConfig, operatorTemplate)).
 		Finish(envfuncs.DestroyCluster(platformClusterName))
 	return nil
 }
 
-func createPlatformCluster(name string) types.EnvFunc {
+func createPlatformCluster(name string, kindConfig string) types.EnvFunc {
 	klog.Info("create platform cluster...")
-	return envfuncs.CreateClusterWithConfig(kind.NewProvider(), name, "../pkg/setup/kind/config.yaml")
+	return envfuncs.CreateClusterWithConfig(kind.NewProvider(), name, kindConfig)
 }
 
-func (s *OpenMCPSetup) cleanup() types.EnvFunc {
+func (s *OpenMCPSetup) cleanup(tmpFiles ...string) types.EnvFunc {
 	return func(ctx context.Context, c *envconf.Config) (context.Context, error) {
 		klog.Info("cleaning up environment...")
+		for _, f := range tmpFiles {
+			os.RemoveAll(f)
+		}
 		for _, sp := range s.ServiceProviders {
 			if err := providers.DeleteServiceProvider(ctx, c, sp.Name, sp.WaitOpts...); err != nil {
 				klog.Errorf("delete service provider failed: %v", err)
@@ -83,10 +94,10 @@ func (s *OpenMCPSetup) verifyEnvironment() types.EnvFunc {
 	}
 }
 
-func (s *OpenMCPSetup) installOpenMCPOperator() types.EnvFunc {
+func (s *OpenMCPSetup) installOpenMCPOperator(tmpl string) types.EnvFunc {
 	return func(ctx context.Context, c *envconf.Config) (context.Context, error) {
 		// apply openmcp operator manifests
-		if _, err := resources.CreateObjectsFromTemplateFile(ctx, c, "../pkg/setup/templates/openmcp-operator.yaml.tmpl", s.Operator); err != nil {
+		if _, err := resources.CreateObjectsFromTemplateFile(ctx, c, tmpl, s.Operator); err != nil {
 			return ctx, err
 		}
 		// wait for deployment to be ready