rnacos 0.8.3

Nacos server re-implemented in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

#![allow(unused_imports)]

use std::sync::Arc;

use crate::config::ConfigUtils;
use crate::grpc::HandlerResult;
use crate::{
    common::appdata::AppShareData,
    config::core::{ConfigActor, ConfigAsyncCmd, ConfigCmd, ConfigKey, ConfigResult},
    grpc::{
        api_model::{BaseResponse, ConfigPublishRequest, ConfigRemoveRequest},
        nacos_proto::Payload,
        PayloadHandler, PayloadUtils,
    },
    raft::cluster::model::DelConfigReq,
};
use actix::prelude::Addr;
use async_trait::async_trait;

pub struct ConfigRemoveRequestHandler {
    app_data: Arc<AppShareData>,
}

impl ConfigRemoveRequestHandler {
    pub fn new(app_data: Arc<AppShareData>) -> Self {
        Self { app_data }
    }
}

#[async_trait]
impl PayloadHandler for ConfigRemoveRequestHandler {
    async fn handle(
        &self,
        request_payload: crate::grpc::nacos_proto::Payload,
        _request_meta: crate::grpc::RequestMeta,
    ) -> anyhow::Result<HandlerResult> {
        let body_vec = request_payload.body.unwrap_or_default().value;
        let request: ConfigRemoveRequest = serde_json::from_slice(&body_vec)?;
        let req = DelConfigReq::new(ConfigKey::new(
            &request.data_id,
            &request.group,
            &ConfigUtils::default_tenant(request.tenant),
        ));
        match self.app_data.config_route.del_config(req).await {
            Ok(_res) => {
                let mut response = BaseResponse::build_success_response();
                response.request_id = request.request_id;
                Ok(HandlerResult::success(PayloadUtils::build_payload(
                    "ConfigRemoveResponse",
                    serde_json::to_string(&response)?,
                )))
            }
            Err(err) => {
                let mut response = BaseResponse::build_error_response(500u16, err.to_string());
                response.request_id = request.request_id;
                Ok(HandlerResult::success(PayloadUtils::build_payload(
                    "ErrorResponse",
                    serde_json::to_string(&response)?,
                )))
            }
        }
    }
}