feat(config): global plugins config

changelog.md

@@ -2,6 +2,7 @@
 
 ### Features
 
+- [#3214](https://github.com/ignite/cli/pull/3214) Global plugins config.
 - [#3142](https://github.com/ignite/cli/pull/3142) Add `ignite network request param-change` command.
 - [#3181](https://github.com/ignite/cli/pull/3181) Addition of `add` `remove` commands for `plugins`
 - [#3184](https://github.com/ignite/cli/pull/3184) Separate `plugins.yml` config file.

ignite/cmd/cmd.go

@@ -28,11 +28,12 @@ import (
 )
 
 const (
-	flagPath       = "path"
-	flagHome       = "home"
-	flagYes        = "yes"
-	flagClearCache = "clear-cache"
-	flagSkipProto  = "skip-proto"
+	flagPath          = "path"
+	flagHome          = "home"
+	flagYes           = "yes"
+	flagClearCache    = "clear-cache"
+	flagSkipProto     = "skip-proto"
+	flagPluginsGlobal = "global"
 
 	checkVersionTimeout = time.Millisecond * 600
 	cacheFileName       = "ignite_cache.db"
@@ -161,6 +162,18 @@ func flagGetClearCache(cmd *cobra.Command) bool {
 	return clearCache
 }
 
+func flagSetPluginsGlobal() *flag.FlagSet {
+	fs := flag.NewFlagSet("", flag.ContinueOnError)
+	fs.BoolP(flagPluginsGlobal, "g", false, "use global plugins configuration"+
+		" ($HOME/.ignite/plugins/plugins.yml)")
+	return fs
+}
+
+func flagGetPluginsGlobal(cmd *cobra.Command) bool {
+	global, _ := cmd.Flags().GetBool(flagPluginsGlobal)
+	return global
+}
+
 func newChainWithHomeFlags(cmd *cobra.Command, chainOption ...chain.Option) (*chain.Chain, error) {
 	// Check if custom home is provided
 	if home := getHome(cmd); home != "" {

ignite/cmd/plugin.go

@@ -19,29 +19,45 @@ import (
 	"github.com/ignite/cli/ignite/services/plugin"
 )
 
-// plugins hold the list of plugin declared in the config.
-// A global variable is used so the list is accessible to the plugin commands.
-var plugins []*plugin.Plugin
-
 const (
 	igniteCmdPrefix = "ignite "
 )
 
-// LoadPlugins tries to load all the plugins found in configuration.
-// If no configuration found, it returns w/o error.
+// plugins hold the list of plugin declared in the config.
+// A global variable is used so the list is accessible to the plugin commands.
+var plugins []*plugin.Plugin
+
+// LoadPlugins tries to load all the plugins found in configurations.
+// If no configurations found, it returns w/o error.
 func LoadPlugins(ctx context.Context, rootCmd *cobra.Command) error {
-	cfg, err := parseLocalPlugins(rootCmd)
-	if err != nil {
-		// if binary is run where there is no plugins.yml, don't load
+	pluginsConfigs := make([]pluginsconfig.Plugin, 0)
+
+	localCfg, err := parseLocalPlugins(rootCmd)
+	if err != nil && !errors.As(err, &cosmosanalysis.ErrPathNotChain{}) {
+		fmt.Printf("error parsing local chain plugins config: %s", err.Error())
 		return nil
+
+	} else if err == nil {
+		pluginsConfigs = append(pluginsConfigs, localCfg.Plugins...)
 	}
 
-	// TODO: parse global config
+	globalCfg, err := parseGlobalPlugins()
+	if err == nil {
+		pluginsConfigs = append(pluginsConfigs, globalCfg.Plugins...)
+	}
 
-	plugins, err = plugin.Load(ctx, cfg)
+	if len(pluginsConfigs) == 0 {
+		return nil
+	}
+
+	uniquePlugins := plugin.RemoveDuplicates(pluginsConfigs)
+	plugins, err = plugin.Load(ctx, uniquePlugins)
 	if err != nil {
 		return err
+	} else if len(plugins) == 0 {
+		return nil
 	}
+
 	return loadPlugins(rootCmd, plugins)
 }
 
@@ -62,6 +78,23 @@ func parseLocalPlugins(cmd *cobra.Command) (*pluginsconfig.Config, error) {
 	return pluginsconfig.ParseDir(wd)
 }
 
+func parseGlobalPlugins() (cfg *pluginsconfig.Config, err error) {
+	globalDir, err := plugin.PluginsPath()
+	if err != nil {
+		return cfg, err
+	}
+
+	cfg, err = pluginsconfig.ParseDir(globalDir)
+	if err != nil {
+		return &pluginsconfig.Config{}, nil
+	}
+
+	for _, p := range cfg.Plugins {
+		p.Global = true
+	}
+	return
+}
+
 func loadPlugins(rootCmd *cobra.Command, plugins []*plugin.Plugin) error {
 	// Link plugins to related commands
 	var loadErrors []string
@@ -373,8 +406,8 @@ func NewPluginUpdate() *cobra.Command {
 func NewPluginAdd() *cobra.Command {
 	cmdPluginAdd := &cobra.Command{
 		Use:   "add [path] [key=value]...",
-		Short: "Adds a plugin declaration to a chain's plugin configuration",
-		Long: `Adds a plugin declaration to a chain's plugin configuration.
+		Short: "Adds a plugin declaration to a plugin configuration",
+		Long: `Adds a plugin declaration to a plugin configuration.
 Respects key value pairs declared after the plugin path to be added to the
 generated configuration definition.
 Example:
@@ -384,7 +417,17 @@ Example:
 			session := cliui.New(cliui.WithStdout(os.Stdout))
 			defer session.End()
 
-			conf, err := parseLocalPlugins(cmd)
+			var (
+				conf *pluginsconfig.Config
+				err  error
+			)
+
+			global := flagGetPluginsGlobal(cmd)
+			if global {
+				conf, err = parseGlobalPlugins()
+			} else {
+				conf, err = parseLocalPlugins(cmd)
+			}
 			if err != nil {
 				return err
 			}
@@ -395,9 +438,11 @@ Example:
 				}
 			}
 
+			fmt.Println(global)
 			p := pluginsconfig.Plugin{
-				Path: args[0],
-				With: make(map[string]string),
+				Path:   args[0],
+				With:   make(map[string]string),
+				Global: global,
 			}
 
 			var pluginArgs []string
@@ -432,6 +477,9 @@ Example:
 			return nil
 		},
 	}
+
+	cmdPluginAdd.Flags().AddFlagSet(flagSetPluginsGlobal())
+
 	return cmdPluginAdd
 }
 
@@ -444,7 +492,17 @@ func NewPluginRemove() *cobra.Command {
 		RunE: func(cmd *cobra.Command, args []string) error {
 			s := cliui.New(cliui.WithStdout(os.Stdout))
 
-			conf, err := parseLocalPlugins(cmd)
+			var (
+				conf *pluginsconfig.Config
+				err  error
+			)
+
+			global := flagGetPluginsGlobal(cmd)
+			if global {
+				conf, err = parseGlobalPlugins()
+			} else {
+				conf, err = parseLocalPlugins(cmd)
+			}
 			if err != nil {
 				return err
 			}
@@ -461,10 +519,14 @@ func NewPluginRemove() *cobra.Command {
 			}
 
 			s.Printf("%s %s removed\n", icons.OK, args[0])
+			s.Printf("\t%s updated\n", conf.Path())
 
 			return nil
 		},
 	}
+
+	cmdPluginRemove.Flags().AddFlagSet(flagSetPluginsGlobal())
+
 	return cmdPluginRemove
 }
 
@@ -552,12 +614,22 @@ func printPlugins(session *cliui.Session) error {
 			hookCount = len(manifest.Hooks)
 			cmdCount  = len(manifest.Commands)
 		)
-		return fmt.Sprintf("%s Loaded 🪝%d 💻%d", icons.OK, hookCount, cmdCount)
+
+		return fmt.Sprintf("%s Loaded: 🪝%d 💻%d", icons.OK, hookCount, cmdCount)
 	}
+
+	installedStatus := func(p *plugin.Plugin) string {
+		installed := "local"
+		if p.IsGlobal() {
+			installed = "global"
+		}
+		return installed
+	}
+
 	for _, p := range plugins {
-		entries = append(entries, []string{p.Path, buildStatus(p)})
+		entries = append(entries, []string{p.Path, buildStatus(p), installedStatus(p)})
 	}
-	if err := session.PrintTable([]string{"Path", "Status"}, entries...); err != nil {
+	if err := session.PrintTable([]string{"Path", "Status", "Config"}, entries...); err != nil {
 		return fmt.Errorf("error while printing plugins: %w", err)
 	}
 	return nil

ignite/config/config.go

@@ -1,20 +1,9 @@
 package config
 
 import (
-	"os"
-
+	"github.com/ignite/cli/ignite/pkg/env"
 	"github.com/ignite/cli/ignite/pkg/xfilepath"
 )
 
 // DirPath returns the path of configuration directory of Ignite.
-var DirPath = xfilepath.JoinFromHome(xfilepath.Path(".ignite"))
-
-// CreateConfigDir creates config directory if it is not created yet.
-func CreateConfigDir() error {
-	path, err := DirPath()
-	if err != nil {
-		return err
-	}
-
-	return os.MkdirAll(path, 0o755)
-}
+var DirPath = xfilepath.Mkdir(env.ConfigDir())

ignite/config/plugins/config.go

@@ -36,6 +36,9 @@ type Plugin struct {
 	Path string `yaml:"path"`
 	// With holds arguments passed to the plugin interface
 	With map[string]string `yaml:"with,omitempty"`
+	// Global holds whether the plugin is installed globally
+	// (default: $HOME/.ignite/plugins/plugins.yml) or locally for a chain.
+	Global bool `yaml:"global,omitempty"`
 }
 
 // Path return the path of the config file.

ignite/pkg/env/env.go

@@ -1,11 +1,37 @@
 package env
 
-import "os"
+import (
+	"fmt"
+	"os"
+	"path"
+
+	"github.com/ignite/cli/ignite/pkg/xfilepath"
+)
 
 const (
-	debug = "IGNT_DEBUG"
+	debug     = "IGNT_DEBUG"
+	configDir = "IGNT_CONFIG_DIR"
 )
 
 func DebugEnabled() bool {
 	return os.Getenv(debug) == "1"
 }
+
+func ConfigDir() xfilepath.PathRetriever {
+	return func() (string, error) {
+		if dir := os.Getenv(configDir); dir != "" {
+			if !path.IsAbs(dir) {
+				panic(fmt.Sprintf("%s must be an absolute path", configDir))
+			}
+			return dir, nil
+		}
+		return xfilepath.JoinFromHome(xfilepath.Path(".ignite"))()
+	}
+}
+
+func SetConfigDir(dir string) {
+	err := os.Setenv(configDir, dir)
+	if err != nil {
+		panic(fmt.Sprintf("set config dir env: %v", err))
+	}
+}

ignite/pkg/xfilepath/xfilepath.go

@@ -26,19 +26,18 @@ func PathWithError(path string, err error) PathRetriever {
 // The returned path retriever eventually returns the error from the first provided path retrievers
 // that returns a non-nil error.
 func Join(paths ...PathRetriever) PathRetriever {
-	var components []string
-	var err error
-	for _, path := range paths {
-		var component string
-		component, err = path()
-		if err != nil {
-			break
-		}
-		components = append(components, component)
-	}
-	path := filepath.Join(components...)
-
 	return func() (string, error) {
+		var components []string
+		var err error
+		for _, path := range paths {
+			var component string
+			component, err = path()
+			if err != nil {
+				break
+			}
+			components = append(components, component)
+		}
+		path := filepath.Join(components...)
 		return path, err
 	}
 }
@@ -52,18 +51,29 @@ func JoinFromHome(paths ...PathRetriever) PathRetriever {
 // List returns a paths retriever from a list of path retrievers.
 // The returned paths retriever eventually returns the error from the first provided path retrievers that returns a non-nil error.
 func List(paths ...PathRetriever) PathsRetriever {
-	var list []string
-	var err error
-	for _, path := range paths {
-		var resolved string
-		resolved, err = path()
-		if err != nil {
-			break
+	return func() ([]string, error) {
+		var list []string
+		var err error
+		for _, path := range paths {
+			var resolved string
+			resolved, err = path()
+			if err != nil {
+				break
+			}
+			list = append(list, resolved)
 		}
-		list = append(list, resolved)
-	}
 
-	return func() ([]string, error) {
 		return list, err
 	}
 }
+
+// Mkdir ensure path exists before returning it.
+func Mkdir(path PathRetriever) PathRetriever {
+	return func() (string, error) {
+		p, err := path()
+		if err != nil {
+			return "", err
+		}
+		return p, os.MkdirAll(p, 0o755)
+	}
+}