|
|
@ -45,8 +45,13 @@ func (s3a *S3ApiServer) PutObjectHandler(w http.ResponseWriter, r *http.Request) |
|
|
|
rAuthType := getRequestAuthType(r) |
|
|
|
dataReader := r.Body |
|
|
|
var s3ErrCode ErrorCode |
|
|
|
if rAuthType == authTypeStreamingSigned { |
|
|
|
switch rAuthType { |
|
|
|
case authTypeStreamingSigned: |
|
|
|
dataReader, s3ErrCode = s3a.iam.newSignV4ChunkedReader(r) |
|
|
|
case authTypeSignedV2, authTypePresignedV2: |
|
|
|
_, s3ErrCode = s3a.iam.isReqAuthenticatedV2(r) |
|
|
|
case authTypePresigned, authTypeSigned: |
|
|
|
_, s3ErrCode = s3a.iam.reqSignatureV4Verify(r) |
|
|
|
} |
|
|
|
if s3ErrCode != ErrNone { |
|
|
|
writeErrorResponse(w, s3ErrCode, r.URL) |
|
|
|