Add support for self-singed CA

Author: mtodor

charts/stackrox-mcp/templates/_helpers.tpl

@@ -80,3 +80,21 @@ TLS Secret name - returns existingSecretName if set, otherwise generates name
 {{- include "stackrox-mcp.fullname" . }}-tls
 {{- end }}
 {{- end }}
+
+{{/*
+Central CA Secret name - returns existingSecretName if set, otherwise generates name
+*/}}
+{{- define "stackrox-mcp.centralCASecretName" -}}
+{{- if .Values.centralCACert.existingSecretName }}
+{{- .Values.centralCACert.existingSecretName }}
+{{- else }}
+{{- include "stackrox-mcp.fullname" . }}-central-ca
+{{- end }}
+{{- end }}
+
+{{/*
+Central CA enabled - returns "true" if either cert or existingSecretName is set
+*/}}
+{{- define "stackrox-mcp.centralCAEnabled" -}}
+{{- if or .Values.centralCACert.cert .Values.centralCACert.existingSecretName }}true{{- end }}
+{{- end }}

charts/stackrox-mcp/templates/central-ca-secret.yaml

@@ -0,0 +1,14 @@
+{{- if and .Values.centralCACert.cert .Values.centralCACert.existingSecretName }}
+{{- fail "centralCACert: cannot set both 'cert' and 'existingSecretName' — use one or the other" }}
+{{- end }}
+{{- if and .Values.centralCACert.cert (not .Values.centralCACert.existingSecretName) }}
+apiVersion: v1
+kind: Secret
+metadata:
+  name: {{ include "stackrox-mcp.fullname" . }}-central-ca
+  labels:
+    {{- include "stackrox-mcp.labels" . | nindent 4 }}
+type: Opaque
+data:
+  ca.crt: {{ .Values.centralCACert.cert | b64enc }}
+{{- end }}

charts/stackrox-mcp/templates/configmap.yaml

@@ -13,6 +13,9 @@ data:
       auth_type: "passthrough"
       insecure_skip_tls_verify: {{ .Values.config.central.insecureSkipTLSVerify }}
       force_http1: {{ .Values.config.central.forceHTTP1 }}
+    {{- if include "stackrox-mcp.centralCAEnabled" . }}
+      ca_cert_path: "/central-ca/ca.crt"
+    {{- end }}
       request_timeout: {{ .Values.config.central.requestTimeout | quote }}
       max_retries: {{ .Values.config.central.maxRetries }}
       initial_backoff: {{ .Values.config.central.initialBackoff | quote }}

charts/stackrox-mcp/templates/deployment.yaml

@@ -111,6 +111,11 @@ spec:
           mountPath: /certs
           readOnly: true
         {{- end }}
+        {{- if include "stackrox-mcp.centralCAEnabled" . }}
+        - name: central-ca
+          mountPath: /central-ca
+          readOnly: true
+        {{- end }}
       volumes:
       - name: config
         configMap:
@@ -121,6 +126,12 @@ spec:
           secretName: {{ include "stackrox-mcp.tlsSecretName" . }}
           defaultMode: 0440
       {{- end }}
+      {{- if include "stackrox-mcp.centralCAEnabled" . }}
+      - name: central-ca
+        secret:
+          secretName: {{ include "stackrox-mcp.centralCASecretName" . }}
+          defaultMode: 0440
+      {{- end }}
       {{- with .Values.nodeSelector }}
       nodeSelector:
         {{- toYaml . | nindent 8 }}

charts/stackrox-mcp/values.yaml

@@ -69,6 +69,12 @@ tlsSecret:
   # Server TLS Private Key (PEM format)
   key: ""
 
+# CA certificate for verifying Central's TLS certificate (e.g., self-signed)
+# Only one of cert or existingSecretName should be set.
+centralCACert:
+  existingSecretName: ""
+  cert: ""
+
 # Resource limits and requests
 resources:
   limits:

internal/client/client.go

@@ -4,7 +4,11 @@ package client
 import (
 	"context"
 	"crypto/tls"
+	"crypto/x509"
+	"encoding/pem"
 	"fmt"
+	"log/slog"
+	"os"
 	"sync"
 	"testing"
 	"time"
@@ -23,6 +27,7 @@ import (
 const (
 	minConnectTimeout = 5 * time.Second
 	backoffJitter     = 0.2
+	maxCACertFileSize = 1 << 20 // 1MB
 )
 
 // Client provides gRPC connection to StackRox Central API.
@@ -229,11 +234,112 @@ func (c *Client) tlsConfig() (*tls.Config, error) {
 		return nil, errors.Wrap(err, "failed to get central URL hostname")
 	}
 
-	return &tls.Config{
+	tlsCfg := &tls.Config{
 		InsecureSkipVerify: c.config.InsecureSkipTLSVerify, //nolint:gosec
 		MinVersion:         tls.VersionTLS12,
 		ServerName:         hostname,
-	}, nil
+	}
+
+	if c.config.CACertPath != "" {
+		certPool, err := loadCACertPool(c.config.CACertPath)
+		if err != nil {
+			return nil, err
+		}
+
+		tlsCfg.RootCAs = certPool
+	}
+
+	return tlsCfg, nil
+}
+
+func loadCACertPool(caCertPath string) (*x509.CertPool, error) {
+	// File size guard
+	fileInfo, err := os.Stat(caCertPath)
+	if err != nil {
+		return nil, errors.Wrapf(err, "failed to access CA certificate at %s", caCertPath)
+	}
+
+	if !fileInfo.Mode().IsRegular() {
+		return nil, errors.Errorf("CA certificate path %s is not a regular file", caCertPath)
+	}
+
+	if fileInfo.Size() == 0 {
+		return nil, errors.Errorf("CA certificate file %s is empty", caCertPath)
+	}
+
+	if fileInfo.Size() > maxCACertFileSize {
+		return nil, errors.Errorf(
+			"CA certificate file %s is too large (%d bytes, max %d)",
+			caCertPath, fileInfo.Size(),
+			maxCACertFileSize,
+		)
+	}
+
+	//nolint: gosec
+	caCert, err := os.ReadFile(caCertPath)
+	if err != nil {
+		return nil, errors.Wrapf(err, "failed to read CA certificate from %s", caCertPath)
+	}
+
+	// Get system cert pool, warn on fallback
+	certPool, err := x509.SystemCertPool()
+	if err != nil {
+		slog.Warn("Failed to load system CA pool, using custom CA only", "error", err)
+
+		certPool = x509.NewCertPool()
+	}
+
+	if !certPool.AppendCertsFromPEM(caCert) {
+		return nil, errors.Errorf("failed to parse CA certificate from %s: no valid PEM data found", caCertPath)
+	}
+
+	showCertInfo(caCert)
+
+	return certPool, nil
+}
+
+// showCertInfo parses and logs certificate metadata.
+func showCertInfo(caCert []byte) {
+	block, _ := pem.Decode(caCert)
+	if block == nil {
+		slog.Warn("Unable to decode CA certificate")
+
+		return
+	}
+
+	cert, err := x509.ParseCertificate(block.Bytes)
+	if err != nil {
+		slog.Warn("Failed to parse CA certificate", "error", err)
+
+		return
+	}
+
+	slog.Info("Loaded CA certificate",
+		"subject", cert.Subject.CommonName,
+		"issuer", cert.Issuer.CommonName,
+		"notAfter", cert.NotAfter,
+		"isCA", cert.IsCA,
+	)
+
+	if !cert.IsCA {
+		slog.Warn("Provided certificate does not have the CA basic constraint set — TLS verification may fail",
+			"subject", cert.Subject.CommonName,
+		)
+	}
+
+	if time.Now().After(cert.NotAfter) {
+		slog.Warn("CA certificate is expired — TLS verification will fail",
+			"subject", cert.Subject.CommonName,
+			"expiredAt", cert.NotAfter,
+		)
+	}
+
+	if time.Now().Before(cert.NotBefore) {
+		slog.Warn("CA certificate is not yet valid",
+			"subject", cert.Subject.CommonName,
+			"validFrom", cert.NotBefore,
+		)
+	}
 }
 
 func (c *Client) connectHTTP1(