ib_tws_core 0.2.0

Core utilities for interacting with Interactive Broker's TWS API
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

use std::io;

use bytes::BytesMut;

use super::wire::{TwsWireDecoder, TwsWireEncoder};
use crate::domain::{Contract, ContractDetails, TagValue};

pub fn encode_contract(buf: &mut BytesMut, contract: &Contract) {
    buf.push_int(contract.con_id);

    buf.push_string(&contract.symbol);
    buf.push_string(&contract.sec_type);
    buf.push_string(&contract.last_trade_date_or_contract_month);
    buf.push_double(contract.strike);
    buf.push_string(&contract.right);
    buf.push_string(&contract.multiplier);
    buf.push_string(&contract.exchange);
    buf.push_string(&contract.primary_exch);
    buf.push_string(&contract.currency);
    buf.push_string(&contract.local_symbol);

    buf.push_string(&contract.trading_class);
}

pub fn read_last_trade_date(
    buf: &mut BytesMut,
    contract: &mut ContractDetails,
    is_bond: bool,
) -> Result<(), io::Error> {
    let last_trade_date_or_contract_month = buf.read_string()?;
    if !last_trade_date_or_contract_month.is_empty() {
        let splitted: Vec<&str> = last_trade_date_or_contract_month.split("\\s+").collect();
        if !splitted.is_empty() {
            if is_bond {
                contract.maturity = splitted[0].to_string();
            } else {
                contract.contract.last_trade_date_or_contract_month = splitted[0].to_string();
            }
        }
        if splitted.len() > 1 {
            contract.last_trade_time = splitted[1].to_string();
        }
        if is_bond && splitted.len() > 2 {
            contract.timezone_id = splitted[2].to_string();
        }
    }
    Ok(())
}

pub fn encode_contract_without_primary_exch(buf: &mut BytesMut, contract: &Contract) {
    buf.push_int(contract.con_id);

    buf.push_string(&contract.symbol);
    buf.push_string(&contract.sec_type);
    buf.push_string(&contract.last_trade_date_or_contract_month);
    buf.push_double(contract.strike);
    buf.push_string(&contract.right);
    buf.push_string(&contract.multiplier);
    buf.push_string(&contract.exchange);
    buf.push_string(&contract.currency);
    buf.push_string(&contract.local_symbol);

    buf.push_string(&contract.trading_class);
}

pub fn encode_tagvalue_as_string(buf: &mut BytesMut, options: &[TagValue]) {
    let count = options.len() as i32;
    //println!("count: {} content: {:?}", count, options);
    let mut sb = "".to_string();
    if count > 0 {
        for elem in options {
            let s = format!("{}={};", elem.tag, elem.value);
            sb.push_str(&s);
        }
    }
    buf.push_string(&sb)
}