ibapi 2.11.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

//! Decoders for display group messages.

use log::warn;

use crate::messages::{IncomingMessages, ResponseMessage};
use crate::Error;

use super::stream_decoders::DisplayGroupUpdate;

/// Decodes a DisplayGroupUpdated message.
pub(crate) fn decode_display_group_updated(message: &mut ResponseMessage) -> Result<DisplayGroupUpdate, Error> {
    // Validate message type
    if message.message_type() != IncomingMessages::DisplayGroupUpdated {
        return Err(Error::Simple(format!("unexpected message type: {:?}", message.message_type())));
    }

    // DisplayGroupUpdated: message_type, version, request_id, contract_info
    let contract_info = if message.len() > 3 {
        message.peek_string(3)
    } else {
        warn!("DisplayGroupUpdated message has fewer fields than expected (len={})", message.len());
        String::new()
    };

    Ok(DisplayGroupUpdate::new(contract_info))
}

#[cfg(test)]
mod tests {
    use super::*;

    fn make_response(fields: &[&str]) -> ResponseMessage {
        let raw = fields.join("\0") + "\0";
        ResponseMessage::from(&raw)
    }

    #[test]
    fn test_decode_display_group_updated() {
        // DisplayGroupUpdated (68), version 1, reqId 9000, contractInfo "265598@SMART"
        let mut message = make_response(&["68", "1", "9000", "265598@SMART"]);

        let result = decode_display_group_updated(&mut message).expect("decoding failed");

        assert_eq!(result.contract_info, "265598@SMART");
    }

    #[test]
    fn test_decode_display_group_updated_empty_group() {
        // Short message with no contract info
        let mut message = make_response(&["68", "1", "9000"]);

        let result = decode_display_group_updated(&mut message).expect("decoding failed");

        assert_eq!(result.contract_info, "");
    }

    #[test]
    fn test_decode_display_group_updated_wrong_message_type() {
        // DisplayGroupList (67) instead of DisplayGroupUpdated (68)
        let mut message = make_response(&["67", "1", "9000", "some data"]);

        let result = decode_display_group_updated(&mut message);

        assert!(result.is_err());
        let err_msg = format!("{:?}", result.unwrap_err());
        assert!(err_msg.contains("unexpected message type"));
    }
}