From 0adeb6e6777cbcafca5dc704701d46360c1fade8 Mon Sep 17 00:00:00 2001 From: Floriane TUERNAL SABOTINOV Date: Sat, 6 Sep 2025 13:45:59 +0200 Subject: [PATCH] use authenticatev2 and not authenticate --- .../websocket/connection_handler/fresh.rs | 26 +++++++++---------- 1 file changed, 12 insertions(+), 14 deletions(-) diff --git a/gateway/src/node/client_handling/websocket/connection_handler/fresh.rs b/gateway/src/node/client_handling/websocket/connection_handler/fresh.rs index f7eca82598..ad283c35db 100644 --- a/gateway/src/node/client_handling/websocket/connection_handler/fresh.rs +++ b/gateway/src/node/client_handling/websocket/connection_handler/fresh.rs @@ -869,21 +869,19 @@ impl FreshHandler { use opentelemetry_sdk::propagation::TraceContextPropagator; use opentelemetry::propagation::TextMapPropagator; - let otel_context = match &request { - ClientControlRequest::Authenticate { otel_context, .. } => otel_context.as_ref(), - _ => None, - }; - if let Some(otel_context) = otel_context { - let carrier = ContextCarrier::from_map(otel_context.clone()); - let propagator = TraceContextPropagator::new(); - let extracted_context = propagator.extract(&carrier); + if let ClientControlRequest::AuthenticateV2(ref auth_req) = request { + if let Some(otel_context) = &auth_req.otel_context { + let carrier = ContextCarrier::from_map(otel_context.clone()); + let propagator = TraceContextPropagator::new(); + let extracted_context = propagator.extract(&carrier); - let span = tracing::info_span!("websocket_authentication"); - span.set_parent(extracted_context.clone()); - - error!("==== Context propagation successful! Current context: {:?} ====", extracted_context); - } else { - warn!("No OpenTelemetry context provided in the request"); + let span = tracing::info_span!("websocket_authentication"); + span.set_parent(extracted_context.clone()); + + error!("==== Context propagation successful! Current context: {:?} ====", extracted_context); + } else { + warn!("No OpenTelemetry context provided in the request"); + } } let auth_result = match request {