Merge branch 'main' into fix/additionals

Author: willstott101

.github/workflows/rust.yml

@@ -14,4 +14,6 @@ jobs:
     steps:
     - uses: actions/checkout@v2
     - name: Check formatting
-      run: cargo fmt -- --check
+      run: cargo +stable fmt -- --check
+    - name: Check linting
+      run: cargo +stable clippy -- -Dwarnings

.github/workflows/zeroconf_test.yaml

@@ -13,7 +13,7 @@ jobs:
     - name: Install our MSRV
       uses: dtolnay/rust-toolchain@stable
       with:
-         toolchain: "1.70"
+         toolchain: "1.74"
 
     - name: Compile example
       run: cargo build --example register

Cargo.toml

@@ -1,35 +1,33 @@
 [package]
 name = "libmdns"
-version = "0.8.0"
+version = "0.9.1"
 authors = ["Will Stott <willstott101+libmdns@gmail.com>"]
-
 description = "mDNS Responder library for building discoverable LAN services in Rust"
 repository = "https://github.com/librespot-org/libmdns"
 readme = "README.md"
 license = "MIT"
 edition = "2018"
+rust-version = "1.74"
 
 [dependencies]
 byteorder = "1.5"
-if-addrs = "0.11.0"
-hostname = "0.3.1"
-log = "0.4"
-multimap = "0.9"
-rand = "0.8"
 futures-util = "0.3"
-thiserror = "1.0"
-tokio = { version = "1.0", features = ["sync", "net", "rt"] }
-socket2 = { version = "0.5", features = ["all"] }
-
-[target.'cfg(windows)'.dependencies]
-winapi = { version = "0.3", features = ["netioapi"] }
-
-[target.'cfg(not(windows))'.dependencies]
-nix = { version = "0.27", features = ["net"] }
+hostname = "0.4"
+if-addrs = { version = "0.14", features = ["link-local"] }
+log = "0.4"
+multimap = { version = "0.10", default-features = false }
+rand = "0.9"
+socket2 = { version = "0.6", features = ["all"] }
+thiserror = "2"
+tokio = { version = "1", default-features = false, features = [
+    "sync",
+    "net",
+    "rt",
+] }
 
 [dev-dependencies]
-env_logger = { version = "0.10", default-features = false, features = [
-  "color",
-  "humantime",
-  "auto-color",
+env_logger = { version = "0.11", default-features = false, features = [
+    "color",
+    "humantime",
+    "auto-color",
 ] }

README.md

@@ -13,14 +13,14 @@ To use it, add this to your `Cargo.toml`:
 
 ```toml
 [dependencies]
-libmdns = "0.7"
+libmdns = "0.9"
 ```
 
-See the [example](https://github.com/librespot-org/libmdns/blob/stable-0.7.x/examples/register.rs) for use within code.
+See the [example](https://github.com/librespot-org/libmdns/blob/stable-0.9.x/examples/register.rs) for use within code.
 
 ## Dependencies
 
-libmdns' oldest supported Rust toolchain is `1.70.0`, _however it may compile fine on older versions of rust._
+libmdns' MSRV (oldest supported Rust toolchain) is 1.74.0.
 
 **We hold no strong garantees for sticking to a Minimum Supported Rust Version**. Please open an issue on GitHub if you need support for older compilers or different platforms.
 

examples/register.rs

@@ -3,13 +3,8 @@ pub fn main() {
     builder.parse_filters("libmdns=debug");
     builder.init();
 
-    let responder = libmdns::Responder::new().unwrap();
-    let _svc = responder.register(
-        "_http._tcp".to_owned(),
-        "libmdns Web Server".to_owned(),
-        80,
-        &["path=/"],
-    );
+    let responder = libmdns::Responder::new();
+    let _svc = responder.register("_http._tcp", "libmdns Web Server", 80, &["path=/"]);
 
     loop {
         ::std::thread::sleep(::std::time::Duration::from_secs(10));

examples/register_with_ip_list.rs

@@ -10,12 +10,7 @@ pub fn main() {
     ];
 
     let responder = libmdns::Responder::new_with_ip_list(vec).unwrap();
-    let _svc = responder.register(
-        "_http._tcp".to_owned(),
-        "libmdns Web Server".to_owned(),
-        80,
-        &["path=/"],
-    );
+    let _svc = responder.register("_http._tcp", "libmdns Web Server", 80, &["path=/"]);
 
     loop {
         ::std::thread::sleep(::std::time::Duration::from_secs(10));

examples/zeroconf_test.py

@@ -1,12 +1,12 @@
-from zeroconf import ServiceBrowser, Zeroconf, IPVersion, ZeroconfServiceTypes
+from zeroconf import ServiceBrowser, ServiceListener, Zeroconf, IPVersion, ZeroconfServiceTypes
 from time import sleep
 
 
 TYPE = "_http._tcp.local."
 NAME = "libmdns Web Server"
 
 
-class MyListener:
+class MyListener(ServiceListener):
     def __init__(self):
         self.found = []
 

src/address_family.rs

@@ -1,15 +1,10 @@
 use super::MDNS_PORT;
-use if_addrs::get_if_addrs;
+use if_addrs::{get_if_addrs, IfAddr};
 use socket2::{Domain, Protocol, SockAddr, Socket, Type};
+use std::collections::HashSet;
 use std::io;
 use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr, UdpSocket};
 
-#[cfg(not(windows))]
-use nix::net::if_::if_nametoindex;
-
-#[cfg(windows)]
-use win::if_nametoindex;
-
 pub enum Inet {}
 
 pub enum Inet6 {}
@@ -34,8 +29,7 @@ pub trait AddressFamily {
         socket.set_reuse_address(true)?;
         socket.set_nonblocking(true)?;
 
-        #[cfg(not(windows))]
-        #[cfg(not(target_os = "illumos"))]
+        #[cfg(all(unix, not(any(target_os = "solaris", target_os = "illumos"))))]
         socket.set_reuse_port(true)?;
 
         socket.bind(&addr)?;
@@ -53,14 +47,13 @@ impl AddressFamily for Inet {
     const DOMAIN: Domain = Domain::IPV4;
 
     fn join_multicast(socket: &Socket, multiaddr: &Self::Addr) -> io::Result<()> {
-        let addresses = get_address_list()?;
-        if addresses.is_empty() {
+        let addrs = get_one_nonloopback_ipv4_addr_per_iface()?;
+        if addrs.is_empty() {
             socket.join_multicast_v4(multiaddr, &Ipv4Addr::UNSPECIFIED)
         } else {
-            for (_, address) in addresses {
-                if let IpAddr::V4(ip) = address {
-                    socket.join_multicast_v4(multiaddr, &ip)?;
-                }
+            // TODO: If any join succeeds return success (log failures)
+            for ip in addrs {
+                socket.join_multicast_v4(multiaddr, &ip)?;
             }
             Ok(())
         }
@@ -76,44 +69,61 @@ impl AddressFamily for Inet6 {
     const DOMAIN: Domain = Domain::IPV6;
 
     fn join_multicast(socket: &Socket, multiaddr: &Self::Addr) -> io::Result<()> {
-        let addresses = get_address_list()?;
-        if addresses.is_empty() {
+        let indexes = get_one_nonloopback_ipv6_index_per_iface()?;
+        if indexes.is_empty() {
             socket.join_multicast_v6(multiaddr, 0)
         } else {
-            // We join multicast by interface, but each interface can have more than one ipv6 address.
-            // So we have to check we're not registering more than once, as the resulting error is then
-            // fatal to ipv6 listening.
-            // TODO: Make each interface resilient to failures on another.
-            let mut registered = Vec::new();
-            for (iface_name, address) in addresses {
-                if let IpAddr::V6(_) = address {
-                    let ipv6_index = if_nametoindex(iface_name.as_str()).unwrap_or(0);
-                    if ipv6_index != 0 && !registered.contains(&ipv6_index) {
-                        socket.join_multicast_v6(multiaddr, ipv6_index)?;
-                        registered.push(ipv6_index);
-                    }
-                }
+            // TODO: If any join succeeds return success (log failures)
+            for ipv6_index in indexes {
+                socket.join_multicast_v6(multiaddr, ipv6_index)?;
             }
             Ok(())
         }
     }
 }
 
-fn get_address_list() -> io::Result<Vec<(String, IpAddr)>> {
+fn get_one_nonloopback_ipv6_index_per_iface() -> io::Result<Vec<u32>> {
+    // There may be multiple ip addresses on a single interface and we join multicast by interface.
+    // Joining multicast on the same interface multiple times returns an error
+    // so we filter duplicate interfaces.
+    let mut collected_interfaces = HashSet::new();
     Ok(get_if_addrs()?
-        .iter()
-        .filter(|iface| !iface.is_loopback())
-        .map(|iface| (iface.name.clone(), iface.ip()))
+        .into_iter()
+        .filter_map(|iface| {
+            if iface.is_loopback() {
+                None
+            } else if matches!(iface.addr, IfAddr::V6(_)) {
+                if collected_interfaces.insert(iface.name.clone()) {
+                    iface.index
+                } else {
+                    None
+                }
+            } else {
+                None
+            }
+        })
         .collect())
 }
 
-#[cfg(windows)]
-mod win {
-    use std::ffi::{CString, NulError};
-    use winapi::shared::netioapi;
-
-    pub fn if_nametoindex(ifname: &str) -> Result<u32, NulError> {
-        let c_str = CString::new(ifname)?;
-        Ok(unsafe { netioapi::if_nametoindex(c_str.as_ptr()) })
-    }
+fn get_one_nonloopback_ipv4_addr_per_iface() -> io::Result<Vec<Ipv4Addr>> {
+    // There may be multiple ip addresses on a single interface and we join multicast by interface.
+    // Joining multicast on the same interface multiple times returns an error
+    // so we filter duplicate interfaces.
+    let mut collected_interfaces = HashSet::new();
+    Ok(get_if_addrs()?
+        .into_iter()
+        .filter_map(|iface| {
+            if iface.is_loopback() {
+                None
+            } else if let IpAddr::V4(ip) = iface.ip() {
+                if collected_interfaces.insert(iface.name.clone()) {
+                    Some(ip)
+                } else {
+                    None
+                }
+            } else {
+                None
+            }
+        })
+        .collect())
 }