azurerm_logic_app_action_http - support for the queries property

internal/services/logic/logic_app_action_http_resource.go

@@ -80,6 +80,15 @@ func resourceLogicAppActionHTTP() *pluginsdk.Resource {
 					Type: pluginsdk.TypeString,
 				},
 			},
+
+			"queries": {
+				Type:     pluginsdk.TypeMap,
+				Optional: true,
+				Elem: &pluginsdk.Schema{
+					Type: pluginsdk.TypeString,
+				},
+			},
+
 			"run_after": {
 				Type:     pluginsdk.TypeSet,
 				Optional: true,
@@ -121,10 +130,17 @@ func resourceLogicAppActionHTTPCreateUpdate(d *pluginsdk.ResourceData, meta inte
 		return err
 	}
 
+	queriesRaw := d.Get("queries").(map[string]interface{})
+	queries, err := expandLogicAppActionHttpQueries(queriesRaw)
+	if err != nil {
+		return err
+	}
+
 	inputs := map[string]interface{}{
 		"method":  d.Get("method").(string),
 		"uri":     d.Get("uri").(string),
 		"headers": headers,
+		"queries": queries,
 	}
 
 	// storing action's body in json object to keep consistent with azure portal
@@ -214,6 +230,13 @@ func resourceLogicAppActionHTTPRead(d *pluginsdk.ResourceData, meta interface{})
 		}
 	}
 
+	if queries := inputs["queries"]; queries != nil {
+		qv := queries.(map[string]interface{})
+		if err := d.Set("queries", qv); err != nil {
+			return fmt.Errorf("setting `queries` for HTTP Action %q: %+v", id.Name, err)
+		}
+	}
+
 	v = action["runAfter"]
 	if v != nil {
 		runAfter, ok := v.(map[string]interface{})
@@ -256,3 +279,18 @@ func expandLogicAppActionHttpHeaders(headersRaw map[string]interface{}) (*map[st
 
 	return &headers, nil
 }
+
+func expandLogicAppActionHttpQueries(queriesRaw map[string]interface{}) (*map[string]string, error) {
+	queries := make(map[string]string)
+
+	for i, v := range queriesRaw {
+		value, err := tags.TagValueToString(v)
+		if err != nil {
+			return nil, err
+		}
+
+		queries[i] = value
+	}
+
+	return &queries, nil
+}

internal/services/logic/logic_app_action_http_resource_test.go

@@ -76,6 +76,21 @@ func TestAccLogicAppActionHttp_headers(t *testing.T) {
 	})
 }
 
+func TestAccLogicAppActionHttp_queries(t *testing.T) {
+	data := acceptance.BuildTestData(t, "azurerm_logic_app_action_http", "test")
+	r := LogicAppActionHttpResource{}
+
+	data.ResourceTest(t, r, []acceptance.TestStep{
+		{
+			Config: r.queries(data),
+			Check: acceptance.ComposeTestCheckFunc(
+				check.That(data.ResourceName).ExistsInAzure(r),
+			),
+		},
+		data.ImportStep(),
+	})
+}
+
 func TestAccLogicAppActionHttp_disappears(t *testing.T) {
 	data := acceptance.BuildTestData(t, "azurerm_logic_app_action_http", "test")
 	r := LogicAppActionHttpResource{}
@@ -196,6 +211,24 @@ resource "azurerm_logic_app_action_http" "test" {
 `, r.template(data), data.RandomInteger)
 }
 
+func (r LogicAppActionHttpResource) queries(data acceptance.TestData) string {
+	return fmt.Sprintf(`
+%s
+
+resource "azurerm_logic_app_action_http" "test" {
+  name         = "action%d"
+  logic_app_id = azurerm_logic_app_workflow.test.id
+  method       = "GET"
+  uri          = "http://example.com/hello"
+
+  queries = {
+    "Hello"     = "World"
+    "Something" = "New"
+  }
+}
+`, r.template(data), data.RandomInteger)
+}
+
 func (r LogicAppActionHttpResource) runAfterCondition(data acceptance.TestData, condition string) string {
 	return fmt.Sprintf(`
 %s

website/docs/r/logic_app_action_http.html.markdown

@@ -50,6 +50,8 @@ The following arguments are supported:
 
 * `headers` - (Optional) Specifies a Map of Key-Value Pairs that should be sent to the `uri` when this HTTP Action is triggered.
 
+* `queries` - (Optional) Specifies a Map of Key-Value Pairs that should be sent to the `uri` when this HTTP Action is triggered.
+
 * `run_after` - (Optional) Specifies the place of the HTTP Action in the Logic App Workflow. If not specified, the HTTP Action is right after the Trigger. A `run_after` block is as defined below.
 
 ---