41 lines
973 B
Rust
41 lines
973 B
Rust
mod plain;
|
|
#[cfg(feature = "direct_tls")]
|
|
mod tls;
|
|
mod unix;
|
|
|
|
use std::sync::Arc;
|
|
|
|
use axum_server::Handle as ServerHandle;
|
|
use conduwuit::Result;
|
|
use conduwuit_service::Services;
|
|
use tokio::sync::broadcast;
|
|
|
|
use super::layers;
|
|
|
|
/// Serve clients
|
|
pub(super) async fn serve(
|
|
services: Arc<Services>,
|
|
handle: ServerHandle,
|
|
shutdown: broadcast::Receiver<()>,
|
|
) -> Result<()> {
|
|
let server = &services.server;
|
|
let config = &server.config;
|
|
let addrs = config.get_bind_addrs();
|
|
let (app, _guard) = layers::build(&services)?;
|
|
|
|
if cfg!(unix) && config.unix_socket_path.is_some() {
|
|
unix::serve(server, app, shutdown).await
|
|
} else if config.tls.certs.is_some() {
|
|
#[cfg(feature = "direct_tls")]
|
|
return tls::serve(server, app, handle, addrs).await;
|
|
|
|
#[cfg(not(feature = "direct_tls"))]
|
|
return conduwuit::Err!(Config(
|
|
"tls",
|
|
"conduwuit was not built with direct TLS support (\"direct_tls\")"
|
|
));
|
|
} else {
|
|
plain::serve(server, app, handle, addrs).await
|
|
}
|
|
}
|