|
|
@@ -15,14 +15,16 @@ limitations under the License.
|
|
|
package secretsink
|
|
|
|
|
|
import (
|
|
|
+ "context"
|
|
|
"errors"
|
|
|
|
|
|
- "github.com/external-secrets/external-secrets/pkg/controllers/secretsink/internal"
|
|
|
"github.com/go-logr/logr"
|
|
|
. "github.com/onsi/ginkgo/v2"
|
|
|
. "github.com/onsi/gomega"
|
|
|
"k8s.io/apimachinery/pkg/types"
|
|
|
ctrl "sigs.k8s.io/controller-runtime"
|
|
|
+
|
|
|
+ "github.com/external-secrets/external-secrets/pkg/controllers/secretsink/internal"
|
|
|
)
|
|
|
|
|
|
var _ = Describe("#Reconcile", func() {
|
|
|
@@ -37,12 +39,11 @@ var _ = Describe("#Reconcile", func() {
|
|
|
statusWriter = new(internal.FakeStatusWriter)
|
|
|
client.StatusReturns(statusWriter)
|
|
|
reconciler = &Reconciler{client, logr.Discard(), nil, nil, 0, ""}
|
|
|
-
|
|
|
})
|
|
|
|
|
|
It("succeeds", func() {
|
|
|
namspacedName := types.NamespacedName{Namespace: "foo", Name: "Bar"}
|
|
|
- _, err := reconciler.Reconcile(nil, ctrl.Request{NamespacedName: namspacedName})
|
|
|
+ _, err := reconciler.Reconcile(context.Background(), ctrl.Request{NamespacedName: namspacedName})
|
|
|
Expect(err).NotTo(HaveOccurred())
|
|
|
Expect(client.GetCallCount()).To(Equal(1))
|
|
|
Expect(client.StatusCallCount()).To(Equal(1))
|
|
|
@@ -55,14 +56,14 @@ var _ = Describe("#Reconcile", func() {
|
|
|
Expect(patch.Type()).To(Equal(types.MergePatchType))
|
|
|
})
|
|
|
|
|
|
- It("notFound", func() {
|
|
|
+ It("notFound", func() {
|
|
|
client.GetReturnsOnCall(0, errors.New("UnknownError"))
|
|
|
|
|
|
namspacedName := types.NamespacedName{Namespace: "foo", Name: "Bar"}
|
|
|
- _, err := reconciler.Reconcile(nil, ctrl.Request{NamespacedName: namspacedName})
|
|
|
-
|
|
|
+ _, err := reconciler.Reconcile(context.Background(), ctrl.Request{NamespacedName: namspacedName})
|
|
|
+
|
|
|
Expect(err).To(HaveOccurred())
|
|
|
Expect(client.GetCallCount()).To(Equal(1))
|
|
|
Expect(client.StatusCallCount()).To(Equal(0))
|
|
|
- })
|
|
|
+ })
|
|
|
})
|