SUMO-170407: updated connection schema

Author: rsanbhad

sumologic/resource_sumologic_connection.go

@@ -77,9 +77,15 @@ func resourceSumologicConnection() *schema.Resource {
 			"webhook_type": {
 				Type:         schema.TypeString,
 				Optional:     true,
-				ValidateFunc: validation.StringInSlice([]string{"AWSLambda", "Azure", "Datadog", "HipChat", "PagerDuty", "Slack", "Webhook", "NewRelic", "Jira", "Opsgenie", "MicrosoftTeams"}, false),
+				ValidateFunc: validation.StringInSlice([]string{"AWSLambda", "Azure", "Datadog", "HipChat", "PagerDuty", "Slack", "Webhook", "NewRelic", "Jira", "Opsgenie", "MicrosoftTeams", "ServiceNow"}, false),
 				Default:      "Webhook",
 			},
+			"connection_subtype": {
+				Type:         schema.TypeString,
+				Optional:     true,
+				ValidateFunc: validation.StringInSlice([]string{"Incident", "Event", ""}, false),
+				Default:      "",
+			},
 		},
 	}
 }
@@ -136,6 +142,7 @@ func resourceSumologicConnectionRead(d *schema.ResourceData, meta interface{}) e
 	}
 	d.Set("default_payload", connection.DefaultPayload)
 	d.Set("webhook_type", connection.WebhookType)
+	d.Set("connection_subtype", connection.ConnectionSubtype)
 	d.SetId(connection.ID)
 
 	log.Println("====End Connection Read====")
@@ -200,8 +207,8 @@ func resourceToConnection(d *schema.ResourceData) Connection {
 	connection.Headers = mapToHeaders(d.Get("headers").(map[string]interface{}))
 	connection.CustomHeaders = mapToHeaders(d.Get("custom_headers").(map[string]interface{}))
 	connection.DefaultPayload = d.Get("default_payload").(string)
-	connection.ConnectionSubtype = d.Get("connection_subtype").(string)
 	connection.WebhookType = d.Get("webhook_type").(string)
+	connection.ConnectionSubtype = d.Get("connection_subtype").(string)
 
 	return connection
 }
@@ -234,4 +241,5 @@ func printConnection(connection Connection) {
 	log.Printf("CustomHeaders: %s", connection.CustomHeaders)
 	log.Printf("DefaultPayload: %s", connection.DefaultPayload)
 	log.Printf("WebhookType: %s", connection.WebhookType)
+	log.Printf("ConnectionSubtype: %s", connection.ConnectionSubtype)
 }

sumologic/resource_sumologic_connection_test.go

@@ -42,6 +42,40 @@ func TestAccConnection_create(t *testing.T) {
 	})
 }
 
+func TestAccConnection_createServiceNowWebhook(t *testing.T) {
+	connectionType := "WebhookConnection"
+	name := acctest.RandomWithPrefix("tf-servicenow-webhook-connection-test-name")
+	description := acctest.RandomWithPrefix("tf-servicenow-webhook-connection-test-description")
+	url := "https://example.com"
+	defaultPayload := "{\"eventType\" : \"{{Name}}\"}"
+	webhookType := "ServiceNow"
+	connectionSubtype := "Incident"
+
+	var connection Connection
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testAccCheckConnectionDestroy,
+		Steps: []resource.TestStep{
+			{
+				Config: createServiceNowWebhookConnectionConfig(name, connectionType, description, url, connectionSubtype, defaultPayload),
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckConnectionExists("sumologic_connection.serviceNowTest", &connection, t),
+					testAccCheckConnectionAttributes("sumologic_connection.serviceNowTest"),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "type", connectionType),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "name", name),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "description", description),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "url", url),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "default_payload", defaultPayload+"\n"),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "webhook_type", webhookType),
+					resource.TestCheckResourceAttr("sumologic_connection.serviceNowTest", "connection_subtype", connectionSubtype),
+				),
+			},
+		},
+	})
+}
+
 func TestAccConnection_update(t *testing.T) {
 	var connection Connection
 	connectionType := "WebhookConnection"
@@ -151,3 +185,19 @@ JSON
 }
 `, name, connectionType, desc, url, webhookType, defaultPayload)
 }
+
+func createServiceNowWebhookConnectionConfig(name, connectionType, desc, url, connectionSubtype, defaultPayload string) string {
+	return fmt.Sprintf(`
+resource "sumologic_connection" "serviceNowTest" {
+	name = "%s"
+	type = "%s"
+	description = "%s"
+	url = "%s"
+	webhook_type = "ServiceNow"
+	connection_subtype = "%s"
+	default_payload = <<JSON
+%s
+JSON
+}
+`, name, connectionType, desc, url, connectionSubtype, defaultPayload)
+}