hotfix 0.12.0

Buy-side FIX engine written in pure Rust
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

use crate::message::OutboundMessage;
use hotfix_message::message::Message;
use hotfix_message::session_fields::{
    ENCRYPT_METHOD, HEART_BT_INT, NEXT_EXPECTED_MSG_SEQ_NUM, RESET_SEQ_NUM_FLAG,
};
use hotfix_message::{FieldType, Part};

#[derive(Clone, Debug)]
pub struct Logon {
    encrypt_method: EncryptMethod,
    heartbeat_interval: u64,
    reset_seq_num_flag: ResetSeqNumFlag,
    next_expected_msg_seq_num: Option<u64>,
}

pub enum ResetSeqNumConfig {
    Reset,
    NoReset(Option<u64>),
}

impl Logon {
    pub const MSG_TYPE: &str = "A";

    pub fn new(heartbeat_interval: u64, reset_config: ResetSeqNumConfig) -> Self {
        let (reset_seq_num_flag, next_expected_msg_seq_num) = match reset_config {
            ResetSeqNumConfig::Reset => (ResetSeqNumFlag::Yes, None),
            ResetSeqNumConfig::NoReset(next) => (ResetSeqNumFlag::No, next),
        };
        Self {
            encrypt_method: EncryptMethod::None,
            heartbeat_interval,
            reset_seq_num_flag,
            next_expected_msg_seq_num,
        }
    }
}

impl OutboundMessage for Logon {
    fn write(&self, msg: &mut Message) {
        msg.set(ENCRYPT_METHOD, self.encrypt_method);
        msg.set(HEART_BT_INT, self.heartbeat_interval);
        msg.set(RESET_SEQ_NUM_FLAG, self.reset_seq_num_flag);

        if let Some(next) = self.next_expected_msg_seq_num {
            msg.set(NEXT_EXPECTED_MSG_SEQ_NUM, next);
        }
    }

    fn message_type(&self) -> &str {
        Self::MSG_TYPE
    }
}

#[derive(Debug, Copy, Clone, PartialEq, Eq, Hash, FieldType)]
pub enum EncryptMethod {
    /// Field variant '0'.
    #[hotfix(variant = "0")]
    None,

    /// Field variant '1'.
    #[hotfix(variant = "1")]
    Pkcs,

    /// Field variant '2'.
    #[hotfix(variant = "2")]
    Des,

    /// Field variant '3'.
    #[hotfix(variant = "3")]
    PkcsDes,

    /// Field variant '4'.
    #[hotfix(variant = "4")]
    PgpDes,

    /// Field variant '5'.
    #[hotfix(variant = "5")]
    PgpDesMd5,

    /// Field variant '6'.
    #[hotfix(variant = "6")]
    PemDesMd5,
}

#[derive(Debug, Copy, Clone, PartialEq, Eq, Hash, FieldType)]
pub enum ResetSeqNumFlag {
    /// Field variant 'Y'.
    #[hotfix(variant = "Y")]
    Yes,

    /// Field variant 'N'.
    #[hotfix(variant = "N")]
    No,
}