move OIDCDiscoveryData to api/

Signed-off-by: Tim Ramlot <42113979+inteon@users.noreply.github.com>

Author: inteon

api/datareading.go

@@ -130,14 +130,14 @@ func (v *GatheredResource) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
-// DynamicData is the DataReading.Data returned by the k8s.DataGathererDynamic
+// DynamicData is the DataReading.Data returned by the k8sdynamic.DataGathererDynamic
 // gatherer
 type DynamicData struct {
 	// Items is a list of GatheredResource
 	Items []*GatheredResource `json:"items"`
 }
 
-// DiscoveryData is the DataReading.Data returned by the k8s.ConfigDiscovery
+// DiscoveryData is the DataReading.Data returned by the k8sdiscovery.DataGathererDiscovery
 // gatherer
 type DiscoveryData struct {
 	// ClusterID is the unique ID of the Kubernetes cluster which this snapshot was taken from.
@@ -149,3 +149,18 @@ type DiscoveryData struct {
 	// See https://godoc.org/k8s.io/apimachinery/pkg/version#Info
 	ServerVersion *version.Info `json:"server_version"`
 }
+
+// OIDCDiscoveryData is the DataReading.Data returned by the oidc.OIDCDiscovery
+// gatherer
+type OIDCDiscoveryData struct {
+	// OIDCConfig contains OIDC configuration data from the API server's
+	// `/.well-known/openid-configuration` endpoint
+	OIDCConfig map[string]any `json:"openid_configuration,omitempty"`
+	// OIDCConfigError contains any error encountered while fetching the OIDC configuration
+	OIDCConfigError string `json:"openid_configuration_error,omitempty"`
+
+	// JWKS contains JWKS data from the API server's `/openid/v1/jwks` endpoint
+	JWKS map[string]any `json:"jwks,omitempty"`
+	// JWKSError contains any error encountered while fetching the JWKS
+	JWKSError string `json:"jwks_error,omitempty"`
+}

pkg/datagatherer/oidc/oidc.go

@@ -7,6 +7,7 @@ import (
 
 	"k8s.io/client-go/rest"
 
+	"github.com/jetstack/preflight/api"
 	"github.com/jetstack/preflight/pkg/datagatherer"
 	"github.com/jetstack/preflight/pkg/kubeconfig"
 )
@@ -73,21 +74,14 @@ func (g *DataGathererOIDC) Fetch() (any, int, error) {
 		return ""
 	}
 
-	return OIDCDiscoveryData{
+	return api.OIDCDiscoveryData{
 		OIDCConfig:      oidcResponse,
 		OIDCConfigError: errToString(oidcErr),
 		JWKS:            jwksResponse,
 		JWKSError:       errToString(jwksErr),
 	}, 1 /* we have 1 result, so return 1 as count */, nil
 }
 
-type OIDCDiscoveryData struct {
-	OIDCConfig      map[string]any `json:"openid_configuration,omitempty"`
-	OIDCConfigError string         `json:"openid_configuration_error,omitempty"`
-	JWKS            map[string]any `json:"jwks,omitempty"`
-	JWKSError       string         `json:"jwks_error,omitempty"`
-}
-
 func (g *DataGathererOIDC) fetchOIDCConfig(ctx context.Context) (map[string]any, error) {
 	// Fetch the OIDC discovery document from the well-known endpoint.
 	bytes, err := g.cl.Get().AbsPath("/.well-known/openid-configuration").Do(ctx).Raw()

pkg/datagatherer/oidc/oidc_test.go

@@ -6,6 +6,7 @@ import (
 	"net/url"
 	"testing"
 
+	"github.com/jetstack/preflight/api"
 	"k8s.io/client-go/discovery"
 	"k8s.io/client-go/rest"
 )
@@ -55,7 +56,7 @@ func TestFetch_Success(t *testing.T) {
 		t.Fatalf("expected count 1, got %d", count)
 	}
 
-	res, ok := anyRes.(OIDCDiscoveryData)
+	res, ok := anyRes.(api.OIDCDiscoveryData)
 	if !ok {
 		t.Fatalf("unexpected result type: %T", anyRes)
 	}
@@ -99,7 +100,7 @@ func TestFetch_Errors(t *testing.T) {
 		t.Fatalf("Fetch returned error: %v", err)
 	}
 
-	res, ok := anyRes.(OIDCDiscoveryData)
+	res, ok := anyRes.(api.OIDCDiscoveryData)
 	if !ok {
 		t.Fatalf("unexpected result type: %T", anyRes)
 	}