Get config instance

adapter/command/claim-rewards.go → adapter/config/claim-rewards.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"

adapter/command/commands.go → adapter/config/commands.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"

adapter/command/exit.go → adapter/config/exit.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"

adapter/command/generate-deposit-data.go → adapter/config/generate-deposit-data.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"encoding/json"

adapter/command/generate-keys.go → adapter/config/generate-keys.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"

adapter/command/get-node-status.go → adapter/config/get-node-status.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"

adapter/config/he-config.go

@@ -0,0 +1,336 @@
+package config
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/nodeset-org/hyperdrive-stakewise/adapter/config/ids"
+	nativecfg "github.com/nodeset-org/hyperdrive-stakewise/shared/config/ids"
+	hdconfig "github.com/nodeset-org/hyperdrive/modules/config"
+	"github.com/urfave/cli/v2"
+	"gopkg.in/yaml.v3"
+)
+
+const (
+	FloatThreshold float64 = 75.0
+)
+
+type PortMode string
+
+const (
+	PortMode_Closed    PortMode = "closed"
+	PortMode_Localhost PortMode = "localhost"
+	PortMode_External  PortMode = "external"
+)
+
+type ExampleConfig struct {
+	// ExampleBool hdconfig.BoolParameterMetadata
+
+	// ExampleInt hdconfig.IntParameterMetadata
+
+	// ExampleUint hdconfig.UintParameterMetadata
+
+	// ExampleFloat hdconfig.FloatParameterMetadata
+
+	// ExampleString hdconfig.StringParameterMetadata
+
+	// ExampleChoice hdconfig.ChoiceParameterMetadata[nativecfg.ExampleOption]
+
+	SubConfig *SubConfig
+
+	ServerConfig *ServerConfig
+}
+
+func NewExampleConfig() *ExampleConfig {
+	cfg := &ExampleConfig{}
+
+	// // ExampleBool
+	// cfg.ExampleBool.ID = hdconfig.Identifier(ids.ExampleBoolID)
+	// cfg.ExampleBool.Name = "Example Boolean"
+	// cfg.ExampleBool.Description.Default = "This is an example of a boolean parameter. It doesn't directly affect the service, but it does control the behavior of some other config parameters."
+	// cfg.ExampleBool.AffectedContainers = []string{shared.ServiceContainerName}
+	// cfg.ExampleBool.Value = cfg.ExampleBool.Default
+
+	// // ExampleInt
+	// cfg.ExampleInt.ID = hdconfig.Identifier(ids.ExampleIntID)
+	// cfg.ExampleInt.Name = "Example Integer"
+	// cfg.ExampleInt.Description.Default = "This is an example of an integer parameter."
+	// cfg.ExampleInt.AffectedContainers = []string{shared.ServiceContainerName}
+	// cfg.ExampleInt.Value = cfg.ExampleInt.Default
+
+	// // ExampleUint
+	// cfg.ExampleUint.ID = hdconfig.Identifier(ids.ExampleUintID)
+	// cfg.ExampleUint.Name = "Example Unsigned Integer"
+	// cfg.ExampleUint.Description.Default = "This is an example of an unsigned integer parameter."
+	// cfg.ExampleUint.AffectedContainers = []string{shared.ServiceContainerName}
+	// cfg.ExampleUint.Value = cfg.ExampleUint.Default
+
+	// // ExampleFloat
+	// cfg.ExampleFloat.ID = hdconfig.Identifier(ids.ExampleFloatID)
+	// cfg.ExampleFloat.Name = "Example Float"
+	// cfg.ExampleFloat.Description.Default = "This is an example of a float parameter with a minimum and maximum set."
+	// cfg.ExampleFloat.Default = 50
+	// cfg.ExampleFloat.MinValue = 0.0
+	// cfg.ExampleFloat.MaxValue = 100.0
+	// cfg.ExampleFloat.Value = cfg.ExampleFloat.Default
+	// cfg.ExampleFloat.AffectedContainers = []string{shared.ServiceContainerName}
+
+	// // ExampleString
+	// cfg.ExampleString.ID = hdconfig.Identifier(ids.ExampleStringID)
+	// cfg.ExampleString.Name = "Example String"
+	// cfg.ExampleString.Description.Default = "This is an example of a string parameter. It has a max length and regex pattern set."
+	// cfg.ExampleString.MaxLength = 10
+	// cfg.ExampleString.Regex = "^[a-zA-Z]*$"
+	// cfg.ExampleString.Value = cfg.ExampleString.Default
+	// cfg.ExampleString.AffectedContainers = []string{shared.ServiceContainerName}
+
+	// // Options for ExampleChoice
+	// options := make([]hdconfig.ParameterMetadataOption[nativecfg.ExampleOption], 3)
+	// options[0].Name = "One"
+	// options[0].Description.Default = "This is the first option."
+	// options[0].Value = nativecfg.ExampleOption_One
+
+	// thresholdString := strconv.FormatFloat(FloatThreshold, 'f', -1, 64)
+	// options[1].Name = "Two"
+	// options[1].Description.Default = "This is the second option. It is hidden when ExampleFloat is less than " + thresholdString + "."
+	// options[1].Description.Template = fmt.Sprintf("{{if lt .GetValue %s %s}}This option is hidden because the float is less than %s.{{else}}This option is visible because the float is greater than or equal to %s.{{end}}", ids.ExampleFloatID, thresholdString, thresholdString, thresholdString)
+	// options[1].Value = nativecfg.ExampleOption_Two
+	// options[1].Disabled.Default = true
+	// options[1].Disabled.Template = "{{if eq .GetValue " + ids.ExampleBoolID + " true}}false{{else}}{{.UseDefault}}{{end}}"
+
+	// options[2].Name = "Three"
+	// options[2].Description.Default = "This is the third option."
+	// options[2].Value = nativecfg.ExampleOption_Three
+
+	// // ExampleChoice
+	// cfg.ExampleChoice.ID = hdconfig.Identifier(ids.ExampleChoiceID)
+	// cfg.ExampleChoice.Name = "Example Choice"
+	// cfg.ExampleChoice.Description.Default = "This is an example of a choice parameter between multiple options."
+	// cfg.ExampleChoice.Options = options
+	// cfg.ExampleChoice.Default = options[0].Value
+	// cfg.ExampleChoice.Value = cfg.ExampleChoice.Default
+	// cfg.ExampleChoice.AffectedContainers = []string{}
+
+	// Subconfigs
+	cfg.SubConfig = NewSubConfig()
+	cfg.ServerConfig = NewServerConfig()
+
+	return cfg
+}
+
+type SubConfig struct {
+	hdconfig.SectionMetadataHeader
+
+	SubExampleBool hdconfig.BoolParameterMetadata
+
+	SubExampleChoice hdconfig.ChoiceParameterMetadata[nativecfg.ExampleOption]
+}
+
+func NewSubConfig() *SubConfig {
+	cfg := &SubConfig{}
+	// cfg.ID = hdconfig.Identifier(ids.SubConfigID)
+	// cfg.Name = "Sub Config"
+	// cfg.Description.Default = "This is a sub-section of the main configuration."
+	// cfg.Hidden.Default = true
+	// cfg.Hidden.Template = "{{if eq .GetValue " + ids.ExampleBoolID + " true}}false{{else}}true{{end}}"
+
+	// // SubExampleBool
+	// cfg.SubExampleBool.ID = hdconfig.Identifier(ids.SubExampleBoolID)
+	// cfg.SubExampleBool.Name = "Sub Example Boolean"
+	// cfg.SubExampleBool.Description.Default = "This is an example of a boolean parameter in a sub-section."
+	// cfg.SubExampleBool.Value = cfg.SubExampleBool.Default
+
+	// // Options for SubExampleChoice
+	// options := make([]hdconfig.ParameterMetadataOption[nativecfg.ExampleOption], 2)
+	// options[0].Name = "One"
+	// options[0].Description.Default = "This is the first option."
+	// options[0].Value = nativecfg.ExampleOption_One
+
+	// options[1].Name = "Two"
+	// options[1].Description.Default = "This is the second option."
+	// options[1].Value = nativecfg.ExampleOption_Two
+
+	// // SubExampleChoice
+	// cfg.SubExampleChoice.ID = hdconfig.Identifier(ids.SubExampleChoiceID)
+	// cfg.SubExampleChoice.Name = "Sub Example Choice"
+	// cfg.SubExampleChoice.Description.Default = "This is an example of a choice parameter between multiple options in a sub-section."
+	// cfg.SubExampleChoice.Options = options
+	// cfg.SubExampleChoice.Default = options[1].Value
+	// cfg.SubExampleChoice.Value = cfg.SubExampleChoice.Default
+
+	return cfg
+}
+
+type ServerConfig struct {
+	hdconfig.SectionMetadataHeader
+
+	Port hdconfig.UintParameterMetadata
+
+	PortMode hdconfig.ChoiceParameterMetadata[PortMode]
+}
+
+func NewServerConfig() *ServerConfig {
+	cfg := &ServerConfig{}
+	// cfg.ID = hdconfig.Identifier(ids.ServerConfigID)
+	// cfg.Name = "Service Config"
+	// cfg.Description.Default = "This is the configuration for the module's service. This isn't used by the service directly, but it is used by Hyperdrive itself in the service's Docker Compose file template to configure the service during its starting process."
+
+	// // Port
+	// cfg.Port.ID = hdconfig.Identifier(ids.PortID)
+	// cfg.Port.Name = "API Port"
+	// cfg.Port.Description.Default = "This is the API port the server should run on."
+	// cfg.Port.Default = uint64(shared.DefaultServerApiPort)
+	// cfg.Port.MinValue = 0
+	// cfg.Port.MaxValue = 65535
+	// cfg.Port.Value = cfg.Port.Default
+	// cfg.Port.AffectedContainers = []string{shared.ServiceContainerName}
+
+	// // Options for PortMode
+	// options := make([]hdconfig.ParameterMetadataOption[PortMode], 3)
+	// options[0].Name = "Closed"
+	// options[0].Description.Default = "The API is only accessible to internal Docker container traffic."
+	// options[0].Value = PortMode_Closed
+
+	// options[1].Name = "Localhost Only"
+	// options[1].Description.Default = "The API is accessible from internal Docker containers and your own local machine, but no other external machines."
+	// options[1].Value = PortMode_Localhost
+
+	// options[2].Name = "All External Traffic"
+	// options[2].Description.Default = "The port is accessible to everything, including external machines.\n\n[orange]Use with caution!"
+	// options[2].Value = PortMode_External
+
+	// // PortMode
+	// cfg.PortMode.ID = hdconfig.Identifier(ids.PortModeID)
+	// cfg.PortMode.Name = "Expose API Port"
+	// cfg.PortMode.Description.Default = "Determine how the server's HTTP API restricts its access from various sources."
+	// cfg.PortMode.Options = options
+	// cfg.PortMode.Default = options[0].Value
+	// cfg.PortMode.Value = cfg.PortMode.Default
+	// cfg.PortMode.AffectedContainers = []string{shared.ServiceContainerName}
+
+	return cfg
+}
+
+func ConvertToMetadata(native *nativecfg.NativeExampleConfig) *ExampleConfig {
+	cfg := NewExampleConfig()
+
+	// cfg.ExampleBool.Value = native.ExampleBool
+	// cfg.ExampleInt.Value = native.ExampleInt
+	// cfg.ExampleUint.Value = native.ExampleUint
+	// cfg.ExampleFloat.Value = native.ExampleFloat
+	// cfg.ExampleString.Value = native.ExampleString
+	// cfg.ExampleChoice.Value = native.ExampleChoice
+
+	cfg.SubConfig.SubExampleBool.Value = native.SubConfig.SubExampleBool
+	cfg.SubConfig.SubExampleChoice.Value = native.SubConfig.SubExampleChoice
+
+	return cfg
+}
+
+func (cfg *ExampleConfig) ConvertToNative() *nativecfg.NativeExampleConfig {
+	// native := &nativecfg.NativeExampleConfig{}
+
+	// native.ExampleBool = cfg.ExampleBool.Value
+	// native.ExampleInt = cfg.ExampleInt.Value
+	// native.ExampleUint = cfg.ExampleUint.Value
+	// native.ExampleFloat = cfg.ExampleFloat.Value
+	// native.ExampleString = cfg.ExampleString.Value
+	// native.ExampleChoice = cfg.ExampleChoice.Value
+	// native.SubConfig.SubExampleBool = cfg.SubConfig.SubExampleBool.Value
+	// native.SubConfig.SubExampleChoice = cfg.SubConfig.SubExampleChoice.Value
+	// return native
+	return nil
+}
+
+// Configuration manager
+type AdapterConfigManager struct {
+	// The adapter configuration
+	AdapterConfig *ExampleConfig
+
+	// The native configuration manager
+	// nativeConfigManager *nativecfg.ConfigManager
+
+	// The path to the adapter configuration file
+	adapterConfigPath string
+}
+
+// Create a new configuration manager for the adapter
+func NewAdapterConfigManager(c *cli.Context) (*AdapterConfigManager, error) {
+	// configDir := c.String(utils.ConfigDirFlag.Name)
+	// if configDir == "" {
+	// 	return nil, fmt.Errorf("config directory is required")
+	// }
+	// return &AdapterConfigManager{
+	// 	// nativeConfigManager: nativecfg.NewConfigManager(filepath.Join(configDir, utils.ServiceConfigFile)),
+	// 	adapterConfigPath: filepath.Join(configDir, utils.AdapterConfigFile),
+	// }, nil
+	return nil, nil
+}
+
+// Load the configuration from disk
+func (m *AdapterConfigManager) LoadConfigFromDisk() (*ExampleConfig, error) {
+	// Load the native config
+	// nativeCfg, err := m.nativeConfigManager.LoadConfigFromFile()
+	// if err != nil {
+	// 	return nil, fmt.Errorf("error loading service config: %w", err)
+	// }
+
+	// // Check if the adapter config exists
+	// _, err = os.Stat(m.adapterConfigPath)
+	// if errors.Is(err, fs.ErrNotExist) {
+	// 	return nil, nil
+	// }
+
+	// Load it
+	bytes, err := os.ReadFile(m.adapterConfigPath)
+	if err != nil {
+		return nil, fmt.Errorf("error reading config file [%s]: %w", m.adapterConfigPath, err)
+	}
+
+	// Deserialize it
+	cfgInstance := map[string]any{}
+	err = yaml.Unmarshal(bytes, &cfgInstance)
+	if err != nil {
+		return nil, fmt.Errorf("error deserializing adapter config file [%s]: %w", m.adapterConfigPath, err)
+	}
+	serverCfg := NewServerConfig()
+	portInt := cfgInstance[ids.PortID].(int)
+	serverCfg.Port.Value = uint64(portInt)
+	serverCfg.PortMode.Value = PortMode(cfgInstance[ids.PortModeID].(string))
+
+	// Merge the configs
+	// modCfg := ConvertToMetadata(nativeCfg)
+	// modCfg.ServerConfig = serverCfg
+	// m.AdapterConfig = modCfg
+	// return modCfg, nil
+	return nil, nil
+}
+
+// Save the configuration to a file. If the config hasn't been loaded yet, this doesn't do anything.
+func (m *AdapterConfigManager) SaveConfigToDisk() error {
+	if m.AdapterConfig == nil {
+		return nil
+	}
+
+	// // Save the native config
+	// nativeCfg := m.AdapterConfig.ConvertToNative()
+	// m.nativeConfigManager.Config = nativeCfg
+	// err := m.nativeConfigManager.SaveConfigToFile()
+	// if err != nil {
+	// 	return fmt.Errorf("error saving service config: %w", err)
+	// }
+
+	// Serialize the adapter config
+	// modCfg := hdconfig.CreateInstanceFromMetadata(m.AdapterConfig.ServerConfig)
+	// bytes, err := yaml.Marshal(modCfg)
+	// if err != nil {
+	// 	return fmt.Errorf("error serializing adapter config: %w", err)
+	// }
+
+	// Write it
+	// err = os.WriteFile(m.adapterConfigPath, bytes, nativecfg.ConfigFileMode)
+	// if err != nil {
+	// 	return fmt.Errorf("error writing adapter config file [%s]: %w", m.adapterConfigPath, err)
+	// }
+	return nil
+}

adapter/config/ids/ids.go

@@ -0,0 +1,16 @@
+package ids
+
+const (
+	ExampleBoolID      string = "exampleBool"
+	ExampleIntID       string = "exampleInt"
+	ExampleUintID      string = "exampleUint"
+	ExampleFloatID     string = "exampleFloat"
+	ExampleStringID    string = "exampleString"
+	ExampleChoiceID    string = "exampleChoice"
+	SubConfigID        string = "subConfig"
+	SubExampleBoolID   string = "subConfigBool"
+	SubExampleChoiceID string = "subConfigChoice"
+	ServerConfigID     string = "server"
+	PortModeID         string = "portMode"
+	PortID             string = "port"
+)

adapter/command/initialize.go → adapter/config/initialize.go

@@ -1,4 +1,4 @@
-package command
+package config
 
 import (
 	"fmt"