ib-flex 0.1.7

Pure Rust parser for Interactive Brokers FLEX XML statements
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

//! Debug full parsing

use std::fs;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let xml = fs::read_to_string("tmp/first_statement.xml")?;

    println!("Testing full parse...");

    match ib_flex::parse_activity_flex(&xml) {
        Ok(stmt) => {
            println!("SUCCESS!");
            println!("Account: {}", stmt.account_id);
            println!("Trades: {}", stmt.trades.items.len());
            println!("Positions: {}", stmt.positions.items.len());
        }
        Err(e) => {
            println!("FAILED: {:?}", e);

            // Try to find which part is failing
            // Test removing the flatten catchall
            use ib_flex::types::activity::*;
            use serde::Deserialize;

            #[derive(Debug, Deserialize)]
            #[serde(rename = "FlexQueryResponse")]
            struct TestResponse {
                #[serde(rename = "FlexStatements")]
                statements: TestStatements,
            }

            #[derive(Debug, Deserialize)]
            struct TestStatements {
                #[serde(rename = "FlexStatement", default)]
                statements: Vec<TestStatement>,
            }

            // Test with more sections
            #[allow(dead_code)]
            #[derive(Debug, Deserialize)]
            struct TestStatement {
                #[serde(rename = "@accountId")]
                account_id: String,
                // Core sections
                #[serde(rename = "Trades", default)]
                trades: TradesWrapper,
                #[serde(rename = "OpenPositions", default)]
                positions: PositionsWrapper,
                #[serde(rename = "CashTransactions", default)]
                cash_transactions: CashTransactionsWrapper,
                #[serde(rename = "CorporateActions", default)]
                corporate_actions: CorporateActionsWrapper,
                #[serde(rename = "SecuritiesInfo", default)]
                securities_info: SecuritiesInfoWrapper,
                #[serde(rename = "ConversionRates", default)]
                conversion_rates: ConversionRatesWrapper,
                // Extended sections
                #[serde(rename = "EquitySummaryInBase", default)]
                equity_summary: EquitySummaryWrapper,
                #[serde(rename = "CashReport", default)]
                cash_report: CashReportWrapper,
                #[serde(rename = "InterestAccruals", default)]
                interest_accruals: InterestAccrualsWrapper,
                #[serde(rename = "MTMPerformanceSummaryInBase", default)]
                mtm_performance: MTMPerformanceSummaryWrapper,
                #[serde(rename = "FIFOPerformanceSummaryInBase", default)]
                fifo_performance: FIFOPerformanceSummaryWrapper,
                #[serde(rename = "MTDYTDPerformanceSummary", default)]
                mtd_ytd_performance: MTDYTDPerformanceSummaryWrapper,
                #[serde(rename = "StmtFunds", default)]
                stmt_funds: StatementOfFundsWrapper,
                #[serde(rename = "ChangeInPositionValues", default)]
                change_in_position_values: ChangeInPositionValueWrapper,
                #[serde(rename = "UnbundledCommissionDetails", default)]
                unbundled_commission: UnbundledCommissionDetailWrapper,
                // Additional sections to test
                #[serde(rename = "ChangeInNAV", default)]
                change_in_nav: Option<ib_flex::types::extended::ChangeInNAV>,
                #[serde(rename = "AccountInformation", default)]
                account_information: Option<ib_flex::types::extended::AccountInformation>,
                // More v0.2.0 sections
                #[serde(rename = "TradeConfirms", default)]
                trade_confirms: ib_flex::types::activity::TradeConfirmsWrapper,
                #[serde(rename = "OptionEAE", default)]
                option_eae: ib_flex::types::activity::OptionEAEWrapper,
                #[serde(rename = "FxTransactions", default)]
                fx_transactions: ib_flex::types::activity::FxTransactionsWrapper,
                #[serde(rename = "ChangeInDividendAccruals", default)]
                change_in_dividend_accruals:
                    ib_flex::types::activity::ChangeInDividendAccrualsWrapper,
                #[serde(rename = "OpenDividendAccruals", default)]
                open_dividend_accruals: ib_flex::types::activity::OpenDividendAccrualsWrapper,
                #[serde(rename = "Transfers", default)]
                transfers: ib_flex::types::activity::TransfersWrapper,
                // v0.3.0 sections - first half
                #[serde(rename = "ClientFees", default)]
                client_fees: ib_flex::types::activity::ClientFeesWrapper,
                #[serde(rename = "ClientFeesDetails", default)]
                client_fees_detail: ib_flex::types::activity::ClientFeesDetailWrapper,
                #[serde(rename = "SLBActivities", default)]
                slb_activities: ib_flex::types::activity::SLBActivitiesWrapper,
                #[serde(rename = "SLBFees", default)]
                slb_fees: ib_flex::types::activity::SLBFeesWrapper,
                #[serde(rename = "HardToBorrowDetails", default)]
                hard_to_borrow_details: ib_flex::types::activity::HardToBorrowDetailsWrapper,
                #[serde(rename = "FxLots", default)]
                fx_lots: ib_flex::types::activity::FxLotsWrapper,
                #[serde(rename = "UnsettledTransfers", default)]
                unsettled_transfers: ib_flex::types::activity::UnsettledTransfersWrapper,
                // v0.3.0 second half - testing each one
                #[serde(rename = "TradeTransfers", default)]
                trade_transfers: ib_flex::types::activity::TradeTransfersWrapper,
                #[serde(rename = "PriorPeriodPositions", default)]
                prior_period_positions: ib_flex::types::activity::PriorPeriodPositionsWrapper,
                // All v0.3.0 sections enabled
                #[serde(rename = "TierInterestDetails", default)]
                tier_interest_details: ib_flex::types::activity::TierInterestDetailsWrapper,
                #[serde(rename = "DebitCardActivities", default)]
                debit_card_activities: ib_flex::types::activity::DebitCardActivitiesWrapper,
                #[serde(rename = "SalesTaxes", default)]
                sales_tax: ib_flex::types::activity::SalesTaxWrapper,
                #[serde(rename = "SymbolSummary", default)]
                symbol_summary: ib_flex::types::activity::SymbolSummaryWrapper,
                #[serde(rename = "AssetSummary", default)]
                asset_summary: ib_flex::types::activity::AssetSummaryWrapper,
                #[serde(rename = "Orders", default)]
                orders: ib_flex::types::activity::OrdersWrapper,
                // Rest ignored with flatten
                #[serde(flatten)]
                _rest: std::collections::HashMap<String, serde::de::IgnoredAny>,
            }

            println!("\nTrying without IgnoredSection, using IgnoredAny directly...");
            match quick_xml::de::from_str::<TestResponse>(&xml) {
                Ok(response) => {
                    println!("  SUCCESS with test struct!");
                    for stmt in &response.statements.statements {
                        println!("    Account: {}", stmt.account_id);
                        println!("    Trades: {}", stmt.trades.items.len());
                    }
                }
                Err(e) => {
                    println!("  FAILED: {:?}", e);
                }
            }
        }
    }

    Ok(())
}