finance-query 3.0.0

A Rust library for querying financial data
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

//! CFTC Commitments of Traders (disaggregated futures-only) wire types.
//!
//! `publicreporting.cftc.gov`'s Socrata API serves every numeric column as a
//! JSON string (Socrata's `number` column type round-trips through strings),
//! so every figure here is `Option<String>` and parsed on the way to the
//! canonical model. Only the columns this adapter maps are modelled — the
//! full dataset carries well over a hundred (old/other/all variants,
//! percent-of-open-interest, trader counts, concentration ratios, …).

use serde::Deserialize;

/// One weekly row of the disaggregated futures-only combined report.
#[derive(Debug, Clone, Deserialize)]
pub(crate) struct CotRow {
    #[serde(default)]
    pub market_and_exchange_names: Option<String>,
    #[serde(default)]
    pub cftc_contract_market_code: Option<String>,
    #[serde(default)]
    pub report_date_as_yyyy_mm_dd: Option<String>,
    #[serde(default)]
    pub open_interest_all: Option<String>,
    #[serde(default)]
    pub prod_merc_positions_long: Option<String>,
    #[serde(default)]
    pub prod_merc_positions_short: Option<String>,
    #[serde(default)]
    pub swap_positions_long_all: Option<String>,
    // Socrata's own column name has the double underscore — not a typo.
    #[serde(default, rename = "swap__positions_short_all")]
    pub swap_positions_short_all: Option<String>,
    #[serde(default, rename = "swap__positions_spread_all")]
    pub swap_positions_spread_all: Option<String>,
    #[serde(default)]
    pub m_money_positions_long_all: Option<String>,
    #[serde(default)]
    pub m_money_positions_short_all: Option<String>,
    #[serde(default)]
    pub m_money_positions_spread: Option<String>,
    #[serde(default)]
    pub other_rept_positions_long: Option<String>,
    #[serde(default)]
    pub other_rept_positions_short: Option<String>,
    #[serde(default)]
    pub other_rept_positions_spread: Option<String>,
    #[serde(default)]
    pub tot_rept_positions_long_all: Option<String>,
    #[serde(default)]
    pub tot_rept_positions_short: Option<String>,
    #[serde(default)]
    pub nonrept_positions_long_all: Option<String>,
    #[serde(default)]
    pub nonrept_positions_short_all: Option<String>,
}

/// A rejected-query error body: `{"message": "..."}`.
#[derive(Debug, Clone, Deserialize)]
pub(crate) struct CftcError {
    #[serde(default)]
    pub message: Option<String>,
}