feat(services/oss): reuse allow_anonymous

Signed-off-by: suyanhanx <[email protected]>

core/src/services/oss/backend.rs

@@ -344,6 +344,7 @@ impl Builder for OssBuilder {
                 endpoint,
                 host,
                 presign_endpoint,
+                allow_anonymous: self.allow_anonymous,
                 signer,
                 loader,
                 client,

core/src/services/oss/core.rs

@@ -45,6 +45,8 @@ pub struct OssCore {
     pub endpoint: String,
     pub presign_endpoint: String,
 
+    pub allow_anonymous: bool,
+
     pub client: HttpClient,
     pub loader: AliyunLoader,
     pub signer: AliyunOssSigner,
@@ -62,30 +64,41 @@ impl Debug for OssCore {
 }
 
 impl OssCore {
-    async fn load_credential(&self) -> Result<AliyunCredential> {
+    async fn load_credential(&self) -> Result<Option<AliyunCredential>> {
+        if self.allow_anonymous {
+            return Ok(None);
+        }
+
         let cred = self
             .loader
             .load()
             .await
             .map_err(new_request_credential_error)?;
 
         if let Some(cred) = cred {
-            Ok(cred)
+            Ok(Some(cred))
         } else {
-            Err(Error::new(
-                ErrorKind::ConfigInvalid,
-                "no valid credential found",
-            ))
+            Ok(None)
         }
     }
 
     pub async fn sign<T>(&self, req: &mut Request<T>) -> Result<()> {
-        let cred = self.load_credential().await?;
+        let cred = if let Some(cred) = self.load_credential().await? {
+            cred
+        } else {
+            return Ok(());
+        };
+
         self.signer.sign(req, &cred).map_err(new_request_sign_error)
     }
 
     pub async fn sign_query<T>(&self, req: &mut Request<T>, duration: Duration) -> Result<()> {
-        let cred = self.load_credential().await?;
+        let cred = if let Some(cred) = self.load_credential().await? {
+            cred
+        } else {
+            return Ok(());
+        };
+
         self.signer
             .sign_query(req, duration, &cred)
             .map_err(new_request_sign_error)