s3manager-web/copy_object.go

53 lines
1.4 KiB
Go
Raw Normal View History

2017-05-08 23:07:07 +02:00
package s3manager
2017-04-21 10:36:22 +02:00
import (
"encoding/json"
"net/http"
2017-05-25 18:33:44 +02:00
"github.com/pkg/errors"
2017-04-21 10:36:22 +02:00
minio "github.com/minio/minio-go"
)
2017-05-08 23:07:07 +02:00
// copyObjectInfo is the information about an object to copy.
type copyObjectInfo struct {
2017-04-21 10:36:22 +02:00
BucketName string `json:"bucketName"`
ObjectName string `json:"objectName"`
SourceBucketName string `json:"sourceBucketName"`
SourceObjectName string `json:"sourceObjectName"`
}
2017-05-08 23:07:07 +02:00
// CopyObjectHandler copies an existing object under a new name.
func CopyObjectHandler(s3 S3) http.Handler {
2017-04-21 10:36:22 +02:00
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
2017-05-08 23:07:07 +02:00
var copy copyObjectInfo
2017-04-21 10:36:22 +02:00
err := json.NewDecoder(r.Body).Decode(&copy)
if err != nil {
2017-05-25 18:33:44 +02:00
handleHTTPError(w, errors.Wrap(err, errDecodingBody))
2017-04-21 10:36:22 +02:00
return
}
2017-07-31 10:57:22 +02:00
src := minio.NewSourceInfo(copy.SourceBucketName, copy.SourceObjectName, nil)
dst, err := minio.NewDestinationInfo(copy.BucketName, copy.ObjectName, nil, nil)
if err != nil {
handleHTTPError(w, errors.Wrap(err, "error creating destination for copying"))
return
}
err = s3.CopyObject(dst, src)
2017-04-21 10:36:22 +02:00
if err != nil {
2017-05-25 18:33:44 +02:00
handleHTTPError(w, errors.Wrap(err, "error copying object"))
2017-04-21 10:36:22 +02:00
return
}
2017-05-08 23:07:07 +02:00
w.Header().Set(HeaderContentType, ContentTypeJSON)
2017-04-21 10:36:22 +02:00
w.WriteHeader(http.StatusCreated)
err = json.NewEncoder(w).Encode(copy)
if err != nil {
2017-05-25 18:33:44 +02:00
handleHTTPError(w, errors.Wrap(err, errEncodingJSON))
2017-04-21 10:36:22 +02:00
return
}
})
}