MeexReay/flowgate
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix request

Browse Source
This commit is contained in:
MeexReay 2025-04-10 02:40:56 +03:00
parent e135292817
commit 614e1900b7
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/flowgate/server.rs
View File

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