update dependencies

Author: ssrlive

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "socks5-impl"
-version = "0.5.2"
+version = "0.5.4"
 authors = ["ssrlive <[email protected]>"]
 description = "Fundamental abstractions and async read / write functions for SOCKS5 protocol and Relatively low-level asynchronized SOCKS5 server implementation based on tokio"
 categories = ["network-programming", "asynchronous"]
@@ -18,19 +18,19 @@ tokio = ["dep:tokio"]
 as-any = "0.3"
 async-trait = "0.1"
 byteorder = "1.4"
-bytes = "1.4"
+bytes = "1.5"
 thiserror = "1.0"
-tokio = { version = "1.29", features = ["full"], optional = true }
+tokio = { version = "1.32", features = ["full"], optional = true }
 
 [dev-dependencies]
-clap = { version = "4.3", features = ["derive"] }
+clap = { version = "4.4", features = ["derive"] }
 dotenvy = "0.15"
 env_logger = "0.10"
 log = "0.4"
-moka = { version = "0.11", features = ["future"] }
+moka = { version = "0.12", features = ["future"] }
 rand = "0.8"
-tokio = { version = "1.29", features = ["macros", "rt-multi-thread"] }
-trust-dns-proto = "0.22"
+tokio = { version = "1.32", features = ["macros", "rt-multi-thread"] }
+trust-dns-proto = "0.23"
 
 [[example]]
 name = "demo-client"

examples/dns.rs

@@ -34,10 +34,10 @@ pub fn extract_ipaddr_from_dns_message(message: &Message) -> Result<IpAddr, Stri
     for answer in message.answers() {
         match answer.data().ok_or("DNS response not contains answer data")? {
             RData::A(addr) => {
-                return Ok(IpAddr::V4(*addr));
+                return Ok(IpAddr::V4((*addr).into()));
             }
             RData::AAAA(addr) => {
-                return Ok(IpAddr::V6(*addr));
+                return Ok(IpAddr::V6((*addr).into()));
             }
             RData::CNAME(name) => {
                 cname = Some(name.to_utf8());

examples/dns2socks.rs

@@ -134,7 +134,7 @@ async fn udp_incoming_handler(
     let domain = dns::extract_domain_from_dns_message(&message)?;
 
     if opt.cache_records {
-        if let Some(cached_message) = dns_cache_get_message(&cache, &message) {
+        if let Some(cached_message) = dns_cache_get_message(&cache, &message).await {
             let data = cached_message.to_vec().map_err(|e| e.to_string())?;
             listener.send_to(&data, &src).await?;
             log_dns_message("DNS query via UDP cache hit", &domain, &cached_message);
@@ -202,7 +202,7 @@ async fn handle_tcp_incoming(
     let domain = dns::extract_domain_from_dns_message(&message)?;
 
     if opt.cache_records {
-        if let Some(cached_message) = dns_cache_get_message(&cache, &message) {
+        if let Some(cached_message) = dns_cache_get_message(&cache, &message).await {
             let data = cached_message.to_vec().map_err(|e| e.to_string())?;
             let len = u16::try_from(data.len()).map_err(|e| e.to_string())?.to_be_bytes().to_vec();
             let data = [len, data].concat();
@@ -268,8 +268,8 @@ pub(crate) fn create_dns_cache() -> Cache<Vec<Query>, Message> {
         .build()
 }
 
-pub(crate) fn dns_cache_get_message(cache: &Cache<Vec<Query>, Message>, message: &Message) -> Option<Message> {
-    if let Some(mut cached_message) = cache.get(&message.queries().to_vec()) {
+pub(crate) async fn dns_cache_get_message(cache: &Cache<Vec<Query>, Message>, message: &Message) -> Option<Message> {
+    if let Some(mut cached_message) = cache.get(&message.queries().to_vec()).await {
         cached_message.set_id(message.id());
         return Some(cached_message);
     }