mirror of https://github.com/grafana/grafana.git
				
				
				
			
		
			
				
	
	
		
			75 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			Go
		
	
	
	
			
		
		
	
	
			75 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			Go
		
	
	
	
package pfs
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"io/fs"
 | 
						|
	"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,
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// TODO convert this to be the new parser for Tree
 | 
						|
func (psr *declParser) Parse(root fs.FS) ([]*PluginDecl, error) {
 | 
						|
	// TODO remove hardcoded tree structure assumption, work from root of provided fs
 | 
						|
	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)
 | 
						|
		pp, err := ParsePluginFS(dir, psr.rt)
 | 
						|
		if err != nil {
 | 
						|
			return nil, fmt.Errorf("parsing plugin failed for %s: %s", dir, err)
 | 
						|
		}
 | 
						|
 | 
						|
		if len(pp.ComposableKinds) == 0 {
 | 
						|
			decls = append(decls, EmptyPluginDecl(path, pp.Properties))
 | 
						|
			continue
 | 
						|
		}
 | 
						|
 | 
						|
		for slotName, kind := range pp.ComposableKinds {
 | 
						|
			slot, err := kindsys.FindSchemaInterface(slotName)
 | 
						|
			if err != nil {
 | 
						|
				return nil, fmt.Errorf("parsing plugin failed for %s: %s", dir, err)
 | 
						|
			}
 | 
						|
			decls = append(decls, &PluginDecl{
 | 
						|
				SchemaInterface: &slot,
 | 
						|
				Lineage:         kind.Lineage(),
 | 
						|
				Imports:         pp.CUEImports,
 | 
						|
				PluginMeta:      pp.Properties,
 | 
						|
				PluginPath:      path,
 | 
						|
				KindDecl:        kind.Decl(),
 | 
						|
			})
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	sort.Slice(decls, func(i, j int) bool {
 | 
						|
		return decls[i].PluginPath < decls[j].PluginPath
 | 
						|
	})
 | 
						|
 | 
						|
	return decls, nil
 | 
						|
}
 |