yfinance-rs 0.9.1

Ergonomic Rust client for Yahoo Finance, supporting historical prices, real-time streaming, options, fundamentals, and more.
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
104
105
106
107
108
109
110
111
112
113
114

use crate::{
    core::{
        CallOptions, DataQuality, ProjectionContext, YfClient, YfError, YfResponse,
        diagnostics::{WireProjection, optional_decimal_f64},
        quotesummary,
    },
    esg::wire::V10Result,
};
use paft::fundamentals::esg::{EsgInvolvement, EsgScores, EsgSummary};

pub(super) async fn fetch_esg_scores(
    client: &YfClient,
    symbol: &str,
    options: &CallOptions,
) -> Result<YfResponse<EsgSummary>, YfError> {
    let root: V10Result =
        quotesummary::fetch_module_result(client, symbol, "esgScores", "esg", options).await?;

    map_esg_scores(symbol, root, options.data_quality())
}

fn map_esg_scores(
    symbol: &str,
    root: V10Result,
    data_quality: DataQuality,
) -> Result<YfResponse<EsgSummary>, YfError> {
    let mut ctx = ProjectionContext::new("esg", data_quality);
    let Some(esg) = root.esg_scores else {
        ctx.unavailable_feature("esgScores")?;
        return Ok(ctx.finish(EsgSummary {
            scores: None,
            involvement: Vec::new(),
        }));
    };

    let environmental = esg.environment_score.optional_raw_field(
        &mut ctx,
        "esgScores.environmentScore",
        Some(symbol),
        "environmentScore",
    )?;
    let social = esg.social_score.optional_raw_field(
        &mut ctx,
        "esgScores.socialScore",
        Some(symbol),
        "socialScore",
    )?;
    let governance = esg.governance_score.optional_raw_field(
        &mut ctx,
        "esgScores.governanceScore",
        Some(symbol),
        "governanceScore",
    )?;

    // Map to paft types: paft::fundamentals::EsgScores now has only environmental/social/governance.
    let scores = EsgScores {
        environmental: optional_decimal_f64(
            &mut ctx,
            "esgScores.environmentScore",
            Some(symbol),
            environmental,
            "ESG score",
        )?,
        social: optional_decimal_f64(
            &mut ctx,
            "esgScores.socialScore",
            Some(symbol),
            social,
            "ESG score",
        )?,
        governance: optional_decimal_f64(
            &mut ctx,
            "esgScores.governanceScore",
            Some(symbol),
            governance,
            "ESG score",
        )?,
    };

    // Collect involvement booleans as individual entries with simple categories.
    let mut involvement: Vec<EsgInvolvement> = Vec::new();
    let mut push_flag = |name: &str, val: Option<bool>| {
        let Some(val) = val else {
            return;
        };
        if val {
            involvement.push(EsgInvolvement {
                category: name.to_string(),
                score: None,
            });
        }
    };
    push_flag("adult", esg.adult);
    push_flag("alcoholic", esg.alcoholic);
    push_flag("animal_testing", esg.animal_testing);
    push_flag("catholic", esg.catholic);
    push_flag("controversial_weapons", esg.controversial_weapons);
    push_flag("small_arms", esg.small_arms);
    push_flag("fur_leather", esg.fur_leather);
    push_flag("gambling", esg.gambling);
    push_flag("gmo", esg.gmo);
    push_flag("military_contract", esg.military_contract);
    push_flag("nuclear", esg.nuclear);
    push_flag("palm_oil", esg.palm_oil);
    push_flag("pesticides", esg.pesticides);
    push_flag("thermal_coal", esg.thermal_coal);
    push_flag("tobacco", esg.tobacco);

    // Return scores together with involvement in a single summary
    Ok(ctx.finish(EsgSummary {
        scores: Some(scores),
        involvement,
    }))
}