|
|
@@ -59,7 +59,7 @@ func TestSSLSimple(t *testing.T) {
|
|
|
srv := NewSSLTestServer(t, defaultProto)
|
|
|
defer srv.Stop()
|
|
|
|
|
|
- db, err := createTestSslCluster(srv.Address, defaultProto).CreateSession()
|
|
|
+ db, err := createTestSslCluster(srv.Address, defaultProto, true).CreateSession()
|
|
|
if err != nil {
|
|
|
t.Fatalf("0x%x: NewCluster: %v", defaultProto, err)
|
|
|
}
|
|
|
@@ -69,13 +69,27 @@ func TestSSLSimple(t *testing.T) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func createTestSslCluster(hosts string, proto uint8) *ClusterConfig {
|
|
|
+func TestSSLSimpleNoClientCert(t *testing.T) {
|
|
|
+ srv := NewSSLTestServer(t, defaultProto)
|
|
|
+ defer srv.Stop()
|
|
|
+
|
|
|
+ db, err := createTestSslCluster(srv.Address, defaultProto, false).CreateSession()
|
|
|
+ if err != nil {
|
|
|
+ t.Fatalf("0x%x: NewCluster: %v", defaultProto, err)
|
|
|
+ }
|
|
|
+
|
|
|
+ if err := db.Query("void").Exec(); err != nil {
|
|
|
+ t.Fatalf("0x%x: %v", defaultProto, err)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func createTestSslCluster(hosts string, proto uint8, useClientCert bool) *ClusterConfig {
|
|
|
cluster := NewCluster(hosts)
|
|
|
sslOpts := &SslOptions{
|
|
|
CaPath: "testdata/pki/ca.crt",
|
|
|
EnableHostVerification: false,
|
|
|
}
|
|
|
- if os.Getenv("REQ_CLIENT_AUTH") != "false" {
|
|
|
+ if useClientCert {
|
|
|
sslOpts.CertPath = "testdata/pki/gocql.crt"
|
|
|
sslOpts.KeyPath = "testdata/pki/gocql.key"
|
|
|
}
|
|
|
@@ -451,7 +465,7 @@ func TestPolicyConnPoolSSL(t *testing.T) {
|
|
|
srv := NewSSLTestServer(t, defaultProto)
|
|
|
defer srv.Stop()
|
|
|
|
|
|
- cluster := createTestSslCluster(srv.Address, defaultProto)
|
|
|
+ cluster := createTestSslCluster(srv.Address, defaultProto, true)
|
|
|
cluster.ConnPoolType = NewRoundRobinConnPool
|
|
|
|
|
|
db, err := cluster.CreateSession()
|