2018-03-15 16:43:07 +00:00
|
|
|
package digitalocean
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"log"
|
2018-04-10 23:10:43 +00:00
|
|
|
"os"
|
2018-03-15 16:43:07 +00:00
|
|
|
"strings"
|
|
|
|
"testing"
|
|
|
|
|
2019-10-22 21:44:03 +00:00
|
|
|
"github.com/hashicorp/terraform-plugin-sdk/helper/acctest"
|
|
|
|
"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
|
|
|
|
"github.com/hashicorp/terraform-plugin-sdk/terraform"
|
2018-03-15 16:43:07 +00:00
|
|
|
|
|
|
|
"github.com/aws/aws-sdk-go/aws"
|
|
|
|
"github.com/aws/aws-sdk-go/aws/awserr"
|
|
|
|
"github.com/aws/aws-sdk-go/aws/credentials"
|
|
|
|
"github.com/aws/aws-sdk-go/aws/session"
|
|
|
|
"github.com/aws/aws-sdk-go/service/s3"
|
2019-10-22 21:44:03 +00:00
|
|
|
"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
|
2018-03-15 16:43:07 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
func TestAccDigitalOceanBucket_basic(t *testing.T) {
|
|
|
|
rInt := acctest.RandInt()
|
|
|
|
|
2019-04-15 15:58:08 +00:00
|
|
|
expectedRegion := "ams3"
|
|
|
|
expectedBucketName := testAccBucketName(rInt)
|
|
|
|
expectBucketURN := fmt.Sprintf("do:space:%s", expectedBucketName)
|
|
|
|
|
2018-03-15 16:43:07 +00:00
|
|
|
resource.Test(t, resource.TestCase{
|
|
|
|
PreCheck: func() { testAccPreCheck(t) },
|
|
|
|
/*
|
2019-01-08 17:21:53 +00:00
|
|
|
IDRefreshName: "digitalocean_spaces_bucket.bucket",
|
2018-03-15 16:43:07 +00:00
|
|
|
IDRefreshIgnore: []string{"force_destroy"},
|
|
|
|
*/
|
|
|
|
Providers: testAccProviders,
|
|
|
|
CheckDestroy: testAccCheckDigitalOceanBucketDestroy,
|
|
|
|
Steps: []resource.TestStep{
|
|
|
|
{
|
|
|
|
Config: testAccDigitalOceanBucketConfig(rInt),
|
|
|
|
Check: resource.ComposeTestCheckFunc(
|
2019-01-08 17:21:53 +00:00
|
|
|
testAccCheckDigitalOceanBucketExists("digitalocean_spaces_bucket.bucket"),
|
2018-03-15 16:43:07 +00:00
|
|
|
resource.TestCheckResourceAttr(
|
2019-04-15 15:58:08 +00:00
|
|
|
"digitalocean_spaces_bucket.bucket", "region", expectedRegion),
|
2018-03-15 16:43:07 +00:00
|
|
|
resource.TestCheckResourceAttr(
|
2019-04-15 15:58:08 +00:00
|
|
|
"digitalocean_spaces_bucket.bucket", "name", expectedBucketName),
|
|
|
|
resource.TestCheckResourceAttr("digitalocean_spaces_bucket.bucket", "urn", expectBucketURN),
|
2018-03-15 16:43:07 +00:00
|
|
|
),
|
|
|
|
},
|
|
|
|
},
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestAccDigitalOceanBucket_region(t *testing.T) {
|
|
|
|
rInt := acctest.RandInt()
|
|
|
|
|
|
|
|
resource.Test(t, resource.TestCase{
|
|
|
|
PreCheck: func() { testAccPreCheck(t) },
|
|
|
|
Providers: testAccProviders,
|
|
|
|
CheckDestroy: testAccCheckDigitalOceanBucketDestroy,
|
|
|
|
Steps: []resource.TestStep{
|
|
|
|
{
|
|
|
|
Config: testAccDigitalOceanBucketConfigWithRegion(rInt),
|
|
|
|
Check: resource.ComposeTestCheckFunc(
|
2019-01-08 17:21:53 +00:00
|
|
|
testAccCheckDigitalOceanBucketExists("digitalocean_spaces_bucket.bucket"),
|
|
|
|
resource.TestCheckResourceAttr("digitalocean_spaces_bucket.bucket", "region", "ams3"),
|
2018-03-15 16:43:07 +00:00
|
|
|
),
|
|
|
|
},
|
|
|
|
},
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestAccDigitalOceanBucket_UpdateAcl(t *testing.T) {
|
|
|
|
ri := acctest.RandInt()
|
2018-12-05 05:17:22 +00:00
|
|
|
preConfig := fmt.Sprintf(testAccDigitalOceanBucketConfigWithACL, ri)
|
|
|
|
postConfig := fmt.Sprintf(testAccDigitalOceanBucketConfigWithACLUpdate, ri)
|
2018-03-15 16:43:07 +00:00
|
|
|
|
|
|
|
resource.Test(t, resource.TestCase{
|
|
|
|
PreCheck: func() { testAccPreCheck(t) },
|
|
|
|
Providers: testAccProviders,
|
|
|
|
CheckDestroy: testAccCheckDigitalOceanBucketDestroy,
|
|
|
|
Steps: []resource.TestStep{
|
|
|
|
{
|
|
|
|
Config: preConfig,
|
|
|
|
Check: resource.ComposeTestCheckFunc(
|
2019-01-08 17:21:53 +00:00
|
|
|
testAccCheckDigitalOceanBucketExists("digitalocean_spaces_bucket.bucket"),
|
2018-03-15 16:43:07 +00:00
|
|
|
resource.TestCheckResourceAttr(
|
2019-01-08 17:21:53 +00:00
|
|
|
"digitalocean_spaces_bucket.bucket", "acl", "public-read"),
|
2018-03-15 16:43:07 +00:00
|
|
|
),
|
|
|
|
},
|
|
|
|
{
|
|
|
|
Config: postConfig,
|
|
|
|
Check: resource.ComposeTestCheckFunc(
|
2019-01-08 17:21:53 +00:00
|
|
|
testAccCheckDigitalOceanBucketExists("digitalocean_spaces_bucket.bucket"),
|
2018-03-15 16:43:07 +00:00
|
|
|
resource.TestCheckResourceAttr(
|
2019-01-08 17:21:53 +00:00
|
|
|
"digitalocean_spaces_bucket.bucket", "acl", "private"),
|
2018-03-15 16:43:07 +00:00
|
|
|
),
|
|
|
|
},
|
|
|
|
},
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
// Test TestAccDigitalOceanBucket_shouldFailNotFound is designed to fail with a "plan
|
|
|
|
// not empty" error in Terraform, to check against regresssions.
|
|
|
|
// See https://github.com/hashicorp/terraform/pull/2925
|
|
|
|
func TestAccDigitalOceanBucket_shouldFailNotFound(t *testing.T) {
|
|
|
|
rInt := acctest.RandInt()
|
|
|
|
resource.Test(t, resource.TestCase{
|
|
|
|
PreCheck: func() { testAccPreCheck(t) },
|
|
|
|
Providers: testAccProviders,
|
|
|
|
CheckDestroy: testAccCheckDigitalOceanBucketDestroy,
|
|
|
|
Steps: []resource.TestStep{
|
|
|
|
{
|
|
|
|
Config: testAccDigitalOceanBucketDestroyedConfig(rInt),
|
|
|
|
Check: resource.ComposeTestCheckFunc(
|
2019-01-08 17:21:53 +00:00
|
|
|
testAccCheckDigitalOceanBucketExists("digitalocean_spaces_bucket.bucket"),
|
|
|
|
testAccCheckDigitalOceanDestroyBucket("digitalocean_spaces_bucket.bucket"),
|
2018-03-15 16:43:07 +00:00
|
|
|
),
|
|
|
|
ExpectNonEmptyPlan: true,
|
|
|
|
},
|
|
|
|
},
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccCheckDigitalOceanBucketDestroy(s *terraform.State) error {
|
|
|
|
return testAccCheckDigitalOceanBucketDestroyWithProvider(s, testAccProvider)
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccCheckDigitalOceanBucketDestroyWithProvider(s *terraform.State, provider *schema.Provider) error {
|
|
|
|
|
|
|
|
for _, rs := range s.RootModule().Resources {
|
2018-12-05 05:17:22 +00:00
|
|
|
sesh, err := session.NewSession(&aws.Config{
|
|
|
|
Region: aws.String(rs.Primary.Attributes["region"]),
|
2019-01-08 17:21:53 +00:00
|
|
|
Credentials: credentials.NewStaticCredentials(os.Getenv("SPACES_ACCESS_KEY_ID"), os.Getenv("SPACES_SECRET_ACCESS_KEY"), "")},
|
2018-12-05 05:17:22 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
svc := s3.New(sesh, &aws.Config{
|
|
|
|
Endpoint: aws.String(fmt.Sprintf("https://%s.digitaloceanspaces.com", rs.Primary.Attributes["region"]))},
|
|
|
|
)
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
|
|
|
}
|
|
|
|
|
2019-01-08 17:21:53 +00:00
|
|
|
if rs.Type != "digitalocean_spaces_bucket" {
|
2018-03-15 16:43:07 +00:00
|
|
|
continue
|
|
|
|
}
|
2018-12-05 05:17:22 +00:00
|
|
|
_, err = svc.DeleteBucket(&s3.DeleteBucketInput{
|
2018-03-15 16:43:07 +00:00
|
|
|
Bucket: aws.String(rs.Primary.ID),
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
if isAWSErr(err, s3.ErrCodeNoSuchBucket, "") {
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccCheckDigitalOceanBucketExists(n string) resource.TestCheckFunc {
|
|
|
|
return testAccCheckDigitalOceanBucketExistsWithProvider(n, func() *schema.Provider { return testAccProvider })
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccCheckDigitalOceanBucketExistsWithProvider(n string, providerF func() *schema.Provider) resource.TestCheckFunc {
|
|
|
|
return func(s *terraform.State) error {
|
|
|
|
rs, ok := s.RootModule().Resources[n]
|
|
|
|
if !ok {
|
|
|
|
return fmt.Errorf("Not found: %s", n)
|
|
|
|
}
|
|
|
|
|
|
|
|
if rs.Primary.ID == "" {
|
|
|
|
return fmt.Errorf("No ID is set")
|
|
|
|
}
|
|
|
|
|
|
|
|
sesh, err := session.NewSession(&aws.Config{
|
2018-12-05 05:17:22 +00:00
|
|
|
Region: aws.String(rs.Primary.Attributes["region"]),
|
2019-01-08 17:21:53 +00:00
|
|
|
Credentials: credentials.NewStaticCredentials(os.Getenv("SPACES_ACCESS_KEY_ID"), os.Getenv("SPACES_SECRET_ACCESS_KEY"), "")},
|
2018-03-15 16:43:07 +00:00
|
|
|
)
|
|
|
|
svc := s3.New(sesh, &aws.Config{
|
2018-12-05 05:17:22 +00:00
|
|
|
Endpoint: aws.String(fmt.Sprintf("https://%s.digitaloceanspaces.com", rs.Primary.Attributes["region"]))},
|
2018-03-15 16:43:07 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
_, err = svc.HeadBucket(&s3.HeadBucketInput{
|
|
|
|
Bucket: aws.String(rs.Primary.ID),
|
|
|
|
})
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
if isAWSErr(err, s3.ErrCodeNoSuchBucket, "") {
|
|
|
|
return fmt.Errorf("Spaces bucket not found")
|
|
|
|
}
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccCheckDigitalOceanDestroyBucket(n string) resource.TestCheckFunc {
|
|
|
|
return func(s *terraform.State) error {
|
|
|
|
rs, ok := s.RootModule().Resources[n]
|
|
|
|
if !ok {
|
|
|
|
return fmt.Errorf("Not found: %s", n)
|
|
|
|
}
|
|
|
|
|
|
|
|
if rs.Primary.ID == "" {
|
|
|
|
return fmt.Errorf("No Spaces Bucket ID is set")
|
|
|
|
}
|
|
|
|
|
|
|
|
sesh, err := session.NewSession(&aws.Config{
|
2018-12-05 05:17:22 +00:00
|
|
|
Region: aws.String(rs.Primary.Attributes["region"]),
|
2019-01-08 17:21:53 +00:00
|
|
|
Credentials: credentials.NewStaticCredentials(os.Getenv("SPACES_ACCESS_KEY_ID"), os.Getenv("SPACES_SECRET_ACCESS_KEY"), "")},
|
2018-03-15 16:43:07 +00:00
|
|
|
)
|
|
|
|
svc := s3.New(sesh, &aws.Config{
|
2018-12-05 05:17:22 +00:00
|
|
|
Endpoint: aws.String(fmt.Sprintf("https://%s.digitaloceanspaces.com", rs.Primary.Attributes["region"]))},
|
2018-03-15 16:43:07 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
log.Fatal(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
_, err = svc.DeleteBucket(&s3.DeleteBucketInput{
|
|
|
|
Bucket: aws.String(rs.Primary.ID),
|
|
|
|
})
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return fmt.Errorf("Error destroying Bucket (%s) in testAccCheckDigitalOceanDestroyBucket: %s", rs.Primary.ID, err)
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func isAWSErr(err error, code string, message string) bool {
|
|
|
|
if err, ok := err.(awserr.Error); ok {
|
|
|
|
return err.Code() == code && strings.Contains(err.Message(), message)
|
|
|
|
}
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
// These need a bit of randomness as the name can only be used once globally
|
|
|
|
func testAccBucketName(randInt int) string {
|
|
|
|
return fmt.Sprintf("tf-test-bucket-%d", randInt)
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccDigitalOceanBucketConfig(randInt int) string {
|
|
|
|
return fmt.Sprintf(`
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2018-11-26 00:11:47 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
2018-03-15 16:43:07 +00:00
|
|
|
acl = "public-read"
|
2019-04-15 15:58:08 +00:00
|
|
|
region = "ams3"
|
2018-03-15 16:43:07 +00:00
|
|
|
}
|
|
|
|
`, randInt)
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccDigitalOceanBucketDestroyedConfig(randInt int) string {
|
|
|
|
return fmt.Sprintf(`
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2018-11-26 00:11:47 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
2018-03-15 16:43:07 +00:00
|
|
|
acl = "public-read"
|
|
|
|
}
|
|
|
|
`, randInt)
|
|
|
|
}
|
|
|
|
|
|
|
|
func testAccDigitalOceanBucketConfigWithRegion(randInt int) string {
|
|
|
|
return fmt.Sprintf(`
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2018-11-26 00:11:47 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
|
|
|
region = "ams3"
|
2018-03-15 16:43:07 +00:00
|
|
|
}
|
|
|
|
`, randInt)
|
|
|
|
}
|
|
|
|
|
2018-12-05 05:17:22 +00:00
|
|
|
func testAccDigitalOceanBucketConfigImport(randInt int) string {
|
|
|
|
return fmt.Sprintf(`
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2019-05-10 19:55:41 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
|
|
|
region = "sfo2"
|
2018-12-05 05:17:22 +00:00
|
|
|
}
|
|
|
|
`, randInt)
|
|
|
|
}
|
|
|
|
|
|
|
|
var testAccDigitalOceanBucketConfigWithACL = `
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2018-11-26 00:11:47 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
2018-03-15 16:43:07 +00:00
|
|
|
acl = "public-read"
|
|
|
|
}
|
|
|
|
`
|
|
|
|
|
2018-12-05 05:17:22 +00:00
|
|
|
var testAccDigitalOceanBucketConfigWithACLUpdate = `
|
2019-01-08 17:21:53 +00:00
|
|
|
resource "digitalocean_spaces_bucket" "bucket" {
|
2018-11-26 00:11:47 +00:00
|
|
|
name = "tf-test-bucket-%d"
|
2018-03-15 16:43:07 +00:00
|
|
|
acl = "private"
|
|
|
|
}
|
|
|
|
`
|