Fix directory decoding

pkg/envoy/directory/decode.go

@@ -25,8 +25,6 @@ func Decode(ctx context.Context, p string, decoders ...decoder) ([]resource.Inte
 	var (
 		f *os.File
 
-		d decoder
-
 		// decoded nodes
 		dnn []resource.Interface
 
@@ -52,37 +50,37 @@ func Decode(ctx context.Context, p string, decoders ...decoder) ([]resource.Inte
 		}
 		defer f.Close()
 
-		for _, d = range decoders {
-			// find compatible decoder
-			if d.CanDecodeFile(f) {
-				break
+		for _, d := range decoders {
+			if !d.CanDecodeFile(f) {
+				// decoder can not handle this file
+				continue
 			}
-			// Do a fallback for extensions
-			if d.CanDecodeExt(info.Name()) {
-				break
+
+			if !d.CanDecodeExt(info.Name()) {
+				// this decoder can not handle this extension
+				continue
 			}
-		}
-		if d == nil {
-			// no decoder found
+
+			if _, err = f.Seek(0, 0); err != nil {
+				return err
+			}
+
+			dir, fn := path.Split(p)
+			do := &envoy.DecoderOpts{
+				Name: fn,
+				Path: dir,
+			}
+
+			if dnn, err = d.Decode(ctx, f, do); err != nil {
+				return fmt.Errorf("failed to decode %s: %w", info.Name(), err)
+			}
+
+			nn = append(nn, dnn...)
+
+			// found compatible decoder
 			return nil
 		}
 
-		_, err = f.Seek(0, 0)
-		if err != nil {
-			return err
-		}
-
-		dir, fn := path.Split(p)
-		do := &envoy.DecoderOpts{
-			Name: fn,
-			Path: dir,
-		}
-
-		if dnn, err = d.Decode(ctx, f, do); err != nil {
-			return fmt.Errorf("failed to decode %s: %w", info.Name(), err)
-		}
-
-		nn = append(nn, dnn...)
 		return nil
 	})
 }

pkg/envoy/yaml/decoder.go

@@ -17,10 +17,6 @@ type (
 	EnvoyMarshler interface {
 		MarshalEnvoy() ([]resource.Interface, error)
 	}
-
-	nodeDecoder interface {
-		DecodeNodes(ctx context.Context) ([]resource.Interface, error)
-	}
 )
 
 func Decoder() *decoder {
@@ -31,12 +27,16 @@ func Decoder() *decoder {
 //
 // @todo Add support for this; current library is unable to detect this.
 func (y *decoder) CanDecodeFile(f io.Reader) bool {
-	return false
+	// relying on can-decode-ext for now
+	return true
 }
 
-func (y *decoder) CanDecodeExt(ext string) bool {
-	pt := strings.Split(ext, ".")
-	return strings.TrimSpace(pt[len(pt)-1]) == "yaml"
+func (y *decoder) CanDecodeExt(name string) bool {
+	var (
+		pt  = strings.Split(name, ".")
+		ext = strings.TrimSpace(pt[len(pt)-1])
+	)
+	return ext == "yaml" || ext == "yml"
 }
 
 func (y *decoder) Decode(ctx context.Context, r io.Reader, dctx *envoy.DecoderOpts) ([]resource.Interface, error) {