fix(macro): change marco's enum to same

fix marco

Signed-off-by: jokemanfire <hu.dingyang@zte.com.cn>

Author: jokemanfire

codegen/src/svcgen.rs

@@ -119,7 +119,7 @@ impl TtrpcServiceGenerator {
                 Err(
                     #mod_path::Error::RpcStatus(
                         #mod_path::get_status(
-                            #mod_path::Code::NotFound,
+                            #mod_path::Code::NOT_FOUND,
                             #err_msg,
                         )
                     )

example/protocols/asynchronous/mod.rs

@@ -0,0 +1,12 @@
+pub mod agent_ttrpc;
+pub mod health_ttrpc;
+pub mod empty;
+pub mod types;
+// @generated
+pub mod streaming;
+pub mod agent;
+pub mod oci;
+pub mod health;
+
+pub mod streaming_ttrpc;
+pub mod gogo;

example/protocols/sync/mod.rs

@@ -0,0 +1,10 @@
+
+pub mod health_ttrpc;
+pub mod types;
+// @generated
+pub mod gogo;
+pub mod health;
+pub mod agent;
+pub mod agent_ttrpc;
+pub mod oci;
+pub mod empty;

example2/async_server.rs

@@ -33,7 +33,7 @@ impl health::Health for HealthService {
     ) -> Result<health::HealthCheckResponse> {
         let mut status = Status::default();
 
-        status.code = Code::NotFound as i32;
+        status.code = Code::NOT_FOUND as i32;
         status.message = "Just for fun".to_string();
 
         sleep(std::time::Duration::from_secs(10)).await;
@@ -52,7 +52,7 @@ impl health::Health for HealthService {
         rep.agent_version = "mock.0.1".to_string();
         rep.grpc_version = "0.0.1".to_string();
         let mut status = Status::default();
-        status.code = Code::NotFound as i32;
+        status.code = Code::NOT_FOUND as i32;
         Ok(rep)
     }
 }

example2/async_stream_server.rs

@@ -122,7 +122,7 @@ impl streaming::Streaming for StreamingService {
         for t in tasks {
             t.await.unwrap().map_err(|e| {
                 ::ttrpc::Error::RpcStatus(::ttrpc::get_status(
-                    ::ttrpc::Code::Unknown,
+                    ::ttrpc::Code::UNKNOWN,
                     e.to_string(),
                 ))
             })?;

example2/server.rs

@@ -36,7 +36,7 @@ impl health::Health for HealthService {
         _: health::CheckRequest,
     ) -> Result<health::HealthCheckResponse> {
         let mut status = Status::default();
-        status.code = Code::NotFound as i32;
+        status.code = Code::NOT_FOUND as i32;
         status.message = "Just for fun".to_owned();
         Err(Error::RpcStatus(status))
     }
@@ -52,7 +52,7 @@ impl health::Health for HealthService {
         rep.agent_version = "mock 0.1".to_owned();
         rep.grpc_version = "0.0.1".to_owned();
         let mut status = Status::default();
-        status.code = Code::NotFound as i32;
+        status.code = Code::NOT_FOUND as i32;
         Ok(rep)
     }
 }

src/asynchronous/utils.rs

@@ -62,7 +62,7 @@ macro_rules! async_request_handler {
         let mut res = ::ttrpc::Response::default();
         match $class.service.$req_fn(&$ctx, req).await {
             Ok(rep) => {
-                res.status = Some(::ttrpc::get_status(::ttrpc::Code::Ok, "".to_string()));
+                res.status = Some(::ttrpc::get_status(::ttrpc::Code::OK, "".to_string()));
                 rep.encode(&mut res.payload)
                     .map_err(::ttrpc::err_to_others!(e, "Encoding error "))?;
             }
@@ -72,7 +72,7 @@ macro_rules! async_request_handler {
                 }
                 _ => {
                     res.status = Some(::ttrpc::get_status(
-                        ::ttrpc::Code::Unknown,
+                        ::ttrpc::Code::UNKNOWN,
                         format!("{:?}", x),
                     ));
                 }
@@ -123,7 +123,7 @@ macro_rules! async_client_streamimg_handler {
         let mut res = ::ttrpc::Response::default();
         match $class.service.$req_fn(&$ctx, stream).await {
             Ok(rep) => {
-                res.status = Some(::ttrpc::get_status(::ttrpc::Code::Ok, "".to_string()));
+                res.status = Some(::ttrpc::get_status(::ttrpc::Code::OK, "".to_string()));
                 rep.encode(&mut res.payload)
                     .map_err(::ttrpc::err_to_others!(e, "Encoding error "))?;
             }
@@ -133,7 +133,7 @@ macro_rules! async_client_streamimg_handler {
                 }
                 _ => {
                     res.status = Some(::ttrpc::get_status(
-                        ::ttrpc::Code::Unknown,
+                        ::ttrpc::Code::UNKNOWN,
                         format!("{:?}", x),
                     ));
                 }
@@ -195,7 +195,7 @@ macro_rules! async_server_streamimg_handler {
                     }
                     _ => {
                         res.status = Some(::ttrpc::get_status(
-                            ::ttrpc::Code::Unknown,
+                            ::ttrpc::Code::UNKNOWN,
                             format!("{:?}", x),
                         ));
                     }
@@ -252,7 +252,7 @@ macro_rules! async_duplex_streamimg_handler {
                     }
                     _ => {
                         res.status = Some(::ttrpc::get_status(
-                            ::ttrpc::Code::Unknown,
+                            ::ttrpc::Code::UNKNOWN,
                             format!("{:?}", x),
                         ));
                     }

src/sync/utils.rs

@@ -115,7 +115,7 @@ macro_rules! request_handler {
         let mut res = ::ttrpc::Response::default();
         match $class.service.$req_fn(&$ctx, req) {
             Ok(rep) => {
-                res.status = Some(::ttrpc::get_status(::ttrpc::Code::Ok, "".to_string()));
+                res.status = Some(::ttrpc::get_status(::ttrpc::Code::OK, "".to_string()));
                 rep.encode(&mut res.payload)
                     .map_err(::ttrpc::err_to_others!(e, "Encoding error "))?;
             }
@@ -125,7 +125,7 @@ macro_rules! request_handler {
                 }
                 _ => {
                     res.status = Some(::ttrpc::get_status(
-                        ::ttrpc::Code::Unknown,
+                        ::ttrpc::Code::UNKNOWN,
                         format!("{:?}", x),
                     ));
                 }