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()
    );
}