YGGverse/agate
1
0
Fork 0
mirror of https://github.com/YGGverse/agate.git synced 2026-04-08 20:45:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Url parsing

Browse source
This commit is contained in:
Matt Brubeck 2020-05-17 12:14:29 -07:00
parent e911d7e38d
commit 0e6163dcd9
3 changed files with 52 additions and 86 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/main.rs
View file

@ -12,15 +12,15 @@ use {
error::Error,
fs::File,
io::BufReader,
path::Path,
sync::Arc,
},
url::Url,
};
pub type Result<T=()> = std::result::Result<T, Box<dyn Error>>;
fn main() -> Result {
env_logger::init();
let certs = certs(&mut BufReader::new(File::open("tests/cert.pem")?))
.expect("Error reading certificate file");
let mut keys = rsa_private_keys(&mut BufReader::new(File::open("tests/key.rsa")?))
@ -54,14 +54,15 @@ async fn connection(acceptor: TlsAcceptor, stream: TcpStream) -> Result {
let stream = acceptor.accept(stream).await?;
let mut stream = async_std::io::BufReader::new(stream);
let mut body = String::new();
stream.read_line(&mut body).await?;
eprintln!("Got request: {:?}", body);
let mut request = String::new();
stream.read_line(&mut request).await?;
let url = Url::parse(request.trim())?;
eprintln!("Got request: {:?}", url);
let mut stream = stream.into_inner();
stream.write_all(b"20 text/gemini\r\n").await?;
stream.write_all(b"=> ").await?;
stream.write_all(body.trim().as_bytes()).await?;
stream.write_all(url.as_str().as_bytes()).await?;
stream.write_all(b" Reload\r\n").await?;
Ok(())
}