OPRUN-3692: Olmv1-catalogd tests for API endpoints

Introduces tests for the new `api/v1/metas` endpoint when
NewOLMCatalogdAPIV1Metas feature gate in enabled.

Author: anik120

test/extended/olm/olmv1.go

@@ -2,8 +2,10 @@ package operators
 
 import (
 	"context"
+	"crypto/tls"
 	"encoding/json"
 	"fmt"
+	"net/http"
 	"os"
 	"path/filepath"
 	"strings"
@@ -71,7 +73,7 @@ var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM] OLMv1 CRDs", func() {
 	})
 })
 
-var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM][Skipped:Disconnected] OLMv1 Catalogs", func() {
+var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM][Skipped:Disconnected] OLMv1 default Catalogs", func() {
 	defer g.GinkgoRecover()
 	oc := exutil.NewCLIWithoutNamespace("default")
 
@@ -99,6 +101,43 @@ var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM][Skipped:Disconnected] OLM
 	})
 })
 
+var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM][Skipped:Disconnected] OLMv1 Catalog's /v1/api/all endpoint", func() {
+	defer g.GinkgoRecover()
+	oc := exutil.NewCLIWithoutNamespace("default")
+
+	g.It("should serve FBC", func(ctx g.SpecContext) {
+		checkFeatureCapability(ctx, oc)
+
+		// Start port-forward in background
+		_, _, _, err := oc.AsAdmin().Run("port-forward").Args("-n", "openshift-catalogd", "svc/catalogd-service", "8080:443").Background()
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		// Wait for port-forward to be established
+		time.Sleep(2 * time.Second)
+
+		g.By("Testing /api/v1/all endpoint for catalog openshift-community-operators")
+		verifyAPIEndpoint(ctx, "https://localhost:8080/catalogs/openshift-community-operators/api/v1/all")
+	})
+})
+
+var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLMCatalogdAPIV1Metas][Skipped:Disconnected] OLMv1 Catalog's /v1/api/metas endpoint", func() {
+	defer g.GinkgoRecover()
+	oc := exutil.NewCLIWithoutNamespace("default")
+	g.It(" should serve the /v1/api/metas API endpoint", func(ctx g.SpecContext) {
+		checkFeatureCapability(ctx, oc)
+
+		// Start port-forward in background
+		_, _, _, err := oc.AsAdmin().Run("port-forward").Args("-n", "openshift-catalogd", "svc/catalogd-service", "8443:443").Background()
+		o.Expect(err).NotTo(o.HaveOccurred())
+
+		// Wait for port-forward to be established
+		time.Sleep(2 * time.Second)
+
+		g.By("Testing api/v1/metas endpoint for catalog openshift-community-operators")
+		verifyAPIEndpoint(ctx, "https://localhost:8443/catalogs/openshift-community-operators/api/v1/metas?schema=olm.package")
+	})
+})
+
 var _ = g.Describe("[sig-olmv1][OCPFeatureGate:NewOLM][Skipped:Disconnected] OLMv1 New Catalog Install", func() {
 	defer g.GinkgoRecover()
 
@@ -419,3 +458,47 @@ func checkFeatureCapability(ctx context.Context, oc *exutil.CLI) {
 		g.Skip("Test only runs with OperatorLifecycleManagerV1 capability")
 	}
 }
+
+// verifyAPIEndpoint tests that an API endpoint is accessible and returns valid JSON
+func verifyAPIEndpoint(ctx g.SpecContext, urlPath string) {
+	var lastError error
+
+	// Retry API call a few times to handle potential connection issues
+	err := wait.PollUntilContextTimeout(ctx, 2*time.Second, 30*time.Second, true,
+		func(ctx context.Context) (bool, error) {
+			// Create a custom HTTP client that skips TLS verification
+			tr := &http.Transport{
+				TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+			}
+			client := &http.Client{Transport: tr}
+
+			resp, err := client.Get(urlPath)
+			if err != nil {
+				lastError = err
+				return false, nil
+			}
+			defer resp.Body.Close()
+
+			// Check status code
+			if resp.StatusCode != http.StatusOK {
+				lastError = fmt.Errorf("unexpected status code: %d", resp.StatusCode)
+				return false, nil
+			}
+
+			// Try to parse response as JSON to verify it's valid
+			var result interface{}
+			decoder := json.NewDecoder(resp.Body)
+			if err := decoder.Decode(&result); err != nil {
+				lastError = fmt.Errorf("failed to parse JSON response: %v", err)
+				return false, nil
+			}
+
+			return true, nil
+		})
+
+	if err != nil {
+		g.Fail(fmt.Sprintf("API endpoint %s is not accessible: %v (last error: %v)", urlPath, err, lastError))
+	}
+
+	g.GinkgoLogr.Info(fmt.Sprintf("Successfully verified API endpoint: %s", urlPath))
+}