aboutsummaryrefslogtreecommitdiff
path: root/weed/s3api/s3api_object_handlers_postpolicy.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-06-10 16:54:36 -0700
committerChris Lu <chris.lu@gmail.com>2021-06-10 16:54:36 -0700
commit33b87244ef99a9651e6564b6cd517e824e35ed70 (patch)
treea79e8203164f5aec6407e85386c4eee285ccd8f0 /weed/s3api/s3api_object_handlers_postpolicy.go
parent40a8cb9b0a10c91fc69a35fac4c9154a4842aa4a (diff)
downloadseaweedfs-33b87244ef99a9651e6564b6cd517e824e35ed70.tar.xz
seaweedfs-33b87244ef99a9651e6564b6cd517e824e35ed70.zip
refactoring
Diffstat (limited to 'weed/s3api/s3api_object_handlers_postpolicy.go')
-rw-r--r--weed/s3api/s3api_object_handlers_postpolicy.go22
1 files changed, 11 insertions, 11 deletions
diff --git a/weed/s3api/s3api_object_handlers_postpolicy.go b/weed/s3api/s3api_object_handlers_postpolicy.go
index 035302ae6..3a979413a 100644
--- a/weed/s3api/s3api_object_handlers_postpolicy.go
+++ b/weed/s3api/s3api_object_handlers_postpolicy.go
@@ -26,23 +26,23 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
reader, err := r.MultipartReader()
if err != nil {
- writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r.URL)
+ writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r)
return
}
form, err := reader.ReadForm(int64(5 * humanize.MiByte))
if err != nil {
- writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r.URL)
+ writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r)
return
}
defer form.RemoveAll()
fileBody, fileName, fileSize, formValues, err := extractPostPolicyFormValues(form)
if err != nil {
- writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r.URL)
+ writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r)
return
}
if fileBody == nil {
- writeErrorResponse(w, s3err.ErrPOSTFileRequired, r.URL)
+ writeErrorResponse(w, s3err.ErrPOSTFileRequired, r)
return
}
defer fileBody.Close()
@@ -60,7 +60,7 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
if successRedirect != "" {
redirectURL, err = url.Parse(successRedirect)
if err != nil {
- writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r.URL)
+ writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r)
return
}
}
@@ -68,13 +68,13 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
// Verify policy signature.
errCode := s3a.iam.doesPolicySignatureMatch(formValues)
if errCode != s3err.ErrNone {
- writeErrorResponse(w, errCode, r.URL)
+ writeErrorResponse(w, errCode, r)
return
}
policyBytes, err := base64.StdEncoding.DecodeString(formValues.Get("Policy"))
if err != nil {
- writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r.URL)
+ writeErrorResponse(w, s3err.ErrMalformedPOSTRequest, r)
return
}
@@ -83,7 +83,7 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
postPolicyForm, err := policy.ParsePostPolicyForm(string(policyBytes))
if err != nil {
- writeErrorResponse(w, s3err.ErrPostPolicyConditionInvalidFormat, r.URL)
+ writeErrorResponse(w, s3err.ErrPostPolicyConditionInvalidFormat, r)
return
}
@@ -99,12 +99,12 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
lengthRange := postPolicyForm.Conditions.ContentLengthRange
if lengthRange.Valid {
if fileSize < lengthRange.Min {
- writeErrorResponse(w, s3err.ErrEntityTooSmall, r.URL)
+ writeErrorResponse(w, s3err.ErrEntityTooSmall, r)
return
}
if fileSize > lengthRange.Max {
- writeErrorResponse(w, s3err.ErrEntityTooLarge, r.URL)
+ writeErrorResponse(w, s3err.ErrEntityTooLarge, r)
return
}
}
@@ -115,7 +115,7 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R
etag, errCode := s3a.putToFiler(r, uploadUrl, fileBody)
if errCode != s3err.ErrNone {
- writeErrorResponse(w, errCode, r.URL)
+ writeErrorResponse(w, errCode, r)
return
}