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
extern crate ssdp;
use self::ssdp::FieldMap;
use self::ssdp::header::{HeaderMut, HeaderRef, Man, MX, ST};
use self::ssdp::message::{Multicast, SearchRequest, SearchResponse};
pub(crate) use self::ssdp::SSDPError;
use device::Speaker;
use error::*;
const SONOS_URN: &str = "schemas-upnp-org:device:ZonePlayer:1";
fn get_header(msg: &SearchResponse, header: &str) -> Result<String> {
let bytes = msg.get_raw(header).chain_err(|| ErrorKind::ParseError)?;
String::from_utf8(bytes[0].clone()).chain_err(|| ErrorKind::ParseError)
}
pub fn discover() -> Result<Vec<Speaker>> {
let mut request = SearchRequest::new();
request.set(Man);
request.set(MX(2));
request.set(ST::Target(FieldMap::URN(String::from(SONOS_URN))));
let mut speakers = Vec::new();
for (msg, src) in request.multicast()? {
let usn = get_header(&msg, "USN")?;
if !usn.contains(SONOS_URN) {
error!("Misbehaving client responded to our discovery ({})", usn);
continue;
}
speakers.push(Speaker::from_ip(src.ip()).chain_err(|| ErrorKind::ParseError)?);
}
Ok(speakers)
}