-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add boolen configuration to enable or disable request interception
- Loading branch information
1 parent
1e05e60
commit 4ea62f8
Showing
12 changed files
with
211 additions
and
52 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| enableTratInterception: "false" |
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 |
|---|---|---|
| @@ -1,11 +1,15 @@ | ||
| docker build -t tconfigd:latest -f ../../service/Dockerfile ../../service/ | ||
|
|
||
| kubectl create namespace tratteria | ||
|
|
||
| kubectl create configmap config --from-file=config.yaml=config.yaml -n tratteria | ||
|
|
||
| cd ../../rules | ||
| chmod +x deploy-rules.sh | ||
| ./deploy-rules.sh example-rules | ||
| cd ../kubernetes/tconfigd | ||
|
|
||
| kubectl apply -f service-account.yaml | ||
| kubectl apply -f deployment.yaml | ||
| kubectl apply -f service.yaml | ||
| kubectl apply -f tratteria-agent-injector-mutating-webhook.yaml | ||
|
|
||
| cd ../../rules | ||
| chmod +x deploy-rules.sh | ||
| ./deploy-rules.sh example-rules |
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
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,121 @@ | ||
| package config | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "os" | ||
| "reflect" | ||
| "regexp" | ||
| "strconv" | ||
|
|
||
| "gopkg.in/yaml.v2" | ||
| ) | ||
|
|
||
| type BoolFromString bool | ||
|
|
||
| func (b *BoolFromString) UnmarshalYAML(unmarshal func(interface{}) error) error { | ||
| var tmp interface{} | ||
| if err := unmarshal(&tmp); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| switch value := tmp.(type) { | ||
| case bool: | ||
| *b = BoolFromString(value) | ||
| case string: | ||
| if matched, envVarName := extractEnvVarName(value); matched { | ||
| envValue, err := getEnvVarValue(envVarName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| boolVal, err := strconv.ParseBool(envValue) | ||
|
|
||
| if err != nil { | ||
| return fmt.Errorf("error parsing boolean from environment variable: %v", err) | ||
| } | ||
|
|
||
| *b = BoolFromString(boolVal) | ||
| } else { | ||
| boolVal, err := strconv.ParseBool(value) | ||
| if err != nil { | ||
| return fmt.Errorf("error parsing boolean from string: %v", err) | ||
| } | ||
|
|
||
| *b = BoolFromString(boolVal) | ||
| } | ||
| default: | ||
| return fmt.Errorf("invalid type for a bool variable, expected bool or string, got %T", tmp) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| type AppConfig struct { | ||
| EnableTratInterception BoolFromString `yaml:"enableTratInterception"` | ||
| } | ||
|
|
||
| func GetAppConfig(configPath string) (*AppConfig, error) { | ||
| data, err := os.ReadFile(configPath) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to read config file: %w", err) | ||
| } | ||
|
|
||
| var cfg AppConfig | ||
| if err := yaml.Unmarshal(data, &cfg); err != nil { | ||
| return nil, fmt.Errorf("failed to unmarshal YAML configuration: %w", err) | ||
| } | ||
|
|
||
| resolveEnvVariables(&cfg) | ||
|
|
||
| return &cfg, nil | ||
| } | ||
|
|
||
| func extractEnvVarName(s string) (bool, string) { | ||
| envVarRegex := regexp.MustCompile(`^\$\{([^}]+)\}$`) | ||
| matches := envVarRegex.FindStringSubmatch(s) | ||
|
|
||
| if len(matches) > 1 { | ||
| return true, matches[1] | ||
| } | ||
|
|
||
| return false, "" | ||
| } | ||
|
|
||
| func getEnvVarValue(envVarName string) (string, error) { | ||
| if envValue, exists := os.LookupEnv(envVarName); exists { | ||
| return envValue, nil | ||
| } | ||
|
|
||
| return "", fmt.Errorf("environment variable %s not set", envVarName) | ||
| } | ||
|
|
||
| func resolveEnvVariablesUtil(v reflect.Value) { | ||
| if v.Kind() == reflect.Ptr { | ||
| v = v.Elem() | ||
| } | ||
|
|
||
| for i := 0; i < v.NumField(); i++ { | ||
| field := v.Field(i) | ||
| if field.Kind() == reflect.String { | ||
| fieldValue := field.String() | ||
|
|
||
| if matched, envVarName := extractEnvVarName(fieldValue); matched { | ||
| envValue, err := getEnvVarValue(envVarName) | ||
| if err != nil { | ||
| panic(err.Error()) | ||
| } | ||
|
|
||
| field.SetString(envValue) | ||
| } | ||
| } else if field.Kind() == reflect.Struct { | ||
| resolveEnvVariablesUtil(field) | ||
| } else if field.Kind() == reflect.Ptr && field.Elem().Kind() == reflect.Struct { | ||
| resolveEnvVariablesUtil(field.Elem()) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func resolveEnvVariables(cfg *AppConfig) { | ||
| v := reflect.ValueOf(cfg) | ||
| resolveEnvVariablesUtil(v) | ||
| } |
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
Oops, something went wrong.