/
import_flexibleengine_s3_bucket.go
45 lines (38 loc) · 1.15 KB
/
import_flexibleengine_s3_bucket.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package flexibleengine
import (
"fmt"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/awserr"
"github.com/aws/aws-sdk-go/service/s3"
"github.com/hashicorp/errwrap"
"github.com/hashicorp/terraform/helper/schema"
)
func resourceS3BucketImportState(
d *schema.ResourceData,
meta interface{}) ([]*schema.ResourceData, error) {
results := make([]*schema.ResourceData, 1, 1)
results[0] = d
config := meta.(*Config)
conn, err := config.computeS3conn(GetRegion(d, config))
if err != nil {
return nil, fmt.Errorf("Error creating FlexibleEngine s3 client: %s", err)
}
pol, err := conn.GetBucketPolicy(&s3.GetBucketPolicyInput{
Bucket: aws.String(d.Id()),
})
if err != nil {
if awsErr, ok := err.(awserr.Error); ok && awsErr.Code() == "NoSuchBucketPolicy" {
// Bucket without policy
return results, nil
}
return nil, errwrap.Wrapf("Error importing AWS S3 bucket policy: {{err}}", err)
}
policy := resourceS3BucketPolicy()
pData := policy.Data(nil)
pData.SetId(d.Id())
pData.SetType("flexibleengine_s3_bucket_policy")
pData.Set("bucket", d.Id())
pData.Set("policy", pol)
results = append(results, pData)
return results, nil
}