refactor: make parse http error code public

.gitignore

@@ -1,3 +1,7 @@
+# IDE and editor
+.vscode
+.idea
+
 **/target
 /Cargo.lock
 

src/http_util/error.rs

@@ -57,6 +57,19 @@ pub fn parse_error_kind(err: &isahc::Error) -> ErrorKind {
  }
 }
 
+/// parse_error_status_code will parse HTTP status code into `ErrorKind`
+pub fn parse_error_status_code(code: StatusCode) -> ErrorKind {
+ match code {
+ StatusCode::NOT_FOUND => ErrorKind::NotFound,
+ StatusCode::FORBIDDEN => ErrorKind::PermissionDenied,
+ StatusCode::INTERNAL_SERVER_ERROR
+ | StatusCode::BAD_GATEWAY
+ | StatusCode::SERVICE_UNAVAILABLE
+ | StatusCode::GATEWAY_TIMEOUT => ErrorKind::Interrupted,
+ _ => ErrorKind::Other,
+ }
+}
+
 /// parse_error_response will try to read and parse error response.
 pub fn parse_error_response(
  op: &'static str,

src/http_util/mod.rs

@@ -31,3 +31,4 @@ pub use uri::percent_encode_path;
 mod error;
 pub use error::parse_error_kind;
 pub use error::parse_error_response;
+pub use error::parse_error_status_code;

src/services/azblob/backend.rs

@@ -18,7 +18,6 @@ use std::fmt::Debug;
 use std::fmt::Formatter;
 use std::fmt::Write;
 use std::io::Error;
-use std::io::ErrorKind;
 use std::io::Result;
 use std::mem;
 use std::sync::Arc;
@@ -45,6 +44,7 @@ use crate::http_util::new_http_channel;
 use crate::http_util::parse_content_length;
 use crate::http_util::parse_error_kind as parse_http_error_kind;
 use crate::http_util::parse_error_response;
+use crate::http_util::parse_error_status_code;
 use crate::http_util::parse_etag;
 use crate::http_util::parse_last_modified;
 use crate::http_util::percent_encode_path;
@@ -326,7 +326,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("create", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("create", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} create: {:?}", args.path(), err);
  Err(err)
  }
@@ -358,7 +360,8 @@ impl Accessor for Backend {
  Ok(Box::new(resp.into_body()))
  }
  _ => {
- let err = parse_error_response("read", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("read", args.path(), parse_error_status_code, resp).await;
  warn!("object {} read: {:?}", args.path(), err);
  Err(err)
  }
@@ -379,7 +382,7 @@ impl Accessor for Backend {
  tx,
  self.client.send_async(req),
  HashSet::from([StatusCode::CREATED, StatusCode::OK]),
- parse_error_kind,
+ parse_error_status_code,
  );
 
  Ok(Box::new(bs))
@@ -442,7 +445,8 @@ impl Accessor for Backend {
  Ok(m)
  }
  _ => {
- let err = parse_error_response("stat", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("stat", args.path(), parse_error_status_code, resp).await;
  warn!("object {} stat: {:?}", args.path(), err);
  Err(err)
  }
@@ -463,7 +467,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("delete", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("delete", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} delete: {:?}", args.path(), err);
  Err(err)
  }
@@ -703,15 +709,3 @@ impl Backend {
  })
  }
 }
-
-pub fn parse_error_kind(code: StatusCode) -> ErrorKind {
- match code {
- StatusCode::NOT_FOUND => ErrorKind::NotFound,
- StatusCode::FORBIDDEN => ErrorKind::PermissionDenied,
- StatusCode::INTERNAL_SERVER_ERROR
- | StatusCode::BAD_GATEWAY
- | StatusCode::SERVICE_UNAVAILABLE
- | StatusCode::GATEWAY_TIMEOUT => ErrorKind::Interrupted,
- _ => ErrorKind::Other,
- }
-}

src/services/azblob/dir_stream.rs

@@ -30,7 +30,7 @@ use super::Backend;
 use crate::error::other;
 use crate::error::ObjectError;
 use crate::http_util::parse_error_response;
-use crate::services::azblob::backend::parse_error_kind;
+use crate::http_util::parse_error_status_code;
 use crate::DirEntry;
 use crate::ObjectMode;
 
@@ -76,9 +76,13 @@ impl futures::Stream for DirStream {
  let mut resp = backend.list_blobs(&path, &next_marker).await?;
 
  if resp.status() != http::StatusCode::OK {
- return Err(
- parse_error_response("list", &path, parse_error_kind, resp).await
- );
+ return Err(parse_error_response(
+ "list",
+ &path,
+ parse_error_status_code,
+ resp,
+ )
+ .await);
  }
 
  let bs = resp

src/services/http/backend.rs

@@ -44,6 +44,7 @@ use crate::http_util::parse_content_length;
 use crate::http_util::parse_content_md5;
 use crate::http_util::parse_error_kind as parse_http_error_kind;
 use crate::http_util::parse_error_response;
+use crate::http_util::parse_error_status_code;
 use crate::http_util::parse_etag;
 use crate::http_util::parse_last_modified;
 use crate::http_util::percent_encode_path;
@@ -322,7 +323,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("create", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("create", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} create: {:?}", args.path(), err);
  Err(err)
  }
@@ -357,7 +360,9 @@ impl Accessor for Backend {
 
  Ok(Box::new(resp.into_body()))
  }
- _ => Err(parse_error_response("read", args.path(), parse_error_kind, resp).await),
+ _ => {
+ Err(parse_error_response("read", args.path(), parse_error_status_code, resp).await)
+ }
  }
  }
 
@@ -374,7 +379,7 @@ impl Accessor for Backend {
  tx,
  self.client.send_async(req),
  HashSet::from([StatusCode::CREATED, StatusCode::OK]),
- parse_error_kind,
+ parse_error_status_code,
  );
 
  self.insert_path(&self.get_index_path(args.path()));
@@ -441,7 +446,9 @@ impl Accessor for Backend {
  debug!("object {} stat finished", &p);
  Ok(m)
  }
- _ => Err(parse_error_response("stat", args.path(), parse_error_kind, resp).await),
+ _ => {
+ Err(parse_error_response("stat", args.path(), parse_error_status_code, resp).await)
+ }
  }
  }
 
@@ -458,7 +465,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("delete", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("delete", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} delete: {:?}", args.path(), err);
  Err(err)
  }
@@ -674,18 +683,6 @@ impl futures::Stream for DirStream {
  }
 }
 
-fn parse_error_kind(code: StatusCode) -> ErrorKind {
- match code {
- StatusCode::NOT_FOUND => ErrorKind::NotFound,
- StatusCode::FORBIDDEN => ErrorKind::PermissionDenied,
- StatusCode::INTERNAL_SERVER_ERROR
- | StatusCode::BAD_GATEWAY
- | StatusCode::SERVICE_UNAVAILABLE
- | StatusCode::GATEWAY_TIMEOUT => ErrorKind::Interrupted,
- _ => ErrorKind::Other,
- }
-}
-
 #[cfg(test)]
 mod tests {
  use anyhow::Result;

src/services/s3/backend.rs

@@ -47,6 +47,7 @@ use crate::http_util::new_http_channel;
 use crate::http_util::parse_content_length;
 use crate::http_util::parse_error_kind as parse_http_error_kind;
 use crate::http_util::parse_error_response;
+use crate::http_util::parse_error_status_code;
 use crate::http_util::parse_etag;
 use crate::http_util::parse_last_modified;
 use crate::http_util::percent_encode_path;
@@ -1136,7 +1137,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("create", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("create", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} create: {:?}", args.path(), err);
  Err(err)
  }
@@ -1175,7 +1178,8 @@ impl Accessor for Backend {
  Ok(Box::new(resp.into_body()))
  }
  _ => {
- let err = parse_error_response("read", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("read", args.path(), parse_error_status_code, resp).await;
  warn!("object {} read: {:?}", args.path(), err);
  Err(err)
  }
@@ -1196,7 +1200,7 @@ impl Accessor for Backend {
  tx,
  self.client.send_async(req),
  HashSet::from([StatusCode::CREATED, StatusCode::OK]),
- parse_error_kind,
+ parse_error_status_code,
  );
 
  Ok(Box::new(bs))
@@ -1260,7 +1264,8 @@ impl Accessor for Backend {
  Ok(m)
  }
  _ => {
- let err = parse_error_response("stat", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("stat", args.path(), parse_error_status_code, resp).await;
  warn!("object {} stat: {:?}", args.path(), err);
  Err(err)
  }
@@ -1282,7 +1287,9 @@ impl Accessor for Backend {
  Ok(())
  }
  _ => {
- let err = parse_error_response("delete", args.path(), parse_error_kind, resp).await;
+ let err =
+ parse_error_response("delete", args.path(), parse_error_status_code, resp)
+ .await;
  warn!("object {} delete: {:?}", args.path(), err);
  Err(err)
  }
@@ -1596,18 +1603,6 @@ impl Backend {
  }
 }
 
-pub(crate) fn parse_error_kind(code: StatusCode) -> ErrorKind {
- match code {
- StatusCode::NOT_FOUND => ErrorKind::NotFound,
- StatusCode::FORBIDDEN => ErrorKind::PermissionDenied,
- StatusCode::INTERNAL_SERVER_ERROR
- | StatusCode::BAD_GATEWAY
- | StatusCode::SERVICE_UNAVAILABLE
- | StatusCode::GATEWAY_TIMEOUT => ErrorKind::Interrupted,
- _ => ErrorKind::Other,
- }
-}
-
 #[cfg(test)]
 mod tests {
  use itertools::iproduct;

src/services/s3/dir_stream.rs

@@ -32,7 +32,7 @@ use super::Backend;
 use crate::error::other;
 use crate::error::ObjectError;
 use crate::http_util::parse_error_response;
-use crate::services::s3::backend::parse_error_kind;
+use crate::http_util::parse_error_status_code;
 use crate::DirEntry;
 use crate::ObjectMode;
 
@@ -78,9 +78,13 @@ impl futures::Stream for DirStream {
  let mut resp = backend.list_objects(&path, &token).await?;
 
  if resp.status() != http::StatusCode::OK {
- return Err(
- parse_error_response("list", &path, parse_error_kind, resp).await
- );
+ return Err(parse_error_response(
+ "list",
+ &path,
+ parse_error_status_code,
+ resp,
+ )
+ .await);
  }
 
  let bs = resp.bytes().await.map_err(|e| {