forked from juju/charm
-
Notifications
You must be signed in to change notification settings - Fork 0
/
config.go
235 lines (216 loc) · 7.02 KB
/
config.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
// Copyright 2011, 2012, 2013 Canonical Ltd.
// Licensed under the LGPLv3, see LICENCE file for details.
package charm
import (
"fmt"
"io"
"io/ioutil"
"strconv"
"github.com/juju/schema"
"gopkg.in/yaml.v2"
)
// Settings is a group of charm config option names and values. A Settings
// S is considered valid by the Config C if every key in S is an option in
// C, and every value either has the correct type or is nil.
type Settings map[string]interface{}
// Option represents a single charm config option.
type Option struct {
Type string `yaml:"type"`
Description string `yaml:"description,omitempty"`
Default interface{} `yaml:"default,omitempty"`
}
// error replaces any supplied non-nil error with a new error describing a
// validation failure for the supplied value.
func (option Option) error(err *error, name string, value interface{}) {
if *err != nil {
*err = fmt.Errorf("option %q expected %s, got %#v", name, option.Type, value)
}
}
// validate returns an appropriately-typed value for the supplied value, or
// returns an error if it cannot be converted to the correct type. Nil values
// are always considered valid.
func (option Option) validate(name string, value interface{}) (_ interface{}, err error) {
if value == nil {
return nil, nil
}
if checker := optionTypeCheckers[option.Type]; checker != nil {
defer option.error(&err, name, value)
if value, err = checker.Coerce(value, nil); err != nil {
return nil, err
}
return value, nil
}
return nil, fmt.Errorf("option %q has unknown type %q", name, option.Type)
}
var optionTypeCheckers = map[string]schema.Checker{
"string": schema.String(),
"int": schema.Int(),
"float": schema.Float(),
"boolean": schema.Bool(),
}
func (option Option) parse(name, str string) (val interface{}, err error) {
switch option.Type {
case "string":
return str, nil
case "int":
val, err = strconv.ParseInt(str, 10, 64)
case "float":
val, err = strconv.ParseFloat(str, 64)
case "boolean":
val, err = strconv.ParseBool(str)
default:
return nil, fmt.Errorf("option %q has unknown type %q", name, option.Type)
}
defer option.error(&err, name, str)
return
}
// Config represents the supported configuration options for a charm,
// as declared in its config.yaml file.
type Config struct {
Options map[string]Option
}
// NewConfig returns a new Config without any options.
func NewConfig() *Config {
return &Config{map[string]Option{}}
}
// ReadConfig reads a Config in YAML format.
func ReadConfig(r io.Reader) (*Config, error) {
data, err := ioutil.ReadAll(r)
if err != nil {
return nil, err
}
var config *Config
if err := yaml.Unmarshal(data, &config); err != nil {
return nil, err
}
if config == nil {
return nil, fmt.Errorf("invalid config: empty configuration")
}
if config.Options == nil {
// We are allowed an empty configuration if the options
// field is explicitly specified, but there is no easy way
// to tell if it was specified or not without unmarshaling
// into interface{} and explicitly checking the field.
var configInterface interface{}
if err := yaml.Unmarshal(data, &configInterface); err != nil {
return nil, err
}
m, _ := configInterface.(map[interface{}]interface{})
if _, ok := m["options"]; !ok {
return nil, fmt.Errorf("invalid config: empty configuration")
}
}
for name, option := range config.Options {
switch option.Type {
case "string", "int", "float", "boolean":
case "":
// Missing type is valid in python.
option.Type = "string"
default:
return nil, fmt.Errorf("invalid config: option %q has unknown type %q", name, option.Type)
}
def := option.Default
if def == "" && option.Type == "string" {
// Skip normal validation for compatibility with pyjuju.
} else if option.Default, err = option.validate(name, def); err != nil {
option.error(&err, name, def)
return nil, fmt.Errorf("invalid config default: %v", err)
}
config.Options[name] = option
}
return config, nil
}
// option returns the named option from the config, or an error if none
// such exists.
func (c *Config) option(name string) (Option, error) {
if option, ok := c.Options[name]; ok {
return option, nil
}
return Option{}, fmt.Errorf("unknown option %q", name)
}
// DefaultSettings returns settings containing the default value of every
// option in the config. Default values may be nil.
func (c *Config) DefaultSettings() Settings {
out := make(Settings)
for name, option := range c.Options {
out[name] = option.Default
}
return out
}
// ValidateSettings returns a copy of the supplied settings with a consistent type
// for each value. It returns an error if the settings contain unknown keys
// or invalid values.
func (c *Config) ValidateSettings(settings Settings) (Settings, error) {
out := make(Settings)
for name, value := range settings {
if option, err := c.option(name); err != nil {
return nil, err
} else if value, err = option.validate(name, value); err != nil {
return nil, err
}
out[name] = value
}
return out, nil
}
// FilterSettings returns the subset of the supplied settings that are valid.
func (c *Config) FilterSettings(settings Settings) Settings {
out := make(Settings)
for name, value := range settings {
if option, err := c.option(name); err == nil {
if value, err := option.validate(name, value); err == nil {
out[name] = value
}
}
}
return out
}
// ParseSettingsStrings returns settings derived from the supplied map. Every
// value in the map must be parseable to the correct type for the option
// identified by its key. Empty values are interpreted as nil.
func (c *Config) ParseSettingsStrings(values map[string]string) (Settings, error) {
out := make(Settings)
for name, str := range values {
option, err := c.option(name)
if err != nil {
return nil, err
}
value, err := option.parse(name, str)
if err != nil {
return nil, err
}
out[name] = value
}
return out, nil
}
// ParseSettingsYAML returns settings derived from the supplied YAML data. The
// YAML must unmarshal to a map of strings to settings data; the supplied key
// must be present in the map, and must point to a map in which every value
// must have, or be a string parseable to, the correct type for the associated
// config option. Empty strings and nil values are both interpreted as nil.
func (c *Config) ParseSettingsYAML(yamlData []byte, key string) (Settings, error) {
var allSettings map[string]Settings
if err := yaml.Unmarshal(yamlData, &allSettings); err != nil {
return nil, fmt.Errorf("cannot parse settings data: %v", err)
}
settings, ok := allSettings[key]
if !ok {
return nil, fmt.Errorf("no settings found for %q", key)
}
out := make(Settings)
for name, value := range settings {
option, err := c.option(name)
if err != nil {
return nil, err
}
// Accept string values for compatibility with python.
if str, ok := value.(string); ok {
if value, err = option.parse(name, str); err != nil {
return nil, err
}
} else if value, err = option.validate(name, value); err != nil {
return nil, err
}
out[name] = value
}
return out, nil
}