feat: deploy flux command

Author: robertgraeff

internal/flux_deployer/deployer.go

@@ -9,6 +9,8 @@ import (
 
 	"github.com/openmcp-project/controller-utils/pkg/clusters"
 	"github.com/sirupsen/logrus"
+	"sigs.k8s.io/kustomize/api/krusty"
+	"sigs.k8s.io/kustomize/kyaml/filesys"
 
 	cfg "github.com/openmcp-project/bootstrapper/internal/config"
 	ocmcli "github.com/openmcp-project/bootstrapper/internal/ocm-cli"
@@ -133,7 +135,7 @@ func (d *FluxDeployer) Deploy(ctx context.Context) (err error) {
 
 	// Kustomize
 	fluxCDEnvDir := filepath.Join(d.repoDir, EnvsDirectoryName, d.Config.Environment, FluxCDDirectoryName)
-	manifests, err := Kustomize(fluxCDEnvDir)
+	manifests, err := d.Kustomize(fluxCDEnvDir)
 	if err != nil {
 		return fmt.Errorf("error kustomizing templated files: %w", err)
 	}
@@ -246,6 +248,26 @@ func applyFluxCDTemplateInput(templateInput map[string]interface{}, fluxcdCV *oc
 	return nil
 }
 
+// Kustomize runs kustomize on the given directory and returns the resulting yaml as a byte slice.
+func (d *FluxDeployer) Kustomize(dir string) ([]byte, error) {
+	d.log.Info("Kustomizing files in directory: %s", dir)
+	fs := filesys.MakeFsOnDisk()
+	opts := krusty.MakeDefaultOptions()
+	kustomizer := krusty.MakeKustomizer(opts)
+
+	resourceMap, err := kustomizer.Run(fs, dir)
+	if err != nil {
+		return nil, fmt.Errorf("error running kustomization: %w", err)
+	}
+
+	resourcesYaml, err := resourceMap.AsYaml()
+	if err != nil {
+		return nil, fmt.Errorf("error converting resources to yaml: %w", err)
+	}
+
+	return resourcesYaml, nil
+}
+
 func (d *FluxDeployer) DeployFluxControllers(ctx context.Context, rootComponentVersion *ocmcli.ComponentVersion, downloadDir string) error {
 	d.log.Info("Deploying flux")