validate all paths

terraform-google-modules · Nov 25, 2024 · 4e2345d · 4e2345d
1 parent a6bc99e
commit 4e2345d
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 1 deletion.
diff --git a/test/fixtures/safer_cluster_iap_bastion/example.tf b/test/fixtures/safer_cluster_iap_bastion/example.tf
@@ -15,7 +15,7 @@
  */
 
 locals {
-  test_command = "gcloud beta compute ssh ${module.example.bastion_name} --tunnel-through-iap --verbosity=error --project ${var.project_ids[1]} --zone ${module.example.bastion_zone} -q -- curl -sS https://${module.example.endpoint}/version -k"
+  test_command = "gcloud beta compute ssh ${module.example.bastion_name} --tunnel-through-iap --verbosity=error --project ${var.project_ids[1]} --zone ${module.example.bastion_zone} -q --command='curl -sS https://${module.example.endpoint}/version -k'"
 }
 
 module "example" {

diff --git a/test/integration/node_pool/node_pool_test.go b/test/integration/node_pool/node_pool_test.go
@@ -15,12 +15,14 @@ package node_pool
 
 import (
 	"fmt"
+	"sync"
 	"testing"
 	"time"
 
 	"github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/gcloud"
 	"github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/golden"
 	"github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/tft"
+	"github.com/GoogleCloudPlatform/cloud-foundation-toolkit/infra/blueprint-test/pkg/utils"
 	"github.com/gruntwork-io/terratest/modules/k8s"
 	"github.com/stretchr/testify/assert"
 	"github.com/terraform-google-modules/terraform-google-kubernetes-engine/test/integration/testutils"
@@ -92,6 +94,34 @@ func TestNodePool(t *testing.T) {
 			g.JSONEq(assert, cluster, pth)
 		}
 
+		fmt.Println("one path")
+		g.JSONPathEqs(assert, cluster, []string{"autoscaling.autoprovisioningNodePoolDefaults.imageType"})
+
+		fmt.Println("multi path")
+		g.JSONPathEqs(assert, cluster, validateJSONPaths)
+
+		fmt.Println("all paths 1")
+		// Test validating all Paths
+		jsonPaths := utils.GetJSONPaths(cluster)
+		var wg sync.WaitGroup
+		numJSONPaths := len(jsonPaths)
+		t.Logf("checking %d JSON paths", numJSONPaths)
+		wg.Add(numJSONPaths)
+		for _, jsonPath := range jsonPaths {
+			go func(path string) {
+				defer wg.Done()
+				t.Logf("checking JSON path: %s", path)
+				g.JSONEq(assert, cluster, path)
+			}(jsonPath)
+		}
+		wg.Wait()
+
+		fmt.Println("all paths 2")
+		// Test validating all Paths
+		evalPaths := utils.GetJSONPaths(cluster)
+		fmt.Println(evalPaths)
+		g.JSONPathEqs(assert, cluster, evalPaths)
+
 		// Pool-01
 		assert.Equal("pool-01", cluster.Get("nodePools.#(name==\"pool-01\").name").String(), "pool-1 exists")
 		assert.Equal("e2-medium", cluster.Get("nodePools.#(name==\"pool-01\").config.machineType").String(), "is the expected machine type")