rtp-parse 0.2.0

RTP packet 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

use parsely_rs::*;

use super::header_extensions::HeaderExtensions;

/// An RTP header
///
/// https://tools.ietf.org/html/rfc3550#section-5.1
///  0                   1                   2                   3
///  0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
/// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
/// |V=2|P|X|  CC   |M|     PT      |       sequence number         |
/// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
/// |                           timestamp                           |
/// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
/// |           synchronization source (SSRC) identifier            |
/// +=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+
/// |            contributing source (CSRC) identifiers             |
/// |                             ....                              |
/// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
/// |              ...extensions (if present)...                    |
/// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
#[derive(Debug, ParselyRead, ParselyWrite, PartialEq)]
pub struct RtpHeader {
    pub version: u2,
    pub has_padding: bool,
    pub has_extensions: bool,
    pub csrc_count: u4,
    pub marked: bool,
    pub payload_type: u7,
    pub seq_num: u16,
    pub timestamp: u32,
    pub ssrc: u32,
    #[parsely_read(count = "csrc_count.into()")]
    pub csrcs: Vec<u32>,
    pub extensions: HeaderExtensions,
}

impl Default for RtpHeader {
    fn default() -> Self {
        Self {
            version: u2::new(2),
            has_padding: false,
            has_extensions: false,
            csrc_count: u4::new(0),
            marked: false,
            payload_type: u7::new(0),
            seq_num: 0,
            timestamp: 0,
            ssrc: 0,
            csrcs: Vec::new(),
            extensions: HeaderExtensions::default(),
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_read_fixed_header() {
        #[rustfmt::skip]
        let mut data = Bits::from_static_bytes(&[
            // V=2,P=false,X=true,CC=2,M=false,PT=100,SeqNum=16535
            0x92, 0x64, 0x40, 0x97,
            // Timestamp: 3899068446
            0xe8, 0x67, 0x10, 0x1e,
            // SSRC: 2828806853
            0xa8, 0x9c, 0x2a, 0xc5,
            // CSRC 1: 123456
            0x00, 0x01, 0xE2, 0x40,
            // CSRC 2: 45678
            0x00, 0x00, 0xB2, 0x6E,
            // 1 extension
            0xbe, 0xde, 0x00, 0x01,
            0x51, 0x00, 0x02, 0x00
        ]);
        let header = RtpHeader::read::<NetworkOrder>(&mut data, ()).unwrap();
        assert_eq!(header.version, 2);
        assert!(!header.has_padding);
        assert!(header.has_extensions);
        assert_eq!(header.csrc_count, 2);
        assert!(!header.marked);
        assert_eq!(header.payload_type, 100);
        assert_eq!(header.seq_num, 16535);
        assert_eq!(header.timestamp, 3899068446);
        assert_eq!(header.ssrc, 2828806853);
        assert_eq!(header.extensions.len(), 1);
        let ext = header.extensions.get_by_id(5).unwrap();
        assert_eq!(ext.data(), &[0, 2]);
    }
}