test: add test for pausing dispatch on cluster queue

Signed-off-by: Tom Watt <[email protected]>
buildkite · Dec 16, 2024 · c71cf2e · c71cf2e
1 parent f6a286e
commit c71cf2e
Showing 1 changed file with 65 additions and 0 deletions.
diff --git a/buildkite/resource_cluster_queue_test.go b/buildkite/resource_cluster_queue_test.go
@@ -36,6 +36,29 @@ func TestAccBuildkiteClusterQueueResource(t *testing.T) {
 		`, fields[0], fields[1], fields[2])
 	}
 
+	configBasicDispatch := func(fields ...string) string {
+		return fmt.Sprintf(`
+		provider "buildkite" {
+			timeouts = {
+				create = "10s"
+				read = "10s"
+				update = "10s"
+				delete = "10s"
+			}
+		}
+		resource "buildkite_cluster" "cluster_test" {
+			name = "Test cluster %s"
+			description = "Acceptance testing cluster"
+		}
+		resource "buildkite_cluster_queue" "foobar" {
+			cluster_id = buildkite_cluster.cluster_test.id
+			key = "queue-%s"
+			description = "Acceptance test %s"
+			dispatch_paused = "%s"
+		}
+		`, fields[0], fields[1], fields[2], fields[3])
+	}
+
 	t.Run("creates a cluster queue", func(t *testing.T) {
 		var cq clusterQueueResourceModel
 		clusterName := acctest.RandString(10)
@@ -119,6 +142,48 @@ func TestAccBuildkiteClusterQueueResource(t *testing.T) {
 		})
 	})
 
+	t.Run("pause dispatch on a cluster queue", func(t *testing.T) {
+		var cq clusterQueueResourceModel
+		clusterName := acctest.RandString(10)
+		queueKey := acctest.RandString(10)
+		queueDesc := acctest.RandString(10)
+		check := resource.ComposeAggregateTestCheckFunc(
+			// Confirm the cluster queue exists in the buildkite API
+			testAccCheckClusterQueueExists("buildkite_cluster_queue.foobar", &cq),
+			// Confirm the cluster queue has the correct values in Buildkite's system
+			testAccCheckClusterQueueRemoteValues(&cq, fmt.Sprintf("Acceptance test %s", queueDesc), fmt.Sprintf("queue-%s", queueKey)),
+			// Confirm the cluster queue has the correct values in terraform state
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "key", fmt.Sprintf("queue-%s", queueKey)),
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "description", fmt.Sprintf("Acceptance test %s", queueDesc)),
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "dispatch_paused", "false"),
+		)
+		checkUpdated := resource.ComposeAggregateTestCheckFunc(
+			// Confirm the cluster queue exists in the buildkite API
+			testAccCheckClusterQueueExists("buildkite_cluster_queue.foobar", &cq),
+			// Confirm the cluster queue has the correct values in Buildkite's system
+			testAccCheckClusterQueueRemoteValues(&cq, fmt.Sprintf("Acceptance test %s", queueDesc), fmt.Sprintf("queue-%s", queueKey)),
+			// Confirm the cluster queue has the correct values in terraform state
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "key", fmt.Sprintf("queue-%s", queueKey)),
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "description", fmt.Sprintf("Acceptance test %s", queueDesc)),
+			resource.TestCheckResourceAttr("buildkite_cluster_queue.foobar", "dispatch_paused", "true"),
+		)
+		resource.ParallelTest(t, resource.TestCase{
+			PreCheck:                 func() { testAccPreCheck(t) },
+			ProtoV6ProviderFactories: protoV6ProviderFactories(),
+			CheckDestroy:             testAccCheckClusterQueueDestroy,
+			Steps: []resource.TestStep{
+				{
+					Config: configBasicDispatch(clusterName, queueKey, queueDesc, "false"),
+					Check:  check,
+				},
+				{
+					Config: configBasicDispatch(clusterName, queueKey, queueDesc, "true"),
+					Check:  checkUpdated,
+				},
+			},
+		})
+	})
+
 	t.Run("imports a cluster queue", func(t *testing.T) {
 		var cq clusterQueueResourceModel
 		clusterName := acctest.RandString(10)