add test cases for XDQP configuration

Author: pengzhouml

test/e2e/install_test.go

@@ -113,7 +113,26 @@ func TestHelmInstall(t *testing.T) {
 	// the generated password should be able to access the manage endpoint
 	assert.Equal(t, 200, response.StatusCode)
 
-	t.Log("====Verify no groups beyond enode were created/modified====")
+	t.Log("====Verify xdqp-ssl-enabled is set to true by default")
+	endpoint := fmt.Sprintf("http://%s/manage/v2/groups/Default/properties?format=json", tunnel8002.Endpoint())
+	t.Logf(`Endpoint for group properties: %s`, endpoint)
+
+	request = digestAuth.NewRequest(username, password, "GET", endpoint, "")
+	resp, err = request.Execute()
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+	defer resp.Body.Close()
+	body, err = ioutil.ReadAll(resp.Body)
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+
+	xdqpSSLEnabled := gjson.Get(string(body), `xdqp-ssl-enabled`)
+	// verify xdqp-ssl-enabled is set to trues
+	assert.Equal(t, true, xdqpSSLEnabled.Bool(), "xdqp-ssl-enabled should be set to true")
+
+	t.Log("====Verify no groups beyond default were created/modified====")
 	groupStatusEndpoint := fmt.Sprintf("http://%s/manage/v2/groups?format=json", tunnel8002.Endpoint())
 	groupStatus := digestAuth.NewRequest(username, password, "GET", groupStatusEndpoint, "")
 	t.Logf(`groupStatusEndpoint: %s`, groupStatusEndpoint)
@@ -129,5 +148,4 @@ func TestHelmInstall(t *testing.T) {
 		t.Errorf("Only one group should exist, instead %v groups exist", groupQuantityJSON.Num)
 	}
 
-	t.Logf("Groups status response:\n" + string(body))
 }

test/e2e/separate_nodes_test.go

@@ -56,6 +56,7 @@ func TestSeparateEDnode(t *testing.T) {
 			"auth.adminUsername":    username,
 			"auth.adminPassword":    password,
 			"group.name":            "dnode",
+			"group.enableXdqpSsl":   "true",
 			"logCollection.enabled": "false",
 		},
 	}
@@ -91,7 +92,6 @@ func TestSeparateEDnode(t *testing.T) {
 	if err != nil {
 		t.Fatalf(err.Error())
 	}
-	t.Logf("Get hosts response:\n" + string(body))
 
 	bootstrapHostJSON := gjson.Get(string(body), `host-default-list.list-items.list-item.#(roleref="bootstrap").nameref`)
 	t.Logf(`BootstrapHost: = %s`, bootstrapHostJSON)
@@ -100,6 +100,25 @@ func TestSeparateEDnode(t *testing.T) {
 		t.Errorf("Bootstrap does not exists on cluster")
 	}
 
+	t.Log("====Verify xdqp-ssl-enabled is set to true")
+	endpoint := fmt.Sprintf("http://%s/manage/v2/groups/dnode/properties?format=json", tunnel.Endpoint())
+	t.Logf(`Endpoint for group properties: %s`, endpoint)
+
+	request := digestAuth.NewRequest(username, password, "GET", endpoint, "")
+	resp, err = request.Execute()
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+	defer resp.Body.Close()
+	body, err = ioutil.ReadAll(resp.Body)
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+
+	xdqpSSLEnabled := gjson.Get(string(body), `xdqp-ssl-enabled`)
+	// verify xdqp-ssl-enabled is set to trues
+	assert.Equal(t, true, xdqpSSLEnabled.Bool(), "xdqp-ssl-enabled should be set to true")
+
 	enodeOptions := &helm.Options{
 		KubectlOptions: kubectlOptions,
 		SetValues: map[string]string{
@@ -111,6 +130,7 @@ func TestSeparateEDnode(t *testing.T) {
 			"auth.adminPassword":    password,
 			"group.name":            "enode",
 			"bootstrapHostName":     bootstrapHostJSON.Str,
+			"group.enableXdqpSsl":   "false",
 			"logCollection.enabled": "false",
 		},
 	}
@@ -120,6 +140,25 @@ func TestSeparateEDnode(t *testing.T) {
 	// wait until the first enode pod is in Ready status
 	k8s.WaitUntilPodAvailable(t, kubectlOptions, enodePodName0, 45, 20*time.Second)
 
+	t.Log("====Verify xdqp-ssl-enabled is set to false on Enode")
+	endpoint = fmt.Sprintf("http://%s/manage/v2/groups/enode/properties?format=json", tunnel.Endpoint())
+	t.Logf(`Endpoint for group properties: %s`, endpoint)
+
+	request = digestAuth.NewRequest(username, password, "GET", endpoint, "")
+	resp, err = request.Execute()
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+	defer resp.Body.Close()
+	body, err = ioutil.ReadAll(resp.Body)
+	if err != nil {
+		t.Fatalf(err.Error())
+	}
+
+	xdqpSSLEnabled = gjson.Get(string(body), `xdqp-ssl-enabled`)
+	// verify xdqp-ssl-enabled is set to false
+	assert.Equal(t, false, xdqpSSLEnabled.Bool())
+
 	groupEndpoint := fmt.Sprintf("http://%s/manage/v2/groups", tunnel.Endpoint())
 	t.Logf(`Endpoint: %s`, groupEndpoint)
 
@@ -132,7 +171,6 @@ func TestSeparateEDnode(t *testing.T) {
 	if body, err = ioutil.ReadAll(resp.Body); err != nil {
 		t.Fatalf(err.Error())
 	}
-	t.Logf("Groups status response:\n" + string(body))
 
 	// verify groups dnode, enode exists on the cluster
 	if !strings.Contains(string(body), "<nameref>dnode</nameref>") && !strings.Contains(string(body), "<nameref>enode</nameref>") {