sipmsg 0.2.3

SIP message parser
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

use crate::{
    common::{
        bnfcore::{is_crlf, is_token_char},
        errorparse::SipParseError,
        nom_wrappers::take_sws,
        take_sws_token,
    },
    headers::{
        header::{HeaderValue, HeaderValueType},
        traits::SipHeaderParser,
    },
};
use nom::bytes::complete::{take_until, take_while1};

// User-Agent  =  "User-Agent" HCOLON server-val *(LWS server-val)
// server-val       =  product / comment
// product          =  token [SLASH product-version]
// product-version  =  token
pub struct UserAgent;

impl SipHeaderParser for UserAgent {
    fn take_value(source_input: &[u8]) -> nom::IResult<&[u8], HeaderValue, SipParseError> {
        let mut tmp_input = source_input;
        loop {
            if tmp_input.len() < 2 || is_crlf(tmp_input) {
                break;
            }

            if tmp_input[0] == b'(' {
                let (input, _) = take_sws_token::lparen(tmp_input)?;
                let (input, _) = take_until(")")(input)?;
                let (input, _) = take_sws_token::rparen(input)?;
                tmp_input = input;
                continue;
            }

            if tmp_input[0] == b'/' {
                let (input, _) = take_sws_token::slash(tmp_input)?;
                let (input, _) = take_while1(is_token_char)(input)?;
                let (input, _) = take_sws(input)?;
                tmp_input = input;
                continue;
            }

            if tmp_input[0] == b'<' {
                let (input, _) = take_sws_token::laquot(tmp_input)?;
                let (input, _) = take_until(">")(input)?;
                let (input, _) = take_sws_token::raquot(input)?;
                tmp_input = input;
                continue;
            }

            let (input, _) = take_while1(is_token_char)(tmp_input)?;
            let (input, _) = take_sws(input)?;
            tmp_input = input;
        }

        let (_, hdr_val) = HeaderValue::new(
            &source_input[..source_input.len() - tmp_input.len()],
            HeaderValueType::UserAgent,
            None,
            None,
        )?;
        Ok((tmp_input, hdr_val))
    }
}

#[cfg(test)]
mod test {
    use super::*;
    #[test]
    fn test_server_value() {
        let (input, val) = UserAgent::take_value("HomeServer v2\r\n".as_bytes()).unwrap();
        assert_eq!(val.vstr, "HomeServer v2");
        assert_eq!(input, b"\r\n");
    }
    #[test]
    fn test_user_agent_val() {
        let user_agent = "<Motorola VT1000 mac: 000CE5C74EF8 sw:VT20_02.03.00_A ln:0 cfg:1253778536520/1002173358>";
        let ua_with_end_line = [user_agent, "\r\n"].join("");
        let (input, val) = UserAgent::take_value(ua_with_end_line.as_bytes()).unwrap();
        assert_eq!(val.vstr, user_agent);
        assert_eq!(input, b"\r\n");
    }
}