Turn off domain sniffing

leaf/src/app/dispatcher.rs

@@ -80,41 +80,43 @@ impl Dispatcher {
     where
         T: 'static + AsyncRead + AsyncWrite + Unpin + Send + Sync,
     {
-        let mut lhs: Box<dyn ProxyStream> =
+        let mut lhs: Box<dyn ProxyStream> = if *option::DOMAIN_SNIFFING
-            if !sess.destination.is_domain() && sess.destination.port() == 443 {
+            && !sess.destination.is_domain()
-                let mut lhs = sniff::SniffingStream::new(lhs);
+            && sess.destination.port() == 443
-                match lhs.sniff().await {
+        {
-                    Ok(res) => {
+            let mut lhs = sniff::SniffingStream::new(lhs);
-                        if let Some(domain) = res {
+            match lhs.sniff().await {
-                            debug!(
+                Ok(res) => {
-                                "sniffed domain {} for tcp link {} <-> {}",
+                    if let Some(domain) = res {
-                                &domain, &sess.source, &sess.destination,
-                            );
-                            sess.destination =
-                                match SocksAddr::try_from((&domain, sess.destination.port())) {
-                                    Ok(a) => a,
-                                    Err(e) => {
-                                        warn!(
-                                            "convert sniffed domain {} to destination failed: {}",
-                                            &domain, e,
-                                        );
-                                        return;
-                                    }
-                                };
-                        }
-                    }
-                    Err(e) => {
                         debug!(
-                            "sniff tcp uplink {} -> {} failed: {}",
+                            "sniffed domain {} for tcp link {} <-> {}",
-                            &sess.source, &sess.destination, e,
+                            &domain, &sess.source, &sess.destination,
                         );
-                        return;
+                        sess.destination =
+                            match SocksAddr::try_from((&domain, sess.destination.port())) {
+                                Ok(a) => a,
+                                Err(e) => {
+                                    warn!(
+                                        "convert sniffed domain {} to destination failed: {}",
+                                        &domain, e,
+                                    );
+                                    return;
+                                }
+                            };
                     }
                 }
-                Box::new(lhs)
+                Err(e) => {
-            } else {
+                    debug!(
-                Box::new(lhs)
+                        "sniff tcp uplink {} -> {} failed: {}",
-            };
+                        &sess.source, &sess.destination, e,
+                    );
+                    return;
+                }
+            }
+            Box::new(lhs)
+        } else {
+            Box::new(lhs)
+        };
 
         let outbound = {
             let router = self.router.read().await;

leaf/src/option/mod.rs

@@ -97,6 +97,10 @@ lazy_static! {
         get_env_var_or("LOG_NO_COLOR", false)
     };
 
+    pub static ref DOMAIN_SNIFFING: bool = {
+        get_env_var_or("DOMAIN_SNIFFING", false)
+    };
+
     /// Uplink timeout after downlink EOF.
     pub static ref TCP_UPLINK_TIMEOUT: u64 = {
         get_env_var_or("TCP_UPLINK_TIMEOUT", 10)