1
|
|
|
package cmd |
2
|
|
|
|
3
|
|
|
import ( |
4
|
|
|
"fmt" |
5
|
|
|
"os" |
6
|
|
|
"strings" |
7
|
|
|
|
8
|
|
|
"github.com/gookit/color" |
9
|
|
|
"github.com/olekukonko/tablewriter" |
10
|
|
|
"github.com/spf13/cobra" |
11
|
|
|
"github.com/spf13/viper" |
12
|
|
|
|
13
|
|
|
"github.com/Permify/permify/internal/config" |
14
|
|
|
"github.com/Permify/permify/pkg/cmd/flags" |
15
|
|
|
) |
16
|
|
|
|
17
|
|
|
func NewConfigCommand() *cobra.Command { |
18
|
|
|
command := &cobra.Command{ |
19
|
|
|
Use: "config", |
20
|
|
|
Short: "inspect permify configuration and environment variables", |
21
|
|
|
RunE: conf(), |
22
|
|
|
Args: cobra.NoArgs, |
23
|
|
|
} |
24
|
|
|
|
25
|
|
|
conf := config.DefaultConfig() |
26
|
|
|
f := command.Flags() |
27
|
|
|
f.StringP("config", "c", "", "config file (default is $HOME/.permify.yaml)") |
28
|
|
|
f.Bool("http-enabled", conf.Server.HTTP.Enabled, "switch option for HTTP server") |
29
|
|
|
f.String("account-id", conf.AccountID, "account id") |
30
|
|
|
f.Int64("server-rate-limit", conf.Server.RateLimit, "the maximum number of requests the server should handle per second") |
31
|
|
|
f.String("server-name-override", conf.Server.NameOverride, "server name override") |
32
|
|
|
f.String("grpc-port", conf.Server.GRPC.Port, "port that GRPC server run on") |
33
|
|
|
f.Bool("grpc-tls-enabled", conf.Server.GRPC.TLSConfig.Enabled, "switch option for GRPC tls server") |
34
|
|
|
f.String("grpc-tls-key-path", conf.Server.GRPC.TLSConfig.KeyPath, "GRPC tls key path") |
35
|
|
|
f.String("grpc-tls-cert-path", conf.Server.GRPC.TLSConfig.CertPath, "GRPC tls certificate path") |
36
|
|
|
f.String("http-port", conf.Server.HTTP.Port, "HTTP port address") |
37
|
|
|
f.Bool("http-tls-enabled", conf.Server.HTTP.TLSConfig.Enabled, "switch option for HTTP tls server") |
38
|
|
|
f.String("http-tls-key-path", conf.Server.HTTP.TLSConfig.KeyPath, "HTTP tls key path") |
39
|
|
|
f.String("http-tls-cert-path", conf.Server.HTTP.TLSConfig.CertPath, "HTTP tls certificate path") |
40
|
|
|
f.StringSlice("http-cors-allowed-origins", conf.Server.HTTP.CORSAllowedOrigins, "CORS allowed origins for http gateway") |
41
|
|
|
f.StringSlice("http-cors-allowed-headers", conf.Server.HTTP.CORSAllowedHeaders, "CORS allowed headers for http gateway") |
42
|
|
|
f.Bool("profiler-enabled", conf.Profiler.Enabled, "switch option for profiler") |
43
|
|
|
f.String("profiler-port", conf.Profiler.Port, "profiler port address") |
44
|
|
|
f.String("log-level", conf.Log.Level, "real time logs of authorization. Permify uses slog as a logger") |
45
|
|
|
f.String("log-output", conf.Log.Output, "logger output valid values json, text") |
46
|
|
|
f.Bool("log-enabled", conf.Log.Enabled, "logger exporter enabled") |
47
|
|
|
f.String("log-exporter", conf.Log.Exporter, "can be; otlp. (integrated metric tools)") |
48
|
|
|
f.String("log-endpoint", conf.Log.Endpoint, "export uri for logs") |
49
|
|
|
f.Bool("log-insecure", conf.Log.Insecure, "use https or http for logs") |
50
|
|
|
f.String("log-urlpath", conf.Log.Urlpath, "allow to set url path for otlp exporter") |
51
|
|
|
f.StringSlice("log-headers", conf.Log.Headers, "allows setting custom headers for the log exporter in key-value pairs") |
52
|
|
|
f.String("log-protocol", conf.Log.Protocol, "allows setting the communication protocol for the log exporter, with options http or grpc") |
53
|
|
|
f.Bool("authn-enabled", conf.Authn.Enabled, "enable server authentication") |
54
|
|
|
f.String("authn-method", conf.Authn.Method, "server authentication method") |
55
|
|
|
f.StringSlice("authn-preshared-keys", conf.Authn.Preshared.Keys, "preshared key/keys for server authentication") |
56
|
|
|
f.String("authn-oidc-issuer", conf.Authn.Oidc.Issuer, "issuer identifier of the OpenID Connect Provider") |
57
|
|
|
f.String("authn-oidc-audience", conf.Authn.Oidc.Audience, "intended audience of the OpenID Connect token") |
58
|
|
|
f.Duration("authn-oidc-refresh-interval", conf.Authn.Oidc.RefreshInterval, "refresh interval for the OpenID Connect configuration") |
59
|
|
|
f.Duration("authn-oidc-backoff-interval", conf.Authn.Oidc.BackoffInterval, "backoff interval for the OpenID Connect configuration") |
60
|
|
|
f.Duration("authn-oidc-backoff-frequency", conf.Authn.Oidc.BackoffFrequency, "backoff frequency for the OpenID Connect configuration") |
61
|
|
|
f.Int("authn-oidc-backoff-max-retries", conf.Authn.Oidc.BackoffMaxRetries, "defines the maximum number of retries for the OpenID Connect configuration") |
62
|
|
|
f.StringSlice("authn-oidc-valid-methods", conf.Authn.Oidc.ValidMethods, "list of valid JWT signing methods for OpenID Connect") |
63
|
|
|
f.Bool("tracer-enabled", conf.Tracer.Enabled, "switch option for tracing") |
64
|
|
|
f.String("tracer-exporter", conf.Tracer.Exporter, "can be; jaeger, signoz, zipkin or otlp. (integrated tracing tools)") |
65
|
|
|
f.String("tracer-endpoint", conf.Tracer.Endpoint, "export uri for tracing data") |
66
|
|
|
f.Bool("tracer-insecure", conf.Tracer.Insecure, "use https or http for tracer data, only used for otlp exporter or signoz") |
67
|
|
|
f.String("tracer-urlpath", conf.Tracer.Urlpath, "allow to set url path for otlp exporter") |
68
|
|
|
f.StringSlice("tracer-headers", conf.Tracer.Headers, "allows setting custom headers for the tracer exporter in key-value pairs") |
69
|
|
|
f.String("tracer-protocol", conf.Tracer.Protocol, "allows setting the communication protocol for the tracer exporter, with options http or grpc") |
70
|
|
|
f.Bool("meter-enabled", conf.Meter.Enabled, "switch option for metric") |
71
|
|
|
f.String("meter-exporter", conf.Meter.Exporter, "can be; otlp. (integrated metric tools)") |
72
|
|
|
f.String("meter-endpoint", conf.Meter.Endpoint, "export uri for metric data") |
73
|
|
|
f.Bool("meter-insecure", conf.Meter.Insecure, "use https or http for metric data") |
74
|
|
|
f.String("meter-urlpath", conf.Meter.Urlpath, "allow to set url path for otlp exporter") |
75
|
|
|
f.StringSlice("meter-headers", conf.Meter.Headers, "allows setting custom headers for the metric exporter in key-value pairs") |
76
|
|
|
f.Int("meter-interval", conf.Meter.Interval, "allows to set metrics to be pushed in certain time interval") |
77
|
|
|
f.String("meter-protocol", conf.Meter.Protocol, "allows setting the communication protocol for the meter exporter, with options http or grpc") |
78
|
|
|
f.Bool("service-circuit-breaker", conf.Service.CircuitBreaker, "switch option for service circuit breaker") |
79
|
|
|
f.Bool("service-watch-enabled", conf.Service.Watch.Enabled, "switch option for watch service") |
80
|
|
|
f.Int64("service-schema-cache-number-of-counters", conf.Service.Schema.Cache.NumberOfCounters, "schema service cache number of counters") |
81
|
|
|
f.String("service-schema-cache-max-cost", conf.Service.Schema.Cache.MaxCost, "schema service cache max cost") |
82
|
|
|
f.Int("service-permission-bulk-limit", conf.Service.Permission.BulkLimit, "bulk operations limit") |
83
|
|
|
f.Int("service-permission-concurrency-limit", conf.Service.Permission.ConcurrencyLimit, "concurrency limit") |
84
|
|
|
f.Int64("service-permission-cache-number-of-counters", conf.Service.Permission.Cache.NumberOfCounters, "permission service cache number of counters") |
85
|
|
|
f.String("service-permission-cache-max-cost", conf.Service.Permission.Cache.MaxCost, "permission service cache max cost") |
86
|
|
|
f.String("database-engine", conf.Database.Engine, "data source. e.g. postgres, memory") |
87
|
|
|
f.String("database-uri", conf.Database.URI, "uri of your data source to store relation tuples and schema") |
88
|
|
|
f.String("database-writer-uri", conf.Database.Writer.URI, "writer uri of your data source to store relation tuples and schema") |
89
|
|
|
f.String("database-reader-uri", conf.Database.Reader.URI, "reader uri of your data source to store relation tuples and schema") |
90
|
|
|
f.Bool("database-auto-migrate", conf.Database.AutoMigrate, "auto migrate database tables") |
91
|
|
|
f.Int("database-max-open-connections", conf.Database.MaxOpenConnections, "maximum number of parallel connections that can be made to the database at any time") |
92
|
|
|
f.Int("database-max-idle-connections", conf.Database.MaxIdleConnections, "maximum number of idle connections that can be made to the database at any time") |
93
|
|
|
f.Duration("database-max-connection-lifetime", conf.Database.MaxConnectionLifetime, "maximum amount of time a connection may be reused") |
94
|
|
|
f.Duration("database-max-connection-idle-time", conf.Database.MaxConnectionIdleTime, "maximum amount of time a connection may be idle") |
95
|
|
|
f.Int("database-max-data-per-write", conf.Database.MaxDataPerWrite, "sets the maximum amount of data per write operation to the database") |
96
|
|
|
f.Int("database-max-retries", conf.Database.MaxRetries, "defines the maximum number of retries for database operations in case of failure") |
97
|
|
|
f.Int("database-watch-buffer-size", conf.Database.WatchBufferSize, "specifies the buffer size for database watch operations, impacting how many changes can be queued") |
98
|
|
|
f.Bool("database-garbage-collection-enabled", conf.Database.GarbageCollection.Enabled, "use database garbage collection for expired relationships and attributes") |
99
|
|
|
f.Duration("database-garbage-collection-interval", conf.Database.GarbageCollection.Interval, "interval for database garbage collection") |
100
|
|
|
f.Duration("database-garbage-collection-timeout", conf.Database.GarbageCollection.Timeout, "timeout for database garbage collection") |
101
|
|
|
f.Duration("database-garbage-collection-window", conf.Database.GarbageCollection.Window, "window for database garbage collection") |
102
|
|
|
f.Bool("distributed-enabled", conf.Distributed.Enabled, "enable distributed") |
103
|
|
|
f.String("distributed-address", conf.Distributed.Address, "distributed address") |
104
|
|
|
f.String("distributed-port", conf.Distributed.Port, "distributed port") |
105
|
|
|
f.Int("distributed-partition-count", conf.Distributed.PartitionCount, "number of partitions for distributed hashing") |
106
|
|
|
f.Int("distributed-replication-factor", conf.Distributed.ReplicationFactor, "number of replicas for distributed hashing") |
107
|
|
|
f.Float64("distributed-load", conf.Distributed.Load, "load factor for distributed hashing") |
108
|
|
|
f.Int("distributed-picker-width", conf.Distributed.PickerWidth, "picker width for distributed hashing") |
109
|
|
|
|
110
|
|
|
command.PreRun = func(cmd *cobra.Command, args []string) { |
111
|
|
|
flags.RegisterServeFlags(f) |
112
|
|
|
} |
113
|
|
|
|
114
|
|
|
return command |
115
|
|
|
} |
116
|
|
|
|
117
|
|
|
func conf() func(cmd *cobra.Command, args []string) error { |
118
|
|
|
return func(cmd *cobra.Command, args []string) error { |
119
|
|
|
var cfg *config.Config |
120
|
|
|
var err error |
121
|
|
|
cfgFile := viper.GetString("config.file") |
122
|
|
|
if cfgFile != "" { |
123
|
|
|
cfg, err = config.NewConfigWithFile(cfgFile) |
124
|
|
|
if err != nil { |
125
|
|
|
return fmt.Errorf("failed to create new config: %w", err) |
|
|
|
|
126
|
|
|
} |
127
|
|
|
|
128
|
|
|
if err = viper.Unmarshal(cfg); err != nil { |
129
|
|
|
return fmt.Errorf("failed to unmarshal config: %w", err) |
|
|
|
|
130
|
|
|
} |
131
|
|
|
} else { |
132
|
|
|
// Load configuration |
133
|
|
|
cfg, err = config.NewConfig() |
134
|
|
|
if err != nil { |
135
|
|
|
return fmt.Errorf("failed to create new config: %w", err) |
|
|
|
|
136
|
|
|
} |
137
|
|
|
|
138
|
|
|
if err = viper.Unmarshal(cfg); err != nil { |
139
|
|
|
return fmt.Errorf("failed to unmarshal config: %w", err) |
|
|
|
|
140
|
|
|
} |
141
|
|
|
} |
142
|
|
|
|
143
|
|
|
var data [][]string |
144
|
|
|
|
145
|
|
|
data = append(data, |
146
|
|
|
[]string{"account_id", cfg.AccountID, getKeyOrigin(cmd, "account-id", "PERMIFY_ACCOUNT_ID")}, |
147
|
|
|
// SERVER |
148
|
|
|
[]string{"server.name_override", fmt.Sprintf("%v", cfg.Server.NameOverride), getKeyOrigin(cmd, "server-name-override", "PERMIFY_NAME_OVERRIDE")}, |
149
|
|
|
[]string{"server.rate_limit", fmt.Sprintf("%v", cfg.Server.RateLimit), getKeyOrigin(cmd, "server-rate-limit", "PERMIFY_RATE_LIMIT")}, |
150
|
|
|
[]string{"server.grpc.port", cfg.Server.GRPC.Port, getKeyOrigin(cmd, "grpc-port", "PERMIFY_GRPC_PORT")}, |
151
|
|
|
[]string{"server.grpc.tls.enabled", fmt.Sprintf("%v", cfg.Server.GRPC.TLSConfig.Enabled), getKeyOrigin(cmd, "grpc-tls-enabled", "PERMIFY_GRPC_TLS_ENABLED")}, |
152
|
|
|
[]string{"server.grpc.tls.cert", cfg.Server.GRPC.TLSConfig.CertPath, getKeyOrigin(cmd, "grpc-tls-cert-path", "PERMIFY_GRPC_TLS_CERT_PATH")}, |
153
|
|
|
[]string{"server.http.enabled", fmt.Sprintf("%v", cfg.Server.HTTP.Enabled), getKeyOrigin(cmd, "http-enabled", "PERMIFY_HTTP_ENABLED")}, |
154
|
|
|
[]string{"server.http.tls.enabled", fmt.Sprintf("%v", cfg.Server.HTTP.TLSConfig.Enabled), getKeyOrigin(cmd, "http-tls-enabled", "PERMIFY_HTTP_TLS_ENABLED")}, |
155
|
|
|
[]string{"server.http.tls.key", HideSecret(cfg.Server.HTTP.TLSConfig.KeyPath), getKeyOrigin(cmd, "http-tls-key-path", "PERMIFY_HTTP_TLS_KEY_PATH")}, |
156
|
|
|
[]string{"server.http.tls.cert", HideSecret(cfg.Server.HTTP.TLSConfig.CertPath), getKeyOrigin(cmd, "http-tls-cert-path", "PERMIFY_HTTP_TLS_CERT_PATH")}, |
157
|
|
|
[]string{"server.http.cors_allowed_origins", fmt.Sprintf("%v", cfg.Server.HTTP.CORSAllowedOrigins), getKeyOrigin(cmd, "http-cors-allowed-origins", "PERMIFY_HTTP_CORS_ALLOWED_ORIGINS")}, |
158
|
|
|
[]string{"server.http.cors_allowed_headers", fmt.Sprintf("%v", cfg.Server.HTTP.CORSAllowedHeaders), getKeyOrigin(cmd, "http-cors-allowed-headers", "PERMIFY_HTTP_CORS_ALLOWED_HEADERS")}, |
159
|
|
|
// PROFILER |
160
|
|
|
[]string{"profiler.enabled", fmt.Sprintf("%v", cfg.Profiler.Enabled), getKeyOrigin(cmd, "profiler-enabled", "PERMIFY_PROFILER_ENABLED")}, |
161
|
|
|
[]string{"profiler.port", cfg.Profiler.Port, getKeyOrigin(cmd, "profiler-port", "PERMIFY_PROFILER_PORT")}, |
162
|
|
|
// LOG |
163
|
|
|
[]string{"logger.level", cfg.Log.Level, getKeyOrigin(cmd, "log-level", "PERMIFY_LOG_LEVEL")}, |
164
|
|
|
[]string{"logger.output", cfg.Log.Output, getKeyOrigin(cmd, "log-output", "PERMIFY_LOG_OUTPUT")}, |
165
|
|
|
[]string{"logger.enabled", fmt.Sprintf("%v", cfg.Log.Enabled), getKeyOrigin(cmd, "log-enabled", "PERMIFY_LOG_ENABLED")}, |
166
|
|
|
[]string{"logger.exporter", cfg.Log.Exporter, getKeyOrigin(cmd, "log-exporter", "PERMIFY_LOG_EXPORTER")}, |
167
|
|
|
[]string{"logger.endpoint", HideSecret(cfg.Log.Exporter), getKeyOrigin(cmd, "log-endpoint", "PERMIFY_LOG_ENDPOINT")}, |
168
|
|
|
[]string{"logger.insecure", fmt.Sprintf("%v", cfg.Log.Insecure), getKeyOrigin(cmd, "log-insecure", "PERMIFY_LOG_INSECURE")}, |
169
|
|
|
[]string{"logger.urlpath", cfg.Log.Urlpath, getKeyOrigin(cmd, "log-urlpath", "PERMIFY_LOG_URL_PATH")}, |
170
|
|
|
[]string{"logger.headers", fmt.Sprintf("%v", cfg.Log.Headers), getKeyOrigin(cmd, "log-headers", "PERMIFY_LOG_HEADERS")}, |
171
|
|
|
[]string{"logger.protocol", cfg.Log.Protocol, getKeyOrigin(cmd, "log-protocol", "PERMIFY_LOG_PROTOCOL")}, |
172
|
|
|
// AUTHN |
173
|
|
|
[]string{"authn.enabled", fmt.Sprintf("%v", cfg.Authn.Enabled), getKeyOrigin(cmd, "authn-enabled", "PERMIFY_AUTHN_ENABLED")}, |
174
|
|
|
[]string{"authn.method", cfg.Authn.Method, getKeyOrigin(cmd, "authn-method", "PERMIFY_AUTHN_METHOD")}, |
175
|
|
|
[]string{"authn.preshared.keys", fmt.Sprintf("%v", HideSecrets(cfg.Authn.Preshared.Keys...)), getKeyOrigin(cmd, "authn-preshared-keys", "PERMIFY_AUTHN_PRESHARED_KEYS")}, |
176
|
|
|
[]string{"authn.oidc.issuer", HideSecret(cfg.Authn.Oidc.Issuer), getKeyOrigin(cmd, "authn-oidc-issuer", "PERMIFY_AUTHN_OIDC_ISSUER")}, |
177
|
|
|
[]string{"authn.oidc.audience", HideSecret(cfg.Authn.Oidc.Audience), getKeyOrigin(cmd, "authn-oidc-audience", "PERMIFY_AUTHN_OIDC_AUDIENCE")}, |
178
|
|
|
[]string{"authn.oidc.refresh_interval", fmt.Sprintf("%v", cfg.Authn.Oidc.RefreshInterval), getKeyOrigin(cmd, "authn-oidc-refresh-interval", "PERMIFY_AUTHN_OIDC_REFRESH_INTERVAL")}, |
179
|
|
|
[]string{"authn.oidc.backoff_interval", fmt.Sprintf("%v", cfg.Authn.Oidc.BackoffInterval), getKeyOrigin(cmd, "authn-oidc-backoff-interval", "PERMIFY_AUTHN_OIDC_BACKOFF_INTERVAL")}, |
180
|
|
|
[]string{"authn.oidc.backoff_max_retries", fmt.Sprintf("%v", cfg.Authn.Oidc.BackoffMaxRetries), getKeyOrigin(cmd, "authn-oidc-backoff-max-retries", "PERMIFY_AUTHN_OIDC_BACKOFF_RETRIES")}, |
181
|
|
|
[]string{"authn.oidc.backoff_frequency", fmt.Sprintf("%v", cfg.Authn.Oidc.BackoffFrequency), getKeyOrigin(cmd, "authn-oidc-backoff-frequency", "PERMIFY_AUTHN_OIDC_BACKOFF_FREQUENCY")}, |
182
|
|
|
[]string{"authn.oidc.valid_methods", fmt.Sprintf("%v", cfg.Authn.Oidc.ValidMethods), getKeyOrigin(cmd, "authn-oidc-valid-methods", "PERMIFY_AUTHN_OIDC_VALID_METHODS")}, |
183
|
|
|
// TRACER |
184
|
|
|
[]string{"tracer.enabled", fmt.Sprintf("%v", cfg.Tracer.Enabled), getKeyOrigin(cmd, "tracer-enabled", "PERMIFY_TRACER_ENABLED")}, |
185
|
|
|
[]string{"tracer.exporter", cfg.Tracer.Exporter, getKeyOrigin(cmd, "tracer-exporter", "PERMIFY_TRACER_EXPORTER")}, |
186
|
|
|
[]string{"tracer.endpoint", HideSecret(cfg.Tracer.Exporter), getKeyOrigin(cmd, "tracer-endpoint", "PERMIFY_TRACER_ENDPOINT")}, |
187
|
|
|
[]string{"tracer.insecure", fmt.Sprintf("%v", cfg.Tracer.Insecure), getKeyOrigin(cmd, "tracer-insecure", "PERMIFY_TRACER_INSECURE")}, |
188
|
|
|
[]string{"tracer.urlpath", cfg.Tracer.Urlpath, getKeyOrigin(cmd, "tracer-urlpath", "PERMIFY_TRACER_URL_PATH")}, |
189
|
|
|
[]string{"tracer.headers", fmt.Sprintf("%v", cfg.Tracer.Headers), getKeyOrigin(cmd, "tracer-headers", "PERMIFY_TRACER_HEADERS")}, |
190
|
|
|
[]string{"tracer.protocol", cfg.Tracer.Protocol, getKeyOrigin(cmd, "tracer-protocol", "PERMIFY_TRACER_PROTOCOL")}, |
191
|
|
|
// METER |
192
|
|
|
[]string{"meter.enabled", fmt.Sprintf("%v", cfg.Meter.Enabled), getKeyOrigin(cmd, "meter-enabled", "PERMIFY_METER_ENABLED")}, |
193
|
|
|
[]string{"meter.exporter", cfg.Meter.Exporter, getKeyOrigin(cmd, "meter-exporter", "PERMIFY_METER_EXPORTER")}, |
194
|
|
|
[]string{"meter.endpoint", HideSecret(cfg.Meter.Exporter), getKeyOrigin(cmd, "meter-endpoint", "PERMIFY_METER_ENDPOINT")}, |
195
|
|
|
[]string{"meter.insecure", fmt.Sprintf("%v", cfg.Meter.Insecure), getKeyOrigin(cmd, "meter-insecure", "PERMIFY_METER_INSECURE")}, |
196
|
|
|
[]string{"meter.urlpath", cfg.Meter.Urlpath, getKeyOrigin(cmd, "meter-urlpath", "PERMIFY_METER_URL_PATH")}, |
197
|
|
|
[]string{"meter.headers", fmt.Sprintf("%v", cfg.Meter.Headers), getKeyOrigin(cmd, "meter-headers", "PERMIFY_METER_HEADERS")}, |
198
|
|
|
[]string{"meter.protocol", cfg.Meter.Protocol, getKeyOrigin(cmd, "meter-protocol", "PERMIFY_METER_PROTOCOL")}, |
199
|
|
|
[]string{"meter.interval", fmt.Sprintf("%v", cfg.Meter.Interval), getKeyOrigin(cmd, "meter-interval", "PERMIFY_METER_INTERVAL")}, |
200
|
|
|
// SERVICE |
201
|
|
|
[]string{"service.circuit_breaker", fmt.Sprintf("%v", cfg.Service.CircuitBreaker), getKeyOrigin(cmd, "service-circuit-breaker", "PERMIFY_SERVICE_CIRCUIT_BREAKER")}, |
202
|
|
|
[]string{"service.schema.cache.number_of_counters", fmt.Sprintf("%v", cfg.Service.Schema.Cache.NumberOfCounters), getKeyOrigin(cmd, "service-schema-cache-number-of-counters", "PERMIFY_SERVICE_WATCH_ENABLED")}, |
203
|
|
|
[]string{"service.schema.cache.max_cost", cfg.Service.Schema.Cache.MaxCost, getKeyOrigin(cmd, "service-schema-cache-max-cost", "PERMIFY_SERVICE_SCHEMA_CACHE_MAX_COST")}, |
204
|
|
|
[]string{"service.permission.bulk_limit", fmt.Sprintf("%v", cfg.Service.Permission.BulkLimit), getKeyOrigin(cmd, "service-permission-bulk-limit", "PERMIFY_SERVICE_PERMISSION_BULK_LIMIT")}, |
205
|
|
|
[]string{"service.permission.concurrency_limit", fmt.Sprintf("%v", cfg.Service.Permission.ConcurrencyLimit), getKeyOrigin(cmd, "service-permission-concurrency-limit", "PERMIFY_SERVICE_PERMISSION_CONCURRENCY_LIMIT")}, |
206
|
|
|
[]string{"service.permission.cache.number_of_counters", fmt.Sprintf("%v", cfg.Service.Permission.Cache.NumberOfCounters), getKeyOrigin(cmd, "service-permission-cache-number-of-counters", "PERMIFY_SERVICE_PERMISSION_CACHE_NUMBER_OF_COUNTERS")}, |
207
|
|
|
[]string{"service.permission.cache.max_cost", fmt.Sprintf("%v", cfg.Service.Permission.Cache.MaxCost), getKeyOrigin(cmd, "service-permission-cache-max-cost", "PERMIFY_SERVICE_PERMISSION_CACHE_MAX_COST")}, |
208
|
|
|
// DATABASE |
209
|
|
|
[]string{"database.engine", cfg.Database.Engine, getKeyOrigin(cmd, "database-engine", "PERMIFY_DATABASE_ENGINE")}, |
210
|
|
|
[]string{"database.uri", HideSecret(cfg.Database.URI), getKeyOrigin(cmd, "database-uri", "PERMIFY_DATABASE_URI")}, |
211
|
|
|
[]string{"database.writer.uri", HideSecret(cfg.Database.Writer.URI), getKeyOrigin(cmd, "database-writer-uri", "PERMIFY_DATABASE_WRITER_URI")}, |
212
|
|
|
[]string{"database.reader.uri", HideSecret(cfg.Database.Reader.URI), getKeyOrigin(cmd, "database-reader-uri", "PERMIFY_DATABASE_READER_URI")}, |
213
|
|
|
[]string{"database.auto_migrate", fmt.Sprintf("%v", cfg.Database.AutoMigrate), getKeyOrigin(cmd, "database-auto-migrate", "PERMIFY_DATABASE_AUTO_MIGRATE")}, |
214
|
|
|
[]string{"database.max_open_connections", fmt.Sprintf("%v", cfg.Database.MaxOpenConnections), getKeyOrigin(cmd, "database-max-open-connections", "PERMIFY_DATABASE_MAX_OPEN_CONNECTIONS")}, |
215
|
|
|
[]string{"database.max_idle_connections", fmt.Sprintf("%v", cfg.Database.MaxIdleConnections), getKeyOrigin(cmd, "database-max-idle-connections", "PERMIFY_DATABASE_MAX_IDLE_CONNECTIONS")}, |
216
|
|
|
[]string{"database.max_connection_lifetime", fmt.Sprintf("%v", cfg.Database.MaxConnectionLifetime), getKeyOrigin(cmd, "database-max-connection-lifetime", "PERMIFY_DATABASE_MAX_CONNECTION_LIFETIME")}, |
217
|
|
|
[]string{"database.max_connection_idle_time", fmt.Sprintf("%v", cfg.Database.MaxConnectionIdleTime), getKeyOrigin(cmd, "database-max-connection-idle-time", "PERMIFY_DATABASE_MAX_CONNECTION_IDLE_TIME")}, |
218
|
|
|
[]string{"database.max_data_per_write", fmt.Sprintf("%v", cfg.Database.MaxDataPerWrite), getKeyOrigin(cmd, "database-max-data-per-write", "PERMIFY_DATABASE_MAX_DATA_PER_WRITE")}, |
219
|
|
|
[]string{"database.max_retries", fmt.Sprintf("%v", cfg.Database.MaxRetries), getKeyOrigin(cmd, "database-max-retries", "PERMIFY_DATABASE_MAX_RETRIES")}, |
220
|
|
|
[]string{"database.watch_buffer_size", fmt.Sprintf("%v", cfg.Database.WatchBufferSize), getKeyOrigin(cmd, "database-watch-buffer-size", "PERMIFY_DATABASE_WATCH_BUFFER_SIZE")}, |
221
|
|
|
[]string{"database.garbage_collection.enabled", fmt.Sprintf("%v", cfg.Database.GarbageCollection.Enabled), getKeyOrigin(cmd, "database-garbage-collection-enabled", "PERMIFY_DATABASE_GARBAGE_COLLECTION_ENABLED")}, |
222
|
|
|
[]string{"database.garbage_collection.interval", fmt.Sprintf("%v", cfg.Database.GarbageCollection.Interval), getKeyOrigin(cmd, "database-garbage-collection-interval", "PERMIFY_DATABASE_GARBAGE_COLLECTION_INTERVAL")}, |
223
|
|
|
[]string{"database.garbage_collection.timeout", fmt.Sprintf("%v", cfg.Database.GarbageCollection.Timeout), getKeyOrigin(cmd, "database-garbage-collection-timeout", "PERMIFY_DATABASE_GARBAGE_COLLECTION_TIMEOUT")}, |
224
|
|
|
[]string{"database.garbage_collection.window", fmt.Sprintf("%v", cfg.Database.GarbageCollection.Window), getKeyOrigin(cmd, "database-garbage-collection-window", "PERMIFY_DATABASE_GARBAGE_COLLECTION_WINDOW")}, |
225
|
|
|
// DISTRIBUTED |
226
|
|
|
[]string{"distributed.enabled", fmt.Sprintf("%v", cfg.Distributed.Enabled), getKeyOrigin(cmd, "distributed-enabled", "PERMIFY_DISTRIBUTED_ENABLED")}, |
227
|
|
|
[]string{"distributed.address", cfg.Distributed.Address, getKeyOrigin(cmd, "distributed-address", "PERMIFY_DISTRIBUTED_ADDRESS")}, |
228
|
|
|
[]string{"distributed.port", cfg.Distributed.Port, getKeyOrigin(cmd, "distributed-port", "PERMIFY_DISTRIBUTED_PORT")}, |
229
|
|
|
) |
230
|
|
|
|
231
|
|
|
renderConfigTable(data) |
232
|
|
|
return nil |
233
|
|
|
} |
234
|
|
|
} |
235
|
|
|
|
236
|
|
|
// getKeyOrigin determines the source of a configuration value. |
237
|
|
|
// It checks whether a value was set via a command-line flag, an environment variable, or defaults to file. |
238
|
|
|
func getKeyOrigin(cmd *cobra.Command, flagKey, envKey string) string { |
239
|
|
|
// Check if the command-line flag (specified by flagKey) was explicitly set by the user. |
240
|
|
|
if cmd.Flags().Changed(flagKey) { |
241
|
|
|
// If the flag was set, return "FLAG" with light green color. |
242
|
|
|
return color.FgLightGreen.Render("FLAG") |
243
|
|
|
} |
244
|
|
|
|
245
|
|
|
// Check if the environment variable (specified by envKey) exists. |
246
|
|
|
_, exists := os.LookupEnv(envKey) |
247
|
|
|
if exists { |
248
|
|
|
// If the environment variable exists, return "ENV" with light blue color. |
249
|
|
|
return color.FgLightBlue.Render("ENV") |
250
|
|
|
} |
251
|
|
|
|
252
|
|
|
// If neither the command-line flag nor the environment variable was set, |
253
|
|
|
// assume the value came from a configuration file. |
254
|
|
|
return color.FgYellow.Render("FILE") |
255
|
|
|
} |
256
|
|
|
|
257
|
|
|
// renderConfigTable displays configuration data in a formatted table on the console. |
258
|
|
|
// It takes a 2D slice of strings where each inner slice represents a row in the table. |
259
|
|
|
func renderConfigTable(data [][]string) { |
260
|
|
|
// Create a new table writer object, writing to standard output. |
261
|
|
|
table := tablewriter.NewWriter(os.Stdout) |
262
|
|
|
|
263
|
|
|
// Set the headers of the table. Each header cell is a column title. |
264
|
|
|
table.Header([]string{"Key", "Value", "Source"}) |
265
|
|
|
|
266
|
|
|
// Loop through the data and add each row to the table. |
267
|
|
|
for _, v := range data { |
268
|
|
|
if err := table.Append(v); err != nil { |
269
|
|
|
fmt.Fprintf(os.Stderr, "failed to append row to table: %v\n", err) |
270
|
|
|
} |
271
|
|
|
} |
272
|
|
|
|
273
|
|
|
// Render the table to standard output, displaying it to the user. |
274
|
|
|
if err := table.Render(); err != nil { |
275
|
|
|
fmt.Fprintf(os.Stderr, "failed to render table: %v\n", err) |
276
|
|
|
} |
277
|
|
|
} |
278
|
|
|
|
279
|
|
|
// HideSecret replaces all but the first and last characters of a string with asterisks |
280
|
|
|
func HideSecret(secret string) string { |
281
|
|
|
if len(secret) <= 2 { |
282
|
|
|
// If the secret is too short, just return asterisks |
283
|
|
|
return strings.Repeat("*", len(secret)) |
284
|
|
|
} |
285
|
|
|
// Keep first and last character visible; replace the rest with asterisks |
286
|
|
|
return string(secret[0]) + strings.Repeat("*", len(secret)-2) + string(secret[len(secret)-1]) |
287
|
|
|
} |
288
|
|
|
|
289
|
|
|
// HideSecrets obscures each string in a given list. |
290
|
|
|
func HideSecrets(secrets ...string) (rv []string) { |
291
|
|
|
// Convert each secret to its hidden version and collect them. |
292
|
|
|
for _, secret := range secrets { |
293
|
|
|
rv = append(rv, HideSecret(secret)) // Hide each secret. |
294
|
|
|
} |
295
|
|
|
return |
296
|
|
|
} |
297
|
|
|
|