feat: read architecture specific common templates file

This change prepares for architecture-specific delivery. The logic
will first attempt to locate the architecture-specific common
templates bundle. If it is not found, it will then fall back to the
generic bundle.

Signed-off-by: Nestor Acuna Blanco <nestor.acuna@ibm.com>

internal/controllers/setup.go

@@ -3,7 +3,6 @@ package controllers
 import (
 	"context"
 	"fmt"
-	"path/filepath"
 
 	"github.com/go-logr/logr"
 	v1 "github.com/openshift/api/config/v1"
@@ -50,8 +49,11 @@ func CreateControllers(ctx context.Context, apiReader client.Reader) ([]Controll
 		return nil, fmt.Errorf("failed to check if running on openshift: %w", err)
 	}
 
-	templatesFile := filepath.Join(templateBundleDir, "common-templates-"+common_templates.Version+".yaml")
-	templatesBundle, err := template_bundle.ReadBundle(templatesFile)
+	templatesBundleFile, err := template_bundle.RetrieveCommonTemplatesBundleFile(templateBundleDir)
+	if err != nil {
+		return nil, err
+	}
+	templatesBundle, err := template_bundle.ReadBundle(templatesBundleFile)
 	if err != nil {
 		return nil, fmt.Errorf("failed to read template bundle: %w", err)
 	}

internal/template-bundle/bundle.go

@@ -6,13 +6,15 @@ import (
 	"fmt"
 	"io"
 	"os"
+	"path/filepath"
 	"runtime"
 
 	templatev1 "github.com/openshift/api/template/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/util/yaml"
 	cdiv1beta1 "kubevirt.io/containerized-data-importer-api/pkg/apis/core/v1beta1"
+	common_templates "kubevirt.io/ssp-operator/internal/operands/common-templates"
 )
 
 type Bundle struct {
@@ -47,6 +49,18 @@ func ReadBundle(filename string) (Bundle, error) {
 	}, nil
 }
 
+func RetrieveCommonTemplatesBundleFile(templateBundleDir string) (string, error) {
+	archDependentFileName := filepath.Join(templateBundleDir, fmt.Sprintf("common-templates-%s-%s.yaml", runtime.GOARCH, common_templates.Version))
+	if _, err := os.Stat(archDependentFileName); err == nil {
+		return archDependentFileName, nil
+	}
+	archIndependentFileName := filepath.Join(templateBundleDir, fmt.Sprintf("common-templates-%s.yaml", common_templates.Version))
+	if _, err := os.Stat(archIndependentFileName); err == nil {
+		return archIndependentFileName, nil
+	}
+	return "", fmt.Errorf("failed to find common-templates bundles, none of the files were found: %s, %s", archDependentFileName, archIndependentFileName)
+}
+
 func readTemplates(filename string) ([]templatev1.Template, error) {
 	var bundle []templatev1.Template
 	file, err := os.ReadFile(filename)

internal/template-bundle/bundle_test.go

@@ -1,11 +1,14 @@
 package template_bundle
 
 import (
+	"fmt"
+	"os"
 	"runtime"
 	"testing"
 
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
+	common_templates "kubevirt.io/ssp-operator/internal/operands/common-templates"
 )
 
 func retrieveSuffix() string {
@@ -19,8 +22,11 @@ func retrieveSuffix() string {
 
 var _ = Describe("Template bundle", Ordered, func() {
 	var (
-		testBundle Bundle
-		nameSuffix string
+		testBundle          Bundle
+		nameSuffix          string
+		tmpDir              string
+		archIndependentFile string
+		archDependentFile   string
 	)
 
 	BeforeAll(func() {
@@ -30,6 +36,12 @@ var _ = Describe("Template bundle", Ordered, func() {
 		nameSuffix = retrieveSuffix()
 	})
 
+	BeforeEach(func() {
+		tmpDir = GinkgoT().TempDir()
+		archIndependentFile = tmpDir + fmt.Sprintf("/common-templates-%s.yaml", common_templates.Version)
+		archDependentFile = tmpDir + fmt.Sprintf("/common-templates-%s-%s.yaml", runtime.GOARCH, common_templates.Version)
+	})
+
 	It("should correctly read templates", func() {
 		templates := testBundle.Templates
 		Expect(templates).To(HaveLen(4))
@@ -75,6 +87,37 @@ var _ = Describe("Template bundle", Ordered, func() {
 		Expect(ds2.Spec.Source.PVC.Name).To(Equal("win10"))
 		Expect(ds2.Spec.Source.PVC.Namespace).To(Equal("kubevirt-os-images"))
 	})
+
+	It("should throw an error retrieving the bundle file", func() {
+		_, err := RetrieveCommonTemplatesBundleFile(tmpDir)
+		Expect(err.Error()).To(ContainSubstring("failed to find common-templates bundles, none of the files were found"))
+	})
+
+	It("should retrieve the bundle arch independent file", func() {
+		err := os.WriteFile(archIndependentFile, []byte(""), 0644)
+		Expect(err).ToNot(HaveOccurred())
+		commonTemplatesBundleFile, err := RetrieveCommonTemplatesBundleFile(tmpDir)
+		Expect(err).ToNot(HaveOccurred())
+		Expect(commonTemplatesBundleFile).To(Equal(archIndependentFile))
+	})
+
+	It("should retrieve the bundle arch dependent file", func() {
+		err := os.WriteFile(archDependentFile, []byte(""), 0644)
+		Expect(err).ToNot(HaveOccurred())
+		commonTemplatesBundleFile, err := RetrieveCommonTemplatesBundleFile(tmpDir)
+		Expect(err).ToNot(HaveOccurred())
+		Expect(commonTemplatesBundleFile).To(Equal(archDependentFile))
+	})
+
+	It("should retrieve the bundle arch dependent file when the generic one also exists", func() {
+		err := os.WriteFile(archIndependentFile, []byte(""), 0644)
+		Expect(err).ToNot(HaveOccurred())
+		err = os.WriteFile(archDependentFile, []byte(""), 0644)
+		Expect(err).ToNot(HaveOccurred())
+		commonTemplatesBundleFile, err := RetrieveCommonTemplatesBundleFile(tmpDir)
+		Expect(err).ToNot(HaveOccurred())
+		Expect(commonTemplatesBundleFile).To(Equal(archDependentFile))
+	})
 })
 
 func TestTemplateBundle(t *testing.T) {