diff --git a/cmd/webhook/config.go b/cmd/webhook/config.go deleted file mode 100644 index 12f47ed..0000000 --- a/cmd/webhook/config.go +++ /dev/null @@ -1,44 +0,0 @@ -package main - -import ( - "os" - "time" - - "github.com/hashicorp/logutils" -) - -type configStructure struct { - // time configuration - TimeFormat string - TimeZoneLocal *time.Location - TimeZoneUTC *time.Location - - // logging - LogLevel int - Log *logutils.LevelFilter - - // webserver - WebSrvPort int - WebSrvIP string - WebSrvReadTimeout int - WebSrvWriteTimeout int - WebSrvIdleTimeout int -} - -type patchOperation struct { - Op string `json:"op"` - Path string `json:"path"` - Value interface{} `json:"value,omitempty"` -} - -// Set Defaults -var config = configStructure{ - TimeFormat: "2006-01-02 15:04:05", - Log: &logutils.LevelFilter{ - Levels: []logutils.LogLevel{"TRACE", "DEBUG", "INFO", "WARNING", "ERROR"}, - Writer: os.Stderr, - }, - WebSrvReadTimeout: 5, - WebSrvWriteTimeout: 10, - WebSrvIdleTimeout: 2, -} diff --git a/cmd/webhook/httpServer.go b/cmd/webhook/httpServer.go index 3c4fe27..414dc80 100644 --- a/cmd/webhook/httpServer.go +++ b/cmd/webhook/httpServer.go @@ -1,5 +1,5 @@ package main - +/* import ( "log" "net/http" @@ -70,3 +70,4 @@ func webHealthCheck(w http.ResponseWriter, r *http.Request) { tmpltError(w, http.StatusBadRequest, InvalidMethod) } } +*/ \ No newline at end of file diff --git a/cmd/webhook/init.go b/cmd/webhook/init.go deleted file mode 100644 index 09c6a5b..0000000 --- a/cmd/webhook/init.go +++ /dev/null @@ -1,115 +0,0 @@ -package main - -import ( - "flag" - "log" - "os" - "strconv" - "time" - - "github.com/hashicorp/logutils" -) - -// getEnvString returns string from environment variable -func getEnvString(env, def string) (val string) { //nolint:deadcode - val = os.Getenv(env) - - if val == "" { - return def - } - - return -} - -// getEnvInt returns int from environment variable -func getEnvInt(env string, def int) (ret int) { - val := os.Getenv(env) - - if val == "" { - return def - } - - ret, err := strconv.Atoi(val) - if err != nil { - log.Fatalf("[ERROR] Environment variable is not numeric: %v\n", env) - } - - return -} - -func setLogLevel(l int) { - switch { - case l <= 20: - config.Log.SetMinLevel(logutils.LogLevel("ERROR")) - case l > 20 && l <= 40: - config.Log.SetMinLevel(logutils.LogLevel("WARNING")) - case l > 40 && l <= 60: - config.Log.SetMinLevel(logutils.LogLevel("INFO")) - case l > 60 && l <= 80: - config.Log.SetMinLevel(logutils.LogLevel("DEBUG")) - case l > 80: - config.Log.SetMinLevel(logutils.LogLevel("TRACE")) - } -} - -func initialize() { - var ( - tz string - err error - ) - - // log configuration - flag.IntVar(&config.LogLevel, - "log", - getEnvInt("LOG_LEVEL", 50), - "(LOG_LEVEL)\nlog level") - // local webserver configuration - flag.IntVar(&config.WebSrvPort, - "http-port", - getEnvInt("HTTP_PORT", 8080), - "(HTTP_PORT)\nlisten port for internal webserver") - flag.StringVar(&config.WebSrvIP, - "http-ip", - getEnvString("HTTP_IP", ""), - "(HTTP_IP)\nlisten ip for internal webserver") - flag.IntVar(&config.WebSrvReadTimeout, - "http-read-timeout", - getEnvInt("HTTP_READ_TIMEOUT", 5), - "(HTTP_READ_TIMEOUT)\ninternal http server read timeout in seconds") - flag.IntVar(&config.WebSrvWriteTimeout, - "http-write-timeout", - getEnvInt("HTTP_WRITE_TIMEOUT", 2), - "(HTTP_WRITE_TIMEOUT\ninternal http server write timeout in seconds") - flag.IntVar(&config.WebSrvIdleTimeout, - "http-idle-timeout", - getEnvInt("HTTP_IDLE_TIMEOUT", 2), - "(HTTP_IDLE_TIMEOUT)\ninternal http server idle timeout in seconds") - // timezone - flag.StringVar(&tz, - "timezone", - getEnvString("TZ", "America/Chicago"), - "(TZ)\ntimezone") - // read command line options - flag.Parse() - - // logging level - setLogLevel(config.LogLevel) - log.SetOutput(config.Log) - - // timezone configuration - config.TimeZoneUTC, _ = time.LoadLocation("UTC") - if config.TimeZoneLocal, err = time.LoadLocation(tz); err != nil { - log.Fatalf("[ERROR] Unable to parse timezone string. Please use one of the timezone database values listed here: %s", "https://en.wikipedia.org/wiki/List_of_tz_database_time_zones") - } - - // print current configuration - log.Printf("[DEBUG] configuration value set: LOG_LEVEL = %s\n", strconv.Itoa(config.LogLevel)) - log.Printf("[DEBUG] configuration value set: HTTP_PORT = %s\n", strconv.Itoa(config.WebSrvPort)) - log.Printf("[DEBUG] configuration value set: HTTP_IP = %s\n", config.WebSrvIP) - log.Printf("[DEBUG] configuration value set: HTTP_READ_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvReadTimeout)) - log.Printf("[DEBUG] configuration value set: HTTP_WRITE_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvWriteTimeout)) - log.Printf("[DEBUG] configuration value set: HTTP_IDLE_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvIdleTimeout)) - log.Printf("[DEBUG] configuration value set: TZ = %s\n", tz) - - log.Println("[INFO] initialization complete") -} diff --git a/cmd/webhook/main.go b/cmd/webhook/main.go index f6dd5ae..404c45c 100644 --- a/cmd/webhook/main.go +++ b/cmd/webhook/main.go @@ -5,6 +5,8 @@ import ( "os" "os/signal" "syscall" + + "mutating-webhook/internal/initialize" ) func forever() { @@ -20,9 +22,9 @@ func main() { log.Println("[DEBUG] shutdown sequence complete") }() - initialize() + initialize.Init() - go httpServer(config.WebSrvIP, config.WebSrvPort) + //go httpServer(config.WebSrvIP, config.WebSrvPort) forever() } diff --git a/cmd/webhook/mutate.go b/cmd/webhook/mutate.go index e3dd07e..649d4be 100644 --- a/cmd/webhook/mutate.go +++ b/cmd/webhook/mutate.go @@ -1,5 +1,5 @@ package main - +/* import ( "fmt" "log" @@ -186,3 +186,4 @@ func mutationRequired(metadata *meta.ObjectMeta) bool { log.Printf("[TRACE] Mutation policy for %v/%v: required:%v", metadata.Namespace, metadata.Name, required) return required } +*/ \ No newline at end of file diff --git a/go.mod b/go.mod index 2d58609..8122d35 100644 --- a/go.mod +++ b/go.mod @@ -2,27 +2,4 @@ module mutating-webhook go 1.19 -require ( - github.com/hashicorp/logutils v1.0.0 - k8s.io/api v0.25.0 - k8s.io/apimachinery v0.25.0 -) - -require ( - github.com/go-logr/logr v1.2.3 // indirect - github.com/gogo/protobuf v1.3.2 // indirect - github.com/google/go-cmp v0.5.8 // indirect - github.com/google/gofuzz v1.2.0 // indirect - github.com/json-iterator/go v1.1.12 // indirect - github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect - github.com/modern-go/reflect2 v1.0.2 // indirect - golang.org/x/net v0.0.0-20220909164309-bea034e7d591 // indirect - golang.org/x/text v0.3.7 // indirect - gopkg.in/inf.v0 v0.9.1 // indirect - gopkg.in/yaml.v2 v2.4.0 // indirect - k8s.io/klog/v2 v2.80.1 // indirect - k8s.io/utils v0.0.0-20220823124924-e9cbc92d1a73 // indirect - sigs.k8s.io/json v0.0.0-20220713155537-f223a00ba0e2 // indirect - sigs.k8s.io/structured-merge-diff/v4 v4.2.3 // indirect - sigs.k8s.io/yaml v1.3.0 // indirect -) +require github.com/hashicorp/logutils v1.0.0 diff --git a/go.sum b/go.sum index b20f8e6..635dc62 100644 --- a/go.sum +++ b/go.sum @@ -1,88 +1,2 @@ -github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= -github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/go-logr/logr v0.1.0/go.mod h1:ixOQHD9gLJUVQQ2ZOR7zLEifBX6tGkNJF4QyIY7sIas= -github.com/go-logr/logr v1.2.0/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= -github.com/go-logr/logr v1.2.3 h1:2DntVwHkVopvECVRSlL5PSo9eG+cAkDCuckLubN+rq0= -github.com/go-logr/logr v1.2.3/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= -github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= -github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q= -github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg= -github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= -github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= -github.com/google/gofuzz v1.2.0 h1:xRy4A+RhZaiKjJ1bPfwQ8sedCA+YS2YcCHW6ec7JMi0= -github.com/google/gofuzz v1.2.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/hashicorp/logutils v1.0.0 h1:dLEQVugN8vlakKOUE3ihGLTZJRB4j+M2cdTm/ORI65Y= github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64= -github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= -github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= -github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8= -github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck= -github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= -github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= -github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= -github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= -github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= -github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= -github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs= -github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= -github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/spf13/afero v1.2.2/go.mod h1:9ZxEEn6pIJ8Rxe320qSDBk6AsU0r9pR7Q4OcevTdifk= -github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA= -github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= -github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= -github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= -github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= -golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= -golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= -golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= -golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= -golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= -golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= -golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= -golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= -golang.org/x/net v0.0.0-20220909164309-bea034e7d591 h1:D0B/7al0LLrVC8aWF4+oxpv/m8bc7ViFfVS8/gXGdqI= -golang.org/x/net v0.0.0-20220909164309-bea034e7d591/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk= -golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= -golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= -golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.7 h1:olpwvP2KacW1ZWvsR7uQhoyTYvKAupfQrRGBFM352Gk= -golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= -golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= -golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= -golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE= -golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= -golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU= -gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc= -gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw= -gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= -gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= -gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= -k8s.io/api v0.25.0 h1:H+Q4ma2U/ww0iGB78ijZx6DRByPz6/733jIuFpX70e0= -k8s.io/api v0.25.0/go.mod h1:ttceV1GyV1i1rnmvzT3BST08N6nGt+dudGrquzVQWPk= -k8s.io/apimachinery v0.25.0 h1:MlP0r6+3XbkUG2itd6vp3oxbtdQLQI94fD5gCS+gnoU= -k8s.io/apimachinery v0.25.0/go.mod h1:qMx9eAk0sZQGsXGu86fab8tZdffHbwUfsvzqKn4mfB0= -k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE= -k8s.io/klog/v2 v2.80.1 h1:atnLQ121W371wYYFawwYx1aEY2eUfs4l3J72wtgAwV4= -k8s.io/klog/v2 v2.80.1/go.mod h1:y1WjHnz7Dj687irZUWR/WLkLc5N1YHtjLdmgWjndZn0= -k8s.io/utils v0.0.0-20220823124924-e9cbc92d1a73 h1:H9TCJUUx+2VA0ZiD9lvtaX8fthFsMoD+Izn93E/hm8U= -k8s.io/utils v0.0.0-20220823124924-e9cbc92d1a73/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA= -sigs.k8s.io/json v0.0.0-20220713155537-f223a00ba0e2 h1:iXTIw73aPyC+oRdyqqvVJuloN1p0AC/kzH07hu3NE+k= -sigs.k8s.io/json v0.0.0-20220713155537-f223a00ba0e2/go.mod h1:B8JuhiUyNFVKdsE8h686QcCxMaH6HrOAZj4vswFpcB0= -sigs.k8s.io/structured-merge-diff/v4 v4.2.3 h1:PRbqxJClWWYMNV1dhaG4NsibJbArud9kFxnAMREiWFE= -sigs.k8s.io/structured-merge-diff/v4 v4.2.3/go.mod h1:qjx8mGObPmV2aSZepjQjbmb2ihdVs8cGKBraizNC69E= -sigs.k8s.io/yaml v1.3.0 h1:a2VclLzOGrwOHDiV8EfBGhvjHvP46CtW5j6POvhYGGo= -sigs.k8s.io/yaml v1.3.0/go.mod h1:GeOyir5tyXNByN85N/dRIT9es5UQNerPYEKK56eTBm8= diff --git a/internal/config/config.go b/internal/config/config.go new file mode 100644 index 0000000..39a1fa7 --- /dev/null +++ b/internal/config/config.go @@ -0,0 +1,55 @@ +package config + +import ( + "fmt" + "time" + + "github.com/hashicorp/logutils" +) + +type Config struct { + // time configuration + TimeFormat string `env:"TIME_FORMAT" default:"2006-01-02 15:04:05"` + TimeZoneLocal *time.Location + TimeZoneUTC *time.Location + + // logging + LogLevel int `env:"LOG_LEVEL" default:"50"` + Log *logutils.LevelFilter + + // webserver + WebServerPort int `env:"WEBSERVER_PORT" default:"8080"` + WebServerIP string `env:"WEBSERVER_IP" default:"0.0.0.0"` + WebServerReadTimeout int `env:"WEBSERVER_READ_TIMEOUT" default:"5"` + WebServerWriteTimeout int `env:"WEBSERVER_WRITE_TIMEOUT" default:"1"` + WebServerIdleTimeout int `env:"WEBSERVER_IDLE_TIMEOUT" default:"2"` +} + +func NewConfig() (*Config, error) { + cfg := &Config{} + + return cfg, nil +} + +func (cfg *Config) Validate() error { + checks := []struct { + bad bool + errMsg string + }{ + {cfg.TimeFormat == "", "no TimeFormat specified"}, + {cfg.LogLevel == 0, "no LogLevel specified"}, + {cfg.WebServerPort == 0, "no WebServer.Port specified"}, + {cfg.WebServerIP == "", "no WebServer.IP specified"}, + {cfg.WebServerReadTimeout == 0, "no WebServer.ReadTimeout specified"}, + {cfg.WebServerWriteTimeout == 0, "no WebServer.WriteTimeout specified"}, + {cfg.WebServerIdleTimeout == 0, "no WebServer.IdleTimeout specified"}, + } + + for _, check := range checks { + if check.bad { + return fmt.Errorf("invalid config: %s", check.errMsg) + } + } + + return nil +} diff --git a/internal/envconfig/envconfig.go b/internal/envconfig/envconfig.go new file mode 100644 index 0000000..4d1c4d2 --- /dev/null +++ b/internal/envconfig/envconfig.go @@ -0,0 +1,117 @@ +package envconfig + +import ( + "fmt" + "reflect" + "strconv" + "strings" +) + +/* +ignored:"true" +env:"ENVIRONMENT_VARIABLE" +default:"default value" +*/ + +type StructInfo struct { + Name string + Alt string + Key string + Field reflect.Value + Tags reflect.StructTag + Type reflect.Type + DefaultValue interface{} +} + +func GetStructInfo(spec interface{}) ([]StructInfo, error) { + s := reflect.ValueOf(spec) + + if s.Kind() != reflect.Pointer { + return []StructInfo{}, fmt.Errorf("getStructInfo() was sent a %s instead of a pointer to a struct.\n", s.Kind()) + } + + s = s.Elem() + if s.Kind() != reflect.Struct { + return []StructInfo{}, fmt.Errorf("getStructInfo() was sent a %s instead of a struct.\n", s.Kind()) + } + typeOfSpec := s.Type() + + infos := make([]StructInfo, 0, s.NumField()) + for i := 0; i < s.NumField(); i++ { + f := s.Field(i) + ftype := typeOfSpec.Field(i) + + ignored, _ := strconv.ParseBool(ftype.Tag.Get("ignored")) + if !f.CanSet() || ignored { + continue + } + + for f.Kind() == reflect.Pointer { + if f.IsNil() { + if f.Type().Elem().Kind() != reflect.Struct { + break + } + f.Set(reflect.New(f.Type().Elem())) + } + f = f.Elem() + } + + info := StructInfo{ + Name: ftype.Name, + Alt: strings.ToUpper(ftype.Tag.Get("env")), + Key: ftype.Name, + Field: f, + Tags: ftype.Tag, + Type: ftype.Type, + } + if info.Alt != "" { + info.Key = info.Alt + } + info.Key = strings.ToUpper(info.Key) + if ftype.Tag.Get("default") != "" { + v, err := typeConversion(ftype.Type.String(), ftype.Tag.Get("default")) + if err != nil { + return []StructInfo{}, err + } + info.DefaultValue = v + } + infos = append(infos, info) + } + return infos, nil +} + +func typeConversion(t, v string) (interface{}, error) { + switch t { + case "string": + return v, nil + case "int": + return strconv.ParseInt(v, 10, 0) + case "int8": + return strconv.ParseInt(v, 10, 8) + case "int16": + return strconv.ParseInt(v, 10, 16) + case "int32": + return strconv.ParseInt(v, 10, 32) + case "int64": + return strconv.ParseInt(v, 10, 64) + case "uint": + return strconv.ParseUint(v, 10, 0) + case "uint16": + return strconv.ParseUint(v, 10, 16) + case "uint32": + return strconv.ParseUint(v, 10, 32) + case "uint64": + return strconv.ParseUint(v, 10, 64) + case "float32": + return strconv.ParseFloat(v, 32) + case "float64": + return strconv.ParseFloat(v, 64) + case "complex64": + return strconv.ParseComplex(v, 64) + case "complex128": + return strconv.ParseComplex(v, 128) + case "bool": + return strconv.ParseBool(v) + } + return nil, fmt.Errorf("Unable to identify type.") +} diff --git a/internal/initialize/initialize.go b/internal/initialize/initialize.go new file mode 100644 index 0000000..06bbaa4 --- /dev/null +++ b/internal/initialize/initialize.go @@ -0,0 +1,186 @@ +package initialize + +import ( + "flag" + "log" + "os" + "reflect" + "strconv" + + "mutating-webhook/internal/config" + "mutating-webhook/internal/envconfig" +) + +// getEnvString returns string from environment variable +func getEnvString(env, def string) (val string) { //nolint:deadcode + val = os.Getenv(env) + + if val == "" { + return def + } + + return +} + +// getEnvInt returns int from environment variable +func getEnvInt(env string, def int) (ret int) { + val := os.Getenv(env) + + if val == "" { + return def + } + + ret, err := strconv.Atoi(val) + if err != nil { + log.Fatalf("[ERROR] Environment variable is not numeric: %v\n", env) + } + + return +} + +// getEnvBool returns boolean from environment variable +func getEnvBool(env string, def bool) bool { + var ( + err error + retVal bool + val = os.Getenv(env) + ) + + if len(val) == 0 { + return def + } else { + retVal, err = strconv.ParseBool(val) + if err != nil { + log.Fatalf("[ERROR] Environment variable is not boolean: %v\n", env) + } + } + + return retVal +} + +/* +func setLogLevel(l int) { + switch { + case l <= 20: + config.Log.SetMinLevel(logutils.LogLevel("ERROR")) + case l > 20 && l <= 40: + config.Log.SetMinLevel(logutils.LogLevel("WARNING")) + case l > 40 && l <= 60: + config.Log.SetMinLevel(logutils.LogLevel("INFO")) + case l > 60 && l <= 80: + config.Log.SetMinLevel(logutils.LogLevel("DEBUG")) + case l > 80: + config.Log.SetMinLevel(logutils.LogLevel("TRACE")) + } +} +*/ + +func Init() { + /* + var ( + tz string + err error + ) + */ + + cfg, err := config.NewConfig() + if err != nil { + log.Fatalf("[FATAL] Unable to initialize.") + } + + cfgInfo, err := envconfig.GetStructInfo(cfg) + if err != nil { + log.Fatalf("[FATAL] %v", err) + } + + for _, info := range cfgInfo { + switch info.Type.String() { + case "string": + var dv string + + if info.DefaultValue != nil { + dv = info.DefaultValue.(string) + } + p := reflect.ValueOf(cfg).Elem().FieldByName(info.Name).Addr().Interface().(*string) + flag.StringVar(p, info.Name, getEnvString(info.Name, dv), "("+info.Key+")") + case "bool": + var dv bool + + if info.DefaultValue != nil { + dv = info.DefaultValue.(bool) + } + p := reflect.ValueOf(cfg).Elem().FieldByName(info.Name).Addr().Interface().(*bool) + flag.BoolVar(p, info.Name, getEnvBool(info.Name, dv), "("+info.Key+")") + case "int": + var dv int + + if info.DefaultValue != nil { + dv = int(info.DefaultValue.(int64)) + } + p := reflect.ValueOf(cfg).Elem().FieldByName(info.Name).Addr().Interface().(*int) + flag.IntVar(p, info.Name, getEnvInt(info.Name, dv), "("+info.Key+")") + } + } + flag.Parse() + + if err = cfg.Validate(); err != nil { + log.Fatalf("[FATAL] %v", err) + } + + /* + // log configuration + flag.IntVar(&config.LogLevel, + "log", + getEnvInt("LOG_LEVEL", 50), + "(LOG_LEVEL)\nlog level") + // local webserver configuration + flag.IntVar(&config.WebSrvPort, + "http-port", + getEnvInt("HTTP_PORT", 8080), + "(HTTP_PORT)\nlisten port for internal webserver") + flag.StringVar(&config.WebSrvIP, + "http-ip", + getEnvString("HTTP_IP", ""), + "(HTTP_IP)\nlisten ip for internal webserver") + flag.IntVar(&config.WebSrvReadTimeout, + "http-read-timeout", + getEnvInt("HTTP_READ_TIMEOUT", 5), + "(HTTP_READ_TIMEOUT)\ninternal http server read timeout in seconds") + flag.IntVar(&config.WebSrvWriteTimeout, + "http-write-timeout", + getEnvInt("HTTP_WRITE_TIMEOUT", 2), + "(HTTP_WRITE_TIMEOUT\ninternal http server write timeout in seconds") + flag.IntVar(&config.WebSrvIdleTimeout, + "http-idle-timeout", + getEnvInt("HTTP_IDLE_TIMEOUT", 2), + "(HTTP_IDLE_TIMEOUT)\ninternal http server idle timeout in seconds") + // timezone + flag.StringVar(&tz, + "timezone", + getEnvString("TZ", "America/Chicago"), + "(TZ)\ntimezone") + // read command line options + flag.Parse() + + // logging level + setLogLevel(config.LogLevel) + log.SetOutput(config.Log) + + // timezone configuration + config.TimeZoneUTC, _ = time.LoadLocation("UTC") + if config.TimeZoneLocal, err = time.LoadLocation(tz); err != nil { + log.Fatalf("[ERROR] Unable to parse timezone string. Please use one of the timezone database values listed here: %s", "https://en.wikipedia.org/wiki/List_of_tz_database_time_zones") + } + + // print current configuration + log.Printf("[DEBUG] configuration value set: LOG_LEVEL = %s\n", strconv.Itoa(config.LogLevel)) + log.Printf("[DEBUG] configuration value set: HTTP_PORT = %s\n", strconv.Itoa(config.WebSrvPort)) + log.Printf("[DEBUG] configuration value set: HTTP_IP = %s\n", config.WebSrvIP) + log.Printf("[DEBUG] configuration value set: HTTP_READ_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvReadTimeout)) + log.Printf("[DEBUG] configuration value set: HTTP_WRITE_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvWriteTimeout)) + log.Printf("[DEBUG] configuration value set: HTTP_IDLE_TIMEOUT = %s\n", strconv.Itoa(config.WebSrvIdleTimeout)) + log.Printf("[DEBUG] configuration value set: TZ = %s\n", tz) + + log.Println("[INFO] initialization complete") + */ +}