From 1968002d656383069a386bd874c9f0cc83e3116e Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Fri, 15 Aug 2025 19:36:22 +0200 Subject: feat(rule-exec): receive messages --- crates/configuration/src/server.rs | 3 +-- crates/configuration/src/server/grpc_svc.rs | 24 ------------------------ 2 files changed, 1 insertion(+), 26 deletions(-) delete mode 100644 crates/configuration/src/server/grpc_svc.rs (limited to 'crates/configuration/src') 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, 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) - } - } -} -- cgit v1.2.3