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

use actix_web::web;

pub mod api;
pub mod model;
pub mod sse;

lazy_static::lazy_static! {
    pub(crate) static ref IGNORE_TRASFER_HEADERS: Vec<&'static  str> =  vec!["host","content-type","content-length","accept-encoding","accept","connection"];
}

pub enum HandleOtherResult {
    Accepted,
}

pub fn mcp_config(config: &mut web::ServiceConfig) {
    config.service(
        web::resource("/rnacos/mcp/sse/messages/{node_id}/{server_key}/{session_id}")
            .route(web::post().to(sse::sse_message)),
    );
    config.service(
        web::resource("/rnacos/mcp/sse/messages/{node_id}/{server_key}/{session_id}/")
            .route(web::post().to(sse::sse_message)),
    );
    config.service(
        web::resource("/rnacos/mcp/sse/{server_key}/{auth_key}")
            .route(web::get().to(sse::sse_connect)),
    );
    config.service(
        web::resource("/rnacos/mcp/sse/{server_key}/{auth_key}/")
            .route(web::get().to(sse::sse_connect)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}")
            .route(web::post().to(api::mcp_handler)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}")
            .route(web::get().to(api::mcp_get_handler)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}")
            .route(web::delete().to(api::mcp_delete_handler)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}/")
            .route(web::post().to(api::mcp_handler)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}/")
            .route(web::get().to(api::mcp_get_handler)),
    );
    config.service(
        web::resource("/rnacos/mcp/{server_key}/{auth_key}/")
            .route(web::delete().to(api::mcp_delete_handler)),
    );
}