add copy to adapter

block/adapter.go

@@ -56,6 +56,7 @@ type Adapter interface {
 	GetRange(obj ObjectPointer, startPosition int64, endPosition int64) (io.ReadCloser, error)
 	GetProperties(obj ObjectPointer) (Properties, error)
 	Remove(obj ObjectPointer) error
+	Copy(sourceObj, destinationObj ObjectPointer) error
 	CreateMultiPartUpload(obj ObjectPointer, r *http.Request, opts CreateMultiPartUploadOpts) (string, error)
 	UploadPart(obj ObjectPointer, sizeBytes int64, reader io.Reader, uploadID string, partNumber int64) (string, error)
 	AbortMultiPartUpload(obj ObjectPointer, uploadID string) error

block/gs/adapter.go

@@ -173,6 +173,25 @@ func (a *Adapter) Remove(obj block.ObjectPointer) error {
 	return nil
 }
 
+func (a *Adapter) Copy(sourceObj, destinationObj block.ObjectPointer) error {
+	var err error
+	defer reportMetrics("Copy", time.Now(), nil, &err)
+	qualifiedDestinationKey, err := resolveNamespace(destinationObj)
+	if err != nil {
+		return err
+	}
+	qualifiedSourceKey, err := resolveNamespace(sourceObj)
+	if err != nil {
+		return err
+	}
+	destinationObjectHandle := a.client.Bucket(qualifiedDestinationKey.StorageNamespace).Object(qualifiedDestinationKey.Key)
+	sourceObjectHandle := a.client.Bucket(qualifiedSourceKey.StorageNamespace).Object(qualifiedSourceKey.Key)
+	_, err = destinationObjectHandle.CopierFrom(sourceObjectHandle).Run(a.ctx)
+	if err != nil {
+		return fmt.Errorf("Copy: %w", err)
+	}
+	return nil
+}
 func (a *Adapter) CreateMultiPartUpload(obj block.ObjectPointer, r *http.Request, opts block.CreateMultiPartUploadOpts) (string, error) {
 	var err error
 	defer reportMetrics("CreateMultiPartUpload", time.Now(), nil, &err)

block/local/adapter.go

@@ -93,6 +93,27 @@ func (l *Adapter) Remove(obj block.ObjectPointer) error {
 	return os.Remove(p)
 }
 
+func (l *Adapter) Copy(sourceObj, destinationObj block.ObjectPointer) error {
+	dest := l.getPath(destinationObj.Identifier)
+	destinationFile, err := os.Create(dest)
+	if err != nil {
+		return err
+	}
+	defer func() {
+		_ = destinationFile.Close()
+	}()
+	source := l.getPath(sourceObj.Identifier)
+	sourceFile, err := os.OpenFile(source, os.O_RDONLY, 0755)
+	defer func() {
+		_ = sourceFile.Close()
+	}()
+	if err != nil {
+		return err
+	}
+	_, err = io.Copy(destinationFile, sourceFile)
+	return err
+}
+
 func (l *Adapter) Get(obj block.ObjectPointer, _ int64) (reader io.ReadCloser, err error) {
 	p := l.getPath(obj.Identifier)
 	f, err := os.OpenFile(p, os.O_RDONLY, 0755)

block/mem/adapter.go

@@ -148,6 +148,16 @@ func (a *Adapter) Remove(obj block.ObjectPointer) error {
 	return nil
 }
 
+func (a *Adapter) Copy(sourceObj, destinationObj block.ObjectPointer) error {
+	a.mutex.Lock()
+	defer a.mutex.Unlock()
+	destinationKey := getKey(destinationObj)
+	sourceKey := getKey(sourceObj)
+	a.data[destinationKey] = a.data[sourceKey]
+	a.properties[destinationKey] = a.properties[sourceKey]
+	return nil
+}
+
 func (a *Adapter) CreateMultiPartUpload(obj block.ObjectPointer, r *http.Request, opts block.CreateMultiPartUploadOpts) (string, error) {
 	a.mutex.Lock()
 	defer a.mutex.Unlock()

block/s3/adapter.go

@@ -323,6 +323,30 @@ func (a *Adapter) Remove(obj block.ObjectPointer) error {
 	return err
 }
 
+func (a *Adapter) Copy(sourceObj, destinationObj block.ObjectPointer) error {
+	var err error
+	defer reportMetrics("Copy", time.Now(), nil, &err)
+
+	qualifiedDestinationKey, err := resolveNamespace(destinationObj)
+	if err != nil {
+		return err
+	}
+	qualifiedSourceKey, err := resolveNamespace(sourceObj)
+	if err != nil {
+		return err
+	}
+	copyObjectParams := &s3.CopyObjectInput{
+		Bucket:     aws.String(qualifiedDestinationKey.StorageNamespace),
+		Key:        aws.String(qualifiedDestinationKey.Key),
+		CopySource: aws.String(qualifiedSourceKey.StorageNamespace + "/" + qualifiedSourceKey.Key),
+	}
+	_, err = a.s3.CopyObject(copyObjectParams)
+	if err != nil {
+		a.log().WithError(err).Error("failed to copy S3 object")
+	}
+	return err
+}
+
 func (a *Adapter) CreateMultiPartUpload(obj block.ObjectPointer, r *http.Request, opts block.CreateMultiPartUploadOpts) (string, error) {
 	var err error
 	defer reportMetrics("CreateMultiPartUpload", time.Now(), nil, &err)

block/transient/adapter.go

@@ -61,6 +61,10 @@ func (a *Adapter) Remove(_ block.ObjectPointer) error {
 	return nil
 }
 
+func (a *Adapter) Copy(_, _ block.ObjectPointer) error {
+	return nil
+}
+
 func (a *Adapter) CreateMultiPartUpload(obj block.ObjectPointer, r *http.Request, opts block.CreateMultiPartUploadOpts) (string, error) {
 	uid := uuid.New()
 	uploadID := hex.EncodeToString(uid[:])

gateway/operations/mock_adapter_test.go

@@ -58,7 +58,9 @@ func (a *mockAdapter) GetProperties(_ block.ObjectPointer) (block.Properties, er
 func (a *mockAdapter) Remove(_ block.ObjectPointer) error {
 	return errors.New(" remove method not implemented in mock adapter")
 }
-
+func (a *mockAdapter) Copy(_, _ block.ObjectPointer) error {
+	return errors.New(" copy method not implemented in mock adapter")
+}
 func (a *mockAdapter) CreateMultiPartUpload(_ block.ObjectPointer, r *http.Request, _ block.CreateMultiPartUploadOpts) (string, error) {
 	panic("try to create multipart in mock adaptor")
 }