cr fixes

Author: Shlomi Kushchi

sdk/core/azure_core_amqp/Cargo.toml

@@ -34,6 +34,7 @@ native-tls = { version = "0.2", optional = true }
 tokio-native-tls = { version = "0.3", optional = true }
 tracing.workspace = true
 typespec = { workspace = true, features = ["amqp"] }
+typespec_client_core = { workspace = true }
 typespec_macros.workspace = true
 
 [dev-dependencies]

sdk/core/azure_core_amqp/src/socks5.rs

@@ -5,12 +5,14 @@
 
 use azure_core::{error::Result, http::Url};
 use native_tls::TlsConnector as NativeTlsConnector;
+use std::collections::HashSet;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 use tokio::io::{AsyncRead, AsyncWrite};
 use tokio_native_tls::TlsConnector;
 use tokio_socks::{tcp::Socks5Stream, TargetAddr};
 use tracing::{debug, error, trace};
+use typespec_client_core::http::Sanitizer;
 
 /// A trait that combines AsyncRead, AsyncWrite, Unpin, Send and Debug for SOCKS5 streams
 pub trait SocksStream: AsyncRead + AsyncWrite + Unpin + Send + std::fmt::Debug + 'static {}
@@ -492,7 +494,7 @@ impl SocksConnection {
         if masked.password().is_some() {
             let _ = masked.set_password(Some("***"));
         }
-        masked.sanitize(&[])
+        masked.sanitize(&HashSet::new())
     }
 }
 

sdk/eventhubs/azure_messaging_eventhubs/Cargo.toml

@@ -26,6 +26,7 @@ futures.workspace = true
 rand.workspace = true
 rand_chacha.workspace = true
 tracing.workspace = true
+typespec_client_core = { workspace = true }
 
 [build-dependencies]
 rustc_version.workspace = true

sdk/eventhubs/azure_messaging_eventhubs/examples/eventhubs_socks5_proxy.rs

@@ -126,6 +126,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 /// to prevent credential exposure in log files.
 fn mask_proxy_credentials(url: &str) -> String {
     use azure_core::http::Url;
+    use std::collections::HashSet;
+    use typespec_client_core::http::Sanitizer;
 
     if let Ok(parsed_url) = Url::parse(url) {
         let mut masked = parsed_url.clone();
@@ -135,7 +137,7 @@ fn mask_proxy_credentials(url: &str) -> String {
         if parsed_url.password().is_some() {
             let _ = masked.set_password(Some("***"));
         }
-        masked.sanitize(&[])
+        masked.sanitize(&HashSet::new())
     } else {
         // If URL parsing fails, return a safe placeholder
         "invalid_proxy_url".to_string()