refactor(app/inbound): forward-compatible test code (#3671)

see linkerd/linkerd2#8733 for more
information.

see #3559 and
#3614 for more information
on the `ForwardCompatibleBody<B>` wrapper.

this branch updates test code in `linkerd-app-inbound` so that it
interacts with request and response bodies via an adapter that polls for
frames in a manner consistent with the 1.0 api of `http_body`.

this allows us to limit the diff in
#3504, which will only
need to remove this adapter once using hyper 1.0.

see #3672 and #3673, which perform the same change for
`linkerd-app-outbound` and `linkerd-app-integration`, respectively.

---

* refactor(app/inbound): `linkerd-http-body-compat` test dependency

Signed-off-by: katelyn martin <[email protected]>

* refactor(app/inbound): use `ForwardCompatibleBody`

see linkerd/linkerd2#8733.

Signed-off-by: katelyn martin <[email protected]>

---------

Signed-off-by: katelyn martin <[email protected]>

Author: cratelyn

Cargo.lock

@@ -1442,6 +1442,7 @@ dependencies = [
  "linkerd-app-core",
  "linkerd-app-test",
  "linkerd-http-access-log",
+ "linkerd-http-body-compat",
  "linkerd-http-metrics",
  "linkerd-idle-cache",
  "linkerd-io",

linkerd/app/inbound/Cargo.toml

@@ -56,6 +56,7 @@ linkerd-meshtls-rustls = { path = "../../meshtls/rustls", features = [
 [dev-dependencies]
 hyper = { workspace = true, features = ["deprecated", "http1", "http2"] }
 linkerd-app-test = { path = "../test" }
+linkerd-http-body-compat = { path = "../../http/body-compat" }
 linkerd-http-metrics = { path = "../../http/metrics", features = ["test-util"] }
 linkerd-idle-cache = { path = "../../idle-cache", features = ["test-util"] }
 linkerd-io = { path = "../../io", features = ["tokio-test"] }

linkerd/app/inbound/src/http/tests.rs

@@ -11,7 +11,7 @@ use linkerd_app_core::{
     classify,
     errors::header::L5D_PROXY_ERROR,
     identity, io, metrics,
-    proxy::http::{self, Body as _, BoxBody},
+    proxy::http::{self, BoxBody},
     svc::{self, http::TracingExecutor, NewService, Param},
     tls,
     transport::{ClientAddr, OrigDstAddr, Remote, ServerAddr},
@@ -631,15 +631,21 @@ async fn grpc_response_class() {
         .body(hyper::Body::default())
         .unwrap();
 
-    let mut rsp = client
+    let rsp = client
         .send_request(req)
         .await
         .expect("HTTP client request failed");
     tracing::info!(?rsp);
     assert_eq!(rsp.status(), http::StatusCode::OK);
 
-    rsp.body_mut().data().await;
-    let trls = rsp.body_mut().trailers().await.unwrap().unwrap();
+    let mut body = linkerd_http_body_compat::ForwardCompatibleBody::new(rsp.into_body());
+    let trls = body
+        .frame()
+        .await
+        .unwrap()
+        .unwrap()
+        .into_trailers()
+        .expect("trailers frame");
     assert_eq!(trls.get("grpc-status").unwrap().to_str().unwrap(), "2");
 
     let response_total = metrics