Archives/phd
2
0
Fork 0
mirror of https://github.com/xvxx/phd synced 2024-11-04 18:00:22 +00:00
Code Issues Projects Releases Wiki Activity

send file

Browse Source
This commit is contained in:
dvkt 2019-12-26 21:56:56 -08:00
parent 3143921a1a
commit dc63bd691a
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/server.rs
View File

@ -40,7 +40,21 @@ async fn client_loop(mut stream: TcpStream, root: String) -> Result<()> {
async fn respond(stream: &mut TcpStream, selector: &str, root: &str) -> Result<()> { async fn respond(stream: &mut TcpStream, selector: &str, root: &str) -> Result<()> {
let mut path = PathBuf::from(root); let mut path = PathBuf::from(root);
path.push(selector.replace("..", ".")); path.push(selector.replace("..", "."));
let mut response = format!("iPath: {}\r\n", path.to_string_lossy());
let md = fs::metadata(path.clone()).await?;
if md.is_file() {
let mut f = fs::File::open(path).await?;
let mut buf = [0; 1024];
let mut bytes = md.len();
while bytes > 0 {
let n = f.read(&mut buf[..]).await?;
bytes -= n as u64;
stream.write_all(&buf).await?;
}
return Ok(());
}
let mut response = String::new();
let mut dir = fs::read_dir(path.clone()).await?; let mut dir = fs::read_dir(path.clone()).await?;
while let Some(Ok(entry)) = dir.next().await { while let Some(Ok(entry)) = dir.next().await {