// 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 hashes::Hash; use minidom::{Element, IntoElements, ElementEmitter}; use chrono::{DateTime, FixedOffset}; use error::Error; use ns; #[derive(Debug, Clone, PartialEq)] pub struct Range { pub offset: u64, pub length: Option, pub hashes: Vec, } impl IntoElements for Range { fn into_elements(self, emitter: &mut ElementEmitter) { let mut elem = Element::builder("range") .ns(ns::JINGLE_FT) .attr("offset", self.offset) .attr("length", self.length) .build(); for hash in self.hashes { elem.append_child(hash.into()); } emitter.append_child(elem); } } #[derive(Debug, Clone)] pub struct File { pub date: Option>, pub media_type: Option, pub name: Option, pub desc: Option, pub size: Option, pub range: Option, pub hashes: Vec, } #[derive(Debug, Clone)] pub struct Description { pub file: File, } #[derive(Debug, Clone)] pub enum Creator { Initiator, Responder, } #[derive(Debug, Clone)] pub struct Checksum { pub name: String, pub creator: Creator, pub file: File, } #[derive(Debug, Clone)] pub struct Received { pub name: String, pub creator: Creator, } impl IntoElements for Received { fn into_elements(self, emitter: &mut ElementEmitter) { let elem = Element::builder("received") .ns(ns::JINGLE_FT) .attr("name", self.name) .attr("creator", match self.creator { Creator::Initiator => "initiator", Creator::Responder => "responder", }) .build(); emitter.append_child(elem); } } impl TryFrom for Description { type Err = Error; fn try_from(elem: Element) -> Result { if !elem.is("description", ns::JINGLE_FT) { return Err(Error::ParseError("This is not a JingleFT description element.")); } if elem.children().count() != 1 { return Err(Error::ParseError("JingleFT description element must have exactly one child.")); } let mut date = None; let mut media_type = None; let mut name = None; let mut desc = None; let mut size = None; let mut range = None; let mut hashes = vec!(); for description_payload in elem.children() { if !description_payload.is("file", ns::JINGLE_FT) { return Err(Error::ParseError("Unknown element in JingleFT description.")); } for file_payload in description_payload.children() { if file_payload.is("date", ns::JINGLE_FT) { if date.is_some() { return Err(Error::ParseError("File must not have more than one date.")); } date = Some(file_payload.text().parse()?); } else if file_payload.is("media-type", ns::JINGLE_FT) { if media_type.is_some() { return Err(Error::ParseError("File must not have more than one media-type.")); } media_type = Some(file_payload.text()); } else if file_payload.is("name", ns::JINGLE_FT) { if name.is_some() { return Err(Error::ParseError("File must not have more than one name.")); } name = Some(file_payload.text()); } else if file_payload.is("desc", ns::JINGLE_FT) { if desc.is_some() { return Err(Error::ParseError("File must not have more than one desc.")); } desc = Some(file_payload.text()); } else if file_payload.is("size", ns::JINGLE_FT) { if size.is_some() { return Err(Error::ParseError("File must not have more than one size.")); } size = Some(file_payload.text().parse()?); } else if file_payload.is("range", ns::JINGLE_FT) { if range.is_some() { return Err(Error::ParseError("File must not have more than one range.")); } let offset = get_attr!(file_payload, "offset", default); let length = get_attr!(file_payload, "length", optional); let mut range_hashes = vec!(); for hash_element in file_payload.children() { if !hash_element.is("hash", ns::HASHES) { return Err(Error::ParseError("Unknown element in JingleFT range.")); } range_hashes.push(Hash::try_from(hash_element.clone())?); } range = Some(Range { offset: offset, length: length, hashes: range_hashes, }); } else if file_payload.is("hash", ns::HASHES) { hashes.push(Hash::try_from(file_payload.clone())?); } else { return Err(Error::ParseError("Unknown element in JingleFT file.")); } } } Ok(Description { file: File { date: date, media_type: media_type, name: name, desc: desc, size: size, range: range, hashes: hashes, }, }) } } 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.to_rfc3339()) .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()); } if let Some(desc) = file.desc { root.append_child(Element::builder("desc") .ns(ns::JINGLE_FT) .append(desc) .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(Element::builder("range") .ns(ns::JINGLE_FT) .append(range) .build()); } for hash in file.hashes { root.append_child(hash.into()); } root } } 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() } } #[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.desc, None); assert_eq!(desc.file.date, Some(DateTime::parse_from_rfc3339("2015-07-26T21:46:00+01:00").unwrap())); 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.desc, None); 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()); } }