github/containerized-data-importer
7
0
Fork 0
mirror of https://github.com/kubevirt/containerized-data-importer.git synced 2025-06-03 06:30:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

transport_test: registry source func test

Browse Source 
Added a test for registry source:
existence of the bin file in the image (i.e. /pvc/usr/bin/cdi-importer).

Change-Id: Iefd825e841a040263679d53749a6361f8bc4560d
Signed-off-by: Daniel Erez <derez@redhat.com>
This commit is contained in:
Daniel Erez 2018-11-29 01:00:34 +02:00
parent 523a24f118
commit 3c70f9501c
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/transport_test.go
View File

@ -77,7 +77,8 @@ var _ = Describe("Transport Tests", func() {
importer, err := utils.FindPodByPrefix(c, ns, common.ImporterPodName, common.CDILabelSelector) importer, err := utils.FindPodByPrefix(c, ns, common.ImporterPodName, common.CDILabelSelector)
Expect(err).NotTo(HaveOccurred(), fmt.Sprintf("Unable to get importer pod %q", ns+"/"+common.ImporterPodName)) Expect(err).NotTo(HaveOccurred(), fmt.Sprintf("Unable to get importer pod %q", ns+"/"+common.ImporterPodName))
err = utils.WaitTimeoutForPodStatus(c, importer.Name, importer.Namespace, v1.PodSucceeded, utils.PodWaitForTime) err = utils.WaitTimeoutForPodStatus(c, importer.Name, importer.Namespace, v1.PodRunning, 5*utils.PodWaitForTime)
Expect(err).NotTo(HaveOccurred(), "Operation timeout on importer pod %q", ns+"/"+common.ImporterPodName)
if shouldSucceed { if shouldSucceed {
By("Verifying PVC is not empty") By("Verifying PVC is not empty")
@ -94,7 +95,11 @@ var _ = Describe("Transport Tests", func() {
// A 0 exitCode should indicate that $expSize == $haveSize // A 0 exitCode should indicate that $expSize == $haveSize
Expect(strconv.Atoi(exitCode)).To(BeZero()) Expect(strconv.Atoi(exitCode)).To(BeZero())
case controller.SourceRegistry: case controller.SourceRegistry:
// TODO: add functionality tests binFile := "/pvc/bin/" + file
command := fmt.Sprintf("[ -e %s ]; echo $?", binFile)
exitCode := f.ExecShellInPod(pod.Name, ns, command)
// A 0 exitCode should indicate that the bin file exists
Expect(strconv.Atoi(exitCode)).To(BeZero())
} }
} else { } else {
By("Verifying PVC is empty") By("Verifying PVC is empty")
@ -104,13 +109,13 @@ var _ = Describe("Transport Tests", func() {
httpNoAuthEp := fmt.Sprintf("http://%s:%d", utils.FileHostName+"."+utils.FileHostNs, utils.HTTPNoAuthPort) httpNoAuthEp := fmt.Sprintf("http://%s:%d", utils.FileHostName+"."+utils.FileHostNs, utils.HTTPNoAuthPort)
httpAuthEp := fmt.Sprintf("http://%s:%d", utils.FileHostName+"."+utils.FileHostNs, utils.HTTPAuthPort) httpAuthEp := fmt.Sprintf("http://%s:%d", utils.FileHostName+"."+utils.FileHostNs, utils.HTTPAuthPort)
registryNoAuthEp := fmt.Sprintf("docker://%s", "registry:5000") registryNoAuthEp := fmt.Sprintf("docker://%s", "docker.io")
DescribeTable("Transport Test Table", it, DescribeTable("Transport Test Table", it,
Entry("should connect to http endpoint without credentials", httpNoAuthEp, targetFile, "", "", controller.SourceHTTP, true), Entry("should connect to http endpoint without credentials", httpNoAuthEp, targetFile, "", "", controller.SourceHTTP, true),
Entry("should connect to http endpoint with credentials", httpAuthEp, targetFile, utils.AccessKeyValue, utils.SecretKeyValue, controller.SourceHTTP, true), Entry("should connect to http endpoint with credentials", httpAuthEp, targetFile, utils.AccessKeyValue, utils.SecretKeyValue, controller.SourceHTTP, true),
Entry("should not connect to http endpoint with invalid credentials", httpAuthEp, targetFile, "gopats", "bradyisthegoat", controller.SourceHTTP, false), Entry("should not connect to http endpoint with invalid credentials", httpAuthEp, targetFile, "gopats", "bradyisthegoat", controller.SourceHTTP, false),
Entry("should connect to QCOW http endpoint without credentials", httpNoAuthEp, targetQCOWFile, "", "", controller.SourceHTTP, true), Entry("should connect to QCOW http endpoint without credentials", httpNoAuthEp, targetQCOWFile, "", "", controller.SourceHTTP, true),
Entry("should connect to QCOW http endpoint with credentials", httpAuthEp, targetQCOWFile, utils.AccessKeyValue, utils.SecretKeyValue, controller.SourceHTTP, true), Entry("should connect to QCOW http endpoint with credentials", httpAuthEp, targetQCOWFile, utils.AccessKeyValue, utils.SecretKeyValue, controller.SourceHTTP, true),
Entry("should connect to registry endpoint without credentials", registryNoAuthEp, "cdi-importer", "", "", controller.SourceRegistry, true), Entry("should connect to registry endpoint without credentials", registryNoAuthEp, "registry", "", "", controller.SourceRegistry, true),
Entry("should not connect to registry endpoint with invalid credentials", registryNoAuthEp, "cdi-importer", "gopats", "bradyisthegoat", controller.SourceRegistry, false)) Entry("should not connect to registry endpoint with invalid credentials", registryNoAuthEp, "registry", "gopats", "bradyisthegoat", controller.SourceRegistry, false))
}) })