use super::future::RequestDecompressionFuture as ResponseFuture;
use super::layer::RequestDecompressionLayer;
use crate::body::UnsyncBoxBody;
use crate::compression_utils::CompressionLevel;
use crate::{
compression_utils::AcceptEncoding, decompression::body::BodyInner,
decompression::DecompressionBody, BoxError,
};
use bytes::Buf;
use http::{header, Request, Response};
use http_body::Body;
use std::task::{Context, Poll};
use tower_service::Service;
#[cfg(any(
feature = "decompression-gzip",
feature = "decompression-deflate",
feature = "decompression-br",
feature = "decompression-zstd",
))]
use crate::content_encoding::SupportedEncodings;
#[derive(Debug, Clone)]
pub struct RequestDecompression<S> {
pub(super) inner: S,
pub(super) accept: AcceptEncoding,
pub(super) pass_through_unaccepted: bool,
}
impl<S, ReqBody, ResBody, D> Service<Request<ReqBody>> for RequestDecompression<S>
where
S: Service<Request<DecompressionBody<ReqBody>>, Response = Response<ResBody>>,
ReqBody: Body,
ResBody: Body<Data = D> + Send + 'static,
<ResBody as Body>::Error: Into<BoxError>,
D: Buf + 'static,
{
type Response = Response<UnsyncBoxBody<D, BoxError>>;
type Error = S::Error;
type Future = ResponseFuture<S::Future, ResBody, S::Error>;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
self.inner.poll_ready(cx)
}
fn call(&mut self, req: Request<ReqBody>) -> Self::Future {
let (mut parts, body) = req.into_parts();
let body =
if let header::Entry::Occupied(entry) = parts.headers.entry(header::CONTENT_ENCODING) {
match entry.get().as_bytes() {
#[cfg(feature = "decompression-gzip")]
b"gzip" if self.accept.gzip() => {
entry.remove();
parts.headers.remove(header::CONTENT_LENGTH);
BodyInner::gzip(crate::compression_utils::WrapBody::new(
body,
CompressionLevel::default(),
))
}
#[cfg(feature = "decompression-deflate")]
b"deflate" if self.accept.deflate() => {
entry.remove();
parts.headers.remove(header::CONTENT_LENGTH);
BodyInner::deflate(crate::compression_utils::WrapBody::new(
body,
CompressionLevel::default(),
))
}
#[cfg(feature = "decompression-br")]
b"br" if self.accept.br() => {
entry.remove();
parts.headers.remove(header::CONTENT_LENGTH);
BodyInner::brotli(crate::compression_utils::WrapBody::new(
body,
CompressionLevel::default(),
))
}
#[cfg(feature = "decompression-zstd")]
b"zstd" if self.accept.zstd() => {
entry.remove();
parts.headers.remove(header::CONTENT_LENGTH);
BodyInner::zstd(crate::compression_utils::WrapBody::new(
body,
CompressionLevel::default(),
))
}
b"identity" => BodyInner::identity(body),
_ if self.pass_through_unaccepted => BodyInner::identity(body),
_ => return ResponseFuture::unsupported_encoding(self.accept),
}
} else {
BodyInner::identity(body)
};
let body = DecompressionBody::new(body);
let req = Request::from_parts(parts, body);
ResponseFuture::inner(self.inner.call(req))
}
}
impl<S> RequestDecompression<S> {
pub fn new(service: S) -> Self {
Self {
inner: service,
accept: AcceptEncoding::default(),
pass_through_unaccepted: false,
}
}
define_inner_service_accessors!();
pub fn layer() -> RequestDecompressionLayer {
RequestDecompressionLayer::new()
}
pub fn pass_through_unaccepted(mut self, enabled: bool) -> Self {
self.pass_through_unaccepted = enabled;
self
}
#[cfg(feature = "decompression-gzip")]
pub fn gzip(mut self, enable: bool) -> Self {
self.accept.set_gzip(enable);
self
}
#[cfg(feature = "decompression-deflate")]
pub fn deflate(mut self, enable: bool) -> Self {
self.accept.set_deflate(enable);
self
}
#[cfg(feature = "decompression-br")]
pub fn br(mut self, enable: bool) -> Self {
self.accept.set_br(enable);
self
}
#[cfg(feature = "decompression-zstd")]
pub fn zstd(mut self, enable: bool) -> Self {
self.accept.set_zstd(enable);
self
}
pub fn no_gzip(mut self) -> Self {
self.accept.set_gzip(false);
self
}
pub fn no_deflate(mut self) -> Self {
self.accept.set_deflate(false);
self
}
pub fn no_br(mut self) -> Self {
self.accept.set_br(false);
self
}
pub fn no_zstd(mut self) -> Self {
self.accept.set_zstd(false);
self
}
}