tickrs 0.15.0

Realtime ticker data in your terminal 📈
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

use async_std::sync::Arc;
use futures::future::BoxFuture;

use super::*;
use crate::YAHOO_CRUMB;

/// Returns the current price, only if it has changed
pub struct CurrentPrice {
    symbol: String,
}

impl CurrentPrice {
    pub fn new(symbol: String) -> CurrentPrice {
        CurrentPrice { symbol }
    }
}

impl AsyncTask for CurrentPrice {
    type Input = String;
    type Response = (f64, Option<f64>, String);

    fn update_interval(&self) -> Option<Duration> {
        Some(Duration::from_secs(1))
    }

    fn input(&self) -> Self::Input {
        self.symbol.clone()
    }

    fn task<'a>(input: Arc<Self::Input>) -> BoxFuture<'a, Option<Self::Response>> {
        Box::pin(async move {
            let symbol = input.as_ref();

            let crumb = YAHOO_CRUMB.read().await.clone();

            if let Some(crumb) = crumb {
                if let Ok(response) = crate::CLIENT.get_company_data(symbol, crumb).await {
                    let regular_price = response.price.regular_market_price.price;

                    let post_price = response.price.post_market_price.price;

                    let volume = response.price.regular_market_volume.fmt.unwrap_or_default();

                    return Some((regular_price, post_price, volume));
                }
            }

            None
        })
    }
}