Fix unhandled errors (#97)

* Fix unhandled errors

* Add changelog note

CHANGELOG.md

@@ -1,5 +1,9 @@
 ## Unreleased
 
+BUGS:
+
+* Added missing error handling when transforming SecretProviderClass config to a Vault request [[GH-97](https://github.com/hashicorp/vault-csi-provider/pull/97)]
+
 ## 0.2.0 (April 14th, 2021)
 
 FEATURES:

Makefile

@@ -32,7 +32,10 @@ lint:
 		--timeout 10m \
 		--enable gofmt \
 		--enable gosimple \
-		--enable govet
+		--enable govet \
+		--enable errcheck \
+		--enable ineffassign \
+		--enable unused
 
 test:
 	gotestsum --format=short-verbose $(CI_TEST_ARGS)

internal/config/config_test.go

@@ -48,6 +48,7 @@ func TestParseParametersFromYaml(t *testing.T) {
 	err := yaml.Unmarshal([]byte(certsSPCYaml), &secretProviderClass)
 	require.NoError(t, err)
 	paramsBytes, err := json.Marshal(secretProviderClass.Spec.Parameters)
+	require.NoError(t, err)
 
 	// This is now the form the provider receives the data in.
 	params, err := parseParameters(hclog.NewNullLogger(), string(paramsBytes))

internal/provider/provider.go

@@ -142,7 +142,10 @@ func generateRequest(client *api.Client, secret config.Secret) (*api.Request, er
 		req.Params = queryParams
 	}
 	if secret.SecretArgs != nil {
-		req.SetJSONBody(secret.SecretArgs)
+		err := req.SetJSONBody(secret.SecretArgs)
+		if err != nil {
+			return nil, err
+		}
 	}
 
 	return req, nil
@@ -174,6 +177,9 @@ func (p *provider) getSecret(ctx context.Context, client *api.Client, secretConf
 	key := cacheKey{secretPath: secretConfig.SecretPath, method: secretConfig.Method}
 	if secret, cached = p.cache[key]; !cached {
 		req, err := generateRequest(client, secretConfig)
+		if err != nil {
+			return "", err
+		}
 		p.logger.Debug("Requesting secret", "secretConfig", secretConfig, "method", req.Method, "path", req.URL.Path, "params", req.Params)
 
 		secret, err = vaultclient.Do(ctx, client, req)

main.go

@@ -93,7 +93,12 @@ func realMain(logger hclog.Logger) error {
 		Addr:    *healthAddr,
 		Handler: mux,
 	}
-	defer ms.Shutdown(context.Background())
+	defer func() {
+		err := ms.Shutdown(context.Background())
+		if err != nil {
+			logger.Error("Error shutting down health handler", "err", err)
+		}
+	}()
 
 	mux.HandleFunc("/health/ready", func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusOK)