feat: Support Aliyun ram AuthPlugin

Author: luoxiner

Cargo.toml

@@ -43,6 +43,7 @@ config = []
 naming = []
 tls = ["reqwest/default-tls"]
 auth-by-http = ["reqwest"]
+auth-by-aliyun = ["ring", "base64", "chrono"]
 
 [dependencies]
 arc-swap = "1.7"
@@ -64,6 +65,11 @@ rand = "0.8.5"
 # now only for feature="auth-by-http"
 reqwest = { version = "0.12", default-features = false, features = [], optional = true }
 
+# only for aliyun-ram-auth
+ring = { version = "0.17.8", default-features = false, optional = true }
+base64 = { version = "0.22.1", default-features = false, optional = true }
+chrono = { version = "0.4", features = ["now"] ,optional = true }
+
 async-trait = "0.1"
 async-stream = "0.3.5"
 tonic = "0.12"
@@ -74,6 +80,7 @@ dashmap = "5.4.0"
 home = "0.5.4"
 
 dotenvy = "0.15"
+log = "0.4.22"
 
 [dev-dependencies]
 tracing-subscriber = { version = "0.3", features = ["default"] }

nacos-macro/src/message/request.rs

@@ -24,6 +24,40 @@ pub(crate) fn grpc_request(
         }
     };
 
+    let into_request_resource = match macro_args.module {
+        super::Module::Naming => {
+            quote! {
+                fn request_resource(&self) -> Option<crate::api::plugin::RequestResource> {
+                        Some(crate::api::plugin::RequestResource {
+                            request_type: "Naming".to_string(),
+                            namespace: self.namespace.clone(),
+                            group: self.group_name.clone(),
+                            resource: self.service_name.clone()
+                        })
+                }
+            }
+        }
+        super::Module::Config => {
+            quote! {
+                fn request_resource(&self) -> Option<crate::api::plugin::RequestResource> {
+                        Some(crate::api::plugin::RequestResource {
+                            request_type: "Config".to_string(),
+                            namespace: self.namespace.clone(),
+                            group: self.group.clone(),
+                            resource: self.data_id.clone()
+                        })
+                    }
+            }
+        }
+        _ => {
+            quote! {
+                fn request_resource(&self) -> Option<crate::api::plugin::RequestResource> {
+                    None
+                }
+            }
+        }
+    };
+
     // add derive GrpcRequestMessage
     let grpc_message_request = quote! {
 
@@ -52,8 +86,9 @@ pub(crate) fn grpc_request(
             fn module(&self) -> &str {
                 #module
             }
-        }
 
+            #into_request_resource
+        }
     };
 
     // add field

src/api/constants.rs

@@ -44,6 +44,12 @@ pub const ENV_NACOS_CLIENT_AUTH_USERNAME: &str = "NACOS_CLIENT_USERNAME";
 
 pub const ENV_NACOS_CLIENT_AUTH_PASSWORD: &str = "NACOS_CLIENT_PASSWORD";
 
+pub const ENV_NACOS_CLIENT_AUTH_ACCESS_KEY: &str = "NACOS_CLIENT_ACCESS_KEY";
+
+pub const ENV_NACOS_CLIENT_AUTH_ACCESS_SECRET: &str = "NACOS_CLIENT_SECRET_KEY";
+
+pub const ENV_NACOS_CLIENT_SIGN_REGION_ID: &str = "NACOS_CLIENT_SIGN_REGION_ID";
+
 /// env `NACOS_CLIENT_NAMING_PUSH_EMPTY_PROTECTION`, default true
 pub const ENV_NACOS_CLIENT_NAMING_PUSH_EMPTY_PROTECTION: &str =
     "NACOS_CLIENT_NAMING_PUSH_EMPTY_PROTECTION";