|
|
@@ -7,23 +7,37 @@
|
|
|
// except according to those terms.
|
|
|
|
|
|
use std::ascii::AsciiExt;
|
|
|
+use std::cmp;
|
|
|
use std::fmt::{self, Formatter};
|
|
|
-use std::net::{Ipv4Addr, Ipv6Addr};
|
|
|
use parser::{ParseResult, ParseError};
|
|
|
-use percent_encoding::{percent_decode};
|
|
|
+use percent_encoding::{from_hex, percent_decode};
|
|
|
|
|
|
|
|
|
/// The host name of an URL.
|
|
|
#[derive(PartialEq, Eq, Clone, Debug, Hash, PartialOrd, Ord)]
|
|
|
#[cfg_attr(feature="heap_size", derive(HeapSizeOf))]
|
|
|
pub enum Host {
|
|
|
- /// A (DNS) domain name.
|
|
|
+ /// A (DNS) domain name or an IPv4 address.
|
|
|
+ ///
|
|
|
+ /// FIXME: IPv4 probably should be a separate variant.
|
|
|
+ /// See https://www.w3.org/Bugs/Public/show_bug.cgi?id=26431
|
|
|
Domain(String),
|
|
|
- /// An IPv4 address.
|
|
|
- V4(Ipv4Addr),
|
|
|
- /// An IPv6 address.
|
|
|
- V6(Ipv6Addr),
|
|
|
+
|
|
|
+ /// An IPv6 address, represented inside `[...]` square brackets
|
|
|
+ /// so that `:` colon characters in the address are not ambiguous
|
|
|
+ /// with the port number delimiter.
|
|
|
+ Ipv6(Ipv6Address),
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+/// A 128 bit IPv6 address
|
|
|
+#[derive(Clone, Eq, PartialEq, Copy, Debug, Hash, PartialOrd, Ord)]
|
|
|
+pub struct Ipv6Address {
|
|
|
+ pub pieces: [u16; 8]
|
|
|
}
|
|
|
+#[cfg(feature="heap_size")]
|
|
|
+known_heap_size!(0, Ipv6Address);
|
|
|
+
|
|
|
|
|
|
impl Host {
|
|
|
/// Parse a host: either an IPv6 address in [] square brackets, or a domain.
|
|
|
@@ -37,30 +51,22 @@ impl Host {
|
|
|
Err(ParseError::EmptyHost)
|
|
|
} else if input.starts_with("[") {
|
|
|
if input.ends_with("]") {
|
|
|
- if let Ok(addr) = input[1..input.len() - 1].parse() {
|
|
|
- Ok(Host::V6(addr))
|
|
|
- } else {
|
|
|
- Err(ParseError::InvalidIpv6Address)
|
|
|
- }
|
|
|
+ Ipv6Address::parse(&input[1..input.len() - 1]).map(Host::Ipv6)
|
|
|
} else {
|
|
|
Err(ParseError::InvalidIpv6Address)
|
|
|
}
|
|
|
} else {
|
|
|
- if let Ok(addr) = input.parse() {
|
|
|
- Ok(Host::V4(addr))
|
|
|
+ let decoded = percent_decode(input.as_bytes());
|
|
|
+ let domain = String::from_utf8_lossy(&decoded);
|
|
|
+ // TODO: Remove this check and use IDNA "domain to ASCII"
|
|
|
+ if !domain.is_ascii() {
|
|
|
+ Err(ParseError::NonAsciiDomainsNotSupportedYet)
|
|
|
+ } else if domain.find(&[
|
|
|
+ '\0', '\t', '\n', '\r', ' ', '#', '%', '/', ':', '?', '@', '[', '\\', ']'
|
|
|
+ ][..]).is_some() {
|
|
|
+ Err(ParseError::InvalidDomainCharacter)
|
|
|
} else {
|
|
|
- let decoded = percent_decode(input.as_bytes());
|
|
|
- let domain = String::from_utf8_lossy(&decoded);
|
|
|
- // TODO: Remove this check and use IDNA "domain to ASCII"
|
|
|
- if !domain.is_ascii() {
|
|
|
- Err(ParseError::NonAsciiDomainsNotSupportedYet)
|
|
|
- } else if domain.find(&[
|
|
|
- '\0', '\t', '\n', '\r', ' ', '#', '%', '/', ':', '?', '@', '[', '\\', ']'
|
|
|
- ][..]).is_some() {
|
|
|
- Err(ParseError::InvalidDomainCharacter)
|
|
|
- } else {
|
|
|
- Ok(Host::Domain(domain.to_ascii_lowercase()))
|
|
|
- }
|
|
|
+ Ok(Host::Domain(domain.to_ascii_lowercase()))
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
@@ -75,11 +81,203 @@ impl Host {
|
|
|
|
|
|
|
|
|
impl fmt::Display for Host {
|
|
|
- fn fmt(&self, f: &mut Formatter) -> fmt::Result {
|
|
|
+ fn fmt(&self, formatter: &mut Formatter) -> fmt::Result {
|
|
|
match *self {
|
|
|
- Host::Domain(ref domain) => domain.fmt(f),
|
|
|
- Host::V4(ref addr) => addr.fmt(f),
|
|
|
- Host::V6(ref addr) => write!(f, "[{}]", addr),
|
|
|
+ Host::Domain(ref domain) => domain.fmt(formatter),
|
|
|
+ Host::Ipv6(ref address) => {
|
|
|
+ try!(formatter.write_str("["));
|
|
|
+ try!(address.fmt(formatter));
|
|
|
+ formatter.write_str("]")
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+impl Ipv6Address {
|
|
|
+ /// Parse an IPv6 address, without the [] square brackets.
|
|
|
+ pub fn parse(input: &str) -> ParseResult<Ipv6Address> {
|
|
|
+ let input = input.as_bytes();
|
|
|
+ let len = input.len();
|
|
|
+ let mut is_ip_v4 = false;
|
|
|
+ let mut pieces = [0, 0, 0, 0, 0, 0, 0, 0];
|
|
|
+ let mut piece_pointer = 0;
|
|
|
+ let mut compress_pointer = None;
|
|
|
+ let mut i = 0;
|
|
|
+
|
|
|
+ if len < 2 {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+
|
|
|
+ if input[0] == b':' {
|
|
|
+ if input[1] != b':' {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ i = 2;
|
|
|
+ piece_pointer = 1;
|
|
|
+ compress_pointer = Some(1);
|
|
|
+ }
|
|
|
+
|
|
|
+ while i < len {
|
|
|
+ if piece_pointer == 8 {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ if input[i] == b':' {
|
|
|
+ if compress_pointer.is_some() {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ i += 1;
|
|
|
+ piece_pointer += 1;
|
|
|
+ compress_pointer = Some(piece_pointer);
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ let start = i;
|
|
|
+ let end = cmp::min(len, start + 4);
|
|
|
+ let mut value = 0u16;
|
|
|
+ while i < end {
|
|
|
+ match from_hex(input[i]) {
|
|
|
+ Some(digit) => {
|
|
|
+ value = value * 0x10 + digit as u16;
|
|
|
+ i += 1;
|
|
|
+ },
|
|
|
+ None => break
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if i < len {
|
|
|
+ match input[i] {
|
|
|
+ b'.' => {
|
|
|
+ if i == start {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ i = start;
|
|
|
+ is_ip_v4 = true;
|
|
|
+ },
|
|
|
+ b':' => {
|
|
|
+ i += 1;
|
|
|
+ if i == len {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ },
|
|
|
+ _ => return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if is_ip_v4 {
|
|
|
+ break
|
|
|
+ }
|
|
|
+ pieces[piece_pointer] = value;
|
|
|
+ piece_pointer += 1;
|
|
|
+ }
|
|
|
+
|
|
|
+ if is_ip_v4 {
|
|
|
+ if piece_pointer > 6 {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ let mut dots_seen = 0;
|
|
|
+ while i < len {
|
|
|
+ // FIXME: https://github.com/whatwg/url/commit/1c22aa119c354e0020117e02571cec53f7c01064
|
|
|
+ let mut value = 0u16;
|
|
|
+ while i < len {
|
|
|
+ let digit = match input[i] {
|
|
|
+ c @ b'0' ... b'9' => c - b'0',
|
|
|
+ _ => break
|
|
|
+ };
|
|
|
+ value = value * 10 + digit as u16;
|
|
|
+ if value == 0 || value > 255 {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if dots_seen < 3 && !(i < len && input[i] == b'.') {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ pieces[piece_pointer] = pieces[piece_pointer] * 0x100 + value;
|
|
|
+ if dots_seen == 0 || dots_seen == 2 {
|
|
|
+ piece_pointer += 1;
|
|
|
+ }
|
|
|
+ i += 1;
|
|
|
+ if dots_seen == 3 && i < len {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ dots_seen += 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ match compress_pointer {
|
|
|
+ Some(compress_pointer) => {
|
|
|
+ let mut swaps = piece_pointer - compress_pointer;
|
|
|
+ piece_pointer = 7;
|
|
|
+ while swaps > 0 {
|
|
|
+ pieces[piece_pointer] = pieces[compress_pointer + swaps - 1];
|
|
|
+ pieces[compress_pointer + swaps - 1] = 0;
|
|
|
+ swaps -= 1;
|
|
|
+ piece_pointer -= 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ _ => if piece_pointer != 8 {
|
|
|
+ return Err(ParseError::InvalidIpv6Address)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Ok(Ipv6Address { pieces: pieces })
|
|
|
+ }
|
|
|
+
|
|
|
+ /// Serialize the IPv6 address to a string.
|
|
|
+ pub fn serialize(&self) -> String {
|
|
|
+ self.to_string()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+impl fmt::Display for Ipv6Address {
|
|
|
+ fn fmt(&self, formatter: &mut Formatter) -> fmt::Result {
|
|
|
+ let (compress_start, compress_end) = longest_zero_sequence(&self.pieces);
|
|
|
+ let mut i = 0;
|
|
|
+ while i < 8 {
|
|
|
+ if i == compress_start {
|
|
|
+ try!(formatter.write_str(":"));
|
|
|
+ if i == 0 {
|
|
|
+ try!(formatter.write_str(":"));
|
|
|
+ }
|
|
|
+ if compress_end < 8 {
|
|
|
+ i = compress_end;
|
|
|
+ } else {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ try!(write!(formatter, "{:x}", self.pieces[i as usize]));
|
|
|
+ if i < 7 {
|
|
|
+ try!(formatter.write_str(":"));
|
|
|
+ }
|
|
|
+ i += 1;
|
|
|
+ }
|
|
|
+ Ok(())
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+fn longest_zero_sequence(pieces: &[u16; 8]) -> (isize, isize) {
|
|
|
+ let mut longest = -1;
|
|
|
+ let mut longest_length = -1;
|
|
|
+ let mut start = -1;
|
|
|
+ macro_rules! finish_sequence(
|
|
|
+ ($end: expr) => {
|
|
|
+ if start >= 0 {
|
|
|
+ let length = $end - start;
|
|
|
+ if length > longest_length {
|
|
|
+ longest = start;
|
|
|
+ longest_length = length;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ };
|
|
|
+ );
|
|
|
+ for i in 0..8 {
|
|
|
+ if pieces[i as usize] == 0 {
|
|
|
+ if start < 0 {
|
|
|
+ start = i;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ finish_sequence!(i);
|
|
|
+ start = -1;
|
|
|
}
|
|
|
}
|
|
|
+ finish_sequence!(8);
|
|
|
+ (longest, longest + longest_length)
|
|
|
}
|