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

//! Macros for generating quote summary accessor methods.
#![allow(missing_docs)]

macro_rules! define_quote_accessors {
    (
        $(
            $(#[$meta:meta])*
            $method_name:ident -> $return_type:ty, $field_name:ident
        ),* $(,)?
    ) => {
        impl Ticker {
            $(
                $(#[$meta])*
                pub async fn $method_name(&self) -> crate::error::Result<Option<$return_type>> {
                    let cache = self.ensure_quote().await?;
                    let value = cache.as_ref().and_then(|e| e.value.$field_name.clone());
                    #[cfg(feature = "translation")]
                    let value = match value {
                        Some(mut v) => {
                            drop(cache);
                            self.translate_response(&mut v).await?;
                            Some(v)
                        }
                        None => None,
                    };
                    Ok(value)
                }
            )*
        }
    };
}

pub(crate) use define_quote_accessors;

/// Dispatch a symbol-keyed provider call and await it.
///
/// `$acc` is the [`ProviderAdapter`](crate::providers::ProviderAdapter)
/// capability accessor (e.g. `as_fundamentals`) and `$op` the
/// [`Operation`](crate::providers::Operation) reported when a routed provider
/// lacks it. Extra `$arg`s are passed after the symbol and must be `Copy` —
/// dispatch may call the closure once per routed provider.
macro_rules! ticker_fetch {
    ($self:expr, $cap:ident, $acc:ident, $op:ident, $fetch:ident $(, $arg:expr)* $(,)?) => {{
        let __sym = $self.symbol.clone();
        $self
            .providers
            .fetch(crate::providers::Capability::$cap, move |p| {
                let __sym = __sym.clone();
                let p = p.clone();
                async move {
                    p.$acc()
                        .ok_or_else(|| p.not_supported(crate::providers::Operation::$op))?
                        .$fetch(&__sym $(, $arg)*)
                        .await
                }
            })
            .await
    }};
}

pub(crate) use ticker_fetch;