azurerm_servicebus_subscription - support status property

azurerm/internal/services/servicebus/helper/entity_status.go

@@ -0,0 +1,22 @@
+package helper
+
+import (
+	"strings"
+
+	"github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2017-04-01/servicebus"
+	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/utils"
+)
+
+func ExpandEntityStatus(input interface{}) servicebus.EntityStatus {
+	entityStatus := servicebus.Unknown
+
+	if status, ok := input.(string); ok {
+		entityStatus = servicebus.EntityStatus(strings.Title(status))
+	}
+
+	return entityStatus
+}
+
+func FlattenEntityStatus(status servicebus.EntityStatus) *string {
+	return utils.String(string(status))
+}

azurerm/internal/services/servicebus/helper/entity_status_test.go

@@ -0,0 +1,75 @@
+package helper
+
+import (
+	"testing"
+
+	"github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2017-04-01/servicebus"
+)
+
+func TestExpandEntityStatus(t *testing.T) {
+	testData := []struct {
+		Name     string
+		Input    string
+		Expected servicebus.EntityStatus
+	}{
+		{
+			Name:     "Active",
+			Input:    "Active",
+			Expected: servicebus.Active,
+		},
+		{
+			Name:     "ReceiveDisabled",
+			Input:    "ReceiveDisabled",
+			Expected: servicebus.ReceiveDisabled,
+		},
+		{
+			Name:     "Disabled",
+			Input:    "Disabled",
+			Expected: servicebus.Disabled,
+		},
+	}
+
+	for _, v := range testData {
+		t.Logf("[DEBUG] Testing %q", v.Name)
+
+		actual := ExpandEntityStatus(v.Input)
+
+		if actual != v.Expected {
+			t.Fatalf("Expected %q but got %q", v.Expected, actual)
+		}
+	}
+}
+
+func TestFlattenEntityStatus(t *testing.T) {
+	testData := []struct {
+		Name     string
+		Input    servicebus.EntityStatus
+		Expected string
+	}{
+		{
+			Name:     "Active",
+			Input:    servicebus.Active,
+			Expected: "Active",
+		},
+		{
+			Name:     "Disabled",
+			Input:    servicebus.Disabled,
+			Expected: "Disabled",
+		},
+		{
+			Name:     "ReceiveDisabled",
+			Input:    servicebus.ReceiveDisabled,
+			Expected: "ReceiveDisabled",
+		},
+	}
+
+	for _, v := range testData {
+		t.Logf("[DEBUG] Testing %q", v.Name)
+
+		actual := FlattenEntityStatus(v.Input)
+
+		if *actual != v.Expected {
+			t.Fatalf("Expected %q but got %q", v.Expected, *actual)
+		}
+	}
+}

azurerm/internal/services/servicebus/resource_arm_servicebus_subscription.go

@@ -7,10 +7,12 @@ import (
 
 	"github.com/Azure/azure-sdk-for-go/services/servicebus/mgmt/2017-04-01/servicebus"
 	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+	"github.com/hashicorp/terraform-plugin-sdk/helper/validation"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/helpers/azure"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/helpers/tf"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/clients"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/features"
+	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/servicebus/helper"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/servicebus/validate"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/timeouts"
 	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/utils"
@@ -106,6 +108,17 @@ func resourceArmServiceBusSubscription() *schema.Resource {
 				Type:     schema.TypeString,
 				Optional: true,
 			},
+
+			"status": {
+				Type:     schema.TypeString,
+				Optional: true,
+				Default:  string(servicebus.Active),
+				ValidateFunc: validation.StringInSlice([]string{
+					string(servicebus.Active),
+					string(servicebus.Disabled),
+					string(servicebus.ReceiveDisabled),
+				}, false),
+			},
 		},
 	}
 }
@@ -145,6 +158,7 @@ func resourceArmServiceBusSubscriptionCreateUpdate(d *schema.ResourceData, meta
 			EnableBatchedOperations:          &enableBatchedOps,
 			MaxDeliveryCount:                 &maxDeliveryCount,
 			RequiresSession:                  &requiresSession,
+			Status:                           helper.ExpandEntityStatus(d.Get("status")),
 		},
 	}
 
@@ -222,6 +236,7 @@ func resourceArmServiceBusSubscriptionRead(d *schema.ResourceData, meta interfac
 		d.Set("requires_session", props.RequiresSession)
 		d.Set("forward_to", props.ForwardTo)
 		d.Set("forward_dead_lettered_messages_to", props.ForwardDeadLetteredMessagesTo)
+		d.Set("status", helper.FlattenEntityStatus(props.Status))
 
 		if count := props.MaxDeliveryCount; count != nil {
 			d.Set("max_delivery_count", int(*count))

azurerm/internal/services/servicebus/tests/resource_arm_servicebus_subscription_test.go

@@ -174,6 +174,43 @@ func TestAccAzureRMServiceBusSubscription_updateForwardDeadLetteredMessagesTo(t
 	})
 }
 
+func TestAccAzureRMServiceBusSubscription_status(t *testing.T) {
+	data := acceptance.BuildTestData(t, "azurerm_servicebus_subscription", "test")
+
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:     func() { acceptance.PreCheck(t) },
+		Providers:    acceptance.SupportedProviders,
+		CheckDestroy: testCheckAzureRMServiceBusSubscriptionDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccAzureRMServiceBusSubscription_basic(data),
+				Check: resource.ComposeTestCheckFunc(
+					testCheckAzureRMServiceBusSubscriptionExists(data.ResourceName),
+					resource.TestCheckResourceAttr(data.ResourceName, "status", "Active"),
+				),
+			},
+			{
+				Config: testAccAzureRMServiceBusSubscription_status(data, "Disabled"),
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr(data.ResourceName, "status", "Disabled"),
+				),
+			},
+			{
+				Config: testAccAzureRMServiceBusSubscription_status(data, "ReceiveDisabled"),
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr(data.ResourceName, "status", "ReceiveDisabled"),
+				),
+			},
+			{
+				Config: testAccAzureRMServiceBusSubscription_status(data, "Active"),
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr(data.ResourceName, "status", "Active"),
+				),
+			},
+		},
+	})
+}
+
 func testCheckAzureRMServiceBusSubscriptionDestroy(s *terraform.State) error {
 	client := acceptance.AzureProvider.Meta().(*clients.Client).ServiceBus.SubscriptionsClient
 	ctx := acceptance.AzureProvider.Meta().(*clients.Client).StopContext
@@ -325,3 +362,8 @@ resource "azurerm_servicebus_topic" "forward_dl_messages_to" {
 	return fmt.Sprintf(forwardToTf, data.RandomInteger, data.Locations.Primary, data.RandomInteger, data.RandomInteger, data.RandomInteger,
 		"forward_dead_lettered_messages_to = \"${azurerm_servicebus_topic.forward_dl_messages_to.name}\"\n", data.RandomInteger)
 }
+
+func testAccAzureRMServiceBusSubscription_status(data acceptance.TestData, status string) string {
+	return fmt.Sprintf(testAccAzureRMServiceBusSubscription_tfTemplate, data.RandomInteger, data.Locations.Primary, data.RandomInteger, data.RandomInteger, data.RandomInteger,
+		fmt.Sprintf("status = \"%s\"", status))
+}

website/docs/r/servicebus_subscription.html.markdown

@@ -76,6 +76,8 @@ The following arguments are supported:
 
 * `forward_dead_lettered_messages_to` - (Optional) The name of a Queue or Topic to automatically forward Dead Letter messages to.
 
+* `status` - (Optional) The status of the Subscription. Possible values are `Active`,`ReceiveDisabled`, or `Disabled`. Defaults to `Active`.
+
 ## Attributes Reference
 
 The following attributes are exported: