From ffe5f19aa091f2a8ad8fdd20f43e93864dae86c6 Mon Sep 17 00:00:00 2001 From: sxlehua <40726210+sxlehua@users.noreply.github.com> Date: Mon, 5 Feb 2024 23:55:07 +0800 Subject: [PATCH] Add s3 postpolicy support header (#5280) * Add s3 postpolicy support header * optimized code --- weed/s3api/s3api_object_handlers_postpolicy.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/weed/s3api/s3api_object_handlers_postpolicy.go b/weed/s3api/s3api_object_handlers_postpolicy.go index 1e7861129..cd80e0ad3 100644 --- a/weed/s3api/s3api_object_handlers_postpolicy.go +++ b/weed/s3api/s3api_object_handlers_postpolicy.go @@ -15,6 +15,7 @@ import ( "github.com/gorilla/mux" "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/s3api/policy" + "github.com/seaweedfs/seaweedfs/weed/s3api/s3_constants" "github.com/seaweedfs/seaweedfs/weed/s3api/s3err" ) @@ -123,6 +124,18 @@ func (s3a *S3ApiServer) PostPolicyBucketHandler(w http.ResponseWriter, r *http.R } r.Header.Set("Content-Type", contentType) + // Add s3 postpolicy support header + for k, _ := range formValues { + if k == "Cache-Control" || k == "Expires" || k == "Content-Disposition" { + r.Header.Set(k, formValues.Get(k)) + continue + } + + if strings.HasPrefix(k, s3_constants.AmzUserMetaPrefix) { + r.Header.Set(k, formValues.Get(k)) + } + } + etag, errCode := s3a.putToFiler(r, uploadUrl, fileBody, "", bucket) if errCode != s3err.ErrNone {