mdns-sd-discovery 0.1.0

Async wrapper for native DNS-SD/mDNS service discovery
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use zbus::proxy;

/// Avahi protocol constant: unspecified address family (IPv4 or IPv6).
pub const AVAHI_PROTO_UNSPEC: i32 = -1;
/// Avahi interface constant: unspecified (all) interfaces.
pub const AVAHI_IF_UNSPEC: i32 = -1;

/// The resolved data returned by `Server.ResolveService`:
/// `(interface, protocol, name, type, domain, host, aprotocol, address, port, txt, flags)`.
pub type ResolvedService = (
    i32,
    i32,
    String,
    String,
    String,
    String,
    i32,
    String,
    u16,
    Vec<Vec<u8>>,
    u32,
);

#[proxy(
    interface = "org.freedesktop.Avahi.Server",
    default_service = "org.freedesktop.Avahi",
    default_path = "/"
)]
pub trait Avahi {
    #[zbus(object = "ServiceTypeBrowser")]
    fn service_type_browser_new(&self, interface: i32, protocol: i32, domain: &str, flags: u32);

    #[zbus(object = "ServiceBrowser")]
    fn service_browser_new(
        &self,
        interface: i32,
        protocol: i32,
        service_type: &str,
        domain: &str,
        flags: u32,
    );

    /// Synchronously resolves a service instance to a connectable endpoint.
    ///
    /// Unlike the signal-based `ServiceResolverNew`, this returns the resolved
    /// data directly as a method reply, avoiding any subscribe-after-create race.
    #[allow(clippy::too_many_arguments)]
    fn resolve_service(
        &self,
        interface: i32,
        protocol: i32,
        name: &str,
        service_type: &str,
        domain: &str,
        aprotocol: i32,
        flags: u32,
    ) -> zbus::Result<ResolvedService>;
}

// The browser objects only need `Free`; their `ItemNew`/`ItemRemove`/`Failure`
// signals are consumed via a raw `MessageStream` that is subscribed *before* the
// browser is created, so the initial (cached) signal burst is not missed.
#[proxy(
    interface = "org.freedesktop.Avahi.ServiceTypeBrowser",
    default_service = "org.freedesktop.Avahi"
)]
pub trait ServiceTypeBrowser {
    fn free(&self) -> zbus::Result<()>;
}

#[proxy(
    interface = "org.freedesktop.Avahi.ServiceBrowser",
    default_service = "org.freedesktop.Avahi"
)]
pub trait ServiceBrowser {
    fn free(&self) -> zbus::Result<()>;
}