use std::{fmt, future::Future, sync::Arc, time::Duration};
use futures_core::stream::Stream;
use xitca_http::{
body::RequestBody,
config::{HttpServiceConfig, DEFAULT_HEADER_LIMIT, DEFAULT_READ_BUF_LIMIT, DEFAULT_WRITE_BUF_LIMIT},
HttpServiceBuilder,
};
use xitca_server::{Builder, ServerFuture};
use xitca_service::ServiceExt;
use crate::{
bytes::Bytes,
http::{Request, RequestExt, Response},
service::{ready::ReadyService, Service},
};
pub struct HttpServer<
S,
const HEADER_LIMIT: usize = DEFAULT_HEADER_LIMIT,
const READ_BUF_LIMIT: usize = DEFAULT_READ_BUF_LIMIT,
const WRITE_BUF_LIMIT: usize = DEFAULT_WRITE_BUF_LIMIT,
> {
service: Arc<S>,
builder: Builder,
config: HttpServiceConfig<HEADER_LIMIT, READ_BUF_LIMIT, WRITE_BUF_LIMIT>,
}
impl<S> HttpServer<S>
where
S: Send + Sync + 'static,
{
pub fn serve(service: S) -> Self {
Self {
service: Arc::new(service),
builder: Builder::new(),
config: HttpServiceConfig::default(),
}
}
}
impl<S, const HEADER_LIMIT: usize, const READ_BUF_LIMIT: usize, const WRITE_BUF_LIMIT: usize>
HttpServer<S, HEADER_LIMIT, READ_BUF_LIMIT, WRITE_BUF_LIMIT>
where
S: Send + Sync + 'static,
{
pub fn server_threads(mut self, num: usize) -> Self {
self.builder = self.builder.server_threads(num);
self
}
pub fn worker_threads(mut self, num: usize) -> Self {
self.builder = self.builder.worker_threads(num);
self
}
pub fn worker_max_blocking_threads(mut self, num: usize) -> Self {
self.builder = self.builder.worker_max_blocking_threads(num);
self
}
pub fn disable_signal(mut self) -> Self {
self.builder = self.builder.disable_signal();
self
}
pub fn backlog(mut self, num: u32) -> Self {
self.builder = self.builder.backlog(num);
self
}
pub fn disable_vectored_write(mut self) -> Self {
self.config = self.config.disable_vectored_write();
self
}
pub fn keep_alive_timeout(mut self, dur: Duration) -> Self {
self.config = self.config.keep_alive_timeout(dur);
self
}
pub fn request_head_timeout(mut self, dur: Duration) -> Self {
self.config = self.config.request_head_timeout(dur);
self
}
pub fn tls_accept_timeout(mut self, dur: Duration) -> Self {
self.config = self.config.tls_accept_timeout(dur);
self
}
pub fn max_read_buf_size<const READ_BUF_LIMIT_2: usize>(
self,
) -> HttpServer<S, HEADER_LIMIT, READ_BUF_LIMIT_2, WRITE_BUF_LIMIT> {
self.mutate_const_generic::<HEADER_LIMIT, READ_BUF_LIMIT_2, WRITE_BUF_LIMIT>()
}
pub fn max_write_buf_size<const WRITE_BUF_LIMIT_2: usize>(
self,
) -> HttpServer<S, HEADER_LIMIT, READ_BUF_LIMIT, WRITE_BUF_LIMIT_2> {
self.mutate_const_generic::<HEADER_LIMIT, READ_BUF_LIMIT, WRITE_BUF_LIMIT_2>()
}
pub fn max_request_headers<const HEADER_LIMIT_2: usize>(
self,
) -> HttpServer<S, HEADER_LIMIT_2, READ_BUF_LIMIT, WRITE_BUF_LIMIT> {
self.mutate_const_generic::<HEADER_LIMIT_2, READ_BUF_LIMIT, WRITE_BUF_LIMIT>()
}
#[doc(hidden)]
pub fn on_worker_start<FS, Fut>(mut self, on_start: FS) -> Self
where
FS: Fn() -> Fut + Send + Sync + 'static,
Fut: Future + Send + 'static,
{
self.builder = self.builder.on_worker_start(on_start);
self
}
#[cfg(not(target_family = "wasm"))]
pub fn bind<A, ResB, BE>(mut self, addr: A) -> std::io::Result<Self>
where
A: std::net::ToSocketAddrs,
S: Service + 'static,
S::Response: ReadyService + Service<Request<RequestExt<RequestBody>>, Response = Response<ResB>> + 'static,
S::Error: fmt::Debug,
<S::Response as Service<Request<RequestExt<RequestBody>>>>::Error: fmt::Debug,
ResB: Stream<Item = Result<Bytes, BE>> + 'static,
BE: fmt::Debug + 'static,
{
let config = self.config;
let service = self.service.clone().enclosed(HttpServiceBuilder::with_config(config));
self.builder = self.builder.bind("xitca-web", addr, service)?;
Ok(self)
}
pub fn listen<ResB, BE>(mut self, listener: std::net::TcpListener) -> std::io::Result<Self>
where
S: Service + 'static,
S::Response: ReadyService + Service<Request<RequestExt<RequestBody>>, Response = Response<ResB>> + 'static,
S::Error: fmt::Debug,
<S::Response as Service<Request<RequestExt<RequestBody>>>>::Error: fmt::Debug,
ResB: Stream<Item = Result<Bytes, BE>> + 'static,
BE: fmt::Debug + 'static,
{
let config = self.config;
let service = self.service.clone().enclosed(HttpServiceBuilder::with_config(config));
self.builder = self.builder.listen("xitca-web", listener, service);
Ok(self)
}
#[cfg(feature = "openssl")]
pub fn bind_openssl<A: std::net::ToSocketAddrs, ResB, BE>(
mut self,
addr: A,
mut builder: openssl_crate::ssl::SslAcceptorBuilder,
) -> std::io::Result<Self>
where
S: Service + 'static,
S::Response: ReadyService + Service<Request<RequestExt<RequestBody>>, Response = Response<ResB>> + 'static,
S::Error: fmt::Debug,
<S::Response as Service<Request<RequestExt<RequestBody>>>>::Error: fmt::Debug,
ResB: Stream<Item = Result<Bytes, BE>> + 'static,
BE: fmt::Debug + 'static,
{
let config = self.config;
const H11: &[u8] = b"\x08http/1.1";
const H2: &[u8] = b"\x02h2";
builder.set_alpn_select_callback(|_, protocols| {
if protocols.windows(3).any(|window| window == H2) {
#[cfg(feature = "http2")]
{
Ok(b"h2")
}
#[cfg(not(feature = "http2"))]
Err(openssl_crate::ssl::AlpnError::ALERT_FATAL)
} else if protocols.windows(9).any(|window| window == H11) {
Ok(b"http/1.1")
} else {
Err(openssl_crate::ssl::AlpnError::NOACK)
}
});
#[cfg(not(feature = "http2"))]
let protos = H11.iter().cloned().collect::<Vec<_>>();
#[cfg(feature = "http2")]
let protos = H11.iter().chain(H2).cloned().collect::<Vec<_>>();
builder.set_alpn_protos(&protos)?;
let acceptor = builder.build();
let service = self
.service
.clone()
.enclosed(HttpServiceBuilder::with_config(config).openssl(acceptor));
self.builder = self.builder.bind("xitca-web-openssl", addr, service)?;
Ok(self)
}
#[cfg(feature = "rustls")]
pub fn bind_rustls<A: std::net::ToSocketAddrs, ResB, BE>(
mut self,
addr: A,
#[cfg_attr(not(all(feature = "http1", feature = "http2")), allow(unused_mut))]
mut config: rustls_crate::ServerConfig,
) -> std::io::Result<Self>
where
S: Service + 'static,
S::Response: ReadyService + Service<Request<RequestExt<RequestBody>>, Response = Response<ResB>> + 'static,
S::Error: fmt::Debug,
<S::Response as Service<Request<RequestExt<RequestBody>>>>::Error: fmt::Debug,
ResB: Stream<Item = Result<Bytes, BE>> + 'static,
BE: fmt::Debug + 'static,
{
let service_config = self.config;
#[cfg(feature = "http2")]
config.alpn_protocols.push("h2".into());
#[cfg(feature = "http1")]
config.alpn_protocols.push("http/1.1".into());
let config = std::sync::Arc::new(config);
let service = self
.service
.clone()
.enclosed(HttpServiceBuilder::with_config(service_config).rustls(config));
self.builder = self.builder.bind("xitca-web-rustls", addr, service)?;
Ok(self)
}
#[cfg(unix)]
pub fn bind_unix<P: AsRef<std::path::Path>, ResB, BE>(mut self, path: P) -> std::io::Result<Self>
where
S: Service + 'static,
S::Response: ReadyService + Service<Request<RequestExt<RequestBody>>, Response = Response<ResB>> + 'static,
S::Error: fmt::Debug,
<S::Response as Service<Request<RequestExt<RequestBody>>>>::Error: fmt::Debug,
ResB: Stream<Item = Result<Bytes, BE>> + 'static,
BE: fmt::Debug + 'static,
{
let config = self.config;
let service = self.service.clone().enclosed(HttpServiceBuilder::with_config(config));
self.builder = self.builder.bind_unix("xitca-web", path, service)?;
Ok(self)
}
pub fn run(self) -> ServerFuture {
self.builder.build()
}
fn mutate_const_generic<const HEADER_LIMIT2: usize, const READ_BUF_LIMIT2: usize, const WRITE_BUF_LIMIT2: usize>(
self,
) -> HttpServer<S, HEADER_LIMIT2, READ_BUF_LIMIT2, WRITE_BUF_LIMIT2> {
HttpServer {
service: self.service,
builder: self.builder,
config: self
.config
.mutate_const_generic::<HEADER_LIMIT2, READ_BUF_LIMIT2, WRITE_BUF_LIMIT2>(),
}
}
}