Create mirrored manifest if missing

Signed-off-by: Andrea Mazzotti <andrea.mazzotti@suse.com>

internal/sync/core.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"fmt"
 
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	kerrors "k8s.io/apimachinery/pkg/util/errors"
 	"k8s.io/client-go/util/retry"
@@ -50,8 +51,21 @@ func NewDefaultSynchronizer(cl client.Client, capiProvider *turtlesv1.CAPIProvid
 func (s *DefaultSynchronizer) Get(ctx context.Context) error {
 	log := log.FromContext(ctx)
 
-	if err := s.client.Get(ctx, client.ObjectKeyFromObject(s.Destination), s.Destination); client.IgnoreNotFound(err) != nil {
-		log.Error(err, "Unable to get mirrored manifest: "+client.ObjectKeyFromObject(s.Destination).String())
+	objKey := client.ObjectKeyFromObject(s.Destination)
+
+	err := s.client.Get(ctx, objKey, s.Destination)
+	if apierrors.IsNotFound(err) {
+		log.Info("Mirrored manifest is missing. Creating a new one.")
+
+		if err := s.client.Create(ctx, s.Destination); err != nil {
+			return fmt.Errorf("creating mirrored manifest: %w", err)
+		}
+
+		return nil
+	}
+
+	if err != nil {
+		log.Error(err, "Unable to get mirrored manifest: "+objKey.String())
 
 		return err
 	}

internal/sync/core_test.go

@@ -22,6 +22,8 @@ import (
 	turtlesv1 "github.com/rancher/turtles/api/v1alpha1"
 	"github.com/rancher/turtles/internal/sync"
 	corev1 "k8s.io/api/core/v1"
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
+	"sigs.k8s.io/controller-runtime/pkg/client"
 	. "sigs.k8s.io/controller-runtime/pkg/envtest/komega"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -89,4 +91,19 @@ var _ = Describe("Core provider", func() {
 		Eventually(Object(secret)).Should(
 			HaveField("OwnerReferences", HaveLen(1)))
 	})
+
+	It("Should create not-found mirrored manifest", func() {
+		secret := &corev1.Secret{ObjectMeta: metav1.ObjectMeta{
+			Name:      "test",
+			Namespace: ns.Name,
+		}}
+
+		err := testEnv.Client.Get(ctx, client.ObjectKeyFromObject(secret), secret)
+		Expect(apierrors.IsNotFound(err)).Should(BeTrue())
+
+		s := sync.NewDefaultSynchronizer(testEnv, capiProvider, secret)
+		Expect(s.Get(ctx)).To(Succeed())
+
+		Expect(testEnv.Client.Get(ctx, client.ObjectKeyFromObject(secret), secret)).Should(Succeed())
+	})
 })