moparisthebest/xmpp-proxy
1
0
Fork 0
Code Issues Pull Requests Projects Releases 3 Wiki Activity

set SRV resolver to LookupIpStrategy::Ipv4AndIpv6

Browse Source
This commit is contained in:
Travis Burtrum 2021-05-18 00:01:49 -04:00
parent f127c02d45
commit 0d2313e86f
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/srv.rs
View File

@ -12,7 +12,13 @@ use crate::stanzafilter::StanzaReader;
use crate::*; use crate::*;
lazy_static::lazy_static! { lazy_static::lazy_static! {
static ref RESOLVER: TokioAsyncResolver = TokioAsyncResolver::tokio_from_system_conf().unwrap(); static ref RESOLVER: TokioAsyncResolver = make_resolver();
}
fn make_resolver() -> TokioAsyncResolver {
let (config, mut options) = trust_dns_resolver::system_conf::read_system_conf().unwrap();
options.ip_strategy = trust_dns_resolver::config::LookupIpStrategy::Ipv4AndIpv6;
TokioAsyncResolver::tokio(config, options).unwrap()
} }
#[derive(Copy, Clone, Debug)] #[derive(Copy, Clone, Debug)]
@ -200,7 +206,15 @@ mod tests {
use crate::srv::*; use crate::srv::*;
#[tokio::test] #[tokio::test]
async fn srv() -> Result<()> { async fn srv() -> Result<()> {
get_xmpp_connections("burtrum.org", true).await?; let domain = "moparisthebest.com";
let is_c2s = true;
for srv in get_xmpp_connections(domain, is_c2s).await? {
let ips = RESOLVER.lookup_ip(srv.target.clone()).await?;
debug!("trying 1 domain {}, SRV: {:?}", domain, srv);
for ip in ips.iter() {
debug!("trying domain {}, ip {}, is_c2s: {}, SRV: {:?}", domain, ip, is_c2s, srv);
}
}
Ok(()) Ok(())
} }
} }