test/e2e: Refactor VerifyImagePullTimer

Refactor out the logic that checks if the image pull timing,
to make the assessment_runner flow cleaner.

Signed-off-by: stevenhorsman <steven@uk.ibm.com>

src/cloud-api-adaptor/test/e2e/assessment_helpers.go

@@ -299,6 +299,20 @@ func VerifyNydusSnapshotter(ctx context.Context, t *testing.T, client klient.Cli
 	return nil
 }
 
+func VerifyImagePullTimer(ctx context.Context, t *testing.T, client klient.Client, pod *v1.Pod) error {
+	caaPod, err := getCaaPod(ctx, client, t)
+	if err != nil {
+		return fmt.Errorf("VerifyImagePullTimer: failed to getCaaPod: %v", err)
+	}
+
+	imagePullTime, err := WatchImagePullTime(ctx, client, caaPod, pod)
+	if err != nil {
+		return fmt.Errorf("VerifyImagePullTimer: WatchImagePullTime failed with %v", err)
+	}
+	t.Logf("Time Taken to pull 4GB Image: %s", imagePullTime)
+	return nil
+}
+
 func GetNodeNameFromPod(ctx context.Context, client klient.Client, customPod *v1.Pod) (string, error) {
 	var getNodeName = func(ctx context.Context, client klient.Client, pod *v1.Pod) (string, error) {
 		return pod.Spec.NodeName, nil

src/cloud-api-adaptor/test/e2e/assessment_runner.go

@@ -334,18 +334,9 @@ func (tc *TestCase) Run() {
 
 			if tc.pod != nil {
 				if tc.imagePullTimer {
-					if err := client.Resources("confidential-containers-system").List(ctx, &podlist); err != nil {
-						t.Fatal(err)
-					}
-					for _, caaPod := range podlist.Items {
-						if caaPod.Labels["app"] == "cloud-api-adaptor" {
-							imagePullTime, err := WatchImagePullTime(ctx, client, &caaPod, tc.pod)
-							if err != nil {
-								t.Fatal(err)
-							}
-							t.Logf("Time Taken to pull 4GB Image: %s", imagePullTime)
-							break
-						}
+					err := VerifyImagePullTimer(ctx, t, client, tc.pod)
+					if err != nil {
+						t.Error(err)
 					}
 				}