ig_trading_api 0.3.0

use colored::*;
use ig_trading_api::streaming_api::StreamingApi;
use lightstreamer_client::item_update::ItemUpdate;
use lightstreamer_client::subscription::{Snapshot, Subscription, SubscriptionMode};
use lightstreamer_client::subscription_listener::SubscriptionListener;
use std::error::Error;

pub struct MySubscriptionListener {}

impl SubscriptionListener for MySubscriptionListener {
    fn on_item_update(&self, update: &ItemUpdate) {
        let not_available = "N/A".to_string();
        let item_name = update.item_name.clone().unwrap_or(not_available.clone());
        let fields = vec![
            "BID", "OFFER", "HIGH", "LOW", "MID_OPEN", "CHANGE", "CHANGE_PCT", "MARKET_DELAY", "UPDATE_TIME"
        ];
        let mut output = String::new();
        for field in fields {
            let value = update.get_value(field).unwrap_or(&not_available);
            let value_str = if update.changed_fields.contains_key(field) {
                value.yellow().to_string()
            } else {
                value.to_string()
            };
            output.push_str(&format!("{}: {}, ", field, value_str));
        }
        println!("{}, {}", item_name, output);
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    //
    // Create a new subscription instance.
    //
    let mut my_subscription = Subscription::new(
        // Subscription mode.
        SubscriptionMode::Merge,
        // Subscription items, i.e. instruments to subscribe to.
        Some(vec![
            "MARKET:IX.D.DAX.IFMM.IP".to_string(), // DAX40 Cash 1€
            "MARKET:CS.D.BITCOIN.CFD.IP".to_string(), // Bitcoin
        ]),
        // Subscription fields, i.e. data fields to receive updates for.
        Some(vec![
            "BID".to_string(),
            "OFFER".to_string(),
            "HIGH".to_string(),
            "LOW".to_string(),
            "MID_OPEN".to_string(),
            "CHANGE".to_string(),
            "CHANGE_PCT".to_string(),
            "MARKET_DELAY".to_string(),
            "MARKET_STATE".to_string(),
            "UPDATE_TIME".to_string(),
        ]),
    )?;
    my_subscription.set_requested_snapshot(Some(Snapshot::Yes))?;
    my_subscription.add_listener(Box::new(MySubscriptionListener {}));

    let mut streaming_api = StreamingApi::new(vec![my_subscription], None).await?;
    streaming_api.connect().await;

    Ok(())
}