Enable/Disable routes based on host #928

somehowchris · 2022-04-09T20:02:48Z

somehowchris
Apr 9, 2022

Hey :)

I’m having a hard time thinking about something.

Cloud foundry has the concept of route services which is basically a kind of hosted app acting as a guarding reverse proxy.

That said. My app should expose an api to just host some things like metrics for prometheus. So /api/* should only be accessible if reached through it's own url i.e. proxy-api.example.com. If it will be used as the reverse proxy it will be called with the destinations host as a X-CF-Forwarded-Url header.

Is it somehow possible to host 1 endpoint with 2 different routers and choose them based on checking if that header exists? Or something like that?

Answered by davidpdrsn

Apr 9, 2022

Sure! You can write a middleware that checks the header and routes the request accordingly.

View full answer

davidpdrsn · 2022-04-09T20:58:40Z

davidpdrsn
Apr 9, 2022
Collaborator

Sure! You can write a middleware that checks the header and routes the request accordingly.

3 replies

somehowchris Apr 9, 2022
Author

I’m sry, kinda really lost currently.

My current state:

let proxy_router: Router = …
let api_router: Router = … 


let app = Router::new().route(
            "/",
            any_service(service_fn(|req: Request<_>| async {
                if req
                    .headers()
                    .get(*headers::http::X_CF_FORWARDED_URL)
                    .is_some()
                {
                    proxy_router.clone().call(req).await
                } else {
                    api_router.clone().call(req).await
                }
            })),
        );

But im getting:


error[E0277]: `(dyn tower::util::boxed_clone::CloneService<Request<Body>, Error = Infallible, Response = Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Future = Pin<Box<(dyn Future<Output = Result<Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>> + Send + 'static)>>> + Send + 'static)` cannot be shared between threads safely
   --> src/lib.rs:31:13
    |
31  |             any_service(service_fn(|req: Request<_>| async {
    |             ^^^^^^^^^^^ `(dyn tower::util::boxed_clone::CloneService<Request<Body>, Error = Infallible, Response = Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Future = Pin<Box<(dyn Future<Output = Result<Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>> + Send + 'static)>>> + Send + 'static)` cannot be shared between threads safely
    |
    = help: the trait `Sync` is not implemented for `(dyn tower::util::boxed_clone::CloneService<Request<Body>, Error = Infallible, Response = Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Future = Pin<Box<(dyn Future<Output = Result<Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>> + Send + 'static)>>> + Send + 'static)`
    = note: required because of the requirements on the impl of `Sync` for `Unique<(dyn tower::util::boxed_clone::CloneService<Request<Body>, Error = Infallible, Response = Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Future = Pin<Box<(dyn Future<Output = Result<Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>> + Send + 'static)>>> + Send + 'static)>`
    = note: required because it appears within the type `Box<(dyn tower::util::boxed_clone::CloneService<Request<Body>, Error = Infallible, Response = Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Future = Pin<Box<(dyn Future<Output = Result<Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>> + Send + 'static)>>> + Send + 'static)>`
    = note: required because it appears within the type `BoxCloneService<Request<Body>, Response<http_body::combinators::box_body::UnsyncBoxBody<axum::body::Bytes, axum::Error>>, Infallible>`
    = note: required because it appears within the type `Route`
    = note: required because it appears within the type `routing::Fallback<Body>`
    = note: required because it appears within the type `Router`
    = note: required because of the requirements on the impl of `Send` for `&Router`
    = note: required because it appears within the type `[closure@src/lib.rs:31:36: 41:14]`
    = note: required because it appears within the type `ServiceFn<[closure@src/lib.rs:31:36: 41:14]>`
note: required by a bound in `any_service`
   --> /workspace/.cargo/registry/src/github.51.al-1ecc6299db9ec823/axum-0.5.1/src/routing/method_routing.rs:385:74
    |
385 |     S: Service<Request<ReqBody>, Response = Response<ResBody>> + Clone + Send + 'static,
    |                                                                          ^^^^ required by this bound in `any_service`

For more information about this error, try `rustc --explain E0277`.

Do you have any idea or hint on how to resolve this?

somehowchris Apr 9, 2022
Author

https://github.com/somehowchris/cf-route-service/blob/main/src/lib.rs#L24

somehowchris Apr 10, 2022
Author

I’m so sorry. Finally got my brain cells together and saw that the solutions was actually already there https://github.com/tokio-rs/axum/blob/main/examples/http-proxy/src/main.rs

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Enable/Disable routes based on host #928

{{title}}

Replies: 1 comment 3 replies

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

Select a reply

Enable/Disable routes based on host #928

somehowchris Apr 9, 2022

Replies: 1 comment · 3 replies

davidpdrsn Apr 9, 2022 Collaborator

somehowchris Apr 9, 2022 Author

somehowchris Apr 9, 2022 Author

somehowchris Apr 10, 2022 Author

somehowchris
Apr 9, 2022

Replies: 1 comment 3 replies

davidpdrsn
Apr 9, 2022
Collaborator

somehowchris Apr 9, 2022
Author

somehowchris Apr 9, 2022
Author

somehowchris Apr 10, 2022
Author