Andres Martinez Gotor
111 lines
3.3 KiB
Go
111 lines
3.3 KiB
Go
package plugincheck
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
sysruntime "runtime"
|
|
|
|
"github.com/Masterminds/semver/v3"
|
|
advisor "github.com/grafana/grafana/apps/advisor/pkg/apis/advisor/v0alpha1"
|
|
"github.com/grafana/grafana/apps/advisor/pkg/app/checks"
|
|
"github.com/grafana/grafana/pkg/cmd/grafana-cli/services"
|
|
"github.com/grafana/grafana/pkg/plugins/repo"
|
|
"github.com/grafana/grafana/pkg/services/pluginsintegration/managedplugins"
|
|
"github.com/grafana/grafana/pkg/services/pluginsintegration/plugininstaller"
|
|
"github.com/grafana/grafana/pkg/services/pluginsintegration/pluginstore"
|
|
)
|
|
|
|
func New(
|
|
pluginStore pluginstore.Store,
|
|
pluginRepo repo.Service,
|
|
pluginPreinstall plugininstaller.Preinstall,
|
|
managedPlugins managedplugins.Manager,
|
|
) checks.Check {
|
|
return &check{
|
|
PluginStore: pluginStore,
|
|
PluginRepo: pluginRepo,
|
|
PluginPreinstall: pluginPreinstall,
|
|
ManagedPlugins: managedPlugins,
|
|
}
|
|
}
|
|
|
|
type check struct {
|
|
PluginStore pluginstore.Store
|
|
PluginRepo repo.Service
|
|
PluginPreinstall plugininstaller.Preinstall
|
|
ManagedPlugins managedplugins.Manager
|
|
}
|
|
|
|
func (c *check) Type() string {
|
|
return "plugin"
|
|
}
|
|
|
|
func (c *check) Run(ctx context.Context, _ *advisor.CheckSpec) (*advisor.CheckV0alpha1StatusReport, error) {
|
|
ps := c.PluginStore.Plugins(ctx)
|
|
|
|
errs := []advisor.CheckReportError{}
|
|
for _, p := range ps {
|
|
// Skip if it's a core plugin
|
|
if p.IsCorePlugin() {
|
|
continue
|
|
}
|
|
|
|
// Check if plugin is deprecated
|
|
i, err := c.PluginRepo.PluginInfo(ctx, p.ID)
|
|
if err != nil {
|
|
continue
|
|
}
|
|
if i.Status == "deprecated" {
|
|
errs = append(errs, advisor.CheckReportError{
|
|
Severity: advisor.CheckReportErrorSeverityHigh,
|
|
Reason: fmt.Sprintf("Plugin deprecated: %s", p.ID),
|
|
Action: "Check the <a href='https://grafana.com/legal/plugin-deprecation/#a-plugin-i-use-is-deprecated-what-should-i-do' target=_blank>documentation</a> for recommended steps.",
|
|
})
|
|
}
|
|
|
|
// Check if plugin has a newer version, only if it's not managed or pinned
|
|
if c.isManaged(ctx, p.ID) || c.PluginPreinstall.IsPinned(p.ID) {
|
|
continue
|
|
}
|
|
compatOpts := repo.NewCompatOpts(services.GrafanaVersion, sysruntime.GOOS, sysruntime.GOARCH)
|
|
info, err := c.PluginRepo.GetPluginArchiveInfo(ctx, p.ID, "", compatOpts)
|
|
if err != nil {
|
|
continue
|
|
}
|
|
if hasUpdate(p, info) {
|
|
errs = append(errs, advisor.CheckReportError{
|
|
Severity: advisor.CheckReportErrorSeverityLow,
|
|
Reason: fmt.Sprintf("New version available for %s", p.ID),
|
|
Action: fmt.Sprintf(
|
|
"Go to the <a href='/plugins/%s?page=version-history'>plugin admin page</a>"+
|
|
" and upgrade to the latest version.", p.ID),
|
|
})
|
|
}
|
|
}
|
|
|
|
return &advisor.CheckV0alpha1StatusReport{
|
|
Count: int64(len(ps)),
|
|
Errors: errs,
|
|
}, nil
|
|
}
|
|
|
|
func hasUpdate(current pluginstore.Plugin, latest *repo.PluginArchiveInfo) bool {
|
|
// If both versions are semver-valid, compare them
|
|
v1, err1 := semver.NewVersion(current.Info.Version)
|
|
v2, err2 := semver.NewVersion(latest.Version)
|
|
if err1 == nil && err2 == nil {
|
|
return v1.LessThan(v2)
|
|
}
|
|
// In other case, assume that a different latest version will always be newer
|
|
return current.Info.Version != latest.Version
|
|
}
|
|
|
|
func (c *check) isManaged(ctx context.Context, pluginID string) bool {
|
|
for _, managedPlugin := range c.ManagedPlugins.ManagedPlugins(ctx) {
|
|
if managedPlugin == pluginID {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|