dceapi-rs 0.1.0

Dalian Commodity Exchange (DCE) API client library
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

//! Market service for quote and market data APIs.

use crate::error::{Error, Result};
use crate::http::{BaseClient, RequestOptions};
use crate::models::{
    ContractStat, ContractStatRequest, MonthQuotesRequest, Quote, QuotesRequest, WeekQuotesRequest,
};

/// API endpoint for night quotes.
const PATH_GET_NIGHT_QUOTES: &str = "/dceapi/forward/publicweb/dailystat/tiNightQuotes";

/// API endpoint for day quotes.
const PATH_GET_DAY_QUOTES: &str = "/dceapi/forward/publicweb/dailystat/dayQuotes";

/// API endpoint for week quotes.
const PATH_GET_WEEK_QUOTES: &str = "/dceapi/forward/publicweb/dailystat/weekQuotes";

/// API endpoint for month quotes.
const PATH_GET_MONTH_QUOTES: &str = "/dceapi/forward/publicweb/dailystat/monthQuotes";

/// API endpoint for contract statistics.
const PATH_GET_CONTRACT_STAT: &str = "/dceapi/forward/publicweb/dailystat/contractStat";

/// Market service for accessing quote and market data.
#[derive(Debug, Clone)]
pub struct MarketService {
    client: BaseClient,
}

impl MarketService {
    /// Create a new market service.
    pub fn new(client: BaseClient) -> Self {
        MarketService { client }
    }

    /// Get night session quotes.
    ///
    /// # Arguments
    /// * `req` - Request with variety and trade date
    /// * `opts` - Optional request options
    pub async fn get_night_quotes(
        &self,
        req: &QuotesRequest,
        opts: Option<RequestOptions>,
    ) -> Result<Vec<Quote>> {
        self.client.do_post(PATH_GET_NIGHT_QUOTES, req, opts).await
    }

    /// Get day session quotes.
    ///
    /// # Arguments
    /// * `req` - Request with variety and trade date
    /// * `opts` - Optional request options
    pub async fn get_day_quotes(
        &self,
        req: &QuotesRequest,
        opts: Option<RequestOptions>,
    ) -> Result<Vec<Quote>> {
        self.client.do_post(PATH_GET_DAY_QUOTES, req, opts).await
    }

    /// Get weekly quotes.
    ///
    /// # Arguments
    /// * `req` - Request with variety, year, and week number
    /// * `opts` - Optional request options
    pub async fn get_week_quotes(
        &self,
        req: &WeekQuotesRequest,
        opts: Option<RequestOptions>,
    ) -> Result<Vec<Quote>> {
        self.client.do_post(PATH_GET_WEEK_QUOTES, req, opts).await
    }

    /// Get monthly quotes.
    ///
    /// # Arguments
    /// * `req` - Request with variety, year, and month
    /// * `opts` - Optional request options
    pub async fn get_month_quotes(
        &self,
        req: &MonthQuotesRequest,
        opts: Option<RequestOptions>,
    ) -> Result<Vec<Quote>> {
        self.client.do_post(PATH_GET_MONTH_QUOTES, req, opts).await
    }

    /// Get contract statistics for a date range.
    ///
    /// # Arguments
    /// * `req` - Request with contract code and date range
    /// * `opts` - Optional request options
    pub async fn get_contract_stat(
        &self,
        req: &ContractStatRequest,
        opts: Option<RequestOptions>,
    ) -> Result<ContractStat> {
        if req.contract_code.is_empty() {
            return Err(Error::validation("contract_code", "contract_code is required"));
        }
        self.client.do_post(PATH_GET_CONTRACT_STAT, req, opts).await
    }
}