RequestDecompressionLayer on complex layers

[junderw]

Summary

Cross referencing: tokio-rs/axum#2747

The root of the issue seems to be RequestDecompression<S> only implementing Service when the inner service S implements Service with DecompressionBody wrapper wedged inside there.

It makes sense why that is so, but the OP is still at a loss as to how to integrate it into their build method.

---

Summary
https://github.com/GreptimeTeam/greptimedb/blob/a58256d4d3f031470dd765a8cbc849dbbba6863a/src/servers/src/http.rs#L660-L694

Could you add RequestDecompressionLayer to the middleware tower in the code snippet above?

I tried:

            .layer(
                ServiceBuilder::new()
                    .layer(HandleErrorLayer::new(handle_error))
                    .layer(RequestDecompressionLayer::new())
                    .layer(TraceLayer::new_for_http())
                    .layer(TimeoutLayer::new(self.options.timeout))
                    .layer(DefaultBodyLimit::max(
                        self.options
                            .body_limit
                            .0
                            .try_into()
                            .unwrap_or_else(|_| DEFAULT_BODY_LIMIT.as_bytes() as usize),
                    ))
                    .layer(middleware::from_fn_with_state(
                        AuthState::new(self.user_provider.clone()),
                        authorize::check_http_auth,
                    )),
            )

and got:

cargo  build --locked --bin greptime
   Compiling servers v0.8.0 (/Users/tison/GreptimeWorkspace/greptimedb/src/servers)
   Compiling cmd v0.8.0 (/Users/tison/GreptimeWorkspace/greptimedb/src/cmd)
error[E0277]: the trait bound `HandleError<RequestDecompression<tower_http::trace::Trace<tower::timeout::Timeout<axum_core::extract::default_body_limit::private::DefaultBodyLimitService<axum::middleware::FromFn<fn(axum::extract::State<AuthState>, http::Request<_>, axum::middleware::Next<_>) -> impl futures::Future<Output = http::Response<http_body::combinators::box_body::UnsyncBoxBody<bytes::Bytes, axum::Error>>> {check_http_auth::<_>}, AuthState, Route, _>>>, SharedClassifier<ServerErrorsAsFailures>>>, fn(Box<(dyn StdError + std::marker::Send + std::marker::Sync + 'static)>) -> impl futures::Future<Output = axum::Json<HttpResponse>> {handle_error}, _>: tower::Service<http::Request<_>>` is not satisfied
   --> src/servers/src/http.rs:665:17
    |
664 |               .layer(
    |                ----- required by a bound introduced by this call
665 | /                 ServiceBuilder::new()
666 | |                     .layer(HandleErrorLayer::new(handle_error))
667 | |                     .layer(RequestDecompressionLayer::new())
668 | |                     .layer(TraceLayer::new_for_http())
...   |
679 | |                         authorize::check_http_auth,
680 | |                     )),
    | |______________________^ the trait `tower::Service<http::Request<_>>` is not implemented for `HandleError<RequestDecompression<Trace<Timeout<DefaultBodyLimitService<FromFn<fn(State<AuthState>, ..., ...) -> ... {check_http_auth::<...>}, ..., ..., ...>>>, ...>>, ..., ...>`
    |
    = help: the following other types implement trait `tower::Service<Request>`:
              HandleError<S, F, ()>
              HandleError<S, F, (T1, T2)>
              HandleError<S, F, (T1, T2, T3)>
              HandleError<S, F, (T1, T2, T3, T4)>
              HandleError<S, F, (T1, T2, T3, T4, T5)>
              HandleError<S, F, (T1, T2, T3, T4, T5, T6)>
              HandleError<S, F, (T1, T2, T3, T4, T5, T6, T7)>
              HandleError<S, F, (T1, T2, T3, T4, T5, T6, T7, T8)>
            and 9 others
note: the method call chain might not have had the expected associated types
   --> src/servers/src/http.rs:666:22
    |
665 |                   ServiceBuilder::new()
    |                   --------------------- this expression has type `ServiceBuilder<Identity>`
666 |                       .layer(HandleErrorLayer::new(handle_error))
    |                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `Layer::Service` is `HandleError<_, fn(Box<dyn Error + Send + Sync>) -> impl Future<Output = Json<HttpResponse>> {handle_error}, _>` here
667 |                       .layer(RequestDecompressionLayer::new())
    |                        --------------------------------------- `Layer::Service` remains `HandleError<RequestDecompression<_>, fn(Box<dyn Error + Send + Sync>) -> impl Future<Output = Json<HttpResponse>> {handle_error}, _>` here
668 |                       .layer(TraceLayer::new_for_http())
...

I tried a lot of other pattern but just lost in the type hell.

axum version
0.6.20

I cannot upgrade due to GreptimeTeam/greptimedb#3610

tower-http version

0.4.4