UPSTREAM: <carry>: [DefaultCatalogTests]: Moving parse of ENVVAR to the caller (follow-up 345)

Author: camilamacedo86

openshift/default-catalog-consistency/pkg/extract/extract.go

@@ -39,7 +39,7 @@ func (r *ExtractedImage) Cleanup() {
 }
 
 // UnpackImage pulls the image, extracts it to disk, and opens it as an OCI store.
-func UnpackImage(ctx context.Context, imageRef, name string) (res *ExtractedImage, err error) {
+func UnpackImage(ctx context.Context, imageRef, name, authPath string) (res *ExtractedImage, err error) {
 	tmpDir, err := os.MkdirTemp("", fmt.Sprintf("oci-%s-", name))
 	if err != nil {
 		return nil, fmt.Errorf("create temp dir: %w", err)
@@ -65,13 +65,13 @@ func UnpackImage(ctx context.Context, imageRef, name string) (res *ExtractedImag
 		//
 		// TODO: Update this to support checking all architectures.
 		// See: https://issues.redhat.com/browse/OPRUN-3793
-		sysCtx := &types.SystemContext{
-			OSChoice: "linux",
-		}
-
-		if authPath := os.Getenv("REGISTRY_AUTH_FILE"); authPath != "" {
+		if authPath == "" {
 			fmt.Println("Using registry auth file:", authPath)
-			sysCtx.AuthFilePath = authPath
+			authPath = os.Getenv("REGISTRY_AUTH_FILE")
+		}
+		sysCtx := &types.SystemContext{
+			OSChoice:     "linux",
+			AuthFilePath: authPath,
 		}
 
 		policyCtx, err := loadPolicyContext(sysCtx, imageRef)

openshift/default-catalog-consistency/test/validate/suite_test.go

@@ -3,6 +3,7 @@ package validate
 import (
 	"context"
 	"fmt"
+	"os"
 	"testing"
 
 	. "github.com/onsi/ginkgo/v2"
@@ -23,6 +24,7 @@ var _ = Describe("Check Catalog Consistency", func() {
 	images, err := utils.ParseImageRefsFromCatalog(catalogsPath)
 	Expect(err).ToNot(HaveOccurred())
 	Expect(images).ToNot(BeEmpty(), "no images found")
+	authPath := os.Getenv("REGISTRY_AUTH_FILE")
 
 	for _, url := range images {
 		name := utils.ImageNameFromRef(url)
@@ -31,7 +33,7 @@ var _ = Describe("Check Catalog Consistency", func() {
 			ctx := context.Background()
 			By(fmt.Sprintf("Validating image: %s", url))
 
-			extractedImage, err := extract.UnpackImage(ctx, url, name)
+			extractedImage, err := extract.UnpackImage(ctx, url, name, authPath)
 			Expect(err).ToNot(HaveOccurred())
 			Expect(check.Check(ctx, extractedImage, check.AllChecks())).To(Succeed())
 			extractedImage.Cleanup()