feat(rule-exec): receive messages

2 files changed, 1 insertions, 26 deletions

diff --git a/crates/configuration/src/server.rs b/crates/configuration/src/server.rs
index 28d6dd8..e31fc60 100644
--- a/crates/configuration/src/server.rs
+++ b/crates/configuration/src/server.rs
@@ -1,10 +1,8 @@
 pub mod error;
-pub mod grpc_svc;
 mod http_svc;
 pub mod reload_stream;
 mod version;
 
-use grpc_svc::interceptor::MyInterceptor;
 use http_svc::build_router;
 use tonic::service::Routes;
 use tower_http::trace::TraceLayer;
@@ -20,6 +18,7 @@ use warden_core::{
         },
     },
 };
+use warden_middleware::grpc::interceptor::MyInterceptor;
 
 use crate::{server::error::AppError, state::AppHandle};
 
diff --git a/crates/configuration/src/server/grpc_svc.rs b/crates/configuration/src/server/grpc_svc.rs
deleted file mode 100644
index 42aa871..0000000
--- a/crates/configuration/src/server/grpc_svc.rs
+++ /dev/null
@@ -1,24 +0,0 @@
-pub mod interceptor {
-    use opentelemetry::global;
-    use tonic::{Status, service::Interceptor};
-    use tracing::Span;
-    use tracing_opentelemetry::OpenTelemetrySpanExt;
-    use warden_stack::tracing::telemetry::tonic::extractor;
-
-    #[derive(Clone, Copy)]
-    pub struct MyInterceptor;
-
-    impl Interceptor for MyInterceptor {
-        fn call(&mut self, request: tonic::Request<()>) -> Result<tonic::Request<()>, Status> {
-            let span = Span::current();
-
-            let cx = global::get_text_map_propagator(|propagator| {
-                propagator.extract(&extractor::MetadataMap(request.metadata()))
-            });
-
-            span.set_parent(cx);
-
-            Ok(request)
-        }
-    }
-}