New Resource: azurerm_logic_app_workflow

azurerm/config.go

@@ -25,6 +25,7 @@ import (
 	"github.com/Azure/azure-sdk-for-go/services/iothub/mgmt/2017-07-01/devices"
 	keyVault "github.com/Azure/azure-sdk-for-go/services/keyvault/2016-10-01/keyvault"
 	"github.com/Azure/azure-sdk-for-go/services/keyvault/mgmt/2016-10-01/keyvault"
+	"github.com/Azure/azure-sdk-for-go/services/logic/mgmt/2016-06-01/logic"
 	"github.com/Azure/azure-sdk-for-go/services/monitor/mgmt/2018-03-01/insights"
 	"github.com/Azure/azure-sdk-for-go/services/mysql/mgmt/2017-12-01/mysql"
 	"github.com/Azure/azure-sdk-for-go/services/network/mgmt/2018-04-01/network"
@@ -149,6 +150,9 @@ type ArmClient struct {
 	keyVaultClient           keyvault.VaultsClient
 	keyVaultManagementClient keyVault.BaseClient
 
+	// Logic
+	logicWorkflowsClient logic.WorkflowsClient
+
 	// Monitor
 	monitorAlertRulesClient insights.AlertRulesClient
 
@@ -397,6 +401,7 @@ func getArmClient(c *authentication.Config) (*ArmClient, error) {
 	client.registerEventGridClients(endpoint, c.SubscriptionID, auth, sender)
 	client.registerEventHubClients(endpoint, c.SubscriptionID, auth, sender)
 	client.registerKeyVaultClients(endpoint, c.SubscriptionID, auth, keyVaultAuth, sender)
+	client.registerLogicClients(endpoint, c.SubscriptionID, auth, sender)
 	client.registerMonitorClients(endpoint, c.SubscriptionID, auth, sender)
 	client.registerNetworkingClients(endpoint, c.SubscriptionID, auth, sender)
 	client.registerOperationalInsightsClients(endpoint, c.SubscriptionID, auth, sender)
@@ -732,6 +737,12 @@ func (c *ArmClient) registerKeyVaultClients(endpoint, subscriptionId string, aut
 	c.keyVaultManagementClient = keyVaultManagementClient
 }
 
+func (c *ArmClient) registerLogicClients(endpoint, subscriptionId string, auth autorest.Authorizer, sender autorest.Sender) {
+	workflowsClient := logic.NewWorkflowsClientWithBaseURI(endpoint, subscriptionId)
+	c.configureClient(&workflowsClient.Client, auth)
+	c.logicWorkflowsClient = workflowsClient
+}
+
 func (c *ArmClient) registerMonitorClients(endpoint, subscriptionId string, auth autorest.Authorizer, sender autorest.Sender) {
 	arc := insights.NewAlertRulesClientWithBaseURI(endpoint, subscriptionId)
 	setUserAgent(&arc.Client)

azurerm/data_source_logic_app_workflow.go

@@ -0,0 +1,108 @@
+package azurerm
+
+import (
+	"fmt"
+
+	"github.com/Azure/azure-sdk-for-go/services/logic/mgmt/2016-06-01/logic"
+	"github.com/hashicorp/terraform/helper/schema"
+	"github.com/terraform-providers/terraform-provider-azurerm/azurerm/utils"
+)
+
+func dataSourceArmLogicAppWorkflow() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceArmLogicAppWorkflowRead,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+
+		Schema: map[string]*schema.Schema{
+			"name": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+
+			"resource_group_name": resourceGroupNameForDataSourceSchema(),
+
+			"location": locationForDataSourceSchema(),
+
+			// TODO: should Parameters be split out into their own object to allow validation on the different sub-types?
+			"parameters": {
+				Type:     schema.TypeMap,
+				Computed: true,
+			},
+
+			"workflow_schema": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+
+			"workflow_version": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+
+			"tags": tagsForDataSourceSchema(),
+
+			"access_endpoint": {
+				Type:     schema.TypeString,
+				Computed: true,
+			},
+		},
+	}
+}
+func dataSourceArmLogicAppWorkflowRead(d *schema.ResourceData, meta interface{}) error {
+	client := meta.(*ArmClient).logicWorkflowsClient
+	ctx := meta.(*ArmClient).StopContext
+
+	name := d.Get("name").(string)
+	resourceGroup := d.Get("resource_group_name").(string)
+
+	resp, err := client.Get(ctx, resourceGroup, name)
+	if err != nil {
+		if utils.ResponseWasNotFound(resp.Response) {
+			return fmt.Errorf("Logic App Workflow %q was not found in Resource Group %q", name, resourceGroup)
+		}
+
+		return fmt.Errorf("[ERROR] Error making Read request on Logic App Workflow %q (Resource Group %q): %+v", name, resourceGroup, err)
+	}
+
+	d.SetId(*resp.ID)
+
+	if location := resp.Location; location != nil {
+		d.Set("location", azureRMNormalizeLocation(*location))
+	}
+
+	if props := resp.WorkflowProperties; props != nil {
+		parameters := flattenLogicAppDataSourceWorkflowParameters(props.Parameters)
+		if err := d.Set("parameters", parameters); err != nil {
+			return fmt.Errorf("Error flattening `parameters`: %+v", err)
+		}
+
+		d.Set("access_endpoint", props.AccessEndpoint)
+
+		if definition := props.Definition; definition != nil {
+			if v, ok := definition.(map[string]interface{}); ok {
+				schema := v["$schema"].(string)
+				version := v["contentVersion"].(string)
+				d.Set("workflow_schema", schema)
+				d.Set("workflow_version", version)
+			}
+		}
+	}
+
+	flattenAndSetTags(d, resp.Tags)
+
+	return nil
+}
+
+func flattenLogicAppDataSourceWorkflowParameters(input map[string]*logic.WorkflowParameter) map[string]interface{} {
+	output := make(map[string]interface{}, 0)
+
+	for k, v := range input {
+		if v != nil {
+			output[k] = v.Value.(string)
+		}
+	}
+
+	return output
+}

azurerm/data_source_logic_app_workflow_test.go

@@ -0,0 +1,80 @@
+package azurerm
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform/helper/acctest"
+	"github.com/hashicorp/terraform/helper/resource"
+)
+
+func TestAccDataSourceAzureRMLogicAppWorkflow_basic(t *testing.T) {
+	dataSourceName := "data.azurerm_logic_app_workflow.test"
+	ri := acctest.RandInt()
+	location := testLocation()
+	config := testAccDataSourceAzureRMLogicAppWorkflow_basic(ri, location)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+				Check: resource.ComposeTestCheckFunc(
+					testCheckAzureRMLogicAppWorkflowExists(dataSourceName),
+					resource.TestCheckResourceAttr(dataSourceName, "parameters.%", "0"),
+					resource.TestCheckResourceAttr(dataSourceName, "tags.%", "0"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccDataSourceAzureRMLogicAppWorkflow_tags(t *testing.T) {
+	dataSourceName := "data.azurerm_logic_app_workflow.test"
+	ri := acctest.RandInt()
+	location := testLocation()
+	config := testAccDataSourceAzureRMLogicAppWorkflow_tags(ri, location)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+				Check: resource.ComposeTestCheckFunc(
+					testCheckAzureRMLogicAppWorkflowExists(dataSourceName),
+					resource.TestCheckResourceAttr(dataSourceName, "parameters.%", "0"),
+					resource.TestCheckResourceAttr(dataSourceName, "tags.%", "1"),
+					resource.TestCheckResourceAttr(dataSourceName, "tags.Source", "AcceptanceTests"),
+				),
+			},
+		},
+	})
+}
+
+func testAccDataSourceAzureRMLogicAppWorkflow_basic(rInt int, location string) string {
+	resource := testAccAzureRMLogicAppWorkflow_empty(rInt, location)
+	return fmt.Sprintf(`
+%s
+
+data "azurerm_logic_app_workflow" "test" {
+  name                = "${azurerm_logic_app_workflow.test.name}"
+  resource_group_name = "${azurerm_logic_app_workflow.test.resource_group_name}"
+}
+`, resource)
+}
+
+func testAccDataSourceAzureRMLogicAppWorkflow_tags(rInt int, location string) string {
+	resource := testAccAzureRMLogicAppWorkflow_tags(rInt, location)
+	return fmt.Sprintf(`
+%s
+
+data "azurerm_logic_app_workflow" "test" {
+  name                = "${azurerm_logic_app_workflow.test.name}"
+  resource_group_name = "${azurerm_logic_app_workflow.test.resource_group_name}"
+}
+`, resource)
+}

azurerm/import_arm_logic_app_action_custom_test.go

@@ -0,0 +1,29 @@
+package azurerm
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform/helper/acctest"
+	"github.com/hashicorp/terraform/helper/resource"
+)
+
+func TestAccAzureRMLogicAppActionCustom_importBasic(t *testing.T) {
+	ri := acctest.RandInt()
+	config := testAccAzureRMLogicAppActionCustom_basic(ri, testLocation())
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+			},
+			{
+				ResourceName:      "azurerm_logic_app_action_custom.test",
+				ImportState:       true,
+				ImportStateVerify: true,
+			},
+		},
+	})
+}

azurerm/import_arm_logic_app_action_http_test.go

@@ -0,0 +1,50 @@
+package azurerm
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform/helper/acctest"
+	"github.com/hashicorp/terraform/helper/resource"
+)
+
+func TestAccAzureRMLogicAppActionHttp_importBasic(t *testing.T) {
+	ri := acctest.RandInt()
+	config := testAccAzureRMLogicAppActionHttp_basic(ri, testLocation())
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+			},
+			{
+				ResourceName:      "azurerm_logic_app_action_http.test",
+				ImportState:       true,
+				ImportStateVerify: true,
+			},
+		},
+	})
+}
+
+func TestAccAzureRMLogicAppActionHttp_importHeaders(t *testing.T) {
+	ri := acctest.RandInt()
+	config := testAccAzureRMLogicAppActionHttp_headers(ri, testLocation())
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+			},
+			{
+				ResourceName:      "azurerm_logic_app_action_http.test",
+				ImportState:       true,
+				ImportStateVerify: true,
+			},
+		},
+	})
+}

azurerm/import_arm_logic_app_trigger_custom_test.go

@@ -0,0 +1,29 @@
+package azurerm
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform/helper/acctest"
+	"github.com/hashicorp/terraform/helper/resource"
+)
+
+func TestAccAzureRMLogicAppTriggerCustom_importBasic(t *testing.T) {
+	ri := acctest.RandInt()
+	config := testAccAzureRMLogicAppTriggerCustom_basic(ri, testLocation())
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testCheckAzureRMLogicAppWorkflowDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+			},
+			{
+				ResourceName:      "azurerm_logic_app_trigger_custom.test",
+				ImportState:       true,
+				ImportStateVerify: true,
+			},
+		},
+	})
+}