// Copyright (c) 2017 Emmanuel Gil Peyrot // // This Source Code Form is subject to the terms of the Mozilla Public // License, v. 2.0. If a copy of the MPL was not distributed with this // file, You can obtain one at http://mozilla.org/MPL/2.0/. use try_from::TryFrom; use std::collections::BTreeMap; use std::str::FromStr; use hashes::Hash; use jingle::{Creator, ContentId}; use date::DateTime; use minidom::{Element, IntoAttributeValue}; use error::Error; use ns; #[derive(Debug, Clone, PartialEq)] pub struct Range { pub offset: u64, pub length: Option, pub hashes: Vec, } impl TryFrom for Range { type Err = Error; fn try_from(elem: Element) -> Result { check_self!(elem, "range", ns::JINGLE_FT); check_no_unknown_attributes!(elem, "range", ["offset", "length"]); let mut hashes = vec!(); for child in elem.children() { hashes.push(Hash::try_from(child.clone())?); } Ok(Range { offset: get_attr!(elem, "offset", default), length: get_attr!(elem, "length", optional), hashes: hashes, }) } } impl From for Element { fn from(range: Range) -> Element { Element::builder("range") .ns(ns::JINGLE_FT) .attr("offset", if range.offset == 0 { None } else { Some(range.offset) }) .attr("length", range.length) .append(range.hashes) .build() } } type Lang = String; generate_id!(Desc); #[derive(Debug, Clone)] pub struct File { pub date: Option, pub media_type: Option, pub name: Option, pub descs: BTreeMap, pub size: Option, pub range: Option, pub hashes: Vec, } impl TryFrom for File { type Err = Error; fn try_from(elem: Element) -> Result { check_self!(elem, "file", ns::JINGLE_FT); check_no_attributes!(elem, "file"); let mut file = File { date: None, media_type: None, name: None, descs: BTreeMap::new(), size: None, range: None, hashes: vec!(), }; for child in elem.children() { if child.is("date", ns::JINGLE_FT) { if file.date.is_some() { return Err(Error::ParseError("File must not have more than one date.")); } file.date = Some(child.text().parse()?); } else if child.is("media-type", ns::JINGLE_FT) { if file.media_type.is_some() { return Err(Error::ParseError("File must not have more than one media-type.")); } file.media_type = Some(child.text()); } else if child.is("name", ns::JINGLE_FT) { if file.name.is_some() { return Err(Error::ParseError("File must not have more than one name.")); } file.name = Some(child.text()); } else if child.is("desc", ns::JINGLE_FT) { let lang = get_attr!(child, "xml:lang", default); let desc = Desc(child.text()); if file.descs.insert(lang, desc).is_some() { return Err(Error::ParseError("Desc element present twice for the same xml:lang.")); } } else if child.is("size", ns::JINGLE_FT) { if file.size.is_some() { return Err(Error::ParseError("File must not have more than one size.")); } file.size = Some(child.text().parse()?); } else if child.is("range", ns::JINGLE_FT) { if file.range.is_some() { return Err(Error::ParseError("File must not have more than one range.")); } file.range = Some(Range::try_from(child.clone())?); } else if child.is("hash", ns::HASHES) { file.hashes.push(Hash::try_from(child.clone())?); } else { return Err(Error::ParseError("Unknown element in JingleFT file.")); } } Ok(file) } } impl From for Element { fn from(file: File) -> Element { let mut root = Element::builder("file") .ns(ns::JINGLE_FT) .build(); if let Some(date) = file.date { root.append_child(Element::builder("date") .ns(ns::JINGLE_FT) .append(date) .build()); } if let Some(media_type) = file.media_type { root.append_child(Element::builder("media-type") .ns(ns::JINGLE_FT) .append(media_type) .build()); } if let Some(name) = file.name { root.append_child(Element::builder("name") .ns(ns::JINGLE_FT) .append(name) .build()); } for (lang, desc) in file.descs.into_iter() { root.append_child(Element::builder("desc") .ns(ns::JINGLE_FT) .attr("xml:lang", lang) .append(desc.0) .build()); } if let Some(size) = file.size { root.append_child(Element::builder("size") .ns(ns::JINGLE_FT) .append(format!("{}", size)) .build()); } if let Some(range) = file.range { root.append_child(range.into()); } for hash in file.hashes { root.append_child(hash.into()); } root } } #[derive(Debug, Clone)] pub struct Description { pub file: File, } impl TryFrom for Description { type Err = Error; fn try_from(elem: Element) -> Result { check_self!(elem, "description", ns::JINGLE_FT, "JingleFT description"); check_no_attributes!(elem, "JingleFT description"); let mut file = None; for child in elem.children() { if file.is_some() { return Err(Error::ParseError("JingleFT description element must have exactly one child.")); } file = Some(File::try_from(child.clone())?); } if file.is_none() { return Err(Error::ParseError("JingleFT description element must have exactly one child.")); } Ok(Description { file: file.unwrap(), }) } } impl From for Element { fn from(description: Description) -> Element { let file: Element = description.file.into(); Element::builder("description") .ns(ns::JINGLE_FT) .append(file) .build() } } #[derive(Debug, Clone)] pub struct Checksum { pub name: ContentId, pub creator: Creator, pub file: File, } impl TryFrom for Checksum { type Err = Error; fn try_from(elem: Element) -> Result { check_self!(elem, "checksum", ns::JINGLE_FT); check_no_unknown_attributes!(elem, "checksum", ["name", "creator"]); let mut file = None; for child in elem.children() { if file.is_some() { return Err(Error::ParseError("JingleFT checksum element must have exactly one child.")); } file = Some(File::try_from(child.clone())?); } if file.is_none() { return Err(Error::ParseError("JingleFT checksum element must have exactly one child.")); } Ok(Checksum { name: get_attr!(elem, "name", required), creator: get_attr!(elem, "creator", required), file: file.unwrap(), }) } } impl From for Element { fn from(checksum: Checksum) -> Element { Element::builder("checksum") .ns(ns::JINGLE_FT) .attr("name", checksum.name) .attr("creator", checksum.creator) .append(checksum.file) .build() } } generate_element_with_only_attributes!(Received, "received", ns::JINGLE_FT, [ name: ContentId = "name" => required, creator: Creator = "creator" => required, ]); #[cfg(test)] mod tests { use super::*; use hashes::Algo; use base64; #[test] fn test_description() { let elem: Element = r#" text/plain test.txt 2015-07-26T21:46:00+01:00 6144 w0mcJylzCn+AfvuGdqkty2+KP48= "#.parse().unwrap(); let desc = Description::try_from(elem).unwrap(); assert_eq!(desc.file.media_type, Some(String::from("text/plain"))); assert_eq!(desc.file.name, Some(String::from("test.txt"))); assert_eq!(desc.file.descs, BTreeMap::new()); assert_eq!(desc.file.date, DateTime::from_str("2015-07-26T21:46:00+01:00").ok()); assert_eq!(desc.file.size, Some(6144u64)); assert_eq!(desc.file.range, None); assert_eq!(desc.file.hashes[0].algo, Algo::Sha_1); assert_eq!(desc.file.hashes[0].hash, base64::decode("w0mcJylzCn+AfvuGdqkty2+KP48=").unwrap()); } #[test] fn test_request() { let elem: Element = r#" w0mcJylzCn+AfvuGdqkty2+KP48= "#.parse().unwrap(); let desc = Description::try_from(elem).unwrap(); assert_eq!(desc.file.media_type, None); assert_eq!(desc.file.name, None); assert_eq!(desc.file.descs, BTreeMap::new()); assert_eq!(desc.file.date, None); assert_eq!(desc.file.size, None); assert_eq!(desc.file.range, None); assert_eq!(desc.file.hashes[0].algo, Algo::Sha_1); assert_eq!(desc.file.hashes[0].hash, base64::decode("w0mcJylzCn+AfvuGdqkty2+KP48=").unwrap()); } #[test] fn test_descs() { let elem: Element = r#" text/plain Fichier secret ! Secret file! w0mcJylzCn+AfvuGdqkty2+KP48= "#.parse().unwrap(); let desc = Description::try_from(elem).unwrap(); assert_eq!(desc.file.descs.keys().cloned().collect::>(), ["en", "fr"]); assert_eq!(desc.file.descs["en"], Desc(String::from("Secret file!"))); assert_eq!(desc.file.descs["fr"], Desc(String::from("Fichier secret !"))); let elem: Element = r#" text/plain Fichier secret ! Secret file! w0mcJylzCn+AfvuGdqkty2+KP48= "#.parse().unwrap(); let error = Description::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Desc element present twice for the same xml:lang."); } #[test] fn test_received() { let elem: Element = "".parse().unwrap(); let received = Received::try_from(elem).unwrap(); assert_eq!(received.name, ContentId(String::from("coucou"))); assert_eq!(received.creator, Creator::Initiator); let elem2 = Element::from(received.clone()); let received2 = Received::try_from(elem2).unwrap(); assert_eq!(received2.name, ContentId(String::from("coucou"))); assert_eq!(received2.creator, Creator::Initiator); let elem: Element = "".parse().unwrap(); let error = Received::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown child in received element."); let elem: Element = "".parse().unwrap(); let error = Received::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown attribute in received element."); let elem: Element = "".parse().unwrap(); let error = Received::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Required attribute 'name' missing."); let elem: Element = "".parse().unwrap(); let error = Received::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown value for 'creator' attribute."); } #[test] fn test_checksum() { let elem: Element = "w0mcJylzCn+AfvuGdqkty2+KP48=".parse().unwrap(); let hash = vec!(195, 73, 156, 39, 41, 115, 10, 127, 128, 126, 251, 134, 118, 169, 45, 203, 111, 138, 63, 143); let checksum = Checksum::try_from(elem).unwrap(); assert_eq!(checksum.name, ContentId(String::from("coucou"))); assert_eq!(checksum.creator, Creator::Initiator); assert_eq!(checksum.file.hashes, vec!(Hash { algo: Algo::Sha_1, hash: hash.clone() })); let elem2 = Element::from(checksum); let checksum2 = Checksum::try_from(elem2).unwrap(); assert_eq!(checksum2.name, ContentId(String::from("coucou"))); assert_eq!(checksum2.creator, Creator::Initiator); assert_eq!(checksum2.file.hashes, vec!(Hash { algo: Algo::Sha_1, hash: hash.clone() })); let elem: Element = "".parse().unwrap(); let error = Checksum::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "This is not a file element."); let elem: Element = "w0mcJylzCn+AfvuGdqkty2+KP48=".parse().unwrap(); let error = Checksum::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown attribute in checksum element."); let elem: Element = "w0mcJylzCn+AfvuGdqkty2+KP48=".parse().unwrap(); let error = Checksum::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Required attribute 'name' missing."); let elem: Element = "w0mcJylzCn+AfvuGdqkty2+KP48=".parse().unwrap(); let error = Checksum::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown value for 'creator' attribute."); } #[test] fn test_range() { let elem: Element = "".parse().unwrap(); let range = Range::try_from(elem).unwrap(); assert_eq!(range.offset, 0); assert_eq!(range.length, None); assert_eq!(range.hashes, vec!()); let elem: Element = "kHp5RSzW/h7Gm1etSf90Mr5PC/k=".parse().unwrap(); let hashes = vec!(Hash { algo: Algo::Sha_1, hash: vec!(144, 122, 121, 69, 44, 214, 254, 30, 198, 155, 87, 173, 73, 255, 116, 50, 190, 79, 11, 249) }); let range = Range::try_from(elem).unwrap(); assert_eq!(range.offset, 2048); assert_eq!(range.length, Some(1024)); assert_eq!(range.hashes, hashes); let elem2 = Element::from(range); let range2 = Range::try_from(elem2).unwrap(); assert_eq!(range2.offset, 2048); assert_eq!(range2.length, Some(1024)); assert_eq!(range2.hashes, hashes); let elem: Element = "".parse().unwrap(); let error = Range::try_from(elem).unwrap_err(); let message = match error { Error::ParseError(string) => string, _ => panic!(), }; assert_eq!(message, "Unknown attribute in range element."); } }