Skip to content

Commit ab32873

Browse files
committed
adding in additional tests from @akalenyu
Signed-off-by: xphyr <xphyr@users.noreply.github.com>
1 parent e73d9a4 commit ab32873

2 files changed

Lines changed: 42 additions & 2 deletions

File tree

pkg/controller/import-controller_test.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -439,7 +439,7 @@ var _ = Describe("ImportConfig Controller reconcile loop", func() {
439439
})
440440

441441
It("Should not set the InsecureTLS environment variable if the AnnInsecureSkipVerify annotation is set to false", func() {
442-
pvc := cc.CreatePvc("testPvc1", "default", map[string]string{cc.AnnEndpoint: testEndPoint, cc.AnnImportPod: "importer-testPvc1", cc.AnnInsecureSkipVerify: "false"}, nil)
442+
pvc := cc.CreatePvc("testPvc1", "default", map[string]string{cc.AnnEndpoint: testEndPoint, cc.AnnImportPod: "importer-testPvc1", cc.AnnInsecureSkipVerify: "false", cc.AnnSource: cc.SourceHTTP}, nil)
443443
pvc.Status.Phase = v1.ClaimBound
444444
reconciler = createImportReconciler(pvc)
445445
_, err := reconciler.Reconcile(context.TODO(), reconcile.Request{NamespacedName: types.NamespacedName{Name: "testPvc1", Namespace: "default"}})
@@ -458,7 +458,7 @@ var _ = Describe("ImportConfig Controller reconcile loop", func() {
458458
})
459459

460460
It("Should set the InsecureTLS environment variable to false if the AnnInsecureSkipVerify annotation is absent", func() {
461-
pvc := cc.CreatePvc("testPvc1", "default", map[string]string{cc.AnnEndpoint: testEndPoint, cc.AnnImportPod: "importer-testPvc1"}, nil)
461+
pvc := cc.CreatePvc("testPvc1", "default", map[string]string{cc.AnnEndpoint: testEndPoint, cc.AnnImportPod: "importer-testPvc1", cc.AnnSource: cc.SourceHTTP}, nil)
462462
pvc.Status.Phase = v1.ClaimBound
463463
reconciler = createImportReconciler(pvc)
464464
_, err := reconciler.Reconcile(context.TODO(), reconcile.Request{NamespacedName: types.NamespacedName{Name: "testPvc1", Namespace: "default"}})
@@ -1339,7 +1339,9 @@ var _ = Describe("isInsecureTLS", func() {
13391339
},
13401340
Entry("return true when AnnInsecureSkipVerify is set to true for http source", cc.SourceHTTP, "true", true),
13411341
Entry("return true when AnnInsecureSkipVerify is set to true for imageio source", cc.SourceImageio, "true", true),
1342+
Entry("return false when AnnInsecureSkipVerify is set to false for http source", cc.SourceHTTP, "false", false),
13421343
Entry("return false when AnnInsecureSkipVerify is not present for http source", cc.SourceHTTP, "", false),
1344+
Entry("return false when AnnInsecureSkipVerify is set to false for imageio source", cc.SourceImageio, "false", false),
13431345
Entry("return false when AnnInsecureSkipVerify is not present for imageio source", cc.SourceImageio, "", false),
13441346
)
13451347
})

pkg/controller/populators/import-populator_test.go

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -285,6 +285,44 @@ var _ = Describe("Import populator tests", func() {
285285
Entry("retain pod annotation is passed", AnnPodRetainAfterCompletion, "true", "true"),
286286
)
287287

288+
It("Should set AnnInsecureSkipVerify on PVC Prime when InsecureSkipVerify is true", func() {
289+
targetPvc := CreatePvcInStorageClass(targetPvcName, metav1.NamespaceDefault, &sc.Name, map[string]string{}, nil, corev1.ClaimPending)
290+
targetPvc.Spec.DataSourceRef = dataSourceRef
291+
volumeImportSource := getVolumeImportSource(true, metav1.NamespaceDefault)
292+
volumeImportSource.Spec.Source.HTTP.InsecureSkipVerify = ptr.To(true)
293+
294+
By("Reconcile")
295+
reconciler = createImportPopulatorReconciler(targetPvc, volumeImportSource, sc)
296+
result, err := reconciler.Reconcile(context.TODO(), reconcile.Request{NamespacedName: types.NamespacedName{Name: targetPvcName, Namespace: metav1.NamespaceDefault}})
297+
Expect(err).To(Not(HaveOccurred()))
298+
Expect(result).To(Not(BeNil()))
299+
300+
By("Checking PVC' annotations")
301+
pvcPrime, err := reconciler.getPVCPrime(targetPvc)
302+
Expect(err).ToNot(HaveOccurred())
303+
Expect(pvcPrime).ToNot(BeNil())
304+
Expect(pvcPrime.GetAnnotations()[AnnInsecureSkipVerify]).To(Equal("true"))
305+
})
306+
307+
It("Should not set AnnInsecureSkipVerify on PVC Prime when InsecureSkipVerify is not set", func() {
308+
targetPvc := CreatePvcInStorageClass(targetPvcName, metav1.NamespaceDefault, &sc.Name, map[string]string{}, nil, corev1.ClaimPending)
309+
targetPvc.Spec.DataSourceRef = dataSourceRef
310+
volumeImportSource := getVolumeImportSource(true, metav1.NamespaceDefault)
311+
312+
By("Reconcile")
313+
reconciler = createImportPopulatorReconciler(targetPvc, volumeImportSource, sc)
314+
result, err := reconciler.Reconcile(context.TODO(), reconcile.Request{NamespacedName: types.NamespacedName{Name: targetPvcName, Namespace: metav1.NamespaceDefault}})
315+
Expect(err).To(Not(HaveOccurred()))
316+
Expect(result).To(Not(BeNil()))
317+
318+
By("Checking PVC' annotations")
319+
pvcPrime, err := reconciler.getPVCPrime(targetPvc)
320+
Expect(err).ToNot(HaveOccurred())
321+
Expect(pvcPrime).ToNot(BeNil())
322+
_, exists := pvcPrime.GetAnnotations()[AnnInsecureSkipVerify]
323+
Expect(exists).To(BeFalse())
324+
})
325+
288326
It("Should not copy target PVC labels to PVC Prime", func() {
289327
targetPvc := CreatePvcInStorageClass(targetPvcName, metav1.NamespaceDefault, &sc.Name,
290328
map[string]string{}, map[string]string{"custom-label": "value"}, corev1.ClaimPending)

0 commit comments

Comments
 (0)