use std::ops::Deref; use std::str::FromStr; use std::fmt; use smallvec::SmallVec; use http::{Header, IntoCollection, MediaType}; use http::parse::parse_accept; #[derive(Debug, Clone, PartialEq)] pub struct WeightedMediaType(pub MediaType, pub Option); impl WeightedMediaType { #[inline(always)] pub fn weight(&self) -> Option { self.1 } #[inline(always)] pub fn weight_or(&self, default: f32) -> f32 { self.1.unwrap_or(default) } #[inline(always)] pub fn media_type(&self) -> &MediaType { &self.0 } #[inline(always)] pub fn into_media_type(self) -> MediaType { self.0 } } impl From for WeightedMediaType { #[inline(always)] fn from(media_type: MediaType) -> WeightedMediaType { WeightedMediaType(media_type, None) } } impl Deref for WeightedMediaType { type Target = MediaType; #[inline(always)] fn deref(&self) -> &MediaType { &self.0 } } // FIXME: `Static` is needed for `const` items. Need `const SmallVec::new`. #[derive(Debug, PartialEq, Clone)] pub enum AcceptParams { Static(&'static [WeightedMediaType]), Dynamic(SmallVec<[WeightedMediaType; 1]>) } /// The HTTP Accept header. #[derive(Debug, Clone, PartialEq)] pub struct Accept(AcceptParams); macro_rules! accept_constructor { ($($name:ident ($check:ident): $str:expr, $t:expr, $s:expr $(; $k:expr => $v:expr)*),+) => { $( #[doc="An `Accept` header with the single media type for "] #[doc=$str] #[doc=": "] #[doc=$t] #[doc="/"] #[doc=$s] #[doc=""] #[allow(non_upper_case_globals)] pub const $name: Accept = Accept( AcceptParams::Static(&[WeightedMediaType(MediaType::$name, None)]) ); )+ }; } impl> From for Accept { #[inline(always)] fn from(items: T) -> Accept { Accept(AcceptParams::Dynamic(items.mapped(|item| item.into()))) } } impl Accept { #[inline(always)] pub fn new>(items: T) -> Accept { Accept(AcceptParams::Dynamic(items.into_collection())) } // FIXME: IMPLEMENT THIS. // #[inline(always)] // pub fn add>(&mut self, media_type: M) { // self.0.push(media_type.into()); // } pub fn preferred(&self) -> &WeightedMediaType { static ANY: WeightedMediaType = WeightedMediaType(MediaType::Any, None); // // See https://tools.ietf.org/html/rfc7231#section-5.3.2. let mut all = self.iter(); let mut preferred = all.next().unwrap_or(&ANY); for current in all { if current.weight().is_none() && preferred.weight().is_some() { preferred = current; } else if current.weight_or(0.0) > preferred.weight_or(1.0) { preferred = current; // FIXME: Prefer text/html over text/*, for example. } else if current.media_type() == preferred.media_type() { if current.weight() == preferred.weight() { let c_count = current.params().filter(|p| p.0 != "q").count(); let p_count = preferred.params().filter(|p| p.0 != "q").count(); if c_count > p_count { preferred = current; } } } } preferred } #[inline(always)] pub fn first(&self) -> Option<&WeightedMediaType> { self.iter().next() } #[inline(always)] pub fn iter<'a>(&'a self) -> impl Iterator + 'a { let slice = match self.0 { AcceptParams::Static(slice) => slice, AcceptParams::Dynamic(ref vec) => &vec[..], }; slice.iter() } #[inline(always)] pub fn media_types<'a>(&'a self) -> impl Iterator + 'a { self.iter().map(|weighted_mt| weighted_mt.media_type()) } known_media_types!(accept_constructor); } impl fmt::Display for Accept { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { for (i, media_type) in self.iter().enumerate() { if i >= 1 { write!(f, ", ")?; } write!(f, "{}", media_type.0)?; } Ok(()) } } impl FromStr for Accept { // Ideally we'd return a `ParseError`, but that requires a lifetime. type Err = String; #[inline] fn from_str(raw: &str) -> Result { parse_accept(raw).map_err(|e| e.to_string()) } } /// Creates a new `Header` with name `Accept` and the value set to the HTTP /// rendering of this `Accept` header. impl Into> for Accept { #[inline(always)] fn into(self) -> Header<'static> { Header::new("Accept", self.to_string()) } } #[cfg(test)] mod test { use http::{Accept, MediaType}; macro_rules! assert_preference { ($string:expr, $expect:expr) => ( let accept: Accept = $string.parse().expect("accept string parse"); let expected: MediaType = $expect.parse().expect("media type parse"); let preferred = accept.preferred(); assert_eq!(preferred.media_type().to_string(), expected.to_string()); ) } #[test] fn test_preferred() { assert_preference!("text/*", "text/*"); assert_preference!("text/*, text/html", "text/*"); assert_preference!("text/*; q=0.1, text/html", "text/html"); assert_preference!("text/*; q=1, text/html", "text/html"); assert_preference!("text/html, text/*", "text/html"); assert_preference!("text/html, text/*; q=1", "text/html"); assert_preference!("text/html, text/*; q=0.1", "text/html"); assert_preference!("text/html, application/json", "text/html"); assert_preference!("a/b; q=0.1, a/b; q=0.2", "a/b; q=0.2"); assert_preference!("a/b; q=0.1, b/c; q=0.2", "b/c; q=0.2"); assert_preference!("a/b; q=0.5, b/c; q=0.2", "a/b; q=0.5"); assert_preference!("a/b; q=0.5, b/c; q=0.2, c/d", "c/d"); assert_preference!("a/b; q=0.5; v=1, a/b", "a/b"); assert_preference!("a/b; v=1, a/b; v=1; c=2", "a/b; v=1; c=2"); assert_preference!("a/b; v=1; c=2, a/b; v=1", "a/b; v=1; c=2"); assert_preference!("a/b; q=0.5; v=1, a/b; q=0.5; v=1; c=2", "a/b; q=0.5; v=1; c=2"); assert_preference!("a/b; q=0.6; v=1, a/b; q=0.5; v=1; c=2", "a/b; q=0.6; v=1"); } }