inventory_plugins

Author: AlexanderGrooff

pkg/config/config.go

@@ -11,18 +11,23 @@ import (
 
 // Config holds all configuration settings
 type Config struct {
-	Logging             LoggingConfig             `mapstructure:"logging"`
-	ExecutionMode       string                    `mapstructure:"execution_mode"`
-	Executor            string                    `mapstructure:"executor"` // "local" or "temporal"
-	Temporal            TemporalConfig            `mapstructure:"temporal"`
-	API                 APIConfig                 `mapstructure:"api"`
-	Daemon              DaemonConfig              `mapstructure:"daemon"`
-	Revert              bool                      `mapstructure:"revert"`
-	Tags                TagsConfig                `mapstructure:"tags"`
-	Facts               map[string]interface{}    `mapstructure:"facts"`
-	HostKeyChecking     bool                      `mapstructure:"host_key_checking"`
-	RolesPath           string                    `mapstructure:"roles_path"` // Colon-delimited paths to search for roles
-	Inventory           string                    `mapstructure:"inventory"`  // Colon-delimited paths to search for inventory files
+	Logging         LoggingConfig          `mapstructure:"logging"`
+	ExecutionMode   string                 `mapstructure:"execution_mode"`
+	Executor        string                 `mapstructure:"executor"` // "local" or "temporal"
+	Temporal        TemporalConfig         `mapstructure:"temporal"`
+	API             APIConfig              `mapstructure:"api"`
+	Daemon          DaemonConfig           `mapstructure:"daemon"`
+	Revert          bool                   `mapstructure:"revert"`
+	Tags            TagsConfig             `mapstructure:"tags"`
+	Facts           map[string]interface{} `mapstructure:"facts"`
+	HostKeyChecking bool                   `mapstructure:"host_key_checking"`
+	RolesPath       string                 `mapstructure:"roles_path"` // Colon-delimited paths to search for roles
+	Inventory       string                 `mapstructure:"inventory"`  // Colon-delimited paths to search for inventory files
+	// Inventory plugins configuration (Ansible-like behaviour)
+	// Colon-delimited paths to search for inventory plugins (e.g. "./plugins/inventory:/usr/share/ansible/plugins/inventory")
+	InventoryPlugins string `mapstructure:"inventory_plugins"`
+	// List of enabled plugin names/patterns (e.g. ["host_list", "script", "yaml", "monkeypatch_batch_strategy"])
+	EnablePlugins       []string                  `mapstructure:"enable_plugins"`
 	PrivilegeEscalation PrivilegeEscalationConfig `mapstructure:"privilege_escalation"`
 	SSH                 SSHConfig                 `mapstructure:"ssh"`
 
@@ -302,6 +307,9 @@ func setDefaults(v *viper.Viper) {
 
 	// Inventory default
 	v.SetDefault("inventory", "") // Default to empty, SDK will use default inventory
+	// Inventory plugins defaults
+	v.SetDefault("inventory_plugins", "")
+	v.SetDefault("enable_plugins", []string{})
 
 	// PrivilegeEscalation defaults
 	v.SetDefault("privilege_escalation.use_interactive", false) // Default to non-interactive (-u) for SSH sessions

pkg/config/config_test.go

@@ -702,7 +702,20 @@ func LoadInventoryWithPaths(path string, inventoryPaths string, workingDir strin
 					"plugin": pluginName,
 				})
 
-				// Load inventory via plugin
+				// Hint plugin loader about the working directory of this inventory file
+				if pluginConfig == nil {
+					pluginConfig = make(map[string]interface{})
+				}
+				pluginConfig["__spage_cwd"] = filepath.Dir(filePath)
+				// Pass through inventory plugin settings from spage config
+				if cfg != nil {
+					if cfg.InventoryPlugins != "" {
+						pluginConfig["__spage_inventory_plugins"] = cfg.InventoryPlugins
+					}
+					if len(cfg.EnablePlugins) > 0 {
+						pluginConfig["__spage_enable_plugins"] = cfg.EnablePlugins
+					}
+				}
 				pluginInventory, err := pm.LoadInventoryFromPlugin(context.Background(), fmt.Sprintf("%v", pluginName), pluginConfig)
 				if err != nil {
 					return nil, fmt.Errorf("failed to load inventory from plugin %s: %w", pluginName, err)