ref(outbound-http): Add a small hack to improve the tracing of outbound http requests through spin core

Signed-off-by: Caleb Schoepp <[email protected]>

Author: calebschoepp

crates/core/src/lib.rs

@@ -19,7 +19,7 @@ use std::{path::PathBuf, time::Duration};
 
 use anyhow::Result;
 use crossbeam_channel::Sender;
-use tracing::instrument;
+use tracing::{field::Empty, instrument};
 use wasmtime::{InstanceAllocationStrategy, PoolingAllocationConfig};
 use wasmtime_wasi::preview2::ResourceTable;
 use wasmtime_wasi_http::types::{default_send_request, WasiHttpCtx, WasiHttpView};
@@ -195,7 +195,7 @@ impl<T: Send + OutboundWasiHttpHandler> WasiHttpView for Data<T> {
         &mut self.table
     }
 
-    #[instrument(name = "start_outbound_http_request", skip_all, fields(otel.kind = "client"))]
+    #[instrument(name = "spin_core.send_request", skip_all, fields(otel.kind = "client", url.full = request.request.uri().to_string(), http.request.method = request.request.method().to_string(), otel.name = request.request.method().to_string(), http.response.status_code = Empty, server.address = Empty, server.port = Empty))]
     fn send_request(
         &mut self,
         mut request: wasmtime_wasi_http::types::OutgoingRequest,
@@ -205,6 +205,15 @@ impl<T: Send + OutboundWasiHttpHandler> WasiHttpView for Data<T> {
     where
         Self: Sized,
     {
+        let current_span = tracing::Span::current();
+        let uri = request.request.uri();
+        if let Some(authority) = uri.authority() {
+            current_span.record("server.address", authority.host());
+            if let Some(port) = authority.port() {
+                current_span.record("server.port", port.as_u16());
+            }
+        }
+
         spin_telemetry::inject_trace_context(&mut request.request);
         T::send_request(self, request)
     }

crates/trigger-http/src/lib.rs

@@ -47,6 +47,7 @@ use tokio::{
 use tracing::{field::Empty, log, Instrument};
 use wasmtime_wasi_http::{
     body::{HyperIncomingBody as Body, HyperOutgoingBody},
+    types::HostFutureIncomingResponse,
     WasiHttpView,
 };
 
@@ -569,7 +570,6 @@ impl HttpRuntimeData {
     ) -> wasmtime::Result<
         wasmtime::component::Resource<wasmtime_wasi_http::types::HostFutureIncomingResponse>,
     > {
-        use wasmtime_wasi_http::types::HostFutureIncomingResponse;
         use wasmtime_wasi_http::types::IncomingResponseInternal;
 
         let this = data.as_ref();
@@ -706,7 +706,35 @@ impl OutboundWasiHttpHandler for HttpRuntimeData {
             return Self::chain_request(data, request, component_id);
         }
 
-        wasmtime_wasi_http::types::default_send_request(data, request)
+        // TODO: This is a temporary workaround to make sure that outbound task is instrumented.
+        // Once Wasmtime gives us the ability to do the spawn ourselves we can just call .instrument
+        // and won't have to do this workaround.
+        let response_handle = wasmtime_wasi_http::types::default_send_request(data, request)?;
+        let response = data.table().get_mut(&response_handle)?;
+        *response = match std::mem::replace(response, HostFutureIncomingResponse::Consumed) {
+            HostFutureIncomingResponse::Pending(handle) => {
+                HostFutureIncomingResponse::Pending(wasmtime_wasi::preview2::spawn(
+                    async move {
+                        let res: std::prelude::v1::Result<
+                            std::prelude::v1::Result<
+                                wasmtime_wasi_http::types::IncomingResponseInternal,
+                                wasmtime_wasi_http::bindings::http::types::ErrorCode,
+                            >,
+                            anyhow::Error,
+                        > = handle.await;
+                        if let Ok(Ok(res)) = &res {
+                            tracing::Span::current()
+                                .record("http.response.status_code", res.resp.status().as_u16());
+                        }
+                        res
+                    }
+                    .instrument(tracing::Span::current()),
+                ))
+            }
+            other => other,
+        };
+
+        Ok(response_handle)
     }
 }