fix gemini request parser, implement tests

src/request.rs

@@ -6,6 +6,7 @@ pub use titan::Titan;
 
 use anyhow::{bail, Result};
 
+/// https://geminiprotocol.net/docs/protocol-specification.gmi#requests
 pub enum Request<'a> {
     Gemini(Gemini),
     Titan(Titan<'a>),
@@ -22,7 +23,6 @@ impl<'a> Request<'a> {
             None => bail!("Empty request"),
         }
     }
-
     pub fn into_bytes(self) -> Vec<u8> {
         match self {
             Self::Gemini(this) => this.into_bytes(),

src/request/gemini.rs

@@ -7,24 +7,34 @@ pub struct Gemini {
 
 impl Gemini {
     pub fn from_bytes(buffer: &[u8]) -> Result<Self> {
-        let mut l: usize = 0;
+        if buffer.len() > 1024 {
-        for b in buffer {
+            bail!("Header bytes length reached")
-            l += 1;
+        }
-            if l > 1024 {
+        match buffer.iter().position(|&b| b == b'\r') {
-                bail!("Max header length reached!")
+            Some(n) => {
-            }
+                if buffer.get(n + 1).is_some_and(|&b| b == b'\n') {
-            if *b == b'\r' {
+                    Ok(Self {
-                continue;
+                        url: String::from_utf8(buffer[..n].to_vec())?,
-            }
+                    })
-            if *b == b'\n' {
+                } else {
-                break;
+                    bail!("LF byte not found")
-            }
+                }
+            }
+            None => bail!("CR byte not found"),
         }
-        Ok(Self {
-            url: String::from_utf8(buffer[..l].to_vec())?,
-        })
     }
     pub fn into_bytes(self) -> Vec<u8> {
-        self.url.to_string().into_bytes()
+        let mut bytes = Vec::with_capacity(self.url.len() + 2);
+        bytes.extend(self.url.into_bytes());
+        bytes.extend(b"\r\n");
+        bytes
     }
 }
+
+#[test]
+fn test() {
+    const REQUEST: &[u8] = "gemini://geminiprotocol.net\r\n".as_bytes();
+    let request = Gemini::from_bytes(REQUEST).unwrap();
+    assert_eq!(request.url, "gemini://geminiprotocol.net");
+    assert_eq!(request.into_bytes(), REQUEST);
+}