lua-astra 0.47.0

mod configs;
mod cookie;
mod requests;
mod responses;
mod routes;
mod websocket;

pub fn register_to_lua(lua: &mlua::Lua) -> mlua::Result<()> {
    // Register function for running the server
    lua.globals().set(
        "astra_internal__start_server",
        lua.create_async_function(|lua, server: mlua::Table| async move {
            let mut hostname = "127.0.0.1".to_string();
            if let Ok(new_hostname) = server.get("hostname") {
                hostname = new_hostname;
            }

            let mut port = 8080;
            if let Ok(new_port) = server.get("port") {
                port = new_port;
            }

            let listener_address: String = format!("{hostname}:{port}");

            #[allow(clippy::expect_used)]
            let listener = tokio::net::TcpListener::bind(listener_address.clone())
                .await
                .expect("Could not create a TCP listener");

            let (shutdown_tx, mut shutdown_rx) = tokio::sync::mpsc::channel(1);
            let shutdown_tx = std::sync::Arc::new(tokio::sync::Mutex::new(shutdown_tx));

            server.set(
                "shutdown",
                lua.create_async_function(move |_, _: ()| {
                    let shutdown_tx = shutdown_tx.clone();

                    async move {
                        let _ = shutdown_tx.lock().await.send(()).await;

                        Ok(())
                    }
                })?,
            )?;

            #[allow(clippy::expect_used)]
            axum::serve(
                listener,
                crate::components::http::server::routes::load_routes(server)
                    .into_make_service_with_connect_info::<std::net::SocketAddr>(),
            )
            .with_graceful_shutdown(async move {
                let sigint = tokio::signal::ctrl_c();
                #[cfg(unix)]
                if let Ok(mut sigterm) =
                    tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())
                    && let Ok(mut sigquit) =
                        tokio::signal::unix::signal(tokio::signal::unix::SignalKind::quit())
                {
                    tokio::select! {
                        _ = sigterm.recv() => {}
                        _ = sigquit.recv() => {}
                        _ = sigint => {}
                        _ = shutdown_rx.recv() => {}
                    }
                }

                #[cfg(not(unix))]
                {
                    tokio::select! {
                        _ = sigint => {}
                        _ = shutdown_rx.recv() => {}
                    }
                }

                // let _ = shutdown_rx.recv().await;
            })
            .await
            .expect("Could not start the HTTP server");

            Ok(())
        })?,
    )?;

    Ok(())
}