From e1a7bb8e81277c3e073897964fc23e4f6bc90f94 Mon Sep 17 00:00:00 2001
From: Ross Kirkpatrick <ross.kirkpatrick@suse.com>
Date: Thu, 28 Apr 2022 13:08:51 -0400
Subject: [PATCH] fix import cycle, enhance stackdump info message (#112)

* fix import cycle, enhance stackdump info message

* fix goimports on config.go
---
 cmd/cmds/tools.go           |  5 +++++
 cmd/server/config/config.go | 38 +++++++++++++++++++++++++++++++++++--
 pkg/csiproxy/csi.go         |  8 ++++----
 pkg/profilings/stack.go     |  2 +-
 pkg/tls/tls.go              |  5 +++--
 5 files changed, 49 insertions(+), 9 deletions(-)

diff --git a/cmd/cmds/tools.go b/cmd/cmds/tools.go
index 64c93bc8..b7212924 100644
--- a/cmd/cmds/tools.go
+++ b/cmd/cmds/tools.go
@@ -4,6 +4,11 @@ import (
 	"github.com/urfave/cli"
 )
 
+func BoolAddr(b bool) *bool {
+	boolVar := b
+	return &boolVar
+}
+
 func JoinFlags(flagSlices ...[]cli.Flag) []cli.Flag {
 	var ret []cli.Flag
 	for _, flags := range flagSlices {
diff --git a/cmd/server/config/config.go b/cmd/server/config/config.go
index 64c5b088..f7df43f1 100644
--- a/cmd/server/config/config.go
+++ b/cmd/server/config/config.go
@@ -8,6 +8,7 @@ import (
 	"github.com/ghodss/yaml"
 	"github.com/pkg/errors"
 	"github.com/rancher/system-agent/pkg/config"
+	"github.com/rancher/wins/cmd/cmds"
 	"github.com/rancher/wins/pkg/csiproxy"
 	"github.com/rancher/wins/pkg/defaults"
 	"github.com/rancher/wins/pkg/tls"
@@ -25,7 +26,7 @@ func DefaultConfig() *Config {
 			Mode:         "watching",
 			WatchingPath: defaults.UpgradeWatchingPath,
 		},
-		TLSConfig: &tls.TLSConfig{
+		TLSConfig: &tls.Config{
 			CertFilePath: defaults.CertPath,
 		},
 	}
@@ -39,7 +40,38 @@ type Config struct {
 	Upgrade     UpgradeConfig       `yaml:"upgrade" json:"upgrade"`
 	SystemAgent *config.AgentConfig `yaml:"systemagent" json:"systemagent"`
 	CSIProxy    *csiproxy.Config    `yaml:"csi-proxy" json:"csi-proxy"`
-	TLSConfig   *tls.TLSConfig      `yaml:"tls-config" json:"tls-config"`
+	TLSConfig   *tls.Config         `yaml:"tls-config" json:"tls-config"`
+}
+
+func (c *Config) ValidateTLSConfig() error {
+	if b, err := ioutil.ReadFile(c.TLSConfig.CertFilePath); b == nil || err != nil {
+		return errors.Wrapf(err, "failed to read certificate from %s", c.TLSConfig.CertFilePath)
+	}
+
+	if c.TLSConfig.CertFilePath != defaults.CertPath {
+		// load non-default certificate file
+		_ = csiproxy.Config{
+			Config: tls.Config{
+				CertFilePath: c.TLSConfig.CertFilePath,
+			},
+		}
+	}
+
+	if *c.TLSConfig.Insecure {
+		// set insecure flag for all subsequent CSI Proxy functions
+		_ = csiproxy.Config{
+			Config: tls.Config{
+				Insecure: cmds.BoolAddr(true),
+			},
+		}
+	} else {
+		_ = csiproxy.Config{
+			Config: tls.Config{
+				Insecure: cmds.BoolAddr(false),
+			},
+		}
+	}
+	return nil
 }
 
 func (c *Config) Validate() error {
@@ -57,6 +89,8 @@ func (c *Config) Validate() error {
 		return errors.Wrap(err, "failed to validate upgrade field")
 	}
 
+	// validate
+
 	return nil
 }
 
diff --git a/pkg/csiproxy/csi.go b/pkg/csiproxy/csi.go
index 6103bf0c..f2027f95 100644
--- a/pkg/csiproxy/csi.go
+++ b/pkg/csiproxy/csi.go
@@ -11,7 +11,6 @@ import (
 	"strings"
 
 	"github.com/pkg/errors"
-	winsConfig "github.com/rancher/wins/cmd/server/config"
 	"github.com/rancher/wins/pkg/concierge"
 	"github.com/rancher/wins/pkg/tls"
 )
@@ -26,6 +25,7 @@ type Config struct {
 	URL         string `yaml:"url" json:"url"`
 	Version     string `yaml:"version" json:"version"`
 	KubeletPath string `yaml:"kubeletPath" json:"kubeletPath"`
+	tls.Config
 }
 
 // Validate ensures that the configuration for CSI Proxy is correct if provided.
@@ -91,9 +91,9 @@ func (p *Proxy) Enable() error {
 		return err
 	}
 	if !ok {
-		wc := winsConfig.Config{}
-		if wc.TLSConfig.CertFilePath != "" {
-			_, err := tls.SetupGenericTLSConfigFromFile(*wc.TLSConfig)
+		if p.cfg.CertFilePath != "" && !*p.cfg.Insecure {
+			// CSI Proxy does not need the certpool that is returned
+			_, err := tls.SetupGenericTLSConfigFromFile()
 			if err != nil {
 				return err
 			}
diff --git a/pkg/profilings/stack.go b/pkg/profilings/stack.go
index 1da758bf..b2e28b1a 100644
--- a/pkg/profilings/stack.go
+++ b/pkg/profilings/stack.go
@@ -76,7 +76,7 @@ func SetupDumpStacks(serviceName string, pid int, cwd string) {
 	}
 
 	go func() {
-		logrus.Infof("Stackdump - waiting signal at %s", event)
+		logrus.Infof("[SetupDumpStacks] stackdump feature successfully initialized - waiting for signal at %s", event)
 		for {
 			windows.WaitForSingleObject(h, windows.INFINITE)
 			fileLoc := filepath.Join(cwd, fmt.Sprintf("%s.%d.stacks.log", serviceName, pid))
diff --git a/pkg/tls/tls.go b/pkg/tls/tls.go
index 12011374..f89661d5 100644
--- a/pkg/tls/tls.go
+++ b/pkg/tls/tls.go
@@ -9,13 +9,14 @@ import (
 	"github.com/sirupsen/logrus"
 )
 
-type TLSConfig struct {
+type Config struct {
 	Insecure     *bool  `yaml:"insecure" json:"insecure"`
 	CertFilePath string `yaml:"CertFilePath" json:"CertFilePath"`
 }
 
 // SetupGenericTLSConfigFromFile returns a x509 system certificate pool containing the specified certificate file
-func SetupGenericTLSConfigFromFile(config TLSConfig) (*x509.CertPool, error) {
+func SetupGenericTLSConfigFromFile() (*x509.CertPool, error) {
+	var config *Config
 	if config.CertFilePath == "" {
 		logrus.Info("[SetupGenericTLSConfigFromFile] specified certificate file path is empty, not modifying system certificate store")
 		return nil, nil