From c2c26e30b44c666fa1b0ebd919f90007fe823680 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Robert=20=C8=98tefan?= <rstefan1@users.noreply.github.com>
Date: Tue, 2 Aug 2022 19:38:15 +0300
Subject: [PATCH] Implement IgnoreAlreadyExists

---
 pkg/client/client_test.go | 26 ++++++++++++++++++++++++++
 pkg/client/interfaces.go  | 10 ++++++++++
 2 files changed, 36 insertions(+)

diff --git a/pkg/client/client_test.go b/pkg/client/client_test.go
index b60324eb33..a43fe87784 100644
--- a/pkg/client/client_test.go
+++ b/pkg/client/client_test.go
@@ -3403,6 +3403,32 @@ var _ = Describe("IgnoreNotFound", func() {
 	})
 })
 
+var _ = Describe("IgnoreAlreadyExists", func() {
+	It("should return nil on a 'AlreadyExists' error", func() {
+		By("creating a AlreadyExists error")
+		err := apierrors.NewAlreadyExists(schema.GroupResource{}, "")
+
+		By("returning no error")
+		Expect(client.IgnoreAlreadyExists(err)).To(Succeed())
+	})
+
+	It("should return the error on a status other than already exists", func() {
+		By("creating a BadRequest error")
+		err := apierrors.NewBadRequest("")
+
+		By("returning an error")
+		Expect(client.IgnoreAlreadyExists(err)).To(HaveOccurred())
+	})
+
+	It("should return the error on a non-status error", func() {
+		By("creating an fmt error")
+		err := fmt.Errorf("arbitrary error")
+
+		By("returning an error")
+		Expect(client.IgnoreAlreadyExists(err)).To(HaveOccurred())
+	})
+})
+
 type fakeReader struct {
 	Called int
 }
diff --git a/pkg/client/interfaces.go b/pkg/client/interfaces.go
index 32b6234cf9..7f8f8f31c6 100644
--- a/pkg/client/interfaces.go
+++ b/pkg/client/interfaces.go
@@ -143,3 +143,13 @@ func IgnoreNotFound(err error) error {
 	}
 	return err
 }
+
+// IgnoreAlreadyExists returns nil on AlreadyExists errors.
+// All other values that are not AlreadyExists errors or nil are returned unmodified.
+func IgnoreAlreadyExists(err error) error {
+	if apierrors.IsAlreadyExists(err) {
+		return nil
+	}
+
+	return err
+}