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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

use std::sync::{Arc, RwLock};

use crate::common::test_utils::helpers::{assert_request, proto_response, TEST_CONTRACT_ID, TEST_REQ_ID_FIRST};
use crate::contracts::Contract;
use crate::fundamental::FundamentalReportType;
use crate::messages::IncomingMessages;
use crate::server_versions;
use crate::stubs::MessageBusStub;
use crate::testdata::builders::fundamental::{fundamental_data_request, fundamental_data_response};
use crate::testdata::builders::ResponseProtoEncoder;
use crate::{Client, Error};

fn aapl_contract() -> Contract {
    let mut contract = Contract::stock("AAPL").build();
    contract.contract_id = TEST_CONTRACT_ID;
    contract
}

#[tokio::test]
async fn fundamental_data_round_trip() {
    let message_bus = Arc::new(MessageBusStub {
        request_messages: RwLock::new(vec![]),
        response_messages: vec![],
        ordered_responses: vec![proto_response(
            IncomingMessages::FundamentalData,
            fundamental_data_response()
                .request_id(TEST_REQ_ID_FIRST)
                .data("<ReportSnapshot>...</ReportSnapshot>")
                .encode_proto(),
        )],
    });

    let client = Client::stubbed(message_bus.clone(), server_versions::FUNDAMENTAL_DATA);
    let contract = aapl_contract();

    let report = client
        .fundamental_data(&contract, FundamentalReportType::ReportSnapshot)
        .await
        .expect("fundamental_data failed");

    assert_request(
        &message_bus,
        0,
        &fundamental_data_request()
            .request_id(TEST_REQ_ID_FIRST)
            .contract(contract.clone())
            .report_type(FundamentalReportType::ReportSnapshot),
    );

    assert_eq!(report.data, "<ReportSnapshot>...</ReportSnapshot>");
}

#[tokio::test]
async fn fundamental_data_propagates_tws_error() {
    let message_bus = Arc::new(MessageBusStub {
        request_messages: RwLock::new(vec![]),
        response_messages: vec![],
        ordered_responses: vec![crate::common::test_utils::helpers::proto_error_response(
            TEST_REQ_ID_FIRST,
            10089,
            "Requested market data is not subscribed",
        )],
    });

    let client = Client::stubbed(message_bus, server_versions::FUNDAMENTAL_DATA);
    let contract = aapl_contract();
    let err = client
        .fundamental_data(&contract, FundamentalReportType::ReportSnapshot)
        .await
        .expect_err("expected TWS error");
    match err {
        Error::Notice(n) => {
            assert_eq!(n.code, 10089);
            assert!(n.message.contains("not subscribed"));
        }
        other => panic!("expected Error::Notice, got {other:?}"),
    }
}