quickfix_spec_parser/model/
message.rs1use std::io;
2
3use quick_xml::events::BytesStart;
4
5use crate::{
6 read_attribute, write_xml_list, FieldValue, FixSpecError, MessageCategory, XmlObject,
7 XmlReadable, XmlReader, XmlWritable, XmlWriter,
8};
9
10#[derive(Debug, Clone)]
12pub struct Message {
13 pub name: String,
15 pub msg_type: String,
17 pub category: MessageCategory,
19 pub values: Vec<FieldValue>,
21}
22
23impl XmlObject for Message {
24 const TAG_NAME: &'static str = "message";
25}
26
27impl XmlReadable for Message {
28 fn parse_xml_node(element: &BytesStart) -> Result<Self, FixSpecError> {
29 let name = read_attribute(element, "name")?;
30 let msg_type = read_attribute(element, "msgtype")?;
31 let category = MessageCategory::parse_xml_element(element)?;
32
33 Ok(Self {
34 name,
35 msg_type,
36 category,
37 values: Vec::new(),
38 })
39 }
40
41 fn parse_xml_tree(element: &BytesStart, reader: &mut XmlReader) -> Result<Self, FixSpecError> {
42 let mut output = Self::parse_xml_node(element)?;
43 output.values = FieldValue::parse_xml_tree(reader, Self::TAG_NAME)?;
44 Ok(output)
45 }
46}
47
48impl XmlWritable for Message {
49 fn write_xml<'a>(&self, writer: &'a mut XmlWriter) -> io::Result<&'a mut XmlWriter> {
50 let element = writer
51 .create_element(Self::TAG_NAME)
52 .with_attribute(("name", self.name.as_str()))
53 .with_attribute(("msgtype", self.msg_type.as_str()))
54 .with_attribute(("msgcat", self.category.as_static_str()));
55
56 if self.values.is_empty() {
57 element.write_empty()
58 } else {
59 element.write_inner_content(|writer| write_xml_list(writer, &self.values))
60 }
61 }
62}