修复镜像回源、解冻对象、生成外链、批量删除接口的bug

.gitignore

@@ -1,2 +1,4 @@
 vendor
 doc
+.idea/
+.DS_Store

aws/version.go

@@ -5,4 +5,4 @@ package aws
 const SDKName = "aws-sdk-go"
 
 // SDKVersion is the version of this SDK
-const SDKVersion = "1.2.6"
+const SDKVersion = "1.2.7"

internal/protocol/body/body.go

@@ -0,0 +1,56 @@
+package body
+
+import (
+	"github.com/ks3sdklib/aws-sdk-go/aws"
+	"github.com/ks3sdklib/aws-sdk-go/internal/protocol/rest"
+	"github.com/ks3sdklib/aws-sdk-go/internal/protocol/restjson"
+	"github.com/ks3sdklib/aws-sdk-go/internal/protocol/restxml"
+)
+
+// Build builds the REST component of a service request.
+func Build(r *aws.Request) {
+	index := IndexOf(jsonRequestApiName, r.Operation.Name)
+	if index != -1 {
+		restjson.Build(r)
+	} else {
+		restxml.Build(r)
+	}
+}
+
+// UnmarshalBody unmarshal a response body for the REST protocol.
+func UnmarshalBody(r *aws.Request) {
+	rest.Unmarshal(r)
+	index := IndexOf(jsonResponseApiName, r.Operation.Name)
+	if index != -1 {
+		restjson.Unmarshal(r)
+	} else {
+		restxml.Unmarshal(r)
+	}
+}
+
+// UnmarshalMeta unmarshal response headers for the REST protocol.
+func UnmarshalMeta(r *aws.Request) {
+	rest.UnmarshalMeta(r)
+}
+
+// UnmarshalError unmarshal a response error for the REST protocol.
+func UnmarshalError(r *aws.Request) {
+	restxml.UnmarshalError(r)
+}
+
+var jsonRequestApiName = []string{
+	"PutBucketMirror",
+}
+
+var jsonResponseApiName = []string{
+	"GetBucketMirror",
+}
+
+func IndexOf(apiNames []string, apiName string) int {
+	for index, value := range apiNames {
+		if value == apiName {
+			return index
+		}
+	}
+	return -1
+}

internal/protocol/jsonrpc/jsonrpc.go

@@ -8,6 +8,7 @@ package jsonrpc
 import (
 	"encoding/json"
 	"io/ioutil"
+	"reflect"
 	"strings"
 
 	"github.com/ks3sdklib/aws-sdk-go/aws"
@@ -22,7 +23,18 @@ func Build(req *aws.Request) {
 	var buf []byte
 	var err error
 	if req.ParamsFilled() {
-		buf, err = jsonutil.BuildJSON(req.Params)
+		v := reflect.ValueOf(req.Params).Elem()
+		if field, ok := v.Type().FieldByName("SDKShapeTraits"); ok {
+			if payloadName := field.Tag.Get("payload"); payloadName != "" {
+				pfield, _ := v.Type().FieldByName(payloadName)
+				if ptag := pfield.Tag.Get("type"); ptag == "" || ptag == "structure" {
+					payload := reflect.Indirect(v.FieldByName(payloadName))
+					if payload.IsValid() && payload.Interface() != nil {
+						buf, err = jsonutil.BuildJSON(payload.Interface())
+					}
+				}
+			}
+		}
 		if err != nil {
 			req.Error = apierr.New("Marshal", "failed encoding JSON RPC request", err)
 			return
@@ -49,9 +61,20 @@ func Build(req *aws.Request) {
 func Unmarshal(req *aws.Request) {
 	defer req.HTTPResponse.Body.Close()
 	if req.DataFilled() {
-		err := jsonutil.UnmarshalJSON(req.Data, req.HTTPResponse.Body)
-		if err != nil {
-			req.Error = apierr.New("Unmarshal", "failed decoding JSON RPC response", err)
+		v := reflect.ValueOf(req.Data).Elem()
+		if field, ok := v.Type().FieldByName("SDKShapeTraits"); ok {
+			if payloadName := field.Tag.Get("payload"); payloadName != "" {
+				pfield, _ := v.Type().FieldByName(payloadName)
+				if ptag := pfield.Tag.Get("type"); ptag == "" || ptag == "structure" {
+					payload := v.FieldByName(payloadName)
+					if payload.IsValid() && payload.Interface() != nil {
+						err := jsonutil.UnmarshalJSON(payload.Interface(), req.HTTPResponse.Body)
+						if err != nil {
+							req.Error = apierr.New("Unmarshal", "failed decoding JSON RPC response", err)
+						}
+					}
+				}
+			}
 		}
 	}
 	return

internal/protocol/rest/unmarshal.go

@@ -19,6 +19,12 @@ func Unmarshal(r *aws.Request) {
 	if r.DataFilled() {
 		v := reflect.Indirect(reflect.ValueOf(r.Data))
 		unmarshalBody(r, v)
+	}
+}
+
+func UnmarshalMeta(r *aws.Request) {
+	if r.DataFilled() {
+		v := reflect.Indirect(reflect.ValueOf(r.Data))
 		unmarshalLocationElements(r, v)
 	}
 }

internal/signer/v2/v2.go

@@ -56,6 +56,7 @@ var signQuerys = map[string]bool{
 	"fetch":                        true,
 	"copy":                         true,
 	"mirror":                       true,
+	"restore":                      true,
 }
 
 type signer struct {

internal/signer/v4/v4_test.go

@@ -24,7 +24,7 @@ func buildSigner(serviceName string, region string, signTime time.Time, expireTi
 	return signer{
 		Request:     req,
 		Time:        signTime,
-		ExpireTime:  expireTime,
+		ExpireTime:  int64(expireTime),
 		Query:       req.URL.Query(),
 		Body:        reader,
 		ServiceName: serviceName,