OCPNODE-3138: Add zstd:chunked image test

Signed-off-by: Ayato Tokubi <[email protected]>

Author: bitoku

test/extended/node/ztsd_chunked.go

@@ -0,0 +1,76 @@
+package node
+
+import (
+	"context"
+	"fmt"
+	"github.com/openshift/origin/test/extended/util/image"
+	e2eoutput "k8s.io/kubernetes/test/e2e/framework/pod/output"
+	"time"
+
+	g "github.com/onsi/ginkgo/v2"
+	o "github.com/onsi/gomega"
+
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	e2epod "k8s.io/kubernetes/test/e2e/framework/pod"
+
+	exutil "github.com/openshift/origin/test/extended/util"
+)
+
+var _ = g.Describe("zstd:chunked Image", func() {
+	defer g.GinkgoRecover()
+	var oc *exutil.CLI
+
+	g.BeforeEach(func() {
+		oc = exutil.NewCLI("zstd-chunked-image")
+	})
+
+	g.It("should successfully run date command", func(ctx context.Context) {
+		namespace := oc.Namespace()
+
+		zstdChunkedImage := "quay.io/crio/busybox:zstd-chunked"
+		// manifestEndpoint is used to check the image is zstd:chunked
+		manifestEndpoint := "https://quay.io/v2/crio/busybox/manifests/zstd-chunked"
+
+		// Define a pod that runs the date command using the zstd-chunked image
+		pod := &corev1.Pod{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      "zstd-chunked-pod",
+				Namespace: namespace,
+			},
+			Spec: corev1.PodSpec{
+				RestartPolicy: corev1.RestartPolicyNever,
+				Containers: []corev1.Container{
+					{
+						Name:    "zstd-chunked-container",
+						Image:   image.LocationFor(zstdChunkedImage),
+						Command: []string{"date"},
+					},
+				},
+			},
+		}
+
+		g.By("Checking that the image is zstd:chunked")
+		execpod := exutil.CreateExecPodOrFail(oc.KubeClient(), namespace, "execpod")
+		_, err := e2eoutput.RunHostCmd(execpod.Namespace, execpod.Name,
+			fmt.Sprintf(
+				"curl %s -H 'Accept: application/vnd.oci.image.manifest.v1+json' | jq -e '.layers[0].annotations.\"io.github.containers.zstd-chunked.manifest-checksum\"'",
+				manifestEndpoint,
+			),
+		)
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		g.By("Creating a pod")
+		pod, err = oc.KubeClient().CoreV1().Pods(namespace).Create(context.Background(), pod, metav1.CreateOptions{})
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		g.By("Waiting for pod to complete")
+		err = e2epod.WaitForPodSuccessInNamespaceTimeout(ctx, oc.KubeClient(), pod.Name, namespace, 1*time.Minute)
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		g.By("Verifying pod completed successfully")
+		pod, err = oc.KubeClient().CoreV1().Pods(namespace).Get(context.Background(), pod.Name, metav1.GetOptions{})
+		o.Expect(err).NotTo(o.HaveOccurred())
+		o.Expect(pod.Status.Phase).To(o.Equal(corev1.PodSucceeded))
+	})
+})

test/extended/util/image/image.go

@@ -58,6 +58,9 @@ var (
 
 		// used by KubeVirt test to start fedora VMs
 		"quay.io/kubevirt/fedora-with-test-tooling-container-disk:20241024_891122a6fc": -1,
+
+		// used by zstd:chunked test
+		"quay.io/crio/busybox:zstd-chunked": -1,
 	}
 )
 

test/extended/util/image/zz_generated.txt

@@ -1,5 +1,6 @@
 # This file is generated by hack/update-generated.sh
 docker.io/library/registry:2.8.0-beta.1 quay.io/openshift/community-e2e-images:e2e-docker-io-library-registry-2-8-0-beta-1-8x_YFKSuz9Xw6lZD
+quay.io/crio/busybox:zstd-chunked quay.io/openshift/community-e2e-images:e2e-quay-io-crio-busybox-zstd-chunked-tGTlEaDfd20SmOkh
 quay.io/kubevirt/fedora-with-test-tooling-container-disk:20241024_891122a6fc quay.io/openshift/community-e2e-images:e2e-quay-io-kubevirt-fedora-with-test-tooling-container-disk-20241024_891122a6fc-IycYTh-87XrXse4E
 quay.io/openshifttest/ldap:1.2 quay.io/openshift/community-e2e-images:e2e-quay-io-openshifttest-ldap-1-2-O3f5zPgtmWzEtasv
 quay.io/openshifttest/multicast:1.1 quay.io/openshift/community-e2e-images:e2e-quay-io-openshifttest-multicast-1-1-XSI8Fm3bAh556UCx