ssdp 0.1.1

An asynchronous abstraction for discovering devices and services on a network.
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

//! Messaging primitives for discovering devices and services.

use std::io::{self};
use std::net::{self, SocketAddr, Ipv4Addr};

use net::connector::{UdpConnector};

mod notify;
mod search;
mod ssdp;

pub use message::search::{SearchRequest, SearchResponse};
pub use message::notify::{NotifyMessage, NotifyListener};

/// Multicast Socket Information
const UPNP_MULTICAST_ADDR: &'static str = "239.255.255.250";
const UPNP_MULTICAST_PORT: u16          = 1900;

/// Default TTL For Multicast
const UPNP_MULTICAST_TTL: i32 = 2;

/// Enumerates different types of SSDP messages.
#[derive(Copy, Clone, Hash, Eq, PartialEq, Debug)]
pub enum MessageType {
    /// A notify message.
    Notify,
    /// A search message.
    Search,
    /// A response to a search message.
    Response
}

/// Generate UdpConnector objects for all local IPv4 interfaces.
fn all_local_connectors(multicast_ttl: Option<i32>) -> io::Result<Vec<UdpConnector>> {
    map_local_ipv4(|&addr| UdpConnector::new((addr, 0), multicast_ttl))
}

/// Generate a list of some object R constructed from all local Ipv4Addr objects.
///
/// If any of the SocketAddrs fail to resolve, this function will not return an error.
fn map_local_ipv4<F, R>(mut f: F) -> io::Result<Vec<R>>
    where F: FnMut(&Ipv4Addr) -> io::Result<R> {
    let host_iter = try!(net::lookup_host(""));
    let mut obj_list = match host_iter.size_hint() {
        (_, Some(n)) => Vec::with_capacity(n),
        (_, None)    => Vec::new()
    };
    
    for host in host_iter.filter_map(|host| host.ok()) {
        match host {
            SocketAddr::V4(n) => obj_list.push(try!(f(n.ip()))),
            _ => ()
        }
    }
    
    Ok(obj_list)
}