From 614e1900b7b42a27085a210765a1368182a13f8b Mon Sep 17 00:00:00 2001
From: MeexReay <meexreay@gmail.com>
Date: Thu, 10 Apr 2025 02:40:56 +0300
Subject: [PATCH] fix request

---
 src/flowgate/server.rs | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/flowgate/server.rs b/src/flowgate/server.rs
index 0033e30..92245c5 100755
--- a/src/flowgate/server.rs
+++ b/src/flowgate/server.rs
@@ -186,7 +186,12 @@ impl FlowgateServer {
         }
 
         let mut raw_status = read_until(&mut stream, b"\r\n").await?;
+
+        let mut request = Vec::new();
+        request.append(&mut raw_status.clone());
+
         raw_status.truncate(raw_status.len() - 2);
+        
         let status =  String::from_utf8(raw_status.clone()).ok()?;
         let status = status.split(" ").collect::<Vec<&str>>();
 
@@ -255,7 +260,6 @@ impl FlowgateServer {
 
         debug!("{} {} got connection", addr, status[1]);
 
-        let mut request = Vec::new();
 
         match &conn.config.ip_forwarding {
             IpForwarding::Simple => {
@@ -277,8 +281,6 @@ impl FlowgateServer {
             _ => {}
         }
 
-        request.append(&mut raw_status.clone());
-
         for (key, value) in headers {
             let mut value = value.to_string();
 
@@ -312,6 +314,8 @@ impl FlowgateServer {
 
         request.append(&mut b"\r\n".to_vec());
 
+        debug!("{:?}", String::from_utf8_lossy(&request));
+
         conn.stream.write_all(&request).await.ok()?;
 
         debug!("{} {} sent request to server", addr, status[1]);