stormchaser-api 1.3.2

A robust, distributed workflow engine for event-driven and human-triggered workflows.
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

use crate::ApiDoc;
use rmcp::transport::streamable_http_server::{
    session::local::LocalSessionManager, StreamableHttpServerConfig, StreamableHttpService,
};
use rmcp_openapi::Server;
use std::io::Error;
use tracing::error;
use url::Url;
use utoipa::OpenApi;

pub fn mcp_service(
    api_base_url: &str,
) -> Option<StreamableHttpService<Server, LocalSessionManager>> {
    let openapi_val = match serde_json::to_value(ApiDoc::openapi()) {
        Ok(value) => value,
        Err(error) => {
            error!(?error, "Failed to serialize OpenAPI spec for MCP service");
            return None;
        }
    };
    let base_url = match Url::parse(api_base_url) {
        Ok(value) => value,
        Err(error) => {
            error!(?error, "Invalid API_BASE_URL; MCP service disabled");
            return None;
        }
    };

    Some(StreamableHttpService::new(
        move || {
            let mut server = Server::new(
                openapi_val.clone(),
                base_url.clone(),
                None,
                None,
                false,
                false,
            );
            server.load_openapi_spec().map_err(|error| {
                error!(?error, "Failed to load MCP OpenAPI spec");
                Error::other(error.to_string())
            })?;
            Ok(server)
        },
        LocalSessionManager::default().into(),
        StreamableHttpServerConfig::default(),
    ))
}