mirror of https://github.com/hashicorp/consul
44 lines
1.1 KiB
Go
44 lines
1.1 KiB
Go
|
package s3
|
||
|
|
|
||
|
|
import (
|
||
|
|
"io/ioutil"
|
||
|
|
"regexp"
|
||
|
|
|
||
|
|
"github.com/aws/aws-sdk-go/aws"
|
||
|
|
"github.com/aws/aws-sdk-go/aws/awserr"
|
||
|
|
"github.com/aws/aws-sdk-go/aws/awsutil"
|
||
|
|
"github.com/aws/aws-sdk-go/aws/request"
|
||
|
|
)
|
||
|
|
|
||
|
|
var reBucketLocation = regexp.MustCompile(`>([^<>]+)<\/Location`)
|
||
|
|
|
||
|
|
func buildGetBucketLocation(r *request.Request) {
|
||
|
|
if r.DataFilled() {
|
||
|
|
out := r.Data.(*GetBucketLocationOutput)
|
||
|
|
b, err := ioutil.ReadAll(r.HTTPResponse.Body)
|
||
|
|
if err != nil {
|
||
|
|
r.Error = awserr.New("SerializationError", "failed reading response body", err)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
match := reBucketLocation.FindSubmatch(b)
|
||
|
|
if len(match) > 1 {
|
||
|
|
loc := string(match[1])
|
||
|
|
out.LocationConstraint = &loc
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func populateLocationConstraint(r *request.Request) {
|
||
|
|
if r.ParamsFilled() && aws.StringValue(r.Config.Region) != "us-east-1" {
|
||
|
|
in := r.Params.(*CreateBucketInput)
|
||
|
|
if in.CreateBucketConfiguration == nil {
|
||
|
|
r.Params = awsutil.CopyOf(r.Params)
|
||
|
|
in = r.Params.(*CreateBucketInput)
|
||
|
|
in.CreateBucketConfiguration = &CreateBucketConfiguration{
|
||
|
|
LocationConstraint: r.Config.Region,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|