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/incubator-opendal.git
The following commit(s) were added to refs/heads/main by this push:
new f269cf0b fix(services/supabase): Supabase ci fix (#2200)
f269cf0b is described below
commit f269cf0bace67b009b7c2e35e3870849ac673dd0
Author: xyJi <[email protected]>
AuthorDate: Thu May 4 01:47:29 2023 +0800
fix(services/supabase): Supabase ci fix (#2200)
* fix create_dir
Signed-off-by: Ji-Xinyou <[email protected]>
* fix delete tests
Signed-off-by: Ji-Xinyou <[email protected]>
* fix delete and skip special chars for supabase
Signed-off-by: Ji-Xinyou <[email protected]>
* fix stat error
Signed-off-by: Ji-Xinyou <[email protected]>
* all ci passes, skip range tests if not supported
Signed-off-by: Ji-Xinyou <[email protected]>
* mark the read_with_range tag for services applied
Signed-off-by: Ji-Xinyou <[email protected]>
* minor
Signed-off-by: Ji-Xinyou <[email protected]>
* minor
Signed-off-by: Ji-Xinyou <[email protected]>
---------
Signed-off-by: Ji-Xinyou <[email protected]>
---
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 | 67 ++++++++++++++++++++++++----
core/src/services/supabase/core.rs | 84 ++++++++++++++++++++++++++++++++---
core/src/services/supabase/error.rs | 36 ++++++++-------
core/src/services/wasabi/backend.rs | 1 +
core/src/services/webdav/backend.rs | 1 +
core/src/services/webhdfs/backend.rs | 1 +
core/tests/behavior/write.rs | 56 +++++++++++++++++++++++
21 files changed, 231 insertions(+), 31 deletions(-)
diff --git a/core/src/raw/adapters/kv/backend.rs
b/core/src/raw/adapters/kv/backend.rs
index 55273102..fbd1a952 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 5c07de8d..423263a6 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 57050e9b..6552ce95 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 5509663b..d18d6e3f 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 33ad34a6..8b214c0c 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 28ba61e1..72a8eeba 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 916f4cf4..4b55014a 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 f00059d1..84853928 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 a39b645c..e76536cc 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 1ccbbc52..ee7086f2 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 7432be7f..d7eb46ae 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 e67492c3..36bb3c0a 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 47bed953..9728b44c 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 d4c54b5f..b98e7aac 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 2b92d2cf..8d86f3d5 100644
--- a/core/src/services/supabase/backend.rs
+++ b/core/src/services/supabase/backend.rs
@@ -218,6 +218,8 @@ impl Accessor for SupabaseBackend {
stat: true,
read: true,
write: true,
+ create_dir: true,
+ delete: true,
..Default::default()
});
@@ -225,8 +227,33 @@ impl Accessor for SupabaseBackend {
am
}
- async fn read(&self, path: &str, _args: OpRead) -> Result<(RpRead,
Self::Reader)> {
- let resp = self.core.supabase_get_object(path).await?;
+ 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, args.range()).await?;
let status = resp.status();
@@ -259,16 +286,38 @@ 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?),
+ }
+ }
+ }
+ }
+
+ async fn delete(&self, path: &str, _: OpDelete) -> Result<RpDelete> {
+ let resp = self.core.supabase_delete_object(path).await?;
+
+ if resp.status().is_success() {
+ Ok(RpDelete::default())
+ } else {
+ // deleting not existing objects is ok
+ let e = parse_error(resp).await?;
+ if e.kind() == ErrorKind::NotFound {
+ Ok(RpDelete::default())
+ } else {
+ Err(e)
}
- _ => Err(parse_error(resp).await?),
}
}
}
diff --git a/core/src/services/supabase/core.rs
b/core/src/services/supabase/core.rs
index 38391427..ccdb2e1a 100644
--- a/core/src/services/supabase/core.rs
+++ b/core/src/services/supabase/core.rs
@@ -109,7 +109,25 @@ impl SupabaseCore {
Ok(req)
}
- pub fn supabase_get_object_public_request(&self, path: &str) ->
Result<Request<AsyncBody>> {
+ 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,
+ _: BytesRange,
+ ) -> Result<Request<AsyncBody>> {
let p = build_abs_path(&self.root, path);
let url = format!(
"{}/storage/v1/object/public/{}/{}",
@@ -118,12 +136,44 @@ impl SupabaseCore {
percent_encode_path(&p)
);
- Request::get(&url)
+ 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,
+ _: BytesRange,
+ ) -> 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)
+ );
+
+ 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>> {
+ 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>> {
+ 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/{}/{}",
@@ -132,7 +182,7 @@ impl SupabaseCore {
percent_encode_path(&p)
);
- Request::get(&url)
+ Request::head(&url)
.body(AsyncBody::Empty)
.map_err(new_request_build_error)
}
@@ -175,11 +225,25 @@ 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, range)?
+ } else {
+ self.supabase_get_object_public_request(path, range)?
+ };
+ self.sign(&mut req)?;
+ 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_get_object_auth_request(path)?
+ self.supabase_head_object_auth_request(path)?
} else {
- self.supabase_get_object_public_request(path)?
+ self.supabase_head_object_public_request(path)?
};
self.sign(&mut req)?;
self.send(req).await
@@ -197,4 +261,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 54f6c61d..1acab706 100644
--- a/core/src/services/supabase/error.rs
+++ b/core/src/services/supabase/error.rs
@@ -39,22 +39,12 @@ 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 (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| (format!("{sb_err:?}"), Some(sb_err)))
+ .map(|sb_err| {
+ (kind, retryable) = parse_supabase_error(&sb_err);
+ (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:?}"));
@@ -65,3 +55,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)
+ }
+}
diff --git a/core/src/services/wasabi/backend.rs
b/core/src/services/wasabi/backend.rs
index 5560fe9f..70453d2f 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 2e9bd7e7..b3b0bb13 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 70b99e71..edddf576 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()
diff --git a/core/tests/behavior/write.rs b/core/tests/behavior/write.rs
index 9b7b4b04..325e17dd 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();
@@ -419,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();
@@ -445,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();
@@ -472,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();
@@ -501,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();
@@ -528,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();
@@ -645,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();
@@ -682,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();
@@ -719,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();
@@ -773,6 +817,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 +1002,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();
