Function run_rest_server

plugins/rest-plugin/src/main.rs:121–208

(
    plugin: Plugin<PluginState>,
    clnrest_options: ClnrestOptions,
    notify_rx: Receiver<serde_json::Value>,
)

}

async fn run_rest_server(
    plugin: Plugin<PluginState>,
    clnrest_options: ClnrestOptions,
    notify_rx: Receiver<serde_json::Value>,
) -> Result<(), anyhow::Error> {
    let (socket_layer, socket_io) = SocketIoBuilder::new()
        .with_state(plugin.clone())
        .build_layer();

    socket_io.ns("/", socketio_on_connect.with(auth_socket_io_middleware));

    tokio::spawn(notification_background_task(socket_io.clone(), notify_rx));

    let swagger_path = if clnrest_options.swagger.eq("/") {
        SWAGGER_FALLBACK.to_string()
    } else {
        clnrest_options.swagger.clone()
    };

    let swagger_router =
        Router::new().merge(SwaggerUi::new(swagger_path).url("/swagger.json", ApiDoc::openapi()));

    let root_router = Router::new()
        .route("/", get(|| async { "Hello, World!" }))
        .layer(ServiceBuilder::new().layer(middleware::from_fn(swagger_redirect_middleware)))
        .layer(Extension(clnrest_options.swagger));

    let rpc_router = Router::new()
        .route("/v1/list-methods", get(list_methods))
        .route("/{*path}", any(call_rpc_method))
        .layer(clnrest_options.cors)
        .layer(Extension(plugin.clone()))
        .layer(
            ServiceBuilder::new().layer(SetResponseHeaderLayer::if_not_present(
                HeaderName::from_str("Content-Security-Policy")?,
                HeaderValue::from_str(&clnrest_options.csp)?,
            )),
        );

    let app = swagger_router
        .merge(root_router)
        .merge(rpc_router)
        .layer(socket_layer);

    match clnrest_options.protocol {
        ClnrestProtocol::Https => {
            let max_retries = 10;
            let mut retries = 0;
            while retries < max_retries && !do_certificates_exist(&clnrest_options.certs) {
                log::debug!("Certificates incomplete. Retrying...");
                time::sleep(Duration::from_millis(500)).await;
                retries += 1;
            }

            if !do_certificates_exist(&clnrest_options.certs) {
                log::debug!("Certificates still not existing after retries. Generating...");
                generate_certificates(&clnrest_options.certs, &plugin.option(&OPT_CLNREST_HOST)?)?;
                log::debug!("Certificates generated.");