test(e2e): add sha256 verification by task ID in containerd/proxy tests

- Add SHA256 verification via task ID alongside existing output-path
  checks
- Sleep 1s before seed client pod init to allow task propagation
- Verify task ID hash matches expected value in containerd and proxy
  tests
- Use `CalculateSha256ByTaskID` with hardcoded task ID in containerd
  test
- Add `WithTaskIDTag("proxy-bytes-100")` tag when computing task ID in
  proxy test

Signed-off-by: Gaius <gaius.qi@gmail.com>

Author: gaius-qi

test/e2e/containerd_test.go

@@ -18,6 +18,7 @@ package e2e
 
 import (
 	"fmt"
+	"time"
 
 	. "github.com/onsi/ginkgo/v2" //nolint
 	. "github.com/onsi/gomega"    //nolint
@@ -71,6 +72,18 @@ var _ = Describe("Containerd with CRI support", func() {
 				Expect(err).NotTo(HaveOccurred())
 				Expect(taskMetadata.Sha256).To(Equal(sha256sum))
 			}
+
+			time.Sleep(1 * time.Second)
+			seedClientPods := make([]*util.PodExec, 3)
+			for i := range 3 {
+				seedClientPods[i], err = util.SeedClientExec(i)
+				fmt.Println(err)
+				Expect(err).NotTo(HaveOccurred())
+			}
+
+			sha256sum, err := util.CalculateSha256ByTaskID(seedClientPods, "99f960a3d990bc51293c661d50aa89af1467e4dbc17525812e3c85cc98a3ed46")
+			Expect(err).NotTo(HaveOccurred())
+			Expect("99f960a3d990bc51293c661d50aa89af1467e4dbc17525812e3c85cc98a3ed46").To(Equal(sha256sum))
 		})
 
 		It("rmi should be ok", Label("containerd", "rmi"), func() {

test/e2e/proxy_test.go

@@ -287,7 +287,11 @@ var _ = Describe("Download Using Proxy", func() {
 			Expect(err).NotTo(HaveOccurred())
 			fmt.Println(string(out))
 
-			sha256sum, err := util.CalculateSha256ByOutput([]*util.PodExec{clientPod}, testFile.GetOutputPath())
+			sha256sum, err := util.CalculateSha256ByTaskID([]*util.PodExec{clientPod}, testFile.GetTaskID(util.WithTaskIDTag("proxy-bytes-100")))
+			Expect(err).NotTo(HaveOccurred())
+			Expect(testFile.GetSha256()).To(Equal(sha256sum))
+
+			sha256sum, err = util.CalculateSha256ByOutput([]*util.PodExec{clientPod}, testFile.GetOutputPath())
 			Expect(err).NotTo(HaveOccurred())
 			got, err := testFile.GetRangeSha256("-100", testFile.GetInfo().Size())
 			Expect(err).NotTo(HaveOccurred())