Function directObjectURL

server/s3/redirect.go:40–75

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

}

func directObjectURL(r *http.Request, authPairs map[string]string) (string, bool) {
	if r.Method != http.MethodGet {
		return "", false
	}
	if hasNonObjectQuery(r) || !s3RequestAuthorized(r, authPairs) {
		return "", false
	}
	bucketName, objectName, ok := parseObjectPath(r.URL.Path)
	if !ok {
		return "", false
	}
	bucket, err := getBucketByName(bucketName)
	if err != nil {
		return "", false
	}
	reqPath := path.Join(bucket.Path, objectName)
	meta, _ := op.GetNearestMeta(reqPath)
	ctx := context.WithValue(r.Context(), conf.MetaKey, meta)
	storage, err := fs.GetStorage(reqPath, &fs.GetStoragesArgs{})
	if err != nil || common.ShouldProxy(storage, path.Base(reqPath)) {
		return "", false
	}
	link, file, err := fs.Link(ctx, reqPath, model.LinkArgs{
		IP:       utils.ClientIP(r),
		Header:   r.Header,
		Redirect: true,
	})
	if err != nil {
		return "", false
	}
	defer link.Close()
	if file == nil || file.IsDir() || link.URL == "" || link.RangeReader != nil {
		return "", false
	}
	return link.URL, true
}

func directUploadURL(r *http.Request, authPairs map[string]string) (string, bool) {
	if r.Method != http.MethodPut || r.ContentLength < 0 {