fix: return json key camelCase

Author: a981008

src/naming/core.rs

@@ -682,7 +682,13 @@ impl NamingActor {
 
         let total = ret.len();
         let start = (page_index - 1) * page_size;
-
+        ret.sort_by(|a, b| {
+            a.service_name
+                .cmp(&b.service_name)
+                .then(a.group_name.cmp(&b.group_name))
+                .then(a.ip.cmp(&b.ip))
+                .then(a.port.cmp(&b.port))
+        });
         let paginated_result = ret
             .into_iter()
             .skip(start)

src/naming/service.rs

@@ -391,6 +391,7 @@ pub struct ServiceInfoDto {
 }
 
 #[derive(Debug, Default, Serialize, Deserialize, Clone)]
+#[serde(rename_all = "camelCase")]
 pub struct SubscriberInfoDto {
     pub service_name: Arc<String>,
     pub group_name: Arc<String>,

src/openapi/naming/service.rs

@@ -1,6 +1,3 @@
-use actix::Addr;
-use actix_web::{web, HttpResponse, Responder, Scope};
-
 use crate::merge_web_param;
 use crate::naming::api_model::ServiceInfoParam;
 use crate::naming::core::{NamingActor, NamingCmd, NamingResult};
@@ -10,6 +7,9 @@ use crate::openapi::constant::EMPTY;
 use crate::openapi::naming::model::{
     ServiceQueryListRequest, ServiceQueryListResponce, ServiceQuerySubscribersListResponce,
 };
+use actix::Addr;
+use actix_web::http::header;
+use actix_web::{web, HttpResponse, Responder, Scope};
 
 pub(super) fn service() -> Scope {
     web::scope("/service")
@@ -152,7 +152,9 @@ pub async fn query_subscribers_list(
                         count: c,
                         subscribers: v,
                     };
-                    HttpResponse::Ok().body(serde_json::to_string(&resp).unwrap())
+                    HttpResponse::Ok()
+                        .insert_header(header::ContentType(mime::APPLICATION_JSON))
+                        .body(serde_json::to_string(&resp).unwrap())
                 }
                 _ => HttpResponse::InternalServerError().body("error"),
             }

src/user/permission.rs

@@ -260,6 +260,7 @@ lazy_static::lazy_static! {
         //WebResource
         R::WebResource("/manage/service"),
         R::WebResource("/manage/service/instance"),
+        R::WebResource("/manage/subscriber"),
         R::WebResource("/rnacos/manage/service"),
         R::WebResource("/rnacos/manage/service/instance"),
         //path
@@ -281,6 +282,7 @@ lazy_static::lazy_static! {
         //WebResource
         R::WebResource("/manage/service"),
         R::WebResource("/manage/service/instance"),
+        R::WebResource("/manage/subscriber"),
         R::WebResource("/rnacos/manage/service"),
         R::WebResource("/rnacos/manage/service/instance"),
         R::WebResource("SERVICE_UPDATE"),