-
-
Notifications
You must be signed in to change notification settings - Fork 398
/
Copy pathsettings.go
91 lines (74 loc) · 2.56 KB
/
settings.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
// This file is part of arduino-cli.
//
// Copyright 2019 ARDUINO SA (http://www.arduino.cc/)
//
// This software is released under the GNU General Public License version 3,
// which covers the main part of arduino-cli.
// The terms of this license can be found at:
// https://www.gnu.org/licenses/gpl-3.0.en.html
//
// You can be released from the requirements of the above licenses by purchasing
// a commercial license. Buying such a license is mandatory if you want to
// modify or otherwise use the software for commercial activities involving the
// Arduino software without disclosing the source code of your own applications.
// To purchase a commercial license, send an email to [email protected].
package daemon
import (
"context"
"encoding/json"
"errors"
"fmt"
rpc "github.com/arduino/arduino-cli/rpc/settings"
"github.com/spf13/viper"
)
// SettingsService implements the `Settings` service
type SettingsService struct{}
// GetAll returns a message with a string field containing all the settings
// currently in use, marshalled in JSON format.
func (s *SettingsService) GetAll(ctx context.Context, req *rpc.GetAllRequest) (*rpc.RawData, error) {
b, err := json.Marshal(viper.AllSettings())
if err == nil {
return &rpc.RawData{
JsonData: string(b),
}, nil
}
return nil, err
}
// Merge applies multiple settings values at once.
func (s *SettingsService) Merge(ctx context.Context, req *rpc.RawData) (*rpc.MergeResponse, error) {
var toMerge map[string]interface{}
if err := json.Unmarshal([]byte(req.GetJsonData()), &toMerge); err != nil {
return nil, err
}
if err := viper.MergeConfigMap(toMerge); err != nil {
return nil, err
}
return &rpc.MergeResponse{}, nil
}
// GetValue returns a settings value given its key. If the key is not present
// an error will be returned, so that we distinguish empty settings from missing
// ones.
func (s *SettingsService) GetValue(ctx context.Context, req *rpc.GetValueRequest) (*rpc.Value, error) {
key := req.GetKey()
value := &rpc.Value{}
fmt.Println(viper.AllKeys())
if !viper.InConfig(key) {
return nil, errors.New("key not found in settings")
}
b, err := json.Marshal(viper.Get(key))
if err == nil {
value.Key = key
value.JsonData = string(b)
}
return value, err
}
// SetValue updates or set a value for a certain key.
func (s *SettingsService) SetValue(ctx context.Context, val *rpc.Value) (*rpc.SetValueResponse, error) {
key := val.GetKey()
var value interface{}
err := json.Unmarshal([]byte(val.GetJsonData()), &value)
if err == nil {
viper.Set(key, value)
}
return &rpc.SetValueResponse{}, err
}