ibapi 5.5.0

An unofficial Rust client for the Interactive Brokers TWS API: market data, orders, and account data, with async (Tokio) and blocking clients for TWS and IB Gateway.
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

//! Client state set by the connection handshake, shared with the transport so
//! a reconnect's handshake refreshes it.

use std::sync::atomic::{AtomicI32, Ordering};
use std::sync::Arc;

use super::id_generator::ClientIdManager;
use crate::connection::ConnectionMetadata;

/// The server version negotiated with the current session. Starts at the
/// first connect's; a successful reconnect stores the new handshake's. Keeps
/// the last good value while a reconnect is in progress.
#[derive(Debug)]
pub(crate) struct ServerVersion(AtomicI32);

impl ServerVersion {
    pub(crate) fn new(version: i32) -> Self {
        Self(AtomicI32::new(version))
    }

    pub(crate) fn get(&self) -> i32 {
        self.0.load(Ordering::Acquire)
    }

    fn set(&self, version: i32) {
        self.0.store(version, Ordering::Release);
    }
}

/// What a reconnect's handshake refreshes on the client: the order-id floor
/// and the server version. The client hands it to the transport once, before
/// the transport starts reading.
#[derive(Debug)]
pub(crate) struct HandshakeState {
    pub(crate) order_ids: Arc<ClientIdManager>,
    pub(crate) server_version: Arc<ServerVersion>,
}

impl HandshakeState {
    /// Applies a reconnect's handshake. The transport calls it before
    /// reporting the session as live, so a caller gating on `is_connected()`
    /// can't allocate below the new order-id floor or check a request against
    /// the old server version.
    pub(crate) fn refresh(&self, metadata: &ConnectionMetadata) {
        // Only the first connect seeded the generator; raise it from the
        // server's floor so allocation never resumes below it.
        self.order_ids.raise_order_id_from_server(metadata.next_order_id);
        self.server_version.set(metadata.server_version);
    }
}

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