-
Notifications
You must be signed in to change notification settings - Fork 5k
/
settings.go
112 lines (103 loc) · 2.92 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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
package settings
import (
"github.com/ghodss/yaml"
"golang.org/x/net/context"
settingspkg "github.com/argoproj/argo-cd/pkg/apiclient/settings"
"github.com/argoproj/argo-cd/pkg/apis/application/v1alpha1"
"github.com/argoproj/argo-cd/util/settings"
)
// Server provides a Settings service
type Server struct {
mgr *settings.SettingsManager
}
// NewServer returns a new instance of the Settings service
func NewServer(mgr *settings.SettingsManager) *Server {
return &Server{
mgr: mgr,
}
}
// Get returns Argo CD settings
func (s *Server) Get(ctx context.Context, q *settingspkg.SettingsQuery) (*settingspkg.Settings, error) {
resourceOverrides, err := s.mgr.GetResourceOverrides()
if err != nil {
return nil, err
}
overrides := make(map[string]*v1alpha1.ResourceOverride)
for k := range resourceOverrides {
val := resourceOverrides[k]
overrides[k] = &val
}
appInstanceLabelKey, err := s.mgr.GetAppInstanceLabelKey()
if err != nil {
return nil, err
}
argoCDSettings, err := s.mgr.GetSettings()
if err != nil {
return nil, err
}
gaSettings, err := s.mgr.GetGoogleAnalytics()
if err != nil {
return nil, err
}
help, err := s.mgr.GetHelp()
if err != nil {
return nil, err
}
plugins, err := s.plugins()
if err != nil {
return nil, err
}
set := settingspkg.Settings{
URL: argoCDSettings.URL,
AppLabelKey: appInstanceLabelKey,
ResourceOverrides: overrides,
StatusBadgeEnabled: argoCDSettings.StatusBadgeEnabled,
KustomizeOptions: &v1alpha1.KustomizeOptions{
BuildOptions: argoCDSettings.KustomizeBuildOptions,
},
GoogleAnalytics: &settingspkg.GoogleAnalyticsConfig{
TrackingID: gaSettings.TrackingID,
AnonymizeUsers: gaSettings.AnonymizeUsers,
},
Help: &settingspkg.Help{
ChatUrl: help.ChatURL,
ChatText: help.ChatText,
},
Plugins: plugins,
}
if argoCDSettings.DexConfig != "" {
var cfg settingspkg.DexConfig
err = yaml.Unmarshal([]byte(argoCDSettings.DexConfig), &cfg)
if err == nil {
set.DexConfig = &cfg
}
}
if oidcConfig := argoCDSettings.OIDCConfig(); oidcConfig != nil {
set.OIDCConfig = &settingspkg.OIDCConfig{
Name: oidcConfig.Name,
Issuer: oidcConfig.Issuer,
ClientID: oidcConfig.ClientID,
CLIClientID: oidcConfig.CLIClientID,
Scopes: oidcConfig.RequestedScopes,
}
if len(argoCDSettings.OIDCConfig().RequestedIDTokenClaims) > 0 {
set.OIDCConfig.IDTokenClaims = argoCDSettings.OIDCConfig().RequestedIDTokenClaims
}
}
return &set, nil
}
func (s *Server) plugins() ([]*settingspkg.Plugin, error) {
in, err := s.mgr.GetConfigManagementPlugins()
if err != nil {
return nil, err
}
out := make([]*settingspkg.Plugin, len(in))
for i, p := range in {
out[i] = &settingspkg.Plugin{Name: p.Name}
}
return out, nil
}
// AuthFuncOverride disables authentication for settings service
func (s *Server) AuthFuncOverride(ctx context.Context, fullMethodName string) (context.Context, error) {
return ctx, nil
}