Merge pull request #555 from SumoLogic/vsinghal-fix-s3-use-versioned-api

set default value for use_versioned_api param to true

Author: sumovishal

sumologic/resource_sumologic_generic_polling_source.go

@@ -128,6 +128,14 @@ func resourceSumologicGenericPollingSource() *schema.Resource {
 				"use_versioned_api": {
 					Type:     schema.TypeBool,
 					Optional: true,
+					Default:  true,
+					DiffSuppressFunc: func(k, old, new string, d *schema.ResourceData) bool {
+						contentType := d.Get("content_type").(string)
+						if contentType != "AwsS3Bucket" {
+							return true
+						}
+						return false
+					},
 				},
 				"path_expression": {
 					Type:     schema.TypeString,
@@ -578,7 +586,8 @@ func getPollingPathSettings(d *schema.ResourceData) (PollingPath, error) {
 			pathSettings.BucketName = path["bucket_name"].(string)
 			pathSettings.PathExpression = path["path_expression"].(string)
 			if path["use_versioned_api"] != nil {
-				pathSettings.UseVersionedApi = path["use_versioned_api"].(bool)
+				val := path["use_versioned_api"].(bool)
+				pathSettings.UseVersionedApi = &val
 			}
 			pathSettings.SnsTopicOrSubscriptionArn = getPollingSnsTopicOrSubscriptionArn(d)
 		case "CloudWatchPath", "AwsInventoryPath":

sumologic/resource_sumologic_s3_source_test.go

@@ -25,13 +25,14 @@ func TestAccSumologicS3Source_create(t *testing.T) {
 	s3ResourceName := "sumologic_s3_source.s3"
 	testAwsRoleArn := os.Getenv("SUMOLOGIC_TEST_ROLE_ARN")
 	testAwsBucket := os.Getenv("SUMOLOGIC_TEST_BUCKET_NAME")
+	useVersionedApi := true
 	resource.Test(t, resource.TestCase{
 		PreCheck:     func() { testAccPreCheckWithAWS(t) },
 		Providers:    testAccProviders,
 		CheckDestroy: testAccCheckS3SourceDestroy,
 		Steps: []resource.TestStep{
 			{
-				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket),
+				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket, useVersionedApi),
 				Check: resource.ComposeTestCheckFunc(
 					testAccCheckS3SourceExists(s3ResourceName, &s3Source),
 					testAccCheckS3SourceValues(&s3Source, sName, sDescription, sCategory),
@@ -43,6 +44,7 @@ func TestAccSumologicS3Source_create(t *testing.T) {
 					resource.TestCheckResourceAttr(s3ResourceName, "category", sCategory),
 					resource.TestCheckResourceAttr(s3ResourceName, "content_type", "AwsS3Bucket"),
 					resource.TestCheckResourceAttr(s3ResourceName, "path.0.type", "S3BucketPathExpression"),
+					resource.TestCheckResourceAttr(s3ResourceName, "path.0.use_versioned_api", "true"),
 				),
 			},
 		},
@@ -56,13 +58,15 @@ func TestAccSumologicS3Source_update(t *testing.T) {
 	s3ResourceName := "sumologic_s3_source.s3"
 	testAwsRoleArn := os.Getenv("SUMOLOGIC_TEST_ROLE_ARN")
 	testAwsBucket := os.Getenv("SUMOLOGIC_TEST_BUCKET_NAME")
+	useVersionedApi := true
+	useVersionedApiUpdated := false
 	resource.Test(t, resource.TestCase{
 		PreCheck:     func() { testAccPreCheckWithAWS(t) },
 		Providers:    testAccProviders,
 		CheckDestroy: testAccCheckHTTPSourceDestroy,
 		Steps: []resource.TestStep{
 			{
-				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket),
+				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket, useVersionedApi),
 				Check: resource.ComposeTestCheckFunc(
 					testAccCheckS3SourceExists(s3ResourceName, &s3Source),
 					testAccCheckS3SourceValues(&s3Source, sName, sDescription, sCategory),
@@ -72,10 +76,11 @@ func TestAccSumologicS3Source_update(t *testing.T) {
 					resource.TestCheckResourceAttr(s3ResourceName, "category", sCategory),
 					resource.TestCheckResourceAttr(s3ResourceName, "content_type", "AwsS3Bucket"),
 					resource.TestCheckResourceAttr(s3ResourceName, "path.0.type", "S3BucketPathExpression"),
+					resource.TestCheckResourceAttr(s3ResourceName, "path.0.use_versioned_api", "true"),
 				),
 			},
 			{
-				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sNameUpdated, sDescriptionUpdated, sCategoryUpdated, testAwsRoleArn, testAwsBucket),
+				Config: testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sNameUpdated, sDescriptionUpdated, sCategoryUpdated, testAwsRoleArn, testAwsBucket, useVersionedApiUpdated),
 				Check: resource.ComposeTestCheckFunc(
 					testAccCheckS3SourceExists(s3ResourceName, &s3Source),
 					testAccCheckS3SourceValues(&s3Source, sNameUpdated, sDescriptionUpdated, sCategoryUpdated),
@@ -85,6 +90,7 @@ func TestAccSumologicS3Source_update(t *testing.T) {
 					resource.TestCheckResourceAttr(s3ResourceName, "category", sCategoryUpdated),
 					resource.TestCheckResourceAttr(s3ResourceName, "content_type", "AwsS3Bucket"),
 					resource.TestCheckResourceAttr(s3ResourceName, "path.0.type", "S3BucketPathExpression"),
+					resource.TestCheckResourceAttr(s3ResourceName, "path.0.use_versioned_api", "false"),
 				),
 			},
 		},
@@ -157,7 +163,7 @@ func testAccCheckS3SourceValues(pollingSource *PollingSource, name, description,
 		return nil
 	}
 }
-func testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket string) string {
+func testAccSumologicS3SourceConfig(cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket string, useVersionedApi bool) string {
 	return fmt.Sprintf(`
 resource "sumologic_collector" "test" {
 	name = "%s"
@@ -180,8 +186,9 @@ resource "sumologic_s3_source" "s3" {
 		type = "S3BucketPathExpression"
 		bucket_name     = "%s"
 		path_expression = "*"
+		use_versioned_api = "%v"
 	  }
 	}
 
-`, cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket)
+`, cName, cDescription, cCategory, sName, sDescription, sCategory, testAwsRoleArn, testAwsBucket, useVersionedApi)
 }

sumologic/sumologic_polling_source.go

@@ -51,7 +51,7 @@ type PollingPath struct {
 	CustomServices            []string                         `json:"customServices,omitempty"`
 	TagFilters                []TagFilter                      `json:"tagFilters,omitempty"`
 	SnsTopicOrSubscriptionArn PollingSnsTopicOrSubscriptionArn `json:"snsTopicOrSubscriptionArn,omitempty"`
-	UseVersionedApi           bool                             `json:"useVersionedApi,omitempty"`
+	UseVersionedApi           *bool                            `json:"useVersionedApi,omitempty"`
 }
 
 type TagFilter struct {