(opendal) branch main updated: feat(services/koofr): Add operation http context (#6096)

[xuanwo]

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

xuanwo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/opendal.git


The following commit(s) were added to refs/heads/main by this push:
     new 93e4a873d feat(services/koofr): Add operation http context (#6096)
93e4a873d is described below

commit 93e4a873d5a23b1ca471db94105233c6325c6bb5
Author: Jorge Hermo <jorgehermogonza...@gmail.com>
AuthorDate: Sun Apr 27 18:12:09 2025 +0200

    feat(services/koofr): Add operation http context (#6096)
    
    * feat(services/koofr): Add operation http context
    
    * feat: remove Operation::Info
---
 core/src/services/koofr/core.rs | 25 +++++++++++++++++++++----
 1 file changed, 21 insertions(+), 4 deletions(-)

diff --git a/core/src/services/koofr/core.rs b/core/src/services/koofr/core.rs
index 4a891fcf8..20088ed2f 100644
--- a/core/src/services/koofr/core.rs
+++ b/core/src/services/koofr/core.rs
@@ -199,6 +199,7 @@ impl KoofrCore {
 
                 let req = req
                     .header(header::CONTENT_TYPE, "application/json")
+                    .extension(Operation::CreateDir)
                     .body(Buffer::from(Bytes::from(bs)))
                     .map_err(new_request_build_error)?;
 
@@ -232,7 +233,10 @@ impl KoofrCore {
 
         let req = self.sign(req).await?;
 
-        let req = req.body(Buffer::new()).map_err(new_request_build_error)?;
+        let req = req
+            .extension(Operation::Stat)
+            .body(Buffer::new())
+            .map_err(new_request_build_error)?;
 
         self.send(req).await
     }
@@ -253,7 +257,10 @@ impl KoofrCore {
 
         let req = self.sign(req).await?;
 
-        let req = req.body(Buffer::new()).map_err(new_request_build_error)?;
+        let req = req
+            .extension(Operation::Read)
+            .body(Buffer::new())
+            .map_err(new_request_build_error)?;
 
         self.info.http_client().fetch(req).await
     }
@@ -289,6 +296,8 @@ impl KoofrCore {
 
         let req = self.sign(req).await?;
 
+        let req = req.extension(Operation::Write);
+
         let req = multipart.apply(req)?;
 
         self.send(req).await
@@ -310,7 +319,10 @@ impl KoofrCore {
 
         let req = self.sign(req).await?;
 
-        let req = req.body(Buffer::new()).map_err(new_request_build_error)?;
+        let req = req
+            .extension(Operation::Delete)
+            .body(Buffer::new())
+            .map_err(new_request_build_error)?;
 
         self.send(req).await
     }
@@ -341,6 +353,7 @@ impl KoofrCore {
 
         let req = req
             .header(header::CONTENT_TYPE, "application/json")
+            .extension(Operation::Copy)
             .body(Buffer::from(Bytes::from(bs)))
             .map_err(new_request_build_error)?;
 
@@ -373,6 +386,7 @@ impl KoofrCore {
 
         let req = req
             .header(header::CONTENT_TYPE, "application/json")
+            .extension(Operation::Rename)
             .body(Buffer::from(Bytes::from(bs)))
             .map_err(new_request_build_error)?;
 
@@ -395,7 +409,10 @@ impl KoofrCore {
 
         let req = self.sign(req).await?;
 
-        let req = req.body(Buffer::new()).map_err(new_request_build_error)?;
+        let req = req
+            .extension(Operation::List)
+            .body(Buffer::new())
+            .map_err(new_request_build_error)?;
 
         self.send(req).await
     }