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

use hotfix_message::MessageBuilder;
use hotfix_message::message::Config as MessageConfig;
use hotfix_store::MessageStore;

use crate::config::SessionConfig;
use crate::message::OutboundMessage;
use crate::message::generate_message;
use crate::message::parser::RawFixMessage;
use crate::session::error::InternalSendError;
use crate::session::state::SessionState;
use crate::store::StoreError;
use hotfix_message::message::Message;

pub(crate) enum TransitionResult {
    Stay,
    TransitionTo(SessionState),
}

/// The result of the pre-processing step for an inbound message.
///
/// Before verification and dispatch, the current state gets a chance to
/// decide whether a message should be processed, queued, or rejected.
#[allow(clippy::large_enum_variant)]
pub(crate) enum PreProcessDecision {
    /// Continue processing this message through verification and dispatch.
    Accept(Message),
    /// The message has been queued for later processing (e.g. AwaitingResend backlog).
    Queued,
    /// The message is not acceptable in this state — disconnect the writer.
    Disconnect,
}

/// The result of verifying an inbound message via a state variant's
/// `handle_verification_issue` method.
pub(crate) enum VerificationResult {
    /// Verification passed — the caller should proceed with handler logic.
    Passed,
    /// A verification issue was detected and handled. The caller should apply
    /// the transition and skip further processing of this message.
    Issue(TransitionResult),
}

pub(crate) struct SessionCtx<A, S> {
    pub config: SessionConfig,
    pub store: S,
    pub application: A,
    pub message_builder: MessageBuilder,
    pub message_config: MessageConfig,
}

pub(crate) struct PreparedMessage {
    pub seq_num: u64,
    pub raw: RawFixMessage,
}

impl<A, S: MessageStore> SessionCtx<A, S> {
    pub async fn prepare_message(
        &mut self,
        message: impl OutboundMessage,
    ) -> Result<PreparedMessage, InternalSendError> {
        let seq_num = self.store.next_sender_seq_number();
        let msg = generate_message(
            &self.config.begin_string,
            &self.config.sender_comp_id,
            &self.config.target_comp_id,
            seq_num,
            message,
        )
        .map_err(|e| {
            InternalSendError::Persist(StoreError::PersistMessage {
                sequence_number: seq_num,
                source: e.into(),
            })
        })?;

        self.store
            .increment_sender_seq_number()
            .await
            .map_err(InternalSendError::SequenceNumber)?;

        self.store
            .add(seq_num, &msg)
            .await
            .map_err(InternalSendError::Persist)?;

        Ok(PreparedMessage {
            seq_num,
            raw: RawFixMessage::new(msg),
        })
    }
}