[incubator-opendal] branch obs-cp created (now e27e7b59)

[su...@apache.org]

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

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


      at e27e7b59 feat(services/obs): add support copy

This branch includes the following new commits:

     new e27e7b59 feat(services/obs): add support copy

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[incubator-opendal] 01/01: feat(services/obs): add support copy

[su...@apache.org]

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

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

commit e27e7b5993b4738d892890c997f150c02be6ca48
Author: suyanhanx <su...@gmail.com>
AuthorDate: Sat Apr 8 12:03:53 2023 +0800

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

diff --git a/core/src/services/obs/backend.rs b/core/src/services/obs/backend.rs
index 3183f02d..93ee55ff 100644
--- a/core/src/services/obs/backend.rs
+++ b/core/src/services/obs/backend.rs
@@ -44,6 +44,7 @@ use crate::*;
 ///
 /// - [x] read
 /// - [x] write
+/// - [x] copy
 /// - [x] list
 /// - [x] scan
 /// - [ ] presign
@@ -314,7 +315,7 @@ impl Accessor for ObsBackend {
         am.set_scheme(Scheme::Obs)
             .set_root(&self.root)
             .set_name(&self.bucket)
-            .set_capabilities(Read | Write | List | Scan)
+            .set_capabilities(Read | Write | Copy | List | Scan)
             .set_hints(ReadStreamable);
 
         am
@@ -366,6 +367,20 @@ impl Accessor for ObsBackend {
         ))
     }
 
+    async fn copy(&self, from: &str, to: &str, _args: OpCopy) -> Result<RpCopy> {
+        let resp = self.obs_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> {
         // Stat root always returns a DIR.
         if path == "/" {
@@ -500,6 +515,23 @@ impl ObsBackend {
         self.client.send_async(req).await
     }
 
+    async fn obs_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 source = format!("/{}/{}", self.bucket, percent_encode_path(&source));
+        let url = format!("{}/{}", self.endpoint, percent_encode_path(&target));
+
+        let mut req = Request::put(&url)
+            .header("x-obs-copy-source", percent_encode_path(&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(crate) async fn obs_list_objects(
         &self,
         path: &str,