Add RFC4475 Short Tortuous INVITE

crates/sipmsg/tests/rfc4475.rs

@@ -0,0 +1,229 @@
+use sipmsg::*;
+
+#[test]
+fn parse_request() {
+    let invite_msg_buf = "INVITE sip:vivekg@chair-dnrc.example.com;unknownparam SIP/2.0\r\n\
+    TO :\r\n \
+     sip:vivekg@chair-dnrc.example.com ;   tag    = 1918181833n\r\n\
+    from   : \"J Rosenberg \\\"\"       <sip:jdrosen@example.com>\r\n \
+      ;\r\n \
+      tag = 98asjd8\r\n\
+    MaX-fOrWaRdS: 0068\r\n\
+    Call-ID: wsinv.ndaksdj@192.0.2.1\r\n\
+    Content-Length   : 150\r\n\
+    cseq: 0009\r\n \
+      INVITE\r\n\
+    Via  : SIP  /   2.0\r\n \
+     /UDP\r\n \
+        192.0.2.2;branch=390skdjuw\r\n\
+    s :\r\n\
+    NewFangledHeader:   newfangled value\r\n \
+     continued newfangled value\r\n\
+    UnknownHeaderWithUnusualValue: ;;,,;;,;\r\n\
+    Content-Type: application/sdp\r\n\
+    Route: \r\n \
+     <sip:services.example.com;lr;unknownwith=value;unknown-no-value>\r\n\
+    v:  SIP  / 2.0  / TCP     spindle.example.com   ;\r\n \
+      branch  =   z9hG4bK9ikj8  ,\r\n \
+     SIP  /    2.0   / UDP  192.168.255.111   ; branch=\r\n \
+     z9hG4bK30239\r\n\
+    m:\"Quoted string \\\"\\\"\" <sip:jdrosen@example.com> ; newparam =\r\n \
+          newvalue ;\r\n \
+          secondparam ; q = 0.33\r\n\
+    \r\n\
+    v=0\
+    o=mhandley 29739 7272939 IN IP4 192.0.2.3\
+    s=-\
+    c=IN IP4 192.0.2.4\
+    t=0 0\
+    m=audio 49217 RTP/AVP 0 12\
+    m=video 3227 RTP/AVP 31\
+    a=rtpmap:31 LPC"
+        .as_bytes();
+
+    let res = SipRequest::parse(invite_msg_buf);
+    let (_, parsed_req) = res.unwrap();
+    let request_line = &parsed_req.rl;
+    let headers = &parsed_req.headers;
+    assert_eq!(request_line.method, SipMethod::INVITE);
+    assert_eq!(request_line.uri.scheme, SipRequestUriScheme::SIP);
+    assert_eq!(request_line.uri.user_info().unwrap().value, "vivekg");
+    assert_eq!(request_line.uri.hostport.host, "chair-dnrc.example.com");
+    assert_eq!(request_line.sip_version, SipVersion(2, 0));
+    assert_eq!(
+        request_line.uri.params().unwrap().get(&"unknownparam"),
+        Some(&None)
+    );
+
+    let to_hdr = headers.get_rfc_s(SipRFCHeader::To).unwrap();
+    assert_eq!(
+        to_hdr.params().unwrap().get(&"tag"),
+        Some(&Some("1918181833n"))
+    );
+    assert_eq!(to_hdr.value.vstr, "sip:vivekg@chair-dnrc.example.com");
+
+    let from_hdr = headers.get_rfc_s(SipRFCHeader::From).unwrap();
+    assert_eq!(
+        from_hdr.value.vstr,
+        "\"J Rosenberg \\\"\"       <sip:jdrosen@example.com>"
+    );
+    assert_eq!(
+        from_hdr.value.tags().unwrap()[&SipHeaderTagType::DisplayName],
+        b"J Rosenberg \\\""
+    );
+    assert_eq!(
+        from_hdr.value.sip_uri().unwrap().user_info().unwrap().value,
+        "jdrosen"
+    );
+    assert_eq!(
+        from_hdr.value.sip_uri().unwrap().hostport.host,
+        "example.com"
+    );
+    assert_eq!(
+        from_hdr.params().unwrap().get(&"tag"),
+        Some(&Some("98asjd8"))
+    );
+
+    let max_forwards = parsed_req
+        .headers
+        .get_rfc_s(SipRFCHeader::MaxForwards)
+        .unwrap();
+    assert_eq!(max_forwards.value.vstr, "0068");
+    assert_eq!(max_forwards.params(), None);
+    assert_eq!(max_forwards.value.vtype, SipHeaderValueType::Digit);
+
+    let call_id = headers.get_rfc_s(SipRFCHeader::CallID).unwrap();
+    assert_eq!(call_id.value.vstr, "wsinv.ndaksdj@192.0.2.1");
+    assert_eq!(
+        call_id.value.tags().unwrap()[&SipHeaderTagType::ID],
+        b"wsinv.ndaksdj"
+    );
+    assert_eq!(
+        call_id.value.tags().unwrap()[&SipHeaderTagType::Host],
+        b"192.0.2.1"
+    );
+
+    let content_length = &parsed_req
+        .headers
+        .get_rfc_s(SipRFCHeader::ContentLength)
+        .unwrap();
+    assert_eq!(content_length.value.vstr, "150");
+
+    let cseq_header = &headers.get_rfc_s(SipRFCHeader::CSeq).unwrap();
+    assert_eq!(cseq_header.value.vstr, "0009\r\n INVITE");
+    assert_eq!(cseq_header.params(), None);
+    assert_eq!(
+        cseq_header.value.tags().unwrap()[&SipHeaderTagType::Number],
+        b"0009"
+    );
+    assert_eq!(
+        cseq_header.value.tags().unwrap()[&SipHeaderTagType::Method],
+        b"INVITE"
+    );
+
+    let via_hdrs = headers.get_rfc(SipRFCHeader::Via).unwrap();
+    let first_via = &via_hdrs[0];
+    assert_eq!(first_via.value.vstr, "SIP  /   2.0\r\n /UDP\r\n 192.0.2.2");
+    assert_eq!(
+        first_via.params().unwrap().get(&"branch"),
+        Some(&Some("390skdjuw"))
+    );
+
+    assert_eq!(
+        first_via.value.tags().unwrap()[&SipHeaderTagType::ProtocolName],
+        b"SIP"
+    );
+    assert_eq!(
+        first_via.value.tags().unwrap()[&SipHeaderTagType::ProtocolVersion],
+        b"2.0"
+    );
+    assert_eq!(
+        first_via.value.tags().unwrap()[&SipHeaderTagType::ProtocolTransport],
+        b"UDP"
+    );
+    assert_eq!(
+        first_via.value.tags().unwrap()[&SipHeaderTagType::Host],
+        b"192.0.2.2"
+    );
+
+    let seond_via = &via_hdrs[1];
+    assert_eq!(
+        seond_via.value.tags().unwrap()[&SipHeaderTagType::ProtocolTransport],
+        b"TCP"
+    );
+    assert_eq!(
+        seond_via.value.vstr,
+        "SIP  / 2.0  / TCP     spindle.example.com"
+    );
+    assert_eq!(
+        seond_via.value.tags().unwrap()[&SipHeaderTagType::Host],
+        b"spindle.example.com"
+    );
+    assert_eq!(
+        seond_via.params().unwrap().get(&"branch"),
+        Some(&Some("z9hG4bK9ikj8"))
+    );
+
+    let subject_hdr = &headers.get_rfc_s(SipRFCHeader::Subject).unwrap();
+    assert_eq!(subject_hdr.value.vtype, SipHeaderValueType::EmptyValue);
+
+    let new_fangled_header = &headers.get_ext_s("newfangledheader").unwrap();
+    assert_eq!(
+        new_fangled_header.value.vstr,
+        "newfangled value\r\n continued newfangled value"
+    );
+
+    let unknown_header_with_unusual_value =
+        &headers.get_ext_s("unknownHeaderwithunusualValue").unwrap();
+    assert_eq!(unknown_header_with_unusual_value.value.vstr, ";;,,;;,;");
+
+    let content_type = &headers.get_rfc_s(SipRFCHeader::ContentType).unwrap();
+    assert_eq!(content_type.value.vstr, "application/sdp");
+
+    let route_header = &headers.get_rfc_s(SipRFCHeader::Route).unwrap();
+    assert_eq!(
+        route_header.value.vstr,
+        "<sip:services.example.com;lr;unknownwith=value;unknown-no-value>"
+    );
+    let route_uri = &route_header.value.sip_uri().unwrap();
+    let route_uri_params = &route_uri.params().unwrap();
+    assert_eq!(route_uri.scheme, sipuri::RequestUriScheme::SIP);
+    assert_eq!(route_uri.hostport.host, "services.example.com");
+    assert_eq!(route_uri_params.get(&"lr"), Some(&None));
+    assert_eq!(route_uri_params.get(&"unknownwith"), Some(&Some("value")));
+    assert_eq!(route_uri_params.get(&"unknown-no-value"), Some(&None));
+    assert_eq!(route_uri_params.get(&"missing_param"), None);
+
+    let contact = &headers.get_rfc_s(SipRFCHeader::Contact).unwrap();
+    assert_eq!(
+        contact.value.vstr,
+        "\"Quoted string \\\"\\\"\" <sip:jdrosen@example.com>"
+    );
+    assert_eq!(
+        contact.value.tags().unwrap()[&SipHeaderTagType::DisplayName],
+        b"Quoted string \\\"\\\""
+    );
+    let contact_params = contact.params().unwrap();
+    assert_eq!(contact_params.get(&"newparam"), Some(&Some("newvalue")));
+    assert_eq!(contact_params.get(&"secondparam"), Some(&None));
+    assert_eq!(contact_params.get(&"q"), Some(&Some("0.33")));
+
+    let contact_uri = &contact.value.sip_uri().unwrap();
+    assert_eq!(contact_uri.scheme, sipuri::RequestUriScheme::SIP);
+    assert_eq!(contact_uri.user_info().unwrap().value, "jdrosen");
+    assert_eq!(contact_uri.hostport.host, "example.com");
+    assert_eq!(contact_uri.params(), None);
+    /*********************************************************/
+    assert_eq!(
+        parsed_req.body.unwrap(),
+        "v=0\
+    o=mhandley 29739 7272939 IN IP4 192.0.2.3\
+    s=-\
+    c=IN IP4 192.0.2.4\
+    t=0 0\
+    m=audio 49217 RTP/AVP 0 12\
+    m=video 3227 RTP/AVP 31\
+    a=rtpmap:31 LPC"
+            .as_bytes()
+    );
+}