Removed opentelemetry_http dependency and http crate bumped to 1

Cargo.toml

@@ -29,9 +29,8 @@ license.workspace = true
 autoexamples = false
 
 [dependencies]
-http = "0.2.11"
+http = "1"
 opentelemetry.workspace = true
-opentelemetry-http = "0.10.0"
 pin-project = "1.1.3"
 tower-layer = "0.3.2"
 tower-service = "0.3.2"

src/trace/extractor.rs

@@ -0,0 +1,20 @@
+//! Implementation of fields injector.
+
+use http::HeaderMap;
+
+pub struct HeaderExtractor<'a>(pub &'a HeaderMap);
+
+impl<'a> opentelemetry::propagation::Extractor for HeaderExtractor<'a> {
+    fn get(&self, key: &str) -> Option<&str> {
+        self.0
+            .get(key)
+            .and_then(|header_value| header_value.to_str().ok())
+    }
+
+    fn keys(&self) -> Vec<&str> {
+        self.0
+            .keys()
+            .map(|header_name| header_name.as_str())
+            .collect()
+    }
+}

src/trace/grpc.rs

@@ -8,13 +8,14 @@ use std::{
 };
 
 use http::{Request, Response};
-use opentelemetry_http::{HeaderExtractor, HeaderInjector};
 use pin_project::pin_project;
 use tower_layer::Layer;
 use tower_service::Service;
 use tracing::{Level, Span};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 
+use super::{extractor::HeaderExtractor, injector::HeaderInjector};
+
 /// Describes the relationship between the [`Span`] and the service producing the span.
 #[derive(Clone, Copy, Debug)]
 enum SpanKind {

src/trace/http.rs

@@ -8,13 +8,14 @@ use std::{
 };
 
 use http::{Method, Request, Response, Version};
-use opentelemetry_http::{HeaderExtractor, HeaderInjector};
 use pin_project::pin_project;
 use tower_layer::Layer;
 use tower_service::Service;
 use tracing::{Level, Span};
 use tracing_opentelemetry::OpenTelemetrySpanExt;
 
+use super::{extractor::HeaderExtractor, injector::HeaderInjector};
+
 /// Describes the relationship between the [`Span`] and the service producing the span.
 #[derive(Clone, Copy, Debug)]
 enum SpanKind {

src/trace/injector.rs

@@ -0,0 +1,17 @@
+//! Implementation of fields injector.
+
+use std::str::FromStr;
+
+use http::{HeaderMap, HeaderName, HeaderValue};
+
+pub struct HeaderInjector<'a>(pub &'a mut HeaderMap);
+
+impl<'a> opentelemetry::propagation::Injector for HeaderInjector<'a> {
+    fn set(&mut self, key: &str, value: String) {
+        if let Ok(header_name) = HeaderName::from_str(key) {
+            if let Ok(header_value) = HeaderValue::from_str(&value) {
+                self.0.insert(header_name, header_value);
+            }
+        }
+    }
+}

src/trace/mod.rs

@@ -8,5 +8,7 @@ pub use self::{
     http::{Http, HttpLayer},
 };
 
+mod extractor;
 pub mod grpc;
 pub mod http;
+mod injector;