pkg/services/pluginsintegration/pluginsources/pluginsources.go - main - githubmirror/grafana

pkg/services/pluginsintegration/pluginsources/pluginsources.go

74 строки2 KB

Andres Martinez Gotor

Plugins: Avoid skipping other plugins directories if one fails to load (#124778)

13 май 2026, 17:19

13 май 2026, 17:190f98a5f

package pluginsources

import (
	"context"
	"path/filepath"

	"github.com/grafana/grafana/pkg/plugins"
	"github.com/grafana/grafana/pkg/plugins/config"
	"github.com/grafana/grafana/pkg/plugins/log"
	"github.com/grafana/grafana/pkg/plugins/manager/sources"
	"github.com/grafana/grafana/pkg/setting"
)

type Service struct {
	cfg            *config.PluginManagementCfg
	staticRootPath string

	log log.Logger
}

func ProvideService(cfg *setting.Cfg, pCcfg *config.PluginManagementCfg) *Service {
	return &Service{
		cfg:            pCcfg,
		staticRootPath: cfg.StaticRootPath,
		log:            log.New("plugin.sources"),
	}
}

func (s *Service) List(_ context.Context) []plugins.PluginSource {
	r := []plugins.PluginSource{ //nolint:prealloc
		sources.NewLocalSource(
			plugins.ClassCore,
			s.corePluginPaths(),
		),
	}
	r = append(r, s.externalPluginSources()...)
	r = append(r, s.pluginSettingSources()...)
	return r
}

func (s *Service) externalPluginSources() []plugins.PluginSource {
	localSrcs := sources.DirAsLocalSources(s.cfg, s.cfg.PluginsPaths, plugins.ClassExternal, s.log)

	srcs := make([]plugins.PluginSource, len(localSrcs))
	for i, src := range localSrcs {
		srcs[i] = src
	}

	return srcs
}

func (s *Service) pluginSettingSources() []plugins.PluginSource {
	srcs := make([]plugins.PluginSource, 0, len(s.cfg.PluginSettings))
	for _, ps := range s.cfg.PluginSettings {
		path, exists := ps["path"]
		if !exists || path == "" {
			continue
		}
		if s.cfg.DevMode {
			srcs = append(srcs, sources.NewUnsafeLocalSource(plugins.ClassExternal, []string{path}))
		} else {
			srcs = append(srcs, sources.NewLocalSource(plugins.ClassExternal, []string{path}))
		}
	}

	return srcs
}

// corePluginPaths provides a list of the Core plugin file system paths
func (s *Service) corePluginPaths() []string {
	datasourcePaths := filepath.Join(s.staticRootPath, "app", "plugins", "datasource")
	panelsPath := filepath.Join(s.staticRootPath, "app", "plugins", "panel")
	return []string{datasourcePaths, panelsPath}
}