-
Notifications
You must be signed in to change notification settings - Fork 130
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
1,273 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,110 @@ | ||
| package ocpp_16_config_manager | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "strings" | ||
|
|
||
| "github.com/lorenzodonini/ocpp-go/ocpp1.6/core" | ||
| "github.com/samber/lo" | ||
| ) | ||
|
|
||
| var ( | ||
| ErrKeyNotFound = errors.New("key not found") | ||
| ErrReadOnly = errors.New("attribute is read-only") | ||
| ) | ||
|
|
||
| type Key string | ||
|
|
||
| func (k Key) String() string { | ||
| return string(k) | ||
| } | ||
|
|
||
| type Config struct { | ||
| Version int `fig:"version" default:"1"` | ||
| Keys []core.ConfigurationKey `fig:"keys"` | ||
| } | ||
|
|
||
| // UpdateKey Update the configuration variable in the configuration if it is not readonly. | ||
| func (config *Config) UpdateKey(key string, value *string) error { | ||
| // Find the index of the key | ||
| configKey, index, isFound := lo.FindIndexOf(config.Keys, func(item core.ConfigurationKey) bool { | ||
| return item.Key == key | ||
| }) | ||
| if !isFound { | ||
| return ErrKeyNotFound | ||
| } | ||
|
|
||
| if configKey.Readonly { | ||
| return ErrReadOnly | ||
| } | ||
|
|
||
| config.Keys[index].Value = value | ||
| return nil | ||
| } | ||
|
|
||
| // UpdateKeyReadability updates whether the key is updatable or not. | ||
| func (config *Config) UpdateKeyReadability(key string, readable bool) error { | ||
| // Find the index of the key | ||
| _, index, isFound := lo.FindIndexOf(config.Keys, func(item core.ConfigurationKey) bool { | ||
| return item.Key == key | ||
| }) | ||
| if !isFound { | ||
| return ErrKeyNotFound | ||
| } | ||
|
|
||
| config.Keys[index].Readonly = readable | ||
| return nil | ||
| } | ||
|
|
||
| // GetConfigurationValue Get the value of specified configuration variable in String format. | ||
| func (config *Config) GetConfigurationValue(key string) (*string, error) { | ||
| configKey, isFound := lo.Find(config.Keys, func(item core.ConfigurationKey) bool { | ||
| return item.Key == key | ||
| }) | ||
|
|
||
| if !isFound { | ||
| return nil, ErrKeyNotFound | ||
| } | ||
|
|
||
| return configKey.Value, nil | ||
| } | ||
|
|
||
| // GetConfig Get the configuration | ||
| func (config *Config) GetConfig() []core.ConfigurationKey { | ||
| return config.Keys | ||
| } | ||
|
|
||
| // GetVersion Get the current version | ||
| func (config *Config) GetVersion() int { | ||
| return config.Version | ||
| } | ||
|
|
||
| // SetVersion Set the current version | ||
| func (config *Config) SetVersion(version int) { | ||
| config.Version = version | ||
| } | ||
|
|
||
| // Validate validates the configuration - check if all mandatory keys are present. | ||
| func (config *Config) Validate(mandatoryKeys []Key) error { | ||
| missingKeys := "" | ||
|
|
||
| containsMandatoryKeys := true | ||
|
|
||
| for _, key := range mandatoryKeys { | ||
| containsKey := lo.ContainsBy(config.Keys, func(item core.ConfigurationKey) bool { | ||
| return item.Key == key.String() | ||
| }) | ||
|
|
||
| if !containsKey { | ||
| missingKeys = strings.Join([]string{missingKeys, key.String()}, ", ") | ||
| containsMandatoryKeys = false | ||
| } | ||
| } | ||
|
|
||
| if !containsMandatoryKeys { | ||
| return fmt.Errorf("missing mandatory keys: %s", missingKeys) | ||
| } | ||
|
|
||
| return nil | ||
| } |
Oops, something went wrong.