Extract gRPC TLS configuration into a shared package (jaegertracing#1840

) * Extract TLS flags and cert loading logic Signed-off-by: Yuri Shkuro <[email protected]> * Rename package Signed-off-by: Yuri Shkuro <[email protected]> * Refactor grpc Signed-off-by: Yuri Shkuro <[email protected]> * Repair tests Signed-off-by: Yuri Shkuro <[email protected]> * Refactor gRPC server in collector Signed-off-by: Yuri Shkuro <[email protected]> * Add ShowCA option Signed-off-by: Yuri Shkuro <[email protected]> * Switch options order Signed-off-by: Yuri Shkuro <[email protected]> * Separate client and server TLS options Signed-off-by: Yuri Shkuro <[email protected]> * Update usage Signed-off-by: Yuri Shkuro <[email protected]> * Rename test, add filepath.Clean Signed-off-by: Yuri Shkuro <[email protected]> Signed-off-by: Jonah Back <[email protected]>
backjo · Dec 19, 2019 · 7919684 · 7919684
1 parent ce3808b
commit 7919684
Show file tree

Hide file tree

Showing 16 changed files with 658 additions and 275 deletions.
diff --git a/cmd/agent/app/reporter/grpc/builder.go b/cmd/agent/app/reporter/grpc/builder.go
@@ -15,20 +15,17 @@
 package grpc
 
 import (
-	"crypto/tls"
-	"crypto/x509"
-	"errors"
-	"fmt"
-	"io/ioutil"
 	"strings"
 
 	grpc_retry "github.com/grpc-ecosystem/go-grpc-middleware/retry"
+	"github.com/pkg/errors"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/resolver"
 	"google.golang.org/grpc/resolver/manual"
 
+	"github.com/jaegertracing/jaeger/pkg/config/tlscfg"
 	"github.com/jaegertracing/jaeger/pkg/discovery"
 	"github.com/jaegertracing/jaeger/pkg/discovery/grpcresolver"
 )
@@ -38,12 +35,8 @@ type ConnBuilder struct {
 	// CollectorHostPorts is list of host:port Jaeger Collectors.
 	CollectorHostPorts []string `yaml:"collectorHostPorts"`
 
-	MaxRetry      uint
-	TLS           bool
-	TLSCA         string
-	TLSServerName string
-	TLSCert       string
-	TLSKey        string
+	MaxRetry uint
+	TLS      tlscfg.Options
 
 	DiscoveryMinPeers int
 	Notifier          discovery.Notifier
@@ -59,49 +52,14 @@ func NewConnBuilder() *ConnBuilder {
 func (b *ConnBuilder) CreateConnection(logger *zap.Logger) (*grpc.ClientConn, error) {
 	var dialOptions []grpc.DialOption
 	var dialTarget string
-	if b.TLS { // user requested a secure connection
+	if b.TLS.Enabled { // user requested a secure connection
 		logger.Info("Agent requested secure grpc connection to collector(s)")
-		var err error
-		var certPool *x509.CertPool
-		if len(b.TLSCA) == 0 { // no truststore given, use SystemCertPool
-			certPool, err = systemCertPool()
-			if err != nil {
-				return nil, err
-			}
-		} else { // setup user specified truststore
-			caPEM, err := ioutil.ReadFile(b.TLSCA)
-			if err != nil {
-				return nil, fmt.Errorf("reading client CA failed, %v", err)
-			}
-
-			certPool = x509.NewCertPool()
-			if !certPool.AppendCertsFromPEM(caPEM) {
-				return nil, fmt.Errorf("building client CA failed, %v", err)
-			}
-		}
-
-		tlsCfg := &tls.Config{
-			MinVersion: tls.VersionTLS12,
-			RootCAs:    certPool,
-			ServerName: b.TLSServerName,
-		}
-
-		if (b.TLSKey == "" || b.TLSCert == "") &&
-			(b.TLSKey != "" || b.TLSCert != "") {
-			return nil, fmt.Errorf("for client auth, both client certificate and key must be supplied")
-		}
-
-		if b.TLSKey != "" && b.TLSCert != "" {
-			tlsCert, err := tls.LoadX509KeyPair(b.TLSCert, b.TLSKey)
-			if err != nil {
-				return nil, fmt.Errorf("could not load server TLS cert and key, %v", err)
-			}
-
-			logger.Info("client TLS authentication enabled")
-			tlsCfg.Certificates = []tls.Certificate{tlsCert}
+		tlsConf, err := b.TLS.Config()
+		if err != nil {
+			return nil, errors.Wrap(err, "failed to load TLS config")
 		}
 
-		creds := credentials.NewTLS(tlsCfg)
+		creds := credentials.NewTLS(tlsConf)
 		dialOptions = append(dialOptions, grpc.WithTransportCredentials(creds))
 	} else { // insecure connection
 		logger.Info("Agent requested insecure grpc connection to collector(s)")