fix: need to use viper.Sub to scope on the protocol namespace and unmarshal
This commit is contained in:
parent
6ddd10a4c9
commit
daf63268eb
|
@ -58,13 +58,15 @@ func NewManager(logger *zap.Logger) (*Manager, error) {
|
||||||
func (m *Manager) ConfigureProtocol(name string, cfg ProtocolConfig) error {
|
func (m *Manager) ConfigureProtocol(name string, cfg ProtocolConfig) error {
|
||||||
defaults := cfg.Defaults()
|
defaults := cfg.Defaults()
|
||||||
|
|
||||||
m.setDefaults(defaults, fmt.Sprintf("protocol.%s", name))
|
protocolPrefix := fmt.Sprintf("protocol.%s", name)
|
||||||
|
|
||||||
|
m.setDefaults(defaults, protocolPrefix)
|
||||||
err := m.maybeSave()
|
err := m.maybeSave()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
return m.viper.Unmarshal(cfg)
|
return m.viper.Sub(protocolPrefix).Unmarshal(cfg)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Manager) setDefaults(defaults map[string]interface{}, prefix string) {
|
func (m *Manager) setDefaults(defaults map[string]interface{}, prefix string) {
|
||||||
|
|
Loading…
Reference in New Issue