hotfix 0.0.15

An experimental FIX engine
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

// re-exposing these as applications need this to define their own messages
pub use hotfix_message::field_types::Timestamp;
pub use hotfix_message::fix44;
pub use hotfix_message::message::{Config, Message};
pub use hotfix_message::{Part, RepeatingGroup};

pub(crate) mod heartbeat;
pub(crate) mod logon;
pub(crate) mod parser;
pub(crate) mod resend_request;
pub(crate) mod sequence_reset;

pub trait FixMessage: Clone + Send + 'static {
    fn write(&self, msg: &mut Message);

    fn message_type(&self) -> &str;

    fn parse(message: &Message) -> Self;
}

pub(crate) fn generate_message(
    sender_comp_id: &str,
    target_comp_id: &str,
    msg_seq_num: usize,
    message: impl FixMessage,
) -> Vec<u8> {
    let mut msg = Message::new("FIX.4.4", message.message_type());
    msg.set(fix44::SENDER_COMP_ID, sender_comp_id);
    msg.set(fix44::TARGET_COMP_ID, target_comp_id.as_bytes());
    msg.set(fix44::MSG_SEQ_NUM, msg_seq_num);
    msg.set(fix44::SENDING_TIME, Timestamp::utc_now());

    message.write(&mut msg);

    msg.encode(&Config::default())
}

pub trait WriteMessage {
    fn write(&self, msg: &mut Message);

    fn message_type(&self) -> &str;
}