[incubator-opendal] 01/01: feat(oss): support copy

[su...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

suyanhanx pushed a commit to branch cp-oss
in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git

commit b88e302304c29697d010484493713a38a5fb943d
Author: suyanhanx <su...@gmail.com>
AuthorDate: Sat Apr 8 10:07:47 2023 +0800

    feat(oss): support copy
    
    Signed-off-by: suyanhanx <su...@gmail.com>
---
 core/src/services/oss/backend.rs | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/core/src/services/oss/backend.rs b/core/src/services/oss/backend.rs
index a1bfeacf..299b618a 100644
--- a/core/src/services/oss/backend.rs
+++ b/core/src/services/oss/backend.rs
@@ -53,6 +53,7 @@ use crate::*;
 ///
 /// - [x] read
 /// - [x] write
+/// - [x] copy
 /// - [x] list
 /// - [x] scan
 /// - [ ] presign
@@ -475,6 +476,19 @@ impl Accessor for OssBackend {
         ))
     }
 
+    async fn copy(&self, from: &str, to: &str, _args: OpCopy) -> Result<RpCopy> {
+        let resp = self.oss_copy_object(from, to).await?;
+        let status = resp.status();
+
+        match status {
+            StatusCode::OK => {
+                resp.into_body().consume().await?;
+                Ok(RpCopy::default())
+            }
+            _ => Err(parse_error(resp).await?),
+        }
+    }
+
     async fn stat(&self, path: &str, _: OpStat) -> Result<RpStat> {
         if path == "/" {
             let m = Metadata::new(EntryMode::DIR);
@@ -756,6 +770,26 @@ impl OssBackend {
         self.client.send_async(req).await
     }
 
+    async fn oss_copy_object(&self, from: &str, to: &str) -> Result<Response<IncomingAsyncBody>> {
+        let source = build_abs_path(&self.root, from);
+        let target = build_abs_path(&self.root, to);
+
+        let url = format!(
+            "{}/{}",
+            self.get_endpoint(false),
+            percent_encode_path(&target)
+        );
+        let source = format!("{}/{}", self.bucket, percent_encode_path(&source));
+
+        let mut req = Request::put(&url)
+            .header("x-oss-copy-source", source)
+            .body(AsyncBody::Empty)
+            .map_err(new_request_build_error)?;
+
+        self.signer.sign(&mut req).map_err(new_request_sign_error)?;
+        self.client.send_async(req).await
+    }
+
     pub(super) async fn oss_list_object(
         &self,
         path: &str,