@@ -1324,7 +1324,10 @@ async fn relay_lookup_ipv4_staggered(
1324
1324
Ok ( mut addrs) => addrs
1325
1325
. next ( )
1326
1326
. map ( |ip| ip. to_canonical ( ) )
1327
- . map ( |addr| SocketAddr :: new ( addr, port) )
1327
+ . map ( |addr| {
1328
+ debug_assert ! ( addr. is_ipv4( ) , "bad DNS lookup: {:?}" , addr) ;
1329
+ SocketAddr :: new ( addr, port)
1330
+ } )
1328
1331
. ok_or ( get_relay_addr_error:: NoAddrFoundSnafu . build ( ) ) ,
1329
1332
Err ( err) => Err ( get_relay_addr_error:: DnsLookupSnafu . into_error ( err) ) ,
1330
1333
}
@@ -1353,14 +1356,16 @@ async fn relay_lookup_ipv6_staggered(
1353
1356
{
1354
1357
Ok ( mut addrs) => addrs
1355
1358
. next ( )
1356
- . map ( |ip| ip. to_canonical ( ) )
1357
- . map ( |addr| SocketAddr :: new ( addr, port) )
1359
+ . map ( |addr| {
1360
+ debug_assert ! ( addr. is_ipv6( ) , "bad DNS lookup: {:?}" , addr) ;
1361
+ SocketAddr :: new ( addr, port)
1362
+ } )
1358
1363
. ok_or ( get_relay_addr_error:: NoAddrFoundSnafu . build ( ) ) ,
1359
1364
Err ( err) => Err ( get_relay_addr_error:: DnsLookupSnafu . into_error ( err) ) ,
1360
1365
}
1361
1366
}
1362
- Some ( url:: Host :: Ipv4 ( addr ) ) => Ok ( SocketAddr :: new ( addr . into ( ) , port ) ) ,
1363
- Some ( url:: Host :: Ipv6 ( _addr ) ) => Err ( get_relay_addr_error :: NoAddrFoundSnafu . build ( ) ) ,
1367
+ Some ( url:: Host :: Ipv4 ( _addr ) ) => Err ( get_relay_addr_error :: NoAddrFoundSnafu . build ( ) ) ,
1368
+ Some ( url:: Host :: Ipv6 ( addr ) ) => Ok ( SocketAddr :: new ( addr . into ( ) , port ) ) ,
1364
1369
None => Err ( get_relay_addr_error:: InvalidHostnameSnafu . build ( ) ) ,
1365
1370
}
1366
1371
}
0 commit comments