fix

Signed-off-by: Charles-Edouard Brétéché <charles.edouard@nirmata.com>

pkg/openapiclient/local_crds.go

@@ -52,9 +52,10 @@ func (k *localCRDsClient) Paths() (map[string]openapi.GroupVersion, error) {
 	for _, current := range k.fileSystems {
 		files, err := fs.ReadDir(current, ".")
 		if err != nil {
-			return nil, fmt.Errorf("error listing %s: %w", current, err)
+			if crossPlatformCheckDirExists(current, ".") {
+				return nil, fmt.Errorf("error listing: %w", err)
+			}
 		}
-
 		for _, f := range files {
 			path := f.Name()
 			if f.IsDir() {

pkg/openapiclient/local_crds_test.go

@@ -95,8 +95,12 @@ func Test_localCRDsClient_Paths(t *testing.T) {
 			),
 		},
 	}, {
-		name:        "invalid fs",
+		name:        "does not exist",
 		fileSystems: []fs.FS{os.DirFS("../../invalid")},
+		want:        map[string]sets.Set[string]{},
+	}, {
+		name:        "not a directory",
+		fileSystems: []fs.FS{os.DirFS("../../testcases/schemas/error_not_a_dir")},
 		wantErr:     true,
 	}}
 	for _, tt := range tests {

pkg/openapiclient/local_schemas.go

@@ -1,9 +1,9 @@
 package openapiclient
 
 import (
-	"errors"
 	"fmt"
 	"io/fs"
+	"os"
 	"path"
 	"strings"
 
@@ -30,16 +30,24 @@ func (k *localSchemasClient) Paths() (map[string]openapi.GroupVersion, error) {
 	if k.fs == nil {
 		return nil, nil
 	}
+	// check if '.' can be listed
+	if _, err := fs.ReadDir(k.fs, "."); err != nil {
+		if crossPlatformCheckDirExists(k.fs, ".") {
+			return nil, fmt.Errorf("error listing %s: %w", ".", err)
+		}
+	}
 	res := map[string]openapi.GroupVersion{}
 	apiGroups, err := fs.ReadDir(k.fs, "apis")
-	if err != nil && !errors.Is(err, fs.ErrNotExist) {
-		return nil, fmt.Errorf("failed reading local files dir %s: %w", "apis", err)
+	if err != nil {
+		if crossPlatformCheckDirExists(k.fs, "apis") {
+			return nil, fmt.Errorf("error listing %s: %w", "apis", err)
+		}
 	}
 	for _, f := range apiGroups {
 		groupPath := path.Join("apis", f.Name())
 		versions, err := fs.ReadDir(k.fs, groupPath)
 		if err != nil {
-			return nil, fmt.Errorf("failed reading local files dir %s: %w", groupPath, err)
+			return nil, fmt.Errorf("error listing %s: %w", groupPath, err)
 		}
 		for _, v := range versions {
 			if !utils.IsJson(v.Name()) {
@@ -51,8 +59,10 @@ func (k *localSchemasClient) Paths() (map[string]openapi.GroupVersion, error) {
 		}
 	}
 	coregroup, err := fs.ReadDir(k.fs, "api")
-	if err != nil && !errors.Is(err, fs.ErrNotExist) {
-		return nil, fmt.Errorf("failed reading local files dir %s: %w", "api", err)
+	if err != nil {
+		if crossPlatformCheckDirExists(k.fs, "api") {
+			return nil, fmt.Errorf("error listing %s: %w", "api", err)
+		}
 	}
 	for _, v := range coregroup {
 		if !utils.IsJson(v.Name()) {
@@ -64,3 +74,11 @@ func (k *localSchemasClient) Paths() (map[string]openapi.GroupVersion, error) {
 	}
 	return res, nil
 }
+
+func crossPlatformCheckDirExists(f fs.FS, path string) bool {
+	_, err := fs.Stat(f, path)
+	if err != nil {
+		return !os.IsNotExist(err)
+	}
+	return true
+}

pkg/openapiclient/local_schemas_test.go

@@ -49,9 +49,8 @@ func TestNewLocalSchemaFiles(t *testing.T) {
 
 func Test_localSchemasClient_Paths(t *testing.T) {
 	tests := []struct {
-		name string
-		fs   fs.FS
-		// dir     string
+		name    string
+		fs      fs.FS
 		want    sets.Set[string]
 		wantErr bool
 	}{{