Function directUploadURL

server/s3/redirect.go:77–118

(r *http.Request, authPairs map[string]string)

}

func directUploadURL(r *http.Request, authPairs map[string]string) (string, bool) {
	if r.Method != http.MethodPut || r.ContentLength < 0 {
		return "", false
	}
	if hasNonObjectQuery(r) || !s3RequestAuthorized(r, authPairs) {
		return "", false
	}
	if r.Header.Get("X-Amz-Copy-Source") != "" ||
		r.Header.Get("X-Amz-Content-Sha256") == "STREAMING-AWS4-HMAC-SHA256-PAYLOAD" {
		return "", false
	}
	bucketName, objectName, ok := parseObjectPath(r.URL.Path)
	if !ok || strings.HasSuffix(objectName, "/") {
		return "", false
	}
	bucket, err := getBucketByName(bucketName)
	if err != nil {
		return "", false
	}
	reqPath := path.Join(bucket.Path, objectName)
	storage, dstDirActualPath, err := op.GetStorageAndActualPath(path.Dir(reqPath))
	if err != nil || storage.Config().NoUpload {
		return "", false
	}
	info, err := op.GetDirectUploadInfo(r.Context(), "HttpDirect", storage, dstDirActualPath, path.Base(reqPath), r.ContentLength, true)
	if err != nil {
		return "", false
	}
	httpInfo, ok := asHTTPDirectUploadInfo(info)
	if !ok {
		return "", false
	}
	method := httpInfo.Method
	if method == "" {
		method = http.MethodPut
	}
	if !strings.EqualFold(method, http.MethodPut) || httpInfo.UploadURL == "" ||
		httpInfo.ChunkSize > 0 || len(httpInfo.Headers) > 0 {
		return "", false
	}
	return httpInfo.UploadURL, true
}

func asHTTPDirectUploadInfo(info any) (*model.HttpDirectUploadInfo, bool) {
	switch v := info.(type) {