From 8cd2ac67d37a5b6e9a1fbd10b70c8c524efed859 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Tue, 2 May 2023 14:15:20 +0800
Subject: [PATCH 1/8] fix create_dir

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/backend.rs | 36 +++++++++++++++++++++++++++
 core/src/services/supabase/core.rs    | 20 +++++++++++++++
 core/src/services/supabase/error.rs   | 13 +++++++---
 core/tests/behavior/main.rs           |  2 ++
 4 files changed, 68 insertions(+), 3 deletions(-)

diff --git a/core/src/services/supabase/backend.rs b/core/src/services/supabase/backend.rs
index 2b92d2cf40e2..817d2c9310ea 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -225,6 +225,31 @@ impl Accessor for SupabaseBackend {
         am
     }
 
+    async fn create_dir(&self, path: &str, _: OpCreate) -> Result<RpCreate> {
+        let mut req =
+            self.core
+                .supabase_upload_object_request(path, Some(0), None, AsyncBody::Empty)?;
+
+        self.core.sign(&mut req)?;
+
+        let resp = self.core.send(req).await?;
+
+        let status = resp.status();
+
+        if status.is_success() {
+            resp.into_body().consume().await?;
+            Ok(RpCreate::default())
+        } else {
+            // create duplicate dir is ok
+            let e = parse_error(resp).await?;
+            if e.kind() == ErrorKind::AlreadyExists {
+                Ok(RpCreate::default())
+            } else {
+                Err(e)
+            }
+        }
+    }
+
     async fn read(&self, path: &str, _args: OpRead) -> Result<(RpRead, Self::Reader)> {
         let resp = self.core.supabase_get_object(path).await?;
 
@@ -271,4 +296,15 @@ impl Accessor for SupabaseBackend {
             _ => Err(parse_error(resp).await?),
         }
     }
+
+    async fn delete(&self, path: &str, _: OpDelete) -> Result<RpDelete> {
+        let resp = self.core.supabase_delete_object(path).await?;
+
+        // deleting not existing objects is ok
+        if resp.status().is_success() || resp.status() == StatusCode::NOT_FOUND {
+            Ok(RpDelete::default())
+        } else {
+            Err(parse_error(resp).await?)
+        }
+    }
 }
diff --git a/core/src/services/supabase/core.rs b/core/src/services/supabase/core.rs
index 38391427b0d6..639da9bf6588 100644
--- a/core/src/services/supabase/core.rs
+++ b/core/src/services/supabase/core.rs
@@ -109,6 +109,20 @@ impl SupabaseCore {
         Ok(req)
     }
 
+    pub fn supabase_delete_object_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+        let p = build_abs_path(&self.root, path);
+        let url = format!(
+            "{}/storage/v1/object/{}/{}",
+            self.endpoint,
+            self.bucket,
+            percent_encode_path(&p)
+        );
+
+        Request::delete(&url)
+            .body(AsyncBody::Empty)
+            .map_err(new_request_build_error)
+    }
+
     pub fn supabase_get_object_public_request(&self, path: &str) -> Result<Request<AsyncBody>> {
         let p = build_abs_path(&self.root, path);
         let url = format!(
@@ -197,4 +211,10 @@ impl SupabaseCore {
         self.sign(&mut req)?;
         self.send(req).await
     }
+
+    pub async fn supabase_delete_object(&self, path: &str) -> Result<Response<IncomingAsyncBody>> {
+        let mut req = self.supabase_delete_object_request(path)?;
+        self.sign(&mut req)?;
+        self.send(req).await
+    }
 }
diff --git a/core/src/services/supabase/error.rs b/core/src/services/supabase/error.rs
index 54f6c61d119f..c4c0a11e5d46 100644
--- a/core/src/services/supabase/error.rs
+++ b/core/src/services/supabase/error.rs
@@ -28,7 +28,7 @@ use crate::Result;
 #[derive(Default, Debug, Deserialize)]
 #[serde(default, rename_all = "camelCase")]
 /// The error returned by Supabase
-struct SupabaseError {
+pub struct SupabaseError {
     status_code: String,
     error: String,
     message: String,
@@ -40,7 +40,7 @@ pub async fn parse_error(resp: Response<IncomingAsyncBody>) -> Result<Error> {
     let bs = body.bytes().await?;
 
     // todo: the supabase error has status code 4XX, handle all that
-    let (kind, retryable) = match parts.status {
+    let (mut kind, retryable) = match parts.status {
         StatusCode::NOT_FOUND => (ErrorKind::NotFound, false),
         StatusCode::FORBIDDEN => (ErrorKind::PermissionDenied, false),
         StatusCode::PRECONDITION_FAILED | StatusCode::NOT_MODIFIED => {
@@ -54,7 +54,14 @@ pub async fn parse_error(resp: Response<IncomingAsyncBody>) -> Result<Error> {
     };
 
     let (message, _) = from_slice::<SupabaseError>(&bs)
-        .map(|sb_err| (format!("{sb_err:?}"), Some(sb_err)))
+        .map(|sb_err| {
+            // http: CONFLICT, this means that the resource already exists
+            if sb_err.status_code == "409" && sb_err.error == "Duplicate" {
+                kind = ErrorKind::AlreadyExists;
+            }
+
+            (format!("{sb_err:?}"), Some(sb_err))
+        })
         .unwrap_or_else(|_| (String::from_utf8_lossy(&bs).into_owned(), None));
 
     let mut err = Error::new(kind, &message).with_context("response", format!("{parts:?}"));
diff --git a/core/tests/behavior/main.rs b/core/tests/behavior/main.rs
index 692ad5c7484b..3e5050861219 100644
--- a/core/tests/behavior/main.rs
+++ b/core/tests/behavior/main.rs
@@ -141,3 +141,5 @@ behavior_tests!(VercelArtifacts);
 behavior_tests!(Webdav);
 #[cfg(feature = "services-webhdfs")]
 behavior_tests!(Webhdfs);
+#[cfg(feature = "services-supabase")]
+behavior_tests!(Supabase);

From 4031e68b2c8bce76e9d7875ad5bb95a8d5610553 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Tue, 2 May 2023 14:32:28 +0800
Subject: [PATCH 2/8] fix delete tests

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/error.rs | 35 +++++++++++++++--------------
 1 file changed, 18 insertions(+), 17 deletions(-)

diff --git a/core/src/services/supabase/error.rs b/core/src/services/supabase/error.rs
index c4c0a11e5d46..aa2a76bcbcc7 100644
--- a/core/src/services/supabase/error.rs
+++ b/core/src/services/supabase/error.rs
@@ -40,26 +40,11 @@ pub async fn parse_error(resp: Response<IncomingAsyncBody>) -> Result<Error> {
     let bs = body.bytes().await?;
 
     // todo: the supabase error has status code 4XX, handle all that
-    let (mut kind, retryable) = match parts.status {
-        StatusCode::NOT_FOUND => (ErrorKind::NotFound, false),
-        StatusCode::FORBIDDEN => (ErrorKind::PermissionDenied, false),
-        StatusCode::PRECONDITION_FAILED | StatusCode::NOT_MODIFIED => {
-            (ErrorKind::ConditionNotMatch, false)
-        }
-        StatusCode::INTERNAL_SERVER_ERROR
-        | StatusCode::BAD_GATEWAY
-        | StatusCode::SERVICE_UNAVAILABLE
-        | StatusCode::GATEWAY_TIMEOUT => (ErrorKind::Unexpected, true),
-        _ => (ErrorKind::Unexpected, false),
-    };
 
+    let (mut kind, mut retryable) = (ErrorKind::Unexpected, false);
     let (message, _) = from_slice::<SupabaseError>(&bs)
         .map(|sb_err| {
-            // http: CONFLICT, this means that the resource already exists
-            if sb_err.status_code == "409" && sb_err.error == "Duplicate" {
-                kind = ErrorKind::AlreadyExists;
-            }
-
+            (kind, retryable) = parse_supabase_error(&sb_err);
             (format!("{sb_err:?}"), Some(sb_err))
         })
         .unwrap_or_else(|_| (String::from_utf8_lossy(&bs).into_owned(), None));
@@ -72,3 +57,19 @@ pub async fn parse_error(resp: Response<IncomingAsyncBody>) -> Result<Error> {
 
     Ok(err)
 }
+
+// Return the error kind and whether it is retryable
+fn parse_supabase_error(err: &SupabaseError) -> (ErrorKind, bool) {
+    let code = err.status_code.parse::<u16>().unwrap();
+    if code == StatusCode::CONFLICT.as_u16() && err.error == "Duplicate" {
+        (ErrorKind::AlreadyExists, false)
+    } else if code == StatusCode::NOT_FOUND.as_u16() {
+        (ErrorKind::NotFound, false)
+    } else if code == StatusCode::FORBIDDEN.as_u16() {
+        (ErrorKind::PermissionDenied, false)
+    } else if code == StatusCode::PRECONDITION_FAILED.as_u16() {
+        (ErrorKind::ConditionNotMatch, false)
+    } else {
+        (ErrorKind::Unexpected, false)
+    }
+}

From 51ebaccc510e9d8d2d66a53c3c917e5f45a0da61 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 00:23:54 +0800
Subject: [PATCH 3/8] fix delete and skip special chars for supabase

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/backend.rs | 11 ++++++++---
 core/tests/behavior/write.rs          | 24 ++++++++++++++++++++++++
 2 files changed, 32 insertions(+), 3 deletions(-)

diff --git a/core/src/services/supabase/backend.rs b/core/src/services/supabase/backend.rs
index 817d2c9310ea..cbe7bb2e7545 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -300,11 +300,16 @@ impl Accessor for SupabaseBackend {
     async fn delete(&self, path: &str, _: OpDelete) -> Result<RpDelete> {
         let resp = self.core.supabase_delete_object(path).await?;
 
-        // deleting not existing objects is ok
-        if resp.status().is_success() || resp.status() == StatusCode::NOT_FOUND {
+        if resp.status().is_success() {
             Ok(RpDelete::default())
         } else {
-            Err(parse_error(resp).await?)
+            // deleting not existing objects is ok
+            let e = parse_error(resp).await?;
+            if e.kind() == ErrorKind::NotFound {
+                Ok(RpDelete::default())
+            } else {
+                Err(e)
+            }
         }
     }
 }
diff --git a/core/tests/behavior/write.rs b/core/tests/behavior/write.rs
index 9b7b4b042830..0376425153e0 100644
--- a/core/tests/behavior/write.rs
+++ b/core/tests/behavior/write.rs
@@ -174,6 +174,12 @@ pub async fn test_write_with_dir_path(op: Operator) -> Result<()> {
 
 /// Write a single file with special chars should succeed.
 pub async fn test_write_with_special_chars(op: Operator) -> Result<()> {
+    // Ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 addressed.
+    if op.info().scheme() == opendal::Scheme::Supabase {
+        warn!("ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 is resolved");
+        return Ok(());
+    }
+
     let path = format!("{} !@#$%^&()_+-=;',.txt", uuid::Uuid::new_v4());
     let (content, size) = gen_bytes();
 
@@ -273,6 +279,12 @@ pub async fn test_stat_dir(op: Operator) -> Result<()> {
 
 /// Stat existing file with special chars should return metadata
 pub async fn test_stat_with_special_chars(op: Operator) -> Result<()> {
+    // Ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 addressed.
+    if op.info().scheme() == opendal::Scheme::Supabase {
+        warn!("ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 is resolved");
+        return Ok(());
+    }
+
     let path = format!("{} !@#$%^&()_+-=;',.txt", uuid::Uuid::new_v4());
     let (content, size) = gen_bytes();
 
@@ -773,6 +785,12 @@ pub async fn test_read_with_dir_path(op: Operator) -> Result<()> {
 
 /// Read file with special chars should succeed.
 pub async fn test_read_with_special_chars(op: Operator) -> Result<()> {
+    // Ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 addressed.
+    if op.info().scheme() == opendal::Scheme::Supabase {
+        warn!("ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 is resolved");
+        return Ok(());
+    }
+
     let path = format!("{} !@#$%^&()_+-=;',.txt", uuid::Uuid::new_v4());
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -952,6 +970,12 @@ pub async fn test_delete_empty_dir(op: Operator) -> Result<()> {
 
 /// Delete file with special chars should succeed.
 pub async fn test_delete_with_special_chars(op: Operator) -> Result<()> {
+    // Ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 addressed.
+    if op.info().scheme() == opendal::Scheme::Supabase {
+        warn!("ignore test for supabase until https://github.com/apache/incubator-opendal/issues/2194 is resolved");
+        return Ok(());
+    }
+
     let path = format!("{} !@#$%^&()_+-=;',.txt", uuid::Uuid::new_v4());
     debug!("Generate a random file: {}", &path);
     let (content, _) = gen_bytes();

From f3cddbe0df1d33a5483ef0ea1978ee20444cbda4 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 01:18:26 +0800
Subject: [PATCH 4/8] fix stat error

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/backend.rs | 20 +++++++++-----
 core/src/services/supabase/core.rs    | 38 +++++++++++++++++++++++++++
 core/src/services/supabase/error.rs   |  2 --
 3 files changed, 51 insertions(+), 9 deletions(-)

diff --git a/core/src/services/supabase/backend.rs b/core/src/services/supabase/backend.rs
index cbe7bb2e7545..346dd4e4108a 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -284,16 +284,22 @@ impl Accessor for SupabaseBackend {
             return Ok(RpStat::new(Metadata::new(EntryMode::DIR)));
         }
 
-        let resp = self.core.supabase_get_object_info(path).await?;
+        // The get_object_info does not contain the file size. Therefore
+        // we first try the get the metadata through head, if we fail,
+        // we then use get_object_info to get the actual error info
+        let mut resp = self.core.supabase_head_object(path).await?;
 
-        let status = resp.status();
-
-        match status {
+        match resp.status() {
             StatusCode::OK => parse_into_metadata(path, resp.headers()).map(RpStat::new),
-            StatusCode::NOT_FOUND if path.ends_with('/') => {
-                Ok(RpStat::new(Metadata::new(EntryMode::DIR)))
+            _ => {
+                resp = self.core.supabase_get_object_info(path).await?;
+                match resp.status() {
+                    StatusCode::NOT_FOUND if path.ends_with('/') => {
+                        Ok(RpStat::new(Metadata::new(EntryMode::DIR)))
+                    }
+                    _ => Err(parse_error(resp).await?),
+                }
             }
-            _ => Err(parse_error(resp).await?),
         }
     }
 
diff --git a/core/src/services/supabase/core.rs b/core/src/services/supabase/core.rs
index 639da9bf6588..e8d0eb05cff3 100644
--- a/core/src/services/supabase/core.rs
+++ b/core/src/services/supabase/core.rs
@@ -137,6 +137,20 @@ impl SupabaseCore {
             .map_err(new_request_build_error)
     }
 
+    pub fn supabase_head_object_public_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+        let p = build_abs_path(&self.root, path);
+        let url = format!(
+            "{}/storage/v1/object/public/{}/{}",
+            self.endpoint,
+            self.bucket,
+            percent_encode_path(&p)
+        );
+
+        Request::head(&url)
+            .body(AsyncBody::Empty)
+            .map_err(new_request_build_error)
+    }
+
     pub fn supabase_get_object_auth_request(&self, path: &str) -> Result<Request<AsyncBody>> {
         let p = build_abs_path(&self.root, path);
         let url = format!(
@@ -151,6 +165,20 @@ impl SupabaseCore {
             .map_err(new_request_build_error)
     }
 
+    pub fn supabase_head_object_auth_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+        let p = build_abs_path(&self.root, path);
+        let url = format!(
+            "{}/storage/v1/object/authenticated/{}/{}",
+            self.endpoint,
+            self.bucket,
+            percent_encode_path(&p)
+        );
+
+        Request::head(&url)
+            .body(AsyncBody::Empty)
+            .map_err(new_request_build_error)
+    }
+
     pub fn supabase_get_object_info_public_request(
         &self,
         path: &str,
@@ -199,6 +227,16 @@ impl SupabaseCore {
         self.send(req).await
     }
 
+    pub async fn supabase_head_object(&self, path: &str) -> Result<Response<IncomingAsyncBody>> {
+        let mut req = if self.key.is_some() {
+            self.supabase_head_object_auth_request(path)?
+        } else {
+            self.supabase_head_object_public_request(path)?
+        };
+        self.sign(&mut req)?;
+        self.send(req).await
+    }
+
     pub async fn supabase_get_object_info(
         &self,
         path: &str,
diff --git a/core/src/services/supabase/error.rs b/core/src/services/supabase/error.rs
index aa2a76bcbcc7..0d641c65de5d 100644
--- a/core/src/services/supabase/error.rs
+++ b/core/src/services/supabase/error.rs
@@ -39,8 +39,6 @@ pub async fn parse_error(resp: Response<IncomingAsyncBody>) -> Result<Error> {
     let (parts, body) = resp.into_parts();
     let bs = body.bytes().await?;
 
-    // todo: the supabase error has status code 4XX, handle all that
-
     let (mut kind, mut retryable) = (ErrorKind::Unexpected, false);
     let (message, _) = from_slice::<SupabaseError>(&bs)
         .map(|sb_err| {

From 46d28160409318282b3b2572d17bd0bea9da2269 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 15:05:59 +0800
Subject: [PATCH 5/8] all ci passes, skip range tests if not supported

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/backend.rs | 10 +++++--
 core/src/services/supabase/core.rs    | 42 +++++++++++++++++----------
 core/tests/behavior/write.rs          | 32 ++++++++++++++++++++
 3 files changed, 67 insertions(+), 17 deletions(-)

diff --git a/core/src/services/supabase/backend.rs b/core/src/services/supabase/backend.rs
index 346dd4e4108a..92bbf08228d7 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -216,9 +216,15 @@ impl Accessor for SupabaseBackend {
             .set_name(&self.core.bucket)
             .set_capability(Capability {
                 stat: true,
+
                 read: true,
+
                 write: true,
 
+                create_dir: true,
+
+                delete: true,
+
                 ..Default::default()
             });
 
@@ -250,8 +256,8 @@ impl Accessor for SupabaseBackend {
         }
     }
 
-    async fn read(&self, path: &str, _args: OpRead) -> Result<(RpRead, Self::Reader)> {
-        let resp = self.core.supabase_get_object(path).await?;
+    async fn read(&self, path: &str, args: OpRead) -> Result<(RpRead, Self::Reader)> {
+        let resp = self.core.supabase_get_object(path, args.range()).await?;
 
         let status = resp.status();
 
diff --git a/core/src/services/supabase/core.rs b/core/src/services/supabase/core.rs
index e8d0eb05cff3..ccdb2e1abad0 100644
--- a/core/src/services/supabase/core.rs
+++ b/core/src/services/supabase/core.rs
@@ -123,7 +123,11 @@ impl SupabaseCore {
             .map_err(new_request_build_error)
     }
 
-    pub fn supabase_get_object_public_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+    pub fn supabase_get_object_public_request(
+        &self,
+        path: &str,
+        _: BytesRange,
+    ) -> Result<Request<AsyncBody>> {
         let p = build_abs_path(&self.root, path);
         let url = format!(
             "{}/storage/v1/object/public/{}/{}",
@@ -132,35 +136,39 @@ impl SupabaseCore {
             percent_encode_path(&p)
         );
 
-        Request::get(&url)
-            .body(AsyncBody::Empty)
-            .map_err(new_request_build_error)
+        let req = Request::get(&url);
+
+        req.body(AsyncBody::Empty).map_err(new_request_build_error)
     }
 
-    pub fn supabase_head_object_public_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+    pub fn supabase_get_object_auth_request(
+        &self,
+        path: &str,
+        _: BytesRange,
+    ) -> Result<Request<AsyncBody>> {
         let p = build_abs_path(&self.root, path);
         let url = format!(
-            "{}/storage/v1/object/public/{}/{}",
+            "{}/storage/v1/object/authenticated/{}/{}",
             self.endpoint,
             self.bucket,
             percent_encode_path(&p)
         );
 
-        Request::head(&url)
-            .body(AsyncBody::Empty)
-            .map_err(new_request_build_error)
+        let req = Request::get(&url);
+
+        req.body(AsyncBody::Empty).map_err(new_request_build_error)
     }
 
-    pub fn supabase_get_object_auth_request(&self, path: &str) -> Result<Request<AsyncBody>> {
+    pub fn supabase_head_object_public_request(&self, path: &str) -> Result<Request<AsyncBody>> {
         let p = build_abs_path(&self.root, path);
         let url = format!(
-            "{}/storage/v1/object/authenticated/{}/{}",
+            "{}/storage/v1/object/public/{}/{}",
             self.endpoint,
             self.bucket,
             percent_encode_path(&p)
         );
 
-        Request::get(&url)
+        Request::head(&url)
             .body(AsyncBody::Empty)
             .map_err(new_request_build_error)
     }
@@ -217,11 +225,15 @@ impl SupabaseCore {
         self.http_client.send(req).await
     }
 
-    pub async fn supabase_get_object(&self, path: &str) -> Result<Response<IncomingAsyncBody>> {
+    pub async fn supabase_get_object(
+        &self,
+        path: &str,
+        range: BytesRange,
+    ) -> Result<Response<IncomingAsyncBody>> {
         let mut req = if self.key.is_some() {
-            self.supabase_get_object_auth_request(path)?
+            self.supabase_get_object_auth_request(path, range)?
         } else {
-            self.supabase_get_object_public_request(path)?
+            self.supabase_get_object_public_request(path, range)?
         };
         self.sign(&mut req)?;
         self.send(req).await
diff --git a/core/tests/behavior/write.rs b/core/tests/behavior/write.rs
index 0376425153e0..325e17dd07a0 100644
--- a/core/tests/behavior/write.rs
+++ b/core/tests/behavior/write.rs
@@ -431,6 +431,10 @@ pub async fn test_read_full(op: Operator) -> Result<()> {
 
 /// Read range content should match.
 pub async fn test_read_range(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -457,6 +461,10 @@ pub async fn test_read_range(op: Operator) -> Result<()> {
 
 /// Read large range content should match.
 pub async fn test_read_large_range(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -484,6 +492,10 @@ pub async fn test_read_large_range(op: Operator) -> Result<()> {
 
 /// Read range content should match.
 pub async fn test_reader_range(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -513,6 +525,10 @@ pub async fn test_reader_range(op: Operator) -> Result<()> {
 
 /// Read range from should match.
 pub async fn test_reader_from(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -540,6 +556,10 @@ pub async fn test_reader_from(op: Operator) -> Result<()> {
 
 /// Read range tail should match.
 pub async fn test_reader_tail(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();
@@ -657,6 +677,10 @@ pub async fn test_read_with_if_none_match(op: Operator) -> Result<()> {
 }
 
 pub async fn test_fuzz_range_reader(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, _) = gen_bytes();
@@ -694,6 +718,10 @@ pub async fn test_fuzz_range_reader(op: Operator) -> Result<()> {
 }
 
 pub async fn test_fuzz_offset_reader(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, _) = gen_bytes();
@@ -731,6 +759,10 @@ pub async fn test_fuzz_offset_reader(op: Operator) -> Result<()> {
 }
 
 pub async fn test_fuzz_part_reader(op: Operator) -> Result<()> {
+    if !op.info().capability().read_with_range {
+        return Ok(());
+    }
+
     let path = uuid::Uuid::new_v4().to_string();
     debug!("Generate a random file: {}", &path);
     let (content, size) = gen_bytes();

From 89cb0466d778e7550bab585aad001721218d44c1 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 16:57:47 +0800
Subject: [PATCH 6/8] mark the read_with_range tag for services applied

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/raw/adapters/kv/backend.rs   | 1 +
 core/src/services/azblob/backend.rs   | 1 +
 core/src/services/azdfs/backend.rs    | 1 +
 core/src/services/fs/backend.rs       | 1 +
 core/src/services/ftp/backend.rs      | 1 +
 core/src/services/gcs/backend.rs      | 1 +
 core/src/services/ghac/backend.rs     | 2 ++
 core/src/services/hdfs/backend.rs     | 2 ++
 core/src/services/http/backend.rs     | 1 +
 core/src/services/ipfs/backend.rs     | 1 +
 core/src/services/ipmfs/backend.rs    | 1 +
 core/src/services/obs/backend.rs      | 1 +
 core/src/services/oss/backend.rs      | 1 +
 core/src/services/s3/backend.rs       | 1 +
 core/src/services/supabase/backend.rs | 4 ----
 core/src/services/wasabi/backend.rs   | 1 +
 core/src/services/webdav/backend.rs   | 1 +
 core/src/services/webhdfs/backend.rs  | 1 +
 18 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/core/src/raw/adapters/kv/backend.rs b/core/src/raw/adapters/kv/backend.rs
index 55273102112f..fbd1a9529042 100644
--- a/core/src/raw/adapters/kv/backend.rs
+++ b/core/src/raw/adapters/kv/backend.rs
@@ -74,6 +74,7 @@ impl<S: Adapter> Accessor for Backend<S> {
         if cap.read {
             cap.read_can_seek = true;
             cap.read_can_next = true;
+            cap.read_with_range = true;
             cap.stat = true;
         }
 
diff --git a/core/src/services/azblob/backend.rs b/core/src/services/azblob/backend.rs
index 5c07de8d6ca4..423263a60dc7 100644
--- a/core/src/services/azblob/backend.rs
+++ b/core/src/services/azblob/backend.rs
@@ -460,6 +460,7 @@ impl Accessor for AzblobBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
                 read_with_override_content_disposition: true,
diff --git a/core/src/services/azdfs/backend.rs b/core/src/services/azdfs/backend.rs
index 57050e9bc3d5..6552ce951f39 100644
--- a/core/src/services/azdfs/backend.rs
+++ b/core/src/services/azdfs/backend.rs
@@ -311,6 +311,7 @@ impl Accessor for AzdfsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 write: true,
                 rename: true,
                 list: true,
diff --git a/core/src/services/fs/backend.rs b/core/src/services/fs/backend.rs
index 5509663bc07a..d18d6e3fdfe8 100644
--- a/core/src/services/fs/backend.rs
+++ b/core/src/services/fs/backend.rs
@@ -303,6 +303,7 @@ impl Accessor for FsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_seek: true,
+                read_with_range: true,
                 write: true,
                 write_without_content_length: true,
                 create_dir: true,
diff --git a/core/src/services/ftp/backend.rs b/core/src/services/ftp/backend.rs
index 33ad34a6046c..8b214c0cbaf3 100644
--- a/core/src/services/ftp/backend.rs
+++ b/core/src/services/ftp/backend.rs
@@ -318,6 +318,7 @@ impl Accessor for FtpBackend {
             .set_root(&self.root)
             .set_capability(Capability {
                 read: true,
+                read_with_range: true,
                 write: true,
                 list: true,
                 ..Default::default()
diff --git a/core/src/services/gcs/backend.rs b/core/src/services/gcs/backend.rs
index 28ba61e1e803..72a8eebaa0b6 100644
--- a/core/src/services/gcs/backend.rs
+++ b/core/src/services/gcs/backend.rs
@@ -381,6 +381,7 @@ impl Accessor for GcsBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
 
diff --git a/core/src/services/ghac/backend.rs b/core/src/services/ghac/backend.rs
index 916f4cf4c8f3..4b55014acbb1 100644
--- a/core/src/services/ghac/backend.rs
+++ b/core/src/services/ghac/backend.rs
@@ -303,6 +303,8 @@ impl Accessor for GhacBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
+
                 write: true,
 
                 ..Default::default()
diff --git a/core/src/services/hdfs/backend.rs b/core/src/services/hdfs/backend.rs
index f00059d11a1c..848539283c53 100644
--- a/core/src/services/hdfs/backend.rs
+++ b/core/src/services/hdfs/backend.rs
@@ -240,6 +240,8 @@ impl Accessor for HdfsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_seek: true,
+                read_with_range: true,
+
                 write: true,
                 list: true,
                 blocking: true,
diff --git a/core/src/services/http/backend.rs b/core/src/services/http/backend.rs
index a39b645ca93f..e76536cc9402 100644
--- a/core/src/services/http/backend.rs
+++ b/core/src/services/http/backend.rs
@@ -265,6 +265,7 @@ impl Accessor for HttpBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
 
diff --git a/core/src/services/ipfs/backend.rs b/core/src/services/ipfs/backend.rs
index 1ccbbc52047b..ee7086f2778a 100644
--- a/core/src/services/ipfs/backend.rs
+++ b/core/src/services/ipfs/backend.rs
@@ -222,6 +222,7 @@ impl Accessor for IpfsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 list: true,
 
                 ..Default::default()
diff --git a/core/src/services/ipmfs/backend.rs b/core/src/services/ipmfs/backend.rs
index 7432be7f4ea9..d7eb46ae5d7b 100644
--- a/core/src/services/ipmfs/backend.rs
+++ b/core/src/services/ipmfs/backend.rs
@@ -77,6 +77,7 @@ impl Accessor for IpmfsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 write: true,
 
                 ..Default::default()
diff --git a/core/src/services/obs/backend.rs b/core/src/services/obs/backend.rs
index e67492c3da55..36bb3c0a155b 100644
--- a/core/src/services/obs/backend.rs
+++ b/core/src/services/obs/backend.rs
@@ -312,6 +312,7 @@ impl Accessor for ObsBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
 
diff --git a/core/src/services/oss/backend.rs b/core/src/services/oss/backend.rs
index 47bed95339bc..9728b44cf189 100644
--- a/core/src/services/oss/backend.rs
+++ b/core/src/services/oss/backend.rs
@@ -430,6 +430,7 @@ impl Accessor for OssBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
 
diff --git a/core/src/services/s3/backend.rs b/core/src/services/s3/backend.rs
index d4c54b5f9948..b98e7aac963d 100644
--- a/core/src/services/s3/backend.rs
+++ b/core/src/services/s3/backend.rs
@@ -920,6 +920,7 @@ impl Accessor for S3Backend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 read_with_if_match: true,
                 read_with_if_none_match: true,
                 read_with_override_cache_control: true,
diff --git a/core/src/services/supabase/backend.rs b/core/src/services/supabase/backend.rs
index 92bbf08228d7..8d86f3d52a91 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -216,13 +216,9 @@ impl Accessor for SupabaseBackend {
             .set_name(&self.core.bucket)
             .set_capability(Capability {
                 stat: true,
-
                 read: true,
-
                 write: true,
-
                 create_dir: true,
-
                 delete: true,
 
                 ..Default::default()
diff --git a/core/src/services/wasabi/backend.rs b/core/src/services/wasabi/backend.rs
index 5560fe9fe844..70453d2f834a 100644
--- a/core/src/services/wasabi/backend.rs
+++ b/core/src/services/wasabi/backend.rs
@@ -908,6 +908,7 @@ impl Accessor for WasabiBackend {
 
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
 
                 write: true,
                 list: true,
diff --git a/core/src/services/webdav/backend.rs b/core/src/services/webdav/backend.rs
index 2e9bd7e7afbd..b3b0bb13b049 100644
--- a/core/src/services/webdav/backend.rs
+++ b/core/src/services/webdav/backend.rs
@@ -269,6 +269,7 @@ impl Accessor for WebdavBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 write: true,
                 list: true,
                 copy: true,
diff --git a/core/src/services/webhdfs/backend.rs b/core/src/services/webhdfs/backend.rs
index 70b99e719091..edddf5765135 100644
--- a/core/src/services/webhdfs/backend.rs
+++ b/core/src/services/webhdfs/backend.rs
@@ -468,6 +468,7 @@ impl Accessor for WebhdfsBackend {
             .set_capability(Capability {
                 read: true,
                 read_can_next: true,
+                read_with_range: true,
                 write: true,
                 list: true,
                 ..Default::default()

From 015301207d728a2a2c0da5dcb1e24d6998ecfce4 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 17:04:13 +0800
Subject: [PATCH 7/8] minor

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/src/services/supabase/error.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/services/supabase/error.rs b/core/src/services/supabase/error.rs
index 0d641c65de5d..1acab7062c66 100644
--- a/core/src/services/supabase/error.rs
+++ b/core/src/services/supabase/error.rs
@@ -28,7 +28,7 @@ use crate::Result;
 #[derive(Default, Debug, Deserialize)]
 #[serde(default, rename_all = "camelCase")]
 /// The error returned by Supabase
-pub struct SupabaseError {
+struct SupabaseError {
     status_code: String,
     error: String,
     message: String,

From e20b9aed5f550842568864281e93fbe7ddbdde98 Mon Sep 17 00:00:00 2001
From: Ji-Xinyou <jerryji0414@outlook.com>
Date: Wed, 3 May 2023 18:01:31 +0800
Subject: [PATCH 8/8] minor

Signed-off-by: Ji-Xinyou <jerryji0414@outlook.com>
---
 core/tests/behavior/main.rs | 2 --
 1 file changed, 2 deletions(-)

diff --git a/core/tests/behavior/main.rs b/core/tests/behavior/main.rs
index 3e5050861219..692ad5c7484b 100644
--- a/core/tests/behavior/main.rs
+++ b/core/tests/behavior/main.rs
@@ -141,5 +141,3 @@ behavior_tests!(VercelArtifacts);
 behavior_tests!(Webdav);
 #[cfg(feature = "services-webhdfs")]
 behavior_tests!(Webhdfs);
-#[cfg(feature = "services-supabase")]
-behavior_tests!(Supabase);