feat: add bytes dependency and optimize buffer handling in test_delay function

src-tauri/src/feat/clash.rs

@@ -5,6 +5,7 @@ use crate::{
     process::AsyncHandler,
     utils,
 };
+use bytes::BytesMut;
 use clash_verge_logging::{Type, logging};
 use serde_yaml_ng::{Mapping, Value};
 use smartstring::alias::String;
@@ -127,6 +128,7 @@ pub async fn test_delay(url: String) -> anyhow::Result<u32> {
 
     tokio::time::timeout(Duration::from_secs(10), async {
         let start = Instant::now();
+        let mut buf = BytesMut::with_capacity(1024);
 
         if is_https {
             let stream = match proxy_port {
@@ -134,9 +136,8 @@ pub async fn test_delay(url: String) -> anyhow::Result<u32> {
                     let mut s = TcpStream::connect(format!("127.0.0.1:{pp}")).await?;
                     s.write_all(format!("CONNECT {host}:{port} HTTP/1.1\r\nHost: {host}:{port}\r\n\r\n").as_bytes())
                         .await?;
-                    let mut buf = [0u8; 1024];
-                    let n = s.read(&mut buf).await?;
-                    if !std::str::from_utf8(&buf[..n]).unwrap_or("").contains("200") {
+                    s.read_buf(&mut buf).await?;
+                    if !buf.windows(3).any(|w| w == b"200") {
                         return Err(anyhow::anyhow!("Proxy CONNECT failed"));
                     }
                     s
@@ -166,7 +167,6 @@ pub async fn test_delay(url: String) -> anyhow::Result<u32> {
                 ),
             };
             stream.write_all(req.as_bytes()).await?;
-            let mut buf = [0u8; 1024];
             let _ = stream.read(&mut buf).await?;
         }