rest-server: use hypers AddrIncoming for proxmox-backup-api
this has a 'from_listener' (tokio::net::TcpListener) since hyper 0.14.5 in the 'tcp' feature (we use 'full', which includes that; since 0.14.13 it is not behind a feature flag anymore). this makes it possible to create a hyper server without our 'StaticIncoming' wrapper and thus makes it unnecessary. The only other thing we have to do is to change the Service impl from tokio::net::TcpStream to hyper::server::conn::AddStream to fulfill the trait requirements. Signed-off-by: Dominik Csapak <d.csapak@proxmox.com> Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
This commit is contained in:
parent
48ba0a2dd5
commit
2ce3e5fb78
@ -10,7 +10,7 @@ anyhow = "1.0"
|
||||
futures = "0.3"
|
||||
handlebars = "3.0"
|
||||
http = "0.2"
|
||||
hyper = { version = "0.14", features = [ "full" ] }
|
||||
hyper = { version = "0.14.5", features = [ "full" ] }
|
||||
lazy_static = "1.4"
|
||||
libc = "0.2"
|
||||
log = "0.4"
|
||||
|
@ -93,7 +93,7 @@ impl tower_service::Service<&Pin<Box<tokio_openssl::SslStream<tokio::net::TcpStr
|
||||
}
|
||||
}
|
||||
|
||||
impl tower_service::Service<&tokio::net::TcpStream> for RestServer {
|
||||
impl tower_service::Service<&hyper::server::conn::AddrStream> for RestServer {
|
||||
type Response = ApiService;
|
||||
type Error = Error;
|
||||
type Future = Pin<Box<dyn Future<Output = Result<ApiService, Error>> + Send>>;
|
||||
@ -102,15 +102,13 @@ impl tower_service::Service<&tokio::net::TcpStream> for RestServer {
|
||||
Poll::Ready(Ok(()))
|
||||
}
|
||||
|
||||
fn call(&mut self, ctx: &tokio::net::TcpStream) -> Self::Future {
|
||||
match ctx.peer_addr() {
|
||||
Err(err) => future::err(format_err!("unable to get peer address - {}", err)).boxed(),
|
||||
Ok(peer) => future::ok(ApiService {
|
||||
peer,
|
||||
api_config: self.api_config.clone(),
|
||||
})
|
||||
.boxed(),
|
||||
}
|
||||
fn call(&mut self, ctx: &hyper::server::conn::AddrStream) -> Self::Future {
|
||||
let peer = ctx.remote_addr();
|
||||
future::ok(ApiService {
|
||||
peer,
|
||||
api_config: self.api_config.clone(),
|
||||
})
|
||||
.boxed()
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user