#![allow(clippy::uninlined_format_args)] use tor_basic_utils::test_rng::testing_rng; use tor_bytes::Error as BytesError; use tor_cell::chancell::msg::HandshakeType; /// Example relay messages to encode and decode. /// /// Except where noted, these were taken by instrumenting Tor /// 0.4.5.0-alpha-dev to dump all of its cells to the logs, and /// running in a chutney network with "test-network-all". use tor_cell::relaycell::{msg, RelayCmd, RelayMsg}; use tor_linkspec::LinkSpec; use tor_llcrypto::pk::rsa::RsaIdentity; use std::net::{IpAddr, Ipv4Addr, SocketAddr}; use hex_literal::hex; #[cfg(feature = "hs")] use tor_cell::relaycell::hs; #[cfg(feature = "experimental-udp")] use tor_cell::relaycell::udp; /// Decode `s`, a hexadecimal value that may have spaces in it. /// /// Panic if the input is not valid hexadecimal fn unhex(s: &str) -> Vec { let mut s = s.to_string(); s.retain(|c| !c.is_whitespace()); hex::decode(s).unwrap() } fn decode(cmd: RelayCmd, body: &[u8]) -> Result { let mut r = tor_bytes::Reader::from_slice_for_test(body); msg::AnyRelayMsg::decode_from_reader(cmd, &mut r) } /// Assert that, when treated as a cell of type `cmd`, the hexadecimal /// body `s` decodes into the message `msg`, and then re-encodes into /// `s2`. fn msg_noncanonical(cmd: RelayCmd, s: &str, s2: &str, msg: &msg::AnyRelayMsg) { assert_eq!(msg.cmd(), cmd); let body = unhex(s); let body2 = unhex(s2); let decoded = decode(cmd, &body[..]).unwrap(); // This is a bit kludgey: we don't implement PartialEq for // messages, but we do implement Debug. That actually seems a // saner arrangement to me as of this writing. assert_eq!(format!("{:?}", decoded), format!("{:?}", msg)); let mut encoded1 = Vec::new(); let mut encoded2 = Vec::new(); decoded.encode_onto(&mut encoded1).expect("Encoding error."); msg.clone() .encode_onto(&mut encoded2) .expect("Encoding error"); assert_eq!(encoded1, encoded2); assert_eq!(body2, encoded2); } /// Assert that, when treated as a cell of type `cmd`, the hexadecimal /// body `s` decodes into the message `msg`, and then re-encodes into /// `s`. fn msg(cmd: RelayCmd, s: &str, msg: &msg::AnyRelayMsg) { msg_noncanonical(cmd, s, s, msg); } /// Assert that, when treated as a cell of type `cmd`, the hexadecimal /// body `s` does not decode, and gives an error equal to `err`. fn msg_error(cmd: RelayCmd, s: &str, e: BytesError) { let body = unhex(s); let decoded = decode(cmd, &body[..]); assert_eq!(decoded.unwrap_err(), e); } #[test] fn test_begin() { let cmd = RelayCmd::BEGIN; assert_eq!(Into::::into(cmd), 1_u8); msg( cmd, "3132372E302E302E313A3730303300", &msg::Begin::new("127.0.0.1", 7003, 0).unwrap().into(), ); // hand-generated test, with flags set. msg( cmd, "7777772e786b63642e636f6d3a34343300 00000003", &msg::Begin::new("www.xkcd.com", 443, 3).unwrap().into(), ); // hand-generated test, with IPv6 set. msg( cmd, "5b323030313a6462383a3a315d3a323200", &msg::Begin::new("2001:db8::1", 22, 0).unwrap().into(), ); // hand-generated failure case: no port after ipv6. msg_error( cmd, "5b3a3a5d21", // [::]! BytesError::InvalidMessage("missing port in begin cell".into()), ); // hand-generated failure case: not ascii. msg_error( cmd, "746f7270726f6a656374e284a22e6f72673a34343300", // torproject™.org:443 BytesError::InvalidMessage("target address in begin cell not ascii".into()), ); // failure on construction: bad address. assert!(matches!( msg::Begin::new("www.torproject™.org", 443, 0), Err(tor_cell::Error::BadStreamAddress) )); } #[test] fn test_begindir() { let cmd = RelayCmd::BEGIN_DIR; assert_eq!(Into::::into(cmd), 13_u8); msg(cmd, "", &msg::AnyRelayMsg::BeginDir(Default::default())); } #[test] fn test_connected() { let cmd = RelayCmd::CONNECTED; assert_eq!(Into::::into(cmd), 4_u8); msg(cmd, "", &msg::Connected::new_empty().into()); let localhost = "127.0.0.1".parse::().unwrap(); msg( cmd, "7F000001 00000E10", &msg::Connected::new_with_addr(localhost, 0xe10).into(), ); // hand-generated for IPv6 let addr = "2001:db8::1122".parse::().unwrap(); msg( cmd, "00000000 06 20010db8 00000000 00000000 00001122 00000E10", &msg::Connected::new_with_addr(addr, 0xe10).into(), ); // hand-generated: bogus address type. msg_error( cmd, "00000000 07 20010db8 00000000 00000000 00001122 00000E10", BytesError::InvalidMessage("Invalid address type in CONNECTED cell".into()), ); } #[test] fn test_drop() { let cmd = RelayCmd::DROP; assert_eq!(Into::::into(cmd), 10_u8); msg(cmd, "", &msg::AnyRelayMsg::Drop(Default::default())); } #[test] fn test_end() { let cmd = RelayCmd::END; assert_eq!(Into::::into(cmd), 3_u8); msg(cmd, "01", &msg::End::new_misc().into()); msg(cmd, "06", &msg::End::new_with_reason(6.into()).into()); // hand-generated, for exit policy rejections let localhost = "127.0.0.7".parse::().unwrap(); msg( cmd, "04 7f000007 00000100", &msg::End::new_exitpolicy(localhost, 256).into(), ); let addr = "2001:db8::f00b".parse::().unwrap(); msg( cmd, "04 20010db8 00000000 00000000 0000f00b 00000200", &msg::End::new_exitpolicy(addr, 512).into(), ); // hand-generated to be empty. msg_noncanonical(cmd, "", "01", &msg::End::new_misc().into()); // hand-generated with no TTL. msg_noncanonical( cmd, "04 7f000007", "04 7f000007 ffffffff", &msg::End::new_exitpolicy(localhost, 0xffffffff).into(), ); } #[test] fn test_extend2() { let cmd = RelayCmd::EXTEND2; assert_eq!(Into::::into(cmd), 14_u8); // TODO: test one with more link specifiers. let body = "02 00 06 7F0000011388 02 14 03479E93EBF3FF2C58C1C9DBF2DE9DE9C2801B3E 0002 0054 03479E93EBF3FF2C58C1C9DBF2DE9DE9C2801B3E36A3E0BDB1F1A10579820243DD2E228B902940EB49EF842646E3926768C28410074BEE50A535116D657C6BFB7E5114119DC69F05DF907EF62002EA782B0A357F"; let handshake = hex::decode("03479E93EBF3FF2C58C1C9DBF2DE9DE9C2801B3E36A3E0BDB1F1A10579820243DD2E228B902940EB49EF842646E3926768C28410074BEE50A535116D657C6BFB7E5114119DC69F05DF907EF62002EA782B0A357F").unwrap(); let rsa = RsaIdentity::from_bytes(&hex::decode("03479E93EBF3FF2C58C1C9DBF2DE9DE9C2801B3E").unwrap()) .unwrap(); let addr = "127.0.0.1:5000".parse::().unwrap(); let ls = vec![ LinkSpec::from(addr).encode().unwrap(), LinkSpec::from(rsa).encode().unwrap(), ]; msg( cmd, body, &msg::Extend2::new(ls, HandshakeType::NTOR, handshake.clone()).into(), ); let message = decode(cmd, &unhex(body)[..]).unwrap(); if let msg::AnyRelayMsg::Extend2(message) = message { assert_eq!(message.handshake_type(), HandshakeType::NTOR); assert_eq!(message.handshake(), &handshake[..]); } else { panic!("that wasn't an extend2"); } } #[test] fn test_extend() { let cmd = RelayCmd::EXTEND; assert_eq!(Into::::into(cmd), 6_u8); let body = "7F000001 138C 71510FC729E1DBE35586F0031D69A38FC684B26D657821EE640C299BA9F8FD38D3A3376F2DD3A79A0B73836AB4B42E5FB3BEE1383F3184A852B292626DCC64AF672A8FAEFC263C38370768EF9EA6C244BA079142D3E23835F6914DE0C7F468316C4265E109F5312987275D61E1DC831A3323195DDE70841CEE2DC30F6DCDBDABA40A75FDFB714431FC5EB8F84D4150EE2C2478A79018F18D7F30F6BB677516CF03390F5180B371DEAEBB89175798864D2130B13ED1D20B254F07 CF555174CBE8AD62A7E764A8F3D85D40C5145ABB"; let addr = "127.0.0.1".parse::().unwrap(); let handshake = hex::decode("71510FC729E1DBE35586F0031D69A38FC684B26D657821EE640C299BA9F8FD38D3A3376F2DD3A79A0B73836AB4B42E5FB3BEE1383F3184A852B292626DCC64AF672A8FAEFC263C38370768EF9EA6C244BA079142D3E23835F6914DE0C7F468316C4265E109F5312987275D61E1DC831A3323195DDE70841CEE2DC30F6DCDBDABA40A75FDFB714431FC5EB8F84D4150EE2C2478A79018F18D7F30F6BB677516CF03390F5180B371DEAEBB89175798864D2130B13ED1D20B254F07").unwrap(); let rsa = RsaIdentity::from_bytes(&hex::decode("CF555174CBE8AD62A7E764A8F3D85D40C5145ABB").unwrap()) .unwrap(); msg( cmd, body, &msg::Extend::new(addr, 5004, handshake, rsa).into(), ); } #[test] fn test_extended2() { let cmd = RelayCmd::EXTENDED2; assert_eq!(Into::::into(cmd), 15_u8); let body = "0040 0026619058EB2661834D54C2624828728F28915587CDAD1AD3373B85F33A480EEA9D3B2CEF8D39C1DBD2FA519E75296B96960690C79A28D6A0D9454F8E9634BD"; let handshake = hex::decode("0026619058EB2661834D54C2624828728F28915587CDAD1AD3373B85F33A480EEA9D3B2CEF8D39C1DBD2FA519E75296B96960690C79A28D6A0D9454F8E9634BD").unwrap(); msg(cmd, body, &msg::Extended2::new(handshake).into()); } #[test] fn test_extended() { let cmd = RelayCmd::EXTENDED; assert_eq!(Into::::into(cmd), 7_u8); let body = "2B079274DEB8B0A03F7BCCA65813FF557ECB6362C44BE4AC0374E5255540D2712ADBE0E858FD433DD2EB473D85D3C69A457DDE9B7F28E95833EDA57416B9409B68271FFF420F57C53EC1B823491C543C69D06A56A20AB95DD595EE2B16F1AAB24E6314E36D80DF76A67970263AC4902DE692A6AF2FE0B16DF6A9E9124675FAB94A4CF7D65D0F3EBA05682F9DC76A2C47DD3566B3"; let handshake = hex::decode(body).unwrap(); msg(cmd, body, &msg::Extended::new(handshake).into()); } #[test] fn test_truncated() { let cmd = RelayCmd::TRUNCATED; assert_eq!(Into::::into(cmd), 9_u8); msg(cmd, "08", &msg::Truncated::new(8.into()).into()); } /* For circuit padding: fn test_padding_negotiate() { let cmd = RelayCmd::PADDING_NEGOTIATE; assert_eq!(Into::::into(cmd), 41_u8); msg(cmd, "0002000000000001", ... ); } PADDING_NEGOTIATED, 42, "0001010000000001" PADDING_NEGOTIATED, 42, "0002010000000001" PADDING_NEGOTIATED, 42, "0002010100000001" */ /* For onion services only: ESTABLISH_INTRO, 32, "008C30818902818100D2419B56BFB89D35EE9EB6FD328EDE897C29DA6DF68E589812D2EEC030C55A56FB010E06097A0A93EEDD8DE351A32DAAF5C7B232DC22E549EF25E8CF5E338C1C12C7828624E61B2700E931B7D532951E8907A477720B087840B7AD9D487D9F1AFBEAEAD2A7C3D9D1EB0E579FFEB9AC2BAA181FE76397D299C469B46969906BD9020301000169529D1D09554CA1C45083A7DDC96BAE22146FC09BD3B9266D17CDEE66EB2D0B7ABBC828ED300BEC8851A2178AFE0FC671D7CC7A7C0A36BE854BBD6AAD7AF4C44F32B804788B5EDA2C0AB041E61AC6C901DCB212356E8D2A00463D6A5B17C1A2DAA409A8E926FAF6592A8C7CF2B45FD8C4A218595016BF52098878FD6B1EDB11D91D32D1B62DED57AB67AB69886E1374B56CFB9E" ESTABLISH_INTRO, 32, "0200200450EFF847E40C180888F5EB9179F9B59F043385834B4C373C328E12FDFF46B400546514E3BA58E95409828A235B6390B3729B4CB8E8607024081C860E1A0D40DC0040AF031A801FE9822853D4674C5061B0352F7E2487415E25E25554C0DBF88146BCA9EBD2BD62338ADF3CC217658110EF38DB505C77B2FB38A1C0AF3C22C948F604" ESTABLISH_RENDEZVOUS, 33, "4AA2BAF815CEBB4B922B5BF6F545AEE0DDBE1254" INTRODUCE1, 34, "000000000000000000000000000000000000000002002011AAA1BA28353424061A63326C3BFF4FE4EC7EC24BB5EB740E9D167DEF103206001E99C1B9B0C24E6C63E9A182C33A8969DF94D08FD9FE98D82E21B262AE6CBC4E58971D6A38426C5D52519AB03377274AF74D2332C8FB599BFCBC5F2B02ECDAC4025EE24B63A824101E29EB9917B1C3A72E16FA2336DC81D0D483D31B9181F7CF628272FA7988301ADCE3B400880C25633718503B10C9F8909DFA50AEEDB90D7FD9D0090DBFAC4E61D527F97FD8C0A8BAB3DABF9A5E3C7FCD5FF843905F2C401743F5019B04A2F1427D3B2343A388846B7EACDD9FD46A24776D0DDDE3696A90EE36DC4732A95BFAFF871AEDE3BB5DD86047905B716148A27FF3C8A5B0F5282DD5430DA7E2A421D5274281EAC6C0EAE94EB17996EE81953FB700DD6D1DC4B7" INTRODUCE1, 34, "3AA272C26715FC3EEFE93C1CEE9ED90ACF702221338BE4032FF7CC8D7B8CF0EFB08FF51C3BCE0A289047ADF9BE51129E5FA81D40307B69577DCC3A899827D4287B00BDD661CA90BE2045D0A86FFEBF4EB9D3135B971B40D587D82F04E00EB3ED0CE3BBD70B2FF32D3BF08AD1A56EFC7C16461D7487506BC58319BFEFE936AAB18B0ACD308EF7F830370CC52A6115819EFE2BED3FC1234EDDF21321AE9D495AD7923BB0B6F275F19B636010D4E46468C366E20C5581730896BB6E2E684C75412E25A27924ED5F682122C0A7F26099E97531212558CD5E289C9CB72D1E09304037EC6A856B50B65642C20E307C4F201392C70764F3DB8AB4F6BC02C546D5FBAD4C3A4426347EECA864A990201E4AA8538104A9ABCA33716E900A7FE6A480FD40735E36C473B943E1BAA7A201397608E0C2C6B96D453B22B1C2A337463FD6BA89E9636FF6AFF0DD19FD121AB4F6605D8102E814FF1C7A31F3A07B1C49FEEC3A89299E60138349C3555D61884F35F3947A49D0E8359D72F7B6D0FCD1D8A489E668AE8A6DB3461A24109323E9BC19FF72413E" INTRODUCE_ACK, 40, "" INTRODUCE_ACK, 40, "000000" INTRO_ESTABLISHED, 38, "00" RENDEZVOUS1, 36, "1757F14E8378746756B5F91D7898084F646DCF5E537657DE71774B44A3A9840BB3D881F24792B74758D67B7B95468537CF9C706992F76AA87E0AC278C3B75B4D747251F7C92CC2FB900249A316771D82B95F669A85C38AC0AD511D00661DA38B060BD297FCC6719EAD00C0301619E20B48B1F150FA42311511E5E683C34C8CD81273683190B018239554956BDB1B8AAE0951D2B5C32CF0EB2B4CC498FABE347DF1B6F273D0E976FE" RENDEZVOUS2, 37, "2CBF819E67317EE501880FBE18515C440FB2F6AEA5D7B4349EFC478A714C237309C0FB63B35DC820513A0DEBED469B3607C06A2B7875B6394019C1081954AA1F77C141C7F4B9772D4026D3F2567CE4BAAC589E4DEACE285A33F12BEFF16FEF6120DBB2E0B1BCF78B2E765DB23464EABA3FC6C5126D551BAA32F7A179AB1BD888E0CB8F1E9CA0D8CE6583C144A551D564652829BA" RENDEZVOUS_ESTABLISHED, 39, "" */ #[test] fn test_resolve() { // these values are hand-generated. let cmd = RelayCmd::RESOLVE; assert_eq!(Into::::into(cmd), 11_u8); let body = hex::encode(b"www.torproject.org\0"); msg(cmd, &body, &msg::Resolve::new("www.torproject.org").into()); let body = hex::encode(b"1.0.0.127.in-addr.arpa\0"); let addr = "127.0.0.1".parse::().unwrap(); msg(cmd, &body, &msg::Resolve::new_reverse(&addr).into()); let body = hex::encode( &b"0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.0.1.0.0.2.ip6.arpa\0"[..], ); let addr = "2001::".parse::().unwrap(); msg(cmd, &body, &msg::Resolve::new_reverse(&addr).into()); } #[test] fn test_resolved() { // these values are hand-generated. let cmd = RelayCmd::RESOLVED; assert_eq!(Into::::into(cmd), 12_u8); msg(cmd, "", &msg::Resolved::new_empty().into()); msg( cmd, "F0 00 00000E10", &msg::Resolved::new_err(true, 3600).into(), ); msg( cmd, "F1 00 00000E10", &msg::Resolved::new_err(false, 3600).into(), ); let mut r = msg::Resolved::new_empty(); r.add_answer(msg::ResolvedVal::Ip("127.0.0.1".parse().unwrap()), 3600); r.add_answer(msg::ResolvedVal::Ip("127.0.0.2".parse().unwrap()), 7200); msg( cmd, "04 04 7f000001 00000E10 04 04 7f000002 00001c20", &r.into(), ); let mut r = msg::Resolved::new_empty(); r.add_answer(msg::ResolvedVal::Ip("1234::5678".parse().unwrap()), 128); msg( cmd, "06 10 12340000000000000000000000005678 00000080", &r.into(), ); let message = decode( cmd, &unhex("06 10 12340000000000000000000000005678 00000080")[..], ) .unwrap(); if let msg::AnyRelayMsg::Resolved(res) = message { assert_eq!( res.into_answers(), vec![(msg::ResolvedVal::Ip("1234::5678".parse().unwrap()), 128_u32)] ); } else { panic!("wrong message type"); } let mut r = msg::Resolved::new_empty(); r.add_answer(msg::ResolvedVal::Hostname("www.torproject.org".into()), 600); msg( cmd, "00 12 7777772e746f7270726f6a6563742e6f7267 00000258", &r.into(), ); // Hand-generated, to try out "unrecognized" let mut r = msg::Resolved::new_empty(); r.add_answer( msg::ResolvedVal::Unrecognized(99, "www.torproject.org".into()), 600, ); msg( cmd, "63 12 7777772e746f7270726f6a6563742e6f7267 00000258", &r.into(), ); // Hand-generated for incorrect length. msg_error( cmd, "04 03 010203 00000001", BytesError::InvalidMessage("Wrong length for RESOLVED answer".into()), ); } #[test] fn test_sendme() { // these values are hand-generated. let cmd = RelayCmd::SENDME; assert_eq!(Into::::into(cmd), 5_u8); msg(cmd, "", &msg::Sendme::new_empty().into()); let tag = hex!("F01234989823478bcdefabcdef01234567890123"); msg( cmd, "01 0014 F01234989823478bcdefabcdef01234567890123", &msg::Sendme::new_tag(tag).into(), ) } #[test] fn test_truncate() { let cmd = RelayCmd::TRUNCATE; assert_eq!(Into::::into(cmd), 8_u8); msg(cmd, "", &msg::AnyRelayMsg::Truncate(Default::default())); } #[test] fn test_unrecognized() { let cmd = 249.into(); // not an actual relay command. // Hand-generated and arbitrary: we don't parse these. msg( cmd, "617262697472617279206279746573", &msg::Unrecognized::new(cmd, &b"arbitrary bytes"[..]).into(), ); } #[test] fn test_data() { let cmd = RelayCmd::DATA; assert_eq!(Into::::into(cmd), 2_u8); // hand-generated; no special encoding. msg( cmd, "474554202f20485454502f312e310d0a0d0a", &msg::Data::new(&b"GET / HTTP/1.1\r\n\r\n"[..]) .unwrap() .into(), ); // Try creating a data cell from too much data. use rand::RngCore; let mut b = vec![0_u8; 3000]; testing_rng().fill_bytes(&mut b[..]); let d = msg::Data::new(&b[..]); assert!(d.is_err()); let (d, rest) = msg::Data::try_split_from(&b[..]).expect("Empty input?"); assert_eq!(d.as_ref(), &b[0..498]); assert_eq!(rest, &b[498..]); } #[cfg(feature = "experimental-udp")] #[test] fn test_connect_udp() { let cmd = RelayCmd::CONNECT_UDP; assert_eq!(Into::::into(cmd), 16_u8); // Valid encoded message. Generated by hand with python. msg( cmd, "00000000 01 0A 7269736575702E6E6574 01BB", &udp::ConnectUdp::new("riseup.net", 443, 0).unwrap().into(), ); // Valid encoded message with flags. Generated by hand with python. msg( cmd, "00000003 01 0E 746F7270726F6A6563742E6F7267 0050", &udp::ConnectUdp::new("torproject.org", 80, 3) .unwrap() .into(), ); let msg_ip_address = |ty: &str, h: &str, addr: &str, port: u16| { let h_len = unhex(h).len(); // Valid encoded message with IP address msg( cmd, &format!("00000000 {} {:02x} {} {:04x}", ty, h_len, h, port), &udp::ConnectUdp::new(addr, port, 0).unwrap().into(), ); // Empty address msg_error( cmd, &format!("00000000 {} 00 {:04x}", ty, port), BytesError::MissingData, ); // Address one byte too short msg_error( cmd, &format!( "00000000 {} {:02x} {} {:04x}", ty, h_len - 1, &h[2..], /* kludge */ port ), BytesError::MissingData, ); // Address one byte too long msg_error( cmd, &format!("00000000 {} {:02x} {} ff {:04x}", ty, h_len + 1, h, port), BytesError::ExtraneousBytes, ); }; // Encoded message with IPv4 msg_ip_address("04", "01020304", "1.2.3.4", 80); // Encoded message with IPv6 msg_ip_address("06", "26000001000200000000000000000004", "2600:1:2::4", 80); // This is a valid cell. Reason is that the hostname is 3 bytes plus the 2 bytes port and a tor // cell payload is for certain 498 bytes so we are just eating random bytes to create a cell. let body = unhex("00000000 01 03 746F726575702E6E6574 01BB"); assert!(decode(cmd, &body[..]).is_ok()); // Truncated as in hostname length way to big for amount of bytes. msg_error( cmd, "00000000 01 56 7269", BytesError::new_incomplete_for_test(0x56 - 2), ); // Unknown address type. msg_error( cmd, "00000000 07 04 01020304", BytesError::InvalidMessage("Invalid address type".into()), ); // A zero length address with and without hostname payload. msg( cmd, "00000000 01 00 01BB", &udp::ConnectUdp::new("", 443, 0).unwrap().into(), ); } #[cfg(feature = "experimental-udp")] #[test] fn test_connected_udp() { let cmd = RelayCmd::CONNECTED_UDP; assert_eq!(Into::::into(cmd), 17_u8); let a_ipv4 = ("1.2.3.4", 80).try_into().unwrap(); let b_ipv4 = ("5.6.7.8", 80).try_into().unwrap(); let a_ipv6 = ("2600::1", 80).try_into().unwrap(); let b_ipv6 = ("2700::1", 80).try_into().unwrap(); // Valid encoded message. Generated by hand with python. msg( cmd, "04 04 01020304 0050 04 04 05060708 0050", &udp::ConnectedUdp::new(a_ipv4, b_ipv4).unwrap().into(), ); // Valid encoded message. Generated by hand with python. msg( cmd, "06 10 26000000000000000000000000000001 0050 06 10 27000000000000000000000000000001 0050", &udp::ConnectedUdp::new(a_ipv6, b_ipv6).unwrap().into(), ); // Invalid our_address msg_error( cmd, "01 04 01020304 0050 04 04 05060708 0050", BytesError::InvalidMessage("Our address is a Hostname".into()), ); // Invalid their_address msg_error( cmd, "04 04 01020304 0050 01 04 05060708 0050", BytesError::InvalidMessage("Their address is a Hostname".into()), ); } #[cfg(feature = "hs")] #[test] fn test_establish_rendezvous() { let cmd = RelayCmd::ESTABLISH_RENDEZVOUS; assert_eq!(Into::::into(cmd), 33_u8); // Valid cookie length let cookie = [1; 20]; msg( cmd, // 20 ones "0101010101010101010101010101010101010101", &hs::EstablishRendezvous::new(cookie.into()).into(), ); // Extra bytes are ignored // 21 ones let body = "010101010101010101010101010101010101010101"; let actual_msg = decode(cmd, &unhex(body)[..]).unwrap(); let mut actual_bytes = vec![]; actual_msg .encode_onto(&mut actual_bytes) .expect("Encode msg onto byte vector"); let expected_bytes = vec![1; 20]; assert_eq!(actual_bytes, expected_bytes); // Invalid cookie length // 19 ones let body = "01010101010101010101010101010101010101"; assert_eq!( decode(cmd, &unhex(body)[..]).unwrap_err(), BytesError::new_incomplete_for_test(1), ); } #[cfg(feature = "hs")] #[test] fn test_establish_intro() { use tor_cell::relaycell::hs::{est_intro::*, UnrecognizedExt}; let cmd = RelayCmd::ESTABLISH_INTRO; let auth_key = [0x33; 32].into(); let extension_dos = DosParams::new(Some(1_i32), Some(2_i32)).expect("invalid EST_INTRO_DOS_EXT parameter(s)"); let handshake_auth = [1; 32]; let sig = [0x15; 64].into(); assert_eq!(Into::::into(cmd), 32); // Establish intro with one recognised extension let mut body = EstablishIntroDetails::new(auth_key); body.set_extension_dos(extension_dos); let es_intro = EstablishIntro::from_parts_for_test(body, handshake_auth.into(), sig); msg( cmd, "02 0020 3333333333333333333333333333333333333333333333333333333333333333 01 01 13 02 01 0000000000000001 02 0000000000000002 0101010101010101010101010101010101010101010101010101010101010101 0040 1515151515151515151515151515151515151515151515151515151515151515 1515151515151515151515151515151515151515151515151515151515151515", &es_intro.into(), ); // Establish intro with no extension let body = EstablishIntroDetails::new(auth_key); let es_intro = EstablishIntro::from_parts_for_test(body, handshake_auth.into(), sig); msg( cmd, "02 0020 3333333333333333333333333333333333333333333333333333333333333333 00 0101010101010101010101010101010101010101010101010101010101010101 0040 1515151515151515151515151515151515151515151515151515151515151515 1515151515151515151515151515151515151515151515151515151515151515", &es_intro.into(), ); // Establish intro with one recognised extension // and one unknown extension let extension_dos = DosParams::new(Some(1_i32), Some(2_i32)).expect("invalid EST_INTRO_DOS_EXT parameter(s)"); let extension_unrecognized = UnrecognizedExt::new(2.into(), vec![0]); let mut body = EstablishIntroDetails::new(auth_key); body.set_extension_dos(extension_dos); body.set_extension_other(extension_unrecognized); let es_intro = EstablishIntro::from_parts_for_test(body, handshake_auth.into(), sig); msg( cmd, "02 0020 3333333333333333333333333333333333333333333333333333333333333333 02 01 13 02 01 0000000000000001 02 0000000000000002 02 01 00 0101010101010101010101010101010101010101010101010101010101010101 0040 1515151515151515151515151515151515151515151515151515151515151515 1515151515151515151515151515151515151515151515151515151515151515", &es_intro.into(), ); } #[cfg(feature = "hs")] #[test] fn establish_intro_roundtrip() { use tor_bytes::Reader; use tor_cell::relaycell::hs::est_intro::*; let mut rng = testing_rng(); // Now, generate an ESTABLISH_INTRO message and make sure it validates. use tor_llcrypto::pk::ed25519; let keypair = ed25519::Keypair::generate(&mut rng); let body = EstablishIntroDetails::new(keypair.verifying_key().into()); let mac_key = b"Amaryllidaceae Allium cepa var. proliferum"; let signed = body .clone() .sign_and_encode(&keypair, &mac_key[..]) .unwrap(); let mut r = Reader::from_slice_for_test(&signed[..]); let parsed = EstablishIntro::decode_from_reader(RelayCmd::ESTABLISH_INTRO, &mut r).unwrap(); let parsed_body = parsed.clone().check_and_unwrap(&mac_key[..]).unwrap(); assert_eq!(format!("{:?}", parsed_body), format!("{:?}", body)); // But it won't validate if we have the wrong MAC key. let check_error = parsed.check_and_unwrap(&mac_key[..3]); assert!(check_error.is_err()); } #[cfg(feature = "hs")] #[test] fn establish_intro_canned() { use tor_bytes::Reader; use tor_cell::relaycell::hs::est_intro::*; // This message was generated by the C tor implementation, in a Chutney network. let message = unhex( "02 0020 75BC879BF697A9B12E1E10596FEF041127FECD11FDD80706AEAE35812EA74328 00 A3DF998D6749A9323035AD23DAA7F8607E4F87473A975E50A42DEC9C0E565C48 0040 5A7F5E53D55B307B5F7866AE14508DDA3412E2B3E4805176C25413CEDF204F7F 53EAECADC0844472AA7BEC3BDCBA0A65F1FCDEF397B399F534F46E535B0E6301", ); let mac_key = unhex("250CCAF964B17B621A58CD82DF5DAFD060BA5F28"); let mut r = Reader::from_slice_for_test(&message[..]); let parsed = EstablishIntro::decode_from_reader(RelayCmd::ESTABLISH_INTRO, &mut r).unwrap(); let _parsed_body = parsed.check_and_unwrap(&mac_key[..]).unwrap(); } #[cfg(feature = "hs")] #[test] fn test_introduce() { use tor_cell::relaycell::hs::{AuthKeyType, Introduce1}; // Testing with Introduce1 only should be sufficient as long as // Introduce1 and Introduce2 share the same inner body let cmd = RelayCmd::INTRODUCE1; let auth_key_type = AuthKeyType::ED25519_SHA3_256; let auth_key = vec![0, 1, 2, 3]; let encrypted = vec![1, 9, 8, 4]; assert_eq!(Into::::into(cmd), 34); // Introduce1 with no extension let intro1 = Introduce1::new(auth_key_type, auth_key, encrypted); msg( cmd, "0000000000000000000000000000000000000000 02 0004 00010203 00 01090804", &intro1.into(), ); // Introduce1 with unknown extensions let body = "0000000000000000000000000000000000000000 02 0004 00010203 02 01 01 00 02 01 00 01090804"; let actual_msg = decode(cmd, &unhex(body)[..]).unwrap(); let mut actual_bytes = Vec::new(); actual_msg .encode_onto(&mut actual_bytes) .expect("Encode msg onto byte vector"); assert_eq!(actual_bytes, unhex(body)); // Introduce1 with legacy key id msg_error( cmd, "1000000000000000000000000000000000000000 02 0004 00010203 00 01090804", BytesError::InvalidMessage("legacy key id in Introduce1.".into()), ); } // TODO: need to add tests for: // - unrecognized // - data #[cfg(feature = "hs")] #[test] fn test_rendezvous() { use tor_cell::relaycell::hs::{Rendezvous1, Rendezvous2}; use tor_hscrypto::RendCookie; let cmd1 = RelayCmd::RENDEZVOUS1; let cmd2 = RelayCmd::RENDEZVOUS2; let cookie = RendCookie::from([0; 20]); // Introduce1 with no extension let rend1 = Rendezvous1::new(cookie, hex!("123456")); msg( cmd1, "0000000000000000000000000000000000000000 123456", &rend1.clone().into(), ); let rend2: Rendezvous2 = rend1.into(); msg(cmd2, "123456", &rend2.into()); } #[cfg(feature = "hs")] #[test] fn test_introduce_ack() { use tor_cell::relaycell::hs::{IntroduceAck, IntroduceAckStatus}; let cmd = RelayCmd::INTRODUCE_ACK; let status = IntroduceAckStatus::SUCCESS; let introduce_ack = IntroduceAck::new(status); msg(cmd, "0000 00", &introduce_ack.into()) } #[cfg(feature = "hs")] #[test] fn test_intro_established() { use tor_cell::relaycell::hs::IntroEstablished; let cmd = RelayCmd::INTRO_ESTABLISHED; let intro_est = IntroEstablished::new(); msg(cmd, "00", &intro_est.into()) } #[cfg(feature = "hs")] #[test] fn testvec_intro_payload() { use tor_bytes::{Reader, Writer}; use tor_cell::relaycell::hs::intro_payload::*; use tor_linkspec::{EncodedLinkSpec, LinkSpecType}; let cookie = hex!("1EFFEACE9BE629B357ADA359071A7912DB828A5B").into(); let onion_key = OnionKey::NtorOnionKey( hex!("7D73D007977A08CD1ABAD50F6B836C718700D687E000728C357ABC7CE3C8334D") .try_into() .unwrap(), ); let link_specifiers = vec![ EncodedLinkSpec::new(LinkSpecType::ORPORT_V4, hex!("7F000001138A")), EncodedLinkSpec::new( LinkSpecType::RSAID, hex!("E48664DBCCEF9650B5D0E7B60E6DE9BCED2FB91E"), ), EncodedLinkSpec::new( LinkSpecType::ED25519ID, hex!("3FF84AA4B21453D20106BD4EDDA919386BF67D541CAA78F38BE6A08C2B3D0C4F"), ), ]; let expected = IntroduceHandshakePayload::new(cookie, onion_key, link_specifiers, None); // Taken from a modified Tor client on a chutney network. let encoded = hex!( "1EFFEACE9BE629B357ADA359071A7912DB828A5B 00 01 0020 7D73D007977A08CD1ABAD50F6B836C718700D687E000728C357ABC7CE3C8334D 03 00 06 7F000001138A 02 14 E48664DBCCEF9650B5D0E7B60E6DE9BCED2FB91E 03 20 3FF84AA4B21453D20106BD4EDDA919386BF67D541CAA78F38BE6A08C2B3D0C4F 000000000000000000000000" ); let padding_len = { let mut r = Reader::from_slice_for_test(&encoded[..]); let got: IntroduceHandshakePayload = r.extract().unwrap(); assert_eq!(format!("{got:?}"), format!("{expected:?}")); r.remaining() }; let mut v = Vec::new(); v.write(&expected).unwrap(); // There is padding so we can't do "eq" directly. assert_eq!(&v[..], &encoded[..v.len()]); assert_eq!(v.len(), encoded.len() - padding_len); }