akshare 0.1.1

//! 数库 (Chinascope) A股新闻情绪指数.

use serde::Deserialize;

use crate::client::AkShareClient;
use crate::error::{Error, Result};
use crate::types::NewsSentimentPoint;

// ---------------------------------------------------------------------------
// Wire types
// ---------------------------------------------------------------------------

#[derive(Debug, Deserialize)]
#[allow(non_snake_case)]
struct ScopeRow {
    #[serde(default)]
    tradeDate: String,
    #[serde(default)]
    maIndex1: Option<f64>,
    #[serde(default)]
    marketClose: Option<f64>,
}

// ---------------------------------------------------------------------------
// Public API
// ---------------------------------------------------------------------------

impl AkShareClient {
    /// 数库 — A股新闻情绪指数.
    pub async fn index_news_sentiment_scope(&self) -> Result<Vec<NewsSentimentPoint>> {
        let response = self
            .get("https://www.chinascope.com/inews/senti/index")
            .query(&[("period", "YEAR")])
            .send()
            .await
            .map_err(Error::from)?
            .error_for_status()
            .map_err(Error::from)?;

        let rows: Vec<ScopeRow> = response.json().await.map_err(Error::from)?;

        let points: Vec<NewsSentimentPoint> = rows
            .into_iter()
            .map(|r| NewsSentimentPoint {
                date: r.tradeDate,
                sentiment_index: r.maIndex1.unwrap_or(0.0),
                csi300: r.marketClose.unwrap_or(0.0),
            })
            .collect();

        if points.is_empty() {
            return Err(Error::not_found("chinascope returned no sentiment data"));
        }
        Ok(points)
    }
}

#[cfg(test)]
mod tests {
    #[test]
    fn test_placeholder() {
        // Scope functions require network access.
    }
}