quickfix-msg-gen 0.2.1

FIX code generator from XML spec file
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use std::collections::HashSet;

use quickfix_spec_parser::{FieldValue, FixSpec, Message};

use crate::{FixCodeSpec, MessageField, MessageGroup, MessageSpec, SubComponent};

pub fn convert_spec(src: FixSpec) -> FixCodeSpec {
    FixCodeSpec {
        headers: convert_field_value_list(&src, &src.headers),
        trailers: convert_field_value_list(&src, &src.trailers),
        messages: convert_messages(&src, &src.messages),
        field_specs: src.field_specs,
    }
}

fn convert_field_value_list(spec: &FixSpec, values: &[FieldValue]) -> Vec<SubComponent> {
    let mut output = Vec::with_capacity(values.len());

    // Convert recursively `FieldValue` to `SubComponent`.
    for value in values {
        match value {
            FieldValue::Field(x) => output.push(SubComponent::Field(MessageField {
                name: x.name.clone(),
                required: x.required,
            })),
            FieldValue::Group(x) => output.push(SubComponent::Group(MessageGroup {
                name: x.name.clone(),
                components: convert_field_value_list(spec, &x.values),
            })),
            FieldValue::Component(component) => {
                let component_spec = spec
                    .component_specs
                    .iter()
                    .find(|x| x.name == component.name)
                    .expect("Cannot find component");

                output.extend(convert_field_value_list(spec, &component_spec.values));
            }
        }
    }

    // Remove duplicate: example FIX4.3 -> RegistrationInstructions -> OwnershipType.
    let mut uniques = HashSet::new();
    output.retain(|x| uniques.insert(x.name().to_string()));

    output
}

fn convert_messages(spec: &FixSpec, messages: &[Message]) -> Vec<MessageSpec> {
    messages
        .iter()
        .map(|message| MessageSpec {
            name: message.name.clone(),
            msg_type: message.msg_type.clone(),
            components: convert_field_value_list(spec, &message.values),
        })
        .collect()
}