summer_web/

lib.rs

//! [![summer-rs](https://img.shields.io/github/stars/summer-rs/summer-rs)](https://summer-rs.github.io/docs/plugins/summer-web)
#![doc = include_str!("../README.md")]
#![doc(html_favicon_url = "https://summer-rs.github.io/favicon.ico")]
#![doc(html_logo_url = "https://summer-rs.github.io/logo.svg")]

/// summer-web config
pub mod config;
/// summer-web defined error
pub mod error;
/// axum extract
pub mod extractor;
/// axum route handler
pub mod handler;
pub mod middleware;
#[cfg(feature = "openapi")]
pub mod openapi;
/// RFC 7807 Problem Details for HTTP APIs
pub mod problem_details;

pub use summer_macros::ProblemDetails;

#[cfg(feature = "socket_io")]
pub use {rmpv, socketioxide};

pub use axum;
pub use summer::async_trait;
use summer::signal;
/////////////////web-macros/////////////////////
/// To use these Procedural Macros, you need to add `summer-web` dependency
pub use summer_macros::middlewares;
pub use summer_macros::nest;

// route macros
pub use summer_macros::delete;
pub use summer_macros::get;
pub use summer_macros::head;
pub use summer_macros::options;
pub use summer_macros::patch;
pub use summer_macros::post;
pub use summer_macros::put;
pub use summer_macros::route;
pub use summer_macros::routes;
pub use summer_macros::trace;

/// SocketIO macros
#[cfg(feature = "socket_io")]
pub use summer_macros::on_connection;
#[cfg(feature = "socket_io")]
pub use summer_macros::on_disconnect;
#[cfg(feature = "socket_io")]
pub use summer_macros::on_fallback;
#[cfg(feature = "socket_io")]
pub use summer_macros::subscribe_message;

/// OpenAPI macros
#[cfg(feature = "openapi")]
pub use summer_macros::api_route;
#[cfg(feature = "openapi")]
pub use summer_macros::api_routes;
#[cfg(feature = "openapi")]
pub use summer_macros::delete_api;
#[cfg(feature = "openapi")]
pub use summer_macros::get_api;
#[cfg(feature = "openapi")]
pub use summer_macros::head_api;
#[cfg(feature = "openapi")]
pub use summer_macros::options_api;
#[cfg(feature = "openapi")]
pub use summer_macros::patch_api;
#[cfg(feature = "openapi")]
pub use summer_macros::post_api;
#[cfg(feature = "openapi")]
pub use summer_macros::put_api;
#[cfg(feature = "openapi")]
pub use summer_macros::trace_api;

/// axum::routing::MethodFilter re-export
pub use axum::routing::MethodFilter;

/// Router with AppState
#[cfg(not(feature = "openapi"))]
pub type Router = axum::Router;
/// MethodRouter with AppState
pub use axum::routing::MethodRouter;

#[cfg(feature = "openapi")]
pub use aide;
#[cfg(feature = "openapi")]
pub use aide::openapi::OpenApi;
#[cfg(feature = "openapi")]
pub type Router = aide::axum::ApiRouter;
#[cfg(feature = "openapi")]
pub use aide::axum::routing::ApiMethodRouter;

#[cfg(feature = "openapi")]
use aide::transform::TransformOpenApi;

use anyhow::Context;
use axum::Extension;
use config::ServerConfig;
use config::WebConfig;
use std::{net::SocketAddr, ops::Deref, sync::Arc};
use summer::plugin::component::ComponentRef;
use summer::plugin::ComponentRegistry;
use summer::plugin::MutableComponentRegistry;
use summer::{
    app::{App, AppBuilder},
    config::ConfigRegistry,
    error::Result,
    event::EventPublisher,
    plugin::Plugin,
};

#[cfg(feature = "socket_io")]
use config::SocketIOConfig;

#[cfg(feature = "openapi")]
use crate::config::OpenApiConfig;

/// Routers collection
#[cfg(feature = "openapi")]
pub type Routers = Vec<aide::axum::ApiRouter>;
#[cfg(not(feature = "openapi"))]
pub type Routers = Vec<axum::Router>;

/// Router layer function type
///
/// Used to add layers (middleware) to the router before the server starts.
/// This enables plugins to dynamically register middleware layers.
///
/// # Example
///
/// ```rust,ignore
/// use summer_web::{Router, LayerConfigurator};
///
/// // In your plugin's build method:
/// app.add_router_layer(|router: Router| {
///     router.layer(MyMiddlewareLayer::new())
/// });
/// ```
pub type RouterLayer = Arc<dyn Fn(Router) -> Router + Send + Sync>;

/// Collection of router layers
pub type RouterLayers = Vec<RouterLayer>;

/// Trait for adding layers to the web router
pub trait LayerConfigurator {
    /// Add a layer function that will be applied to the router before the server starts.
    ///
    /// Layers are applied in the order they are added.
    ///
    /// # Example
    ///
    /// ```rust,ignore
    /// use summer_web::LayerConfigurator;
    ///
    /// app.add_router_layer(|router| {
    ///     router.layer(MyAuthLayer::new(state))
    /// });
    /// ```
    fn add_router_layer<F>(&mut self, layer: F) -> &mut Self
    where
        F: Fn(Router) -> Router + Send + Sync + 'static;
}

impl LayerConfigurator for AppBuilder {
    fn add_router_layer<F>(&mut self, layer: F) -> &mut Self
    where
        F: Fn(Router) -> Router + Send + Sync + 'static,
    {
        if let Some(layers) = self.get_component_ref::<RouterLayers>() {
            unsafe {
                let raw_ptr = ComponentRef::into_raw(layers);
                let layers = &mut *(raw_ptr as *mut RouterLayers);
                layers.push(Arc::new(layer));
            }
            self
        } else {
            let layers: RouterLayers = vec![Arc::new(layer)];
            self.add_component(layers)
        }
    }
}

/// OpenAPI
#[cfg(feature = "openapi")]
type OpenApiTransformer = fn(TransformOpenApi) -> TransformOpenApi;

/// Web Configurator
pub trait WebConfigurator {
    /// add route to app registry
    fn add_router(&mut self, router: Router) -> &mut Self;

    /// Initialize OpenAPI Documents
    #[cfg(feature = "openapi")]
    fn openapi(&mut self, openapi: OpenApi) -> &mut Self;

    /// Defining OpenAPI Documents
    #[cfg(feature = "openapi")]
    fn api_docs(&mut self, api_docs: OpenApiTransformer) -> &mut Self;
}

impl WebConfigurator for AppBuilder {
    fn add_router(&mut self, router: Router) -> &mut Self {
        if let Some(routers) = self.get_component_ref::<Routers>() {
            unsafe {
                let raw_ptr = ComponentRef::into_raw(routers);
                let routers = &mut *(raw_ptr as *mut Routers);
                routers.push(router);
            }
            self
        } else {
            self.add_component(vec![router])
        }
    }

    /// Initialize OpenAPI Documents
    #[cfg(feature = "openapi")]
    fn openapi(&mut self, openapi: OpenApi) -> &mut Self {
        self.add_component(openapi)
    }

    #[cfg(feature = "openapi")]
    fn api_docs(&mut self, api_docs: OpenApiTransformer) -> &mut Self {
        self.add_component(api_docs)
    }
}

/// State of App
#[derive(Clone)]
pub struct AppState {
    /// App Registry Ref
    pub app: Arc<App>,
}

/// Web Plugin Definition
pub struct WebPlugin;

pub use summer::event::{ServerProtocol, ServerStartedEvent};

#[async_trait]
impl Plugin for WebPlugin {
    async fn build(&self, app: &mut AppBuilder) {
        let mut config = app
            .get_config::<WebConfig>()
            .expect("web plugin config load failed");

        config.normalize_prefixes();

        #[cfg(feature = "socket_io")]
        let socketio_config = app.get_config::<SocketIOConfig>().ok();

        // 1. collect router
        let routers = app.get_component_ref::<Routers>();
        let mut router: Router = match routers {
            Some(rs) => {
                let mut router = Router::new();
                for r in rs.deref().iter() {
                    router = router.merge(r.to_owned());
                }
                router
            }
            None => Router::new(),
        };
        if let Some(middlewares) = config.middlewares {
            router = crate::middleware::apply_middleware(router, middlewares);
        }

        #[cfg(feature = "socket_io")]
        if let Some(socketio_config) = socketio_config {
            router = enable_socketio(socketio_config, app, router);
        }

        app.add_component(router);

        let server_conf = config.server;
        #[cfg(feature = "openapi")]
        {
            let openapi_conf = config.openapi;
            app.add_component(openapi_conf.clone());
        }

        app.add_scheduler(move |app: Arc<App>| Box::new(Self::schedule(app, server_conf)));
    }
}

impl WebPlugin {
    async fn schedule(app: Arc<App>, config: ServerConfig) -> Result<String> {
        let mut router = app.get_expect_component::<Router>();

        // Apply custom router layers registered by plugins
        // This is done in schedule() after all plugins have built,
        // ensuring plugins that depend on other plugins can still register layers
        if let Some(layers) = app.get_component_ref::<RouterLayers>() {
            for layer_fn in layers.deref().iter() {
                router = layer_fn(router);
            }
        }

        // 2. bind tcp listener
        let addr = SocketAddr::from((config.binding, config.port));
        let listener = tokio::net::TcpListener::bind(addr)
            .await
            .with_context(|| format!("bind tcp listener failed:{addr}"))?;
        tracing::info!("bind tcp listener: {addr}");

        // 3. openapi
        #[cfg(feature = "openapi")]
        let router = {
            let openapi_conf = app.get_expect_component::<OpenApiConfig>();
            finish_openapi(&app, router, openapi_conf, &config.global_prefix)
        };

        // 4. axum server
        let mut router = router.layer(Extension(AppState { app: app.clone() }));

        if !config.global_prefix.is_empty() {
            router = axum::Router::new().nest(&config.global_prefix, router)
        };

        tracing::info!("axum server started");
        // summer-nacos listens for this to register the HTTP endpoint (with grpc if both plugins run).
        app.publish(ServerStartedEvent {
            addr,
            protocol: ServerProtocol::Http,
        })
        .await?;
        if config.connect_info {
            // with client connect info
            let service = router.into_make_service_with_connect_info::<SocketAddr>();
            let server = axum::serve(listener, service);
            if config.graceful {
                server
                    .with_graceful_shutdown(signal::shutdown_signal("axum web server"))
                    .await
            } else {
                server.await
            }
        } else {
            let service = router.into_make_service();
            let server = axum::serve(listener, service);
            if config.graceful {
                server
                    .with_graceful_shutdown(signal::shutdown_signal("axum web server"))
                    .await
            } else {
                server.await
            }
        }
        .context("start axum server failed")?;

        Ok("axum schedule finished".to_string())
    }
}

#[cfg(feature = "openapi")]
pub fn enable_openapi() {
    aide::generate::on_error(|error| {
        tracing::error!("{error}");
    });
    aide::generate::extract_schemas(false);
}

#[cfg(feature = "socket_io")]
pub fn enable_socketio(
    socketio_config: SocketIOConfig,
    app: &mut AppBuilder,
    router: Router,
) -> Router {
    tracing::info!(
        "Configuring SocketIO with namespace: {}",
        socketio_config.default_namespace
    );

    let (layer, io) = socketioxide::SocketIo::builder().build_layer();

    let ns_path = socketio_config.default_namespace.clone();
    let ns_path_for_closure = ns_path.clone();
    io.ns(ns_path, move |socket: socketioxide::extract::SocketRef| async move {
        use summer::tracing::info;

        info!(socket_id = ?socket.id, "New socket connected to namespace: {}", ns_path_for_closure);

        crate::handler::auto_socketio_setup(&socket);
    });

    app.add_component(io);
    router.layer(layer)
}

#[cfg(feature = "openapi")]
fn finish_openapi(
    app: &App,
    router: aide::axum::ApiRouter,
    openapi_conf: OpenApiConfig,
    global_prefix: &str,
) -> axum::Router {
    let router = router.nest_api_service(
        &openapi_conf.doc_prefix,
        docs_routes(&openapi_conf, global_prefix),
    );

    let mut api = app.get_component::<OpenApi>().unwrap_or_else(|| OpenApi {
        info: openapi_conf.info,
        ..Default::default()
    });

    let router = if let Some(api_docs) = app.get_component::<OpenApiTransformer>() {
        router.finish_api_with(&mut api, api_docs)
    } else {
        router.finish_api(&mut api)
    };

    // Prepend global_prefix to all API paths in the OpenAPI spec,
    // since finish_api() generates paths before nest(global_prefix) is applied.
    if !global_prefix.is_empty() {
        if let Some(ref mut paths) = api.paths {
            let old_paths = std::mem::take(&mut paths.paths);
            for (path, item) in old_paths {
                paths.paths.insert(format!("{global_prefix}{path}"), item);
            }
        }
    }

    router.layer(Extension(Arc::new(api)))
}

#[cfg(feature = "openapi")]
pub fn docs_routes(
    OpenApiConfig { doc_prefix, info }: &OpenApiConfig,
    global_prefix: &str,
) -> aide::axum::ApiRouter {
    let router = aide::axum::ApiRouter::new();
    let _openapi_path = &format!("{global_prefix}{doc_prefix}/openapi.json");
    let _doc_title = &info.title;

    #[cfg(feature = "openapi-scalar")]
    let router = router.route(
        "/scalar",
        aide::scalar::Scalar::new(_openapi_path)
            .with_title(_doc_title)
            .axum_route(),
    );
    #[cfg(feature = "openapi-redoc")]
    let router = router.route(
        "/redoc",
        aide::redoc::Redoc::new(_openapi_path)
            .with_title(_doc_title)
            .axum_route(),
    );
    #[cfg(feature = "openapi-swagger")]
    let router = router.route(
        "/swagger",
        aide::swagger::Swagger::new(_openapi_path)
            .with_title(_doc_title)
            .axum_route(),
    );

    router.route("/openapi.json", axum::routing::get(serve_docs))
}

#[cfg(feature = "openapi")]
async fn serve_docs(Extension(api): Extension<Arc<OpenApi>>) -> impl aide::axum::IntoApiResponse {
    axum::response::IntoResponse::into_response(axum::Json(api.as_ref()))
}

#[cfg(feature = "openapi")]
pub fn default_transform<'a>(
    path_item: aide::transform::TransformPathItem<'a>,
) -> aide::transform::TransformPathItem<'a> {
    path_item
}