Fix bugs

src/handlers/update/authenticate.rs

@@ -1,4 +1,5 @@
 use diesel::PgConnection;
+use reqwest::header::ACCEPT;
 
 use crate::{
     config::Config,
@@ -34,16 +35,20 @@ pub async fn authenticate(
 }
 
 async fn validate_ssh(username: &String, sig: &Sig) -> Result<bool, reqwest::Error> {
-    Ok(reqwest::get(format!(
+    let client = reqwest::Client::new();
-        "{}/users/keys/{}",
+    Ok(client
-        Config::get().zauth_url,
+        .get(format!(
-        username
+            "{}/users/{}/keys",
-    ))
+            Config::get().zauth_url,
-    .await?
+            username
-    .json::<Vec<String>>()
+        ))
-    .await?
+        .header(ACCEPT, "application/json")
-    .iter()
+        .send()
-    .any(|key| sig.verify_ssh(&key).is_ok_and(|b| b)))
+        .await?
+        .json::<Vec<String>>()
+        .await?
+        .iter()
+        .any(|key| sig.verify_ssh(&key).is_ok_and(|b| b)))
 }
 
 async fn validate_dnskey(

src/reader.rs

@@ -71,7 +71,9 @@ impl<'a> Reader<'a> {
                 message: String::from("Seeking into the future is not allowed!!"),
             })
         } else {
-            Ok(Reader::new(&self.buffer[position..self.position]))
+            let mut reader = Reader::new(&self.buffer[0..self.position]);
+            reader.position = position;
+            Ok(reader)
         }
     }
 }

src/resolver.rs

@@ -50,7 +50,6 @@ async fn get_response(bytes: &[u8]) -> Message {
                 response
             }
             Err(e) => {
-                println!("{:#?}", message);
                 eprintln!("{}", e.to_string());
                 message.set_response(e.rcode());
                 message