ibapi 3.0.1

A Rust implementation of the Interactive Brokers TWS API, providing a reliable and user friendly interface for TWS and IB Gateway. Designed with a focus on simplicity and performance.
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

use super::*;
use crate::trace::common::storage::async_ops;
use serial_test::serial;

#[tokio::test]
#[serial]
async fn test_no_interaction_initially() {
    // Clear to ensure clean initial state
    async_ops::clear().await;
    assert!(last_interaction().await.is_none());
}

#[tokio::test]
#[serial]
async fn test_record_and_retrieve_interaction() {
    // Record a request - this replaces any previous interaction
    record_request("TEST_REQUEST".to_string()).await;

    // Should be able to get it back
    let interaction = last_interaction().await.expect("Should have interaction");
    assert_eq!(interaction.request, "TEST_REQUEST");
    assert_eq!(interaction.responses.len(), 0);
}

#[tokio::test]
#[serial]
async fn test_record_request_and_responses() {
    // Record a request - this replaces any previous interaction
    record_request("REQUEST_1".to_string()).await;

    // Record some responses
    record_response("RESPONSE_1".to_string()).await;
    record_response("RESPONSE_2".to_string()).await;

    // Check the interaction
    let interaction = last_interaction().await.expect("Should have interaction");
    assert_eq!(interaction.request, "REQUEST_1");
    assert_eq!(interaction.responses.len(), 2);
    assert_eq!(interaction.responses[0], "RESPONSE_1");
    assert_eq!(interaction.responses[1], "RESPONSE_2");
}

#[tokio::test]
#[serial]
async fn test_new_request_replaces_old() {
    // First interaction
    record_request("REQUEST_1".to_string()).await;
    record_response("RESPONSE_1".to_string()).await;

    // Second interaction - this replaces the first
    record_request("REQUEST_2".to_string()).await;
    record_response("RESPONSE_2".to_string()).await;

    // Should only have the second interaction
    let interaction = last_interaction().await.expect("Should have interaction");
    assert_eq!(interaction.request, "REQUEST_2");
    assert_eq!(interaction.responses.len(), 1);
    assert_eq!(interaction.responses[0], "RESPONSE_2");
}