From e1d816b8038c82167c6f46c6fe0f3f4da0cc1bb0 Mon Sep 17 00:00:00 2001
From: yjkt <mpbgp@qq.com>
Date: Mon, 18 May 2026 12:59:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=A7=A3=E6=9E=90=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Cargo.toml      |  2 +-
 src/client.rs   | 76 +++++++++++++++++++++++++++++++------------------
 src/protocol.rs |  2 ++
 3 files changed, 52 insertions(+), 28 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index cf6b05d..732d48d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "mt5-rs"
-version = "0.1.0"
+version = "0.1.1"
 edition = "2021"
 rust-version = "1.70"
 description = "A pure Rust library for MetaTrader 5 IPC communication (no Python dependency)"
diff --git a/src/client.rs b/src/client.rs
index 73976e0..773a765 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -201,35 +201,39 @@ impl Mt5Client {
         let pipe = self.pipe()?;
         let resp = pipe.send(180, &[])?;
 
-        let mut reader = Reader::new(&resp);
-
-        let community_account = reader.read_bool();
-        let community_connection = reader.read_bool();
-        let connected = reader.read_bool();
-        let dlls_allowed = reader.read_bool();
-        let trade_allowed = reader.read_bool();
-        let trade_api_disabled = reader.read_bool();
-        let email_enabled = reader.read_bool();
-        let ftp_enabled = reader.read_bool();
-        let notifications_enabled = reader.read_bool();
-        let mqid = reader.read_bool();
-        let build = reader.read_i64();
-        let max_bars = reader.read_i64();
-        let code_page = reader.read_i64();
-        let ping_last = reader.read_i64();
-        let community_balance = reader.read_f64();
-        let retransmission = reader.read_f64();
-        let company = reader.read_string();
-        let name = reader.read_string();
-        let language = reader.read_string();
-        let path = reader.read_string();
-        let data_path = reader.read_string();
-        let common_data_path = reader.read_string();
-
-        if reader.has_error() {
-            return Err(Mt5Error::InvalidResponse("Failed to read terminal info".into()));
+        if resp.len() < 40 {
+            return Err(Mt5Error::InvalidResponse("Response too short".into()));
         }
 
+        let community_account = resp[2] != 0;
+        let community_connection = resp[3] != 0;
+        let connected = resp[6] != 0;
+        let dlls_allowed = resp[7] != 0;
+        let trade_allowed = resp[8] != 0;
+        let trade_api_disabled = resp[9] != 0;
+        let email_enabled = resp[10] != 0;
+        let ftp_enabled = resp[11] != 0;
+        let notifications_enabled = resp[4] != 0;
+        let mqid = resp[5] != 0;
+
+        let build = u16::from_le_bytes([resp[0], resp[1]]) as i64;
+        let max_bars = u32::from_le_bytes([resp[12], resp[13], resp[14], resp[15]]) as i64;
+        let code_page = u16::from_le_bytes([resp[17], resp[18]]) as i64;
+        let ping_last = u16::from_le_bytes([resp[21], resp[22]]) as i64;
+        let community_balance = f64::from_le_bytes([
+            resp[24], resp[25], resp[26], resp[27], resp[28], resp[29], resp[30], resp[31],
+        ]);
+        let retransmission = f64::from_le_bytes([
+            resp[32], resp[33], resp[34], resp[35], resp[36], resp[37], resp[38], resp[39],
+        ]);
+
+        let company = read_string_at_offset(&resp, 41);
+        let name = read_string_at_offset(&resp, 561);
+        let language = read_string_at_offset(&resp, 1081);
+        let path = read_string_at_offset(&resp, 1601);
+        let data_path = read_string_at_offset(&resp, 2121);
+        let common_data_path = read_string_at_offset(&resp, 2641);
+
         Ok(TerminalInfo {
             community_account,
             community_connection,
@@ -1343,3 +1347,21 @@ impl<'a> Reader<'a> {
         String::from_utf16_lossy(&chars)
     }
 }
+
+fn read_string_at_offset(data: &[u8], offset: usize) -> String {
+    if offset >= data.len() {
+        return String::new();
+    }
+    
+    let mut chars = Vec::new();
+    let mut pos = offset;
+    while pos + 1 < data.len() {
+        let c = u16::from_le_bytes([data[pos], data[pos + 1]]);
+        pos += 2;
+        if c == 0 {
+            break;
+        }
+        chars.push(c);
+    }
+    String::from_utf16_lossy(&chars)
+}
diff --git a/src/protocol.rs b/src/protocol.rs
index ca02ef1..c7e37d8 100644
--- a/src/protocol.rs
+++ b/src/protocol.rs
@@ -155,6 +155,8 @@ impl Drop for NamedPipeClient {
     }
 }
 
+unsafe impl Send for NamedPipeClient {}
+
 pub fn compute_pipe_name(terminal_path: &str) -> String {
     let input = format!(r"\\?\{}", terminal_path.to_lowercase());
     let input_utf16: Vec<u16> = input.encode_utf16().collect();