shairplay 0.3.0

Pure Rust AirPlay server library
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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

//! RAOP-specific SDP parser. Extracts fields needed for AirPlay audio streaming.
//! Equivalent to sdp.c.
/// Parsed SDP session description with fields needed for AirPlay audio setup.
pub struct Sdp {
    version: Option<String>,
    origin: Option<String>,
    session: Option<String>,
    connection: Option<String>,
    time: Option<String>,
    media: Option<String>,
    rtpmap: Option<String>,
    fmtp: Option<String>,
    rsaaeskey: Option<String>,
    fpaeskey: Option<String>,
    aesiv: Option<String>,
    min_latency: Option<String>,
}

impl Sdp {
    /// Parse SDP data. Equivalent to sdp_init + parse_sdp_data.
    pub fn parse(data: &str) -> Self {
        let mut sdp = Self {
            version: None,
            origin: None,
            session: None,
            connection: None,
            time: None,
            media: None,
            rtpmap: None,
            fmtp: None,
            rsaaeskey: None,
            fpaeskey: None,
            aesiv: None,
            min_latency: None,
        };

        for line in data.lines() {
            let line = line.trim_end_matches('\r');
            if line.len() < 2 || line.as_bytes()[1] != b'=' {
                continue;
            }
            let value = &line[2..];
            match line.as_bytes()[0] {
                b'v' => sdp.version = Some(value.to_string()),
                b'o' => sdp.origin = Some(value.to_string()),
                b's' => sdp.session = Some(value.to_string()),
                b'c' => sdp.connection = Some(value.to_string()),
                b't' => sdp.time = Some(value.to_string()),
                b'm' => sdp.media = Some(value.to_string()),
                b'a' => {
                    if let Some(colon) = value.find(':') {
                        let key = &value[..colon];
                        let val = &value[colon + 1..];
                        match key {
                            "rtpmap" if sdp.rtpmap.is_none() => {
                                sdp.rtpmap = Some(val.to_string());
                            }
                            "fmtp" if sdp.fmtp.is_none() => {
                                sdp.fmtp = Some(val.to_string());
                            }
                            "rsaaeskey" => sdp.rsaaeskey = Some(val.to_string()),
                            "fpaeskey" => sdp.fpaeskey = Some(val.to_string()),
                            "aesiv" => sdp.aesiv = Some(val.to_string()),
                            "min-latency" => sdp.min_latency = Some(val.to_string()),
                            _ => {}
                        }
                    }
                }
                _ => {}
            }
        }

        sdp
    }

    /// SDP version (v=).
    pub fn version(&self) -> Option<&str> {
        self.version.as_deref()
    }
    /// Session origin (o=).
    pub fn origin(&self) -> Option<&str> {
        self.origin.as_deref()
    }
    /// Session name (s=).
    pub fn session(&self) -> Option<&str> {
        self.session.as_deref()
    }
    /// Connection address (c=). Used to determine IPv4/IPv6.
    pub fn connection(&self) -> Option<&str> {
        self.connection.as_deref()
    }
    /// Timing (t=).
    pub fn time(&self) -> Option<&str> {
        self.time.as_deref()
    }
    /// Media description (m=).
    pub fn media(&self) -> Option<&str> {
        self.media.as_deref()
    }
    /// RTP map (a=rtpmap).
    pub fn rtpmap(&self) -> Option<&str> {
        self.rtpmap.as_deref()
    }
    /// Format parameters (a=fmtp). Contains ALAC config.
    pub fn fmtp(&self) -> Option<&str> {
        self.fmtp.as_deref()
    }
    /// RSA-encrypted AES key (a=rsaaeskey).
    pub fn rsaaeskey(&self) -> Option<&str> {
        self.rsaaeskey.as_deref()
    }
    /// FairPlay-encrypted AES key (a=fpaeskey).
    pub fn fpaeskey(&self) -> Option<&str> {
        self.fpaeskey.as_deref()
    }
    /// AES initialization vector (a=aesiv).
    pub fn aesiv(&self) -> Option<&str> {
        self.aesiv.as_deref()
    }
    /// Minimum latency (a=min-latency).
    pub fn min_latency(&self) -> Option<&str> {
        self.min_latency.as_deref()
    }
}