Add test case for happy logon flow

Author: davidsteiner

crates/hotfix/tests/session_test_cases/heartbeat_tests.rs

@@ -23,7 +23,7 @@ async fn test_heartbeats() {
         .await;
     // counterparty responds with a logon to establish a happy session
     mock_counterparty.send_logon().await;
-    tokio::task::yield_now().await;
+    session.assert_status(Status::Active).await;
 
     // let's wait enough time for a heartbeat and assert that the heartbeat was sent
     tokio::time::advance(std::time::Duration::from_secs(HEARTBEAT_INTERVAL + 1)).await;

crates/hotfix/tests/session_test_cases/logon_tests.rs

@@ -0,0 +1,26 @@
+use crate::common::session_assertions::SessionAssertions;
+use crate::common::setup::setup;
+use hotfix::session::Status;
+use hotfix_message::Part;
+use hotfix_message::fix44::MSG_TYPE;
+
+/// Tests successful FIX session establishment via logon message exchange.
+/// Verifies that a session sends a logon message, receives a response,
+/// transitions to Active status, and disconnects cleanly.
+#[tokio::test]
+async fn test_happy_logon() {
+    let (session, mut mock_counterparty) = setup().await;
+
+    // assert that a logon message is received (type 'A')
+    mock_counterparty
+        .assert_next(|msg| assert_eq!(msg.header().get::<&str>(MSG_TYPE).unwrap(), "A"))
+        .await;
+    // counterparty responds with a logon to establish a happy session
+    mock_counterparty.send_logon().await;
+    session.assert_status(Status::Active).await;
+
+    session
+        .disconnect("Test Session Finished".to_string())
+        .await;
+    mock_counterparty.assert_disconnected().await;
+}

crates/hotfix/tests/session_test_cases/mod.rs

@@ -1 +1,2 @@
 mod heartbeat_tests;
+mod logon_tests;