grafana/pkg/plugins/pfs/decl_parser.go

package pfs

import (
	"fmt"
	"io/fs"
	"log"
	"os"
	"path/filepath"
	"sort"

	"github.com/grafana/grafana/pkg/kindsys"
	"github.com/grafana/thema"
)

type declParser struct {
	rt   *thema.Runtime
	skip map[string]bool
}

func NewDeclParser(rt *thema.Runtime, skip map[string]bool) *declParser {
	return &declParser{
		rt:   rt,
		skip: skip,
	}
}

func (psr *declParser) Parse(root fs.FS) ([]*PluginDecl, error) {
	plugins, err := fs.Glob(root, "**/**/plugin.json")
	if err != nil {
		return nil, fmt.Errorf("error finding plugin dirs: %w", err)
	}

	decls := make([]*PluginDecl, 0)
	for _, plugin := range plugins {
		path := filepath.Dir(plugin)
		base := filepath.Base(path)
		if skip, ok := psr.skip[base]; ok && skip {
			continue
		}

		dir := os.DirFS(path)
		ptree, err := ParsePluginFS(dir, psr.rt)
		if err != nil {
			log.Println(fmt.Errorf("parsing plugin failed for %s: %s", dir, err))
			continue
		}

		p := ptree.RootPlugin()
		slots := p.SlotImplementations()

		if len(slots) == 0 {
			decls = append(decls, EmptyPluginDecl(path, p.Meta()))
			continue
		}

		for slotName, lin := range slots {
			slot, err := kindsys.FindSchemaInterface(slotName)
			if err != nil {
				log.Println(fmt.Errorf("parsing plugin failed for %s: %s", dir, err))
				continue
			}
			decls = append(decls, &PluginDecl{
				SchemaInterface: &slot,
				Lineage:         lin,
				Imports:         p.CUEImports(),
				PluginMeta:      p.Meta(),
				PluginPath:      path,
			})
		}
	}

	sort.Slice(decls, func(i, j int) bool {
		return decls[i].PluginPath < decls[j].PluginPath
	})

	return decls, nil
}