ibapi 3.3.0

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

//! Asynchronous implementation of configuration retrieval.

use crate::{
    common::request_helpers,
    protocol::{check_version, Features},
    Client, Error,
};

use super::builder::UpdateConfigBuilder;
use super::{common::decoders, encoders, Config};

impl Client {
    /// Reads the TWS/Gateway configuration (API, precautions, orders, and
    /// lock-and-exit settings) the gateway is currently running with.
    ///
    /// This is a read-only snapshot; fields the gateway does not report are
    /// left as `None`.
    ///
    /// # Examples
    ///
    /// ```no_run
    /// use ibapi::prelude::*;
    ///
    /// #[tokio::main]
    /// async fn main() {
    ///     let client = Client::connect("127.0.0.1:4002", 100).await.expect("connection failed");
    ///     let config = client.config().await.expect("request config failed");
    ///     println!("{config:?}");
    /// }
    /// ```
    pub async fn config(&self) -> Result<Config, Error> {
        check_version(self.server_version(), Features::CONFIG)?;

        request_helpers::one_shot_request_with_retry(self, encoders::encode_request_config, decoders::decode_config_message, || {
            Err(Error::UnexpectedEndOfStream)
        })
        .await
    }

    /// Begins a fluent [`UpdateConfigBuilder`] to edit the TWS/Gateway
    /// configuration. Set only the groups you want to change and terminate with
    /// [`submit`](UpdateConfigBuilder::submit).
    ///
    /// # Examples
    ///
    /// ```no_run
    /// use ibapi::prelude::*;
    /// use ibapi::config::{OrdersConfig, OrdersSmartRouting};
    ///
    /// #[tokio::main]
    /// async fn main() {
    ///     let client = Client::connect("127.0.0.1:4002", 100).await.expect("connection failed");
    ///
    ///     let response = client
    ///         .update_config()
    ///         .orders(OrdersConfig {
    ///             smart_routing: Some(OrdersSmartRouting {
    ///                 seek_price_improvement: Some(true),
    ///                 ..Default::default()
    ///             }),
    ///         })
    ///         .submit()
    ///         .await
    ///         .expect("update config failed");
    ///     println!("{response:?}");
    /// }
    /// ```
    pub fn update_config(&self) -> UpdateConfigBuilder<'_, Client> {
        UpdateConfigBuilder::new(self)
    }
}

#[cfg(test)]
#[path = "async_tests.rs"]
mod tests;