tradier 0.1.2

This project involves the development of a Rust library for managing trades and market data using the Tradier broker API. The main objective is to provide an efficient and secure interface for executing trades, retrieving real-time quotes, managing portfolios, and accessing historical market data. The library focuses on leveraging Rust's performance and concurrency advantages, enabling integration into high-frequency trading applications and data-intensive financial processing.
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

use std::error::Error;
use tracing::{error, info};
use tradier::utils::logger::setup_logger;
use tradier::wssession::AccountSession;
use tradier::wssession::{MarketSession, MarketSessionFilter, MarketSessionPayload};
use tradier::Config;

/// Initializes the program entry point.
///
/// - Sets up the logger using `setup_logger` for structured logging output.
/// - Loads API configuration from `Config`.
/// - Creates a `SessionManager` to manage singleton WebSocket sessions, enforcing that only one session
///   exists at a time.
///
/// The program enters an infinite loop to continuously create and manage WebSocket streaming sessions.
/// For each loop iteration:
///
/// 1. **MarketSession**: Attempts to create a market session for streaming real-time quotes and trades.
///    If successful, it streams data for specified symbols using `MarketSessionPayload`.
///    On any streaming error, it logs the issue and attempts to reconnect.
/// 2. **AccountSession**: Creates an account session to manage account-level WebSocket interactions,
///    but does not start streaming in this example. The account session creation is logged.
///
/// If either session fails to be created, an error message is logged, and the loop retries
/// after a 5-second delay.
///
/// ## Errors
/// Returns `Err` if there are any issues with initial setup, such as configuration loading or
/// logging initialization.
///
/// ## Returns
/// `Ok(())` if the main function completes successfully (though in this example, it will loop indefinitely).
///
/// ## Examples
/// ```no_run
/// tokio::spawn(async move {
///     main().await.expect("Main function failed");
/// });
/// ```
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    setup_logger();

    let config = Config::new();
    loop {
        match MarketSession::new(&config).await {
            Ok(market_session) => {
                info!(
                    "Market streaming wssession created with id: {}",
                    market_session.get_session_id()
                );
                let symbols = ["AAPL".to_string(), "MSFT".to_string()];
                let payload = MarketSessionPayload::builder()
                    .symbols(&symbols)
                    .filters(&[MarketSessionFilter::QUOTE, MarketSessionFilter::TRADE])
                    .session_id(market_session.get_session_id())
                    .linebreak(true)
                    .valid_only(true)
                    .build();
                if let Err(e) = market_session.ws_stream(payload).await {
                    error!("Streaming error: {}. Reconnecting...", e);
                }
            }
            Err(e) => {
                error!(
                    "Failed to create market streaming wssession: {}. Retrying...",
                    e
                );
            }
        }

        // Example of creating an AccountSession (not used in streaming)
        match AccountSession::new(&config).await {
            Ok(account_session) => {
                info!(
                    "Account wssession created with id: {}",
                    account_session.get_session_id()
                );
                // You can use account_session for account-related operations here
            }
            Err(e) => {
                error!("Failed to create account wssession: {}.", e);
            }
        }

        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
    }
}