X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Fhttp.rs;h=073ba66b50ce701ec10cdffb14e0ef24401a219f;hb=99c90e3e3a77d431e3c6b7149aa43f93a793f579;hp=5312bbba06b43aac42588653f4827aa43fba2927;hpb=c54ddf75aedb65acabadb5545ac760418d8a28d4;p=dnssec-prover diff --git a/src/http.rs b/src/http.rs index 5312bbb..073ba66 100644 --- a/src/http.rs +++ b/src/http.rs @@ -116,13 +116,16 @@ mod imp { "AAAA" => build_aaaa_proof_async(resolver_sockaddr, &query_name).await, _ => break 'ret_err, }; - let proof = if let Ok(proof) = proof_res { proof } else { + let (proof, cache_ttl) = if let Ok(proof) = proof_res { proof } else { response = ("404 Not Found", "Failed to generate proof for given domain"); break 'ret_err; }; let _ = socket.write_all( - format!("HTTP/1.1 200 OK\r\nContent-Length: {}\r\nContent-Type: application/octet-stream\r\nAccess-Control-Allow-Origin: *\r\n\r\n", proof.len()).as_bytes() + format!( + "HTTP/1.1 200 OK\r\nContent-Length: {}\r\nContent-Type: application/octet-stream\r\nCache-Control: public, max-age={}, s-maxage={}\r\nAccess-Control-Allow-Origin: *\r\n\r\n", + proof.len(), cache_ttl, cache_ttl + ).as_bytes() ).await; let _ = socket.write_all(&proof).await; return; @@ -140,7 +143,8 @@ mod imp { mod test { use super::*; - use crate::validation::{parse_rr_stream, verify_rr_stream}; + use crate::ser::parse_rr_stream; + use crate::validation::verify_rr_stream; use minreq; @@ -162,7 +166,7 @@ mod test { #[tokio::test(flavor = "multi_thread", worker_threads = 1)] async fn test_lookup_a() { - let ns = "4.4.4.4:53".parse().unwrap(); + let ns = "9.9.9.9:53".parse().unwrap(); let listener = tokio::net::TcpListener::bind("127.0.0.1:17493").await .expect("Failed to bind to socket"); tokio::spawn(imp::run_server(listener, ns)); @@ -173,7 +177,7 @@ mod test { assert_eq!(resp.status_code, 200); let rrs = parse_rr_stream(resp.as_bytes()).unwrap(); let verified_rrs = verify_rr_stream(&rrs).unwrap(); - assert_eq!(verified_rrs.verified_rrs.len(), 1); + assert!(verified_rrs.verified_rrs.len() >= 1); } #[tokio::test(flavor = "multi_thread", worker_threads = 1)]