diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-26 12:09:50 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-26 12:09:50 -0700 |
| commit | c50ec1599c953068ff2e7f4835d30b044ac3325d (patch) | |
| tree | d4046ac2180929adcba5f2d45b19e6e2ba081add | |
| parent | ea0180de4e35c2d1d856e153150f30915a712fc5 (diff) | |
| download | seaweedfs-c50ec1599c953068ff2e7f4835d30b044ac3325d.tar.xz seaweedfs-c50ec1599c953068ff2e7f4835d30b044ac3325d.zip | |
auth for presigned put object part
| -rw-r--r-- | weed/s3api/s3api_object_multipart_handlers.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/weed/s3api/s3api_object_multipart_handlers.go b/weed/s3api/s3api_object_multipart_handlers.go index 3282e4176..438af4b60 100644 --- a/weed/s3api/s3api_object_multipart_handlers.go +++ b/weed/s3api/s3api_object_multipart_handlers.go @@ -173,8 +173,6 @@ func (s3a *S3ApiServer) PutObjectPartHandler(w http.ResponseWriter, r *http.Requ vars := mux.Vars(r) bucket := vars["bucket"] - rAuthType := getRequestAuthType(r) - uploadID := r.URL.Query().Get("uploadId") exists, err := s3a.exists(s3a.genUploadsFolder(bucket), uploadID, true) if !exists { @@ -193,10 +191,16 @@ func (s3a *S3ApiServer) PutObjectPartHandler(w http.ResponseWriter, r *http.Requ return } - var s3ErrCode ErrorCode + rAuthType := getRequestAuthType(r) dataReader := r.Body - if rAuthType == authTypeStreamingSigned { + var s3ErrCode ErrorCode + 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) |