quantsupport 0.1.7

use std::any::{Any, TypeId};
use std::collections::HashMap;

use crate::utils::errors::QSError;
use crate::{
    core::{
        evaluationresults::EvaluationResults, pricer::ErasedPricer, pricingcontext::PricingContext,
        request::Request,
    },
    utils::errors::Result,
};

/// Dispatches pricing requests to registered [`ErasedPricer`] implementations.
#[derive(Default)]
pub struct Evaluator {
    // Models should be passed somewhere...
    pricers: HashMap<TypeId, Box<dyn ErasedPricer>>,
}

impl Evaluator {
    /// Creates a new [`Evaluator`] with the specified models and pricers.
    #[must_use]
    pub fn new(pricers: HashMap<TypeId, Box<dyn ErasedPricer>>) -> Self {
        Self { pricers }
    }

    /// Evaluates the given trade using the registered models and pricers, returning the evaluation results.
    ///
    /// # Errors
    /// Returns an error if no pricer is registered for the trade type or if evaluation fails.
    pub fn evaluate(
        &self,
        trade: &dyn Any,
        requests: &[Request],
        context: &PricingContext,
    ) -> Result<EvaluationResults> {
        let trade_type_id = trade.type_id();
        self.pricers.get(&trade_type_id).map_or_else(
            || {
                Err(QSError::NotFoundErr(format!(
                    "No pricer registered for trade type: {trade_type_id:?}"
                )))
            },
            |pricer| pricer.evaluate_erased(trade, requests, context),
        )
    }
}

#[cfg(test)]
mod tests {
    use std::any::TypeId;
    use std::collections::HashMap;

    use super::Evaluator;
    use crate::{
        core::{
            evaluationresults::EvaluationResults,
            marketdatahandling::marketdata::{MarketDataProvider, MarketDataRequest},
            pricer::{ErasedPricer, Pricer},
            pricingcontext::PricingContext,
            request::Request,
        },
        utils::errors::Result,
    };

    struct DummyTrade;
    struct UnregisteredTrade;

    struct DummyPricer;

    impl Pricer for DummyPricer {
        type Item = DummyTrade;
        type Policy = ();

        fn evaluate(
            &self,
            _trade: &DummyTrade,
            _requests: &[Request],
            ctx: &impl MarketDataProvider,
        ) -> Result<EvaluationResults> {
            Ok(EvaluationResults::new(ctx.evaluation_date(), "dummy".to_string()).with_price(42.0))
        }

        fn market_data_request(&self, _trade: &DummyTrade) -> Option<MarketDataRequest> {
            None
        }

        fn set_discount_policy(&mut self, _policy: Box<Self::Policy>) {}

        fn discount_policy(&self) -> Option<&Self::Policy> {
            None
        }
    }

    #[test]
    fn dispatches_to_registered_pricer_by_trade_type() -> Result<()> {
        let mut pricers: HashMap<TypeId, Box<dyn ErasedPricer>> = HashMap::new();
        pricers.insert(TypeId::of::<DummyTrade>(), Box::new(DummyPricer));
        let evaluator = Evaluator::new(pricers);

        let ctx = PricingContext::new();
        let results = evaluator.evaluate(&DummyTrade, &[Request::Value], &ctx)?;
        assert_eq!(results.price(), Some(42.0));
        Ok(())
    }

    #[test]
    fn unregistered_trade_type_is_an_error() {
        let evaluator = Evaluator::new(HashMap::new());
        let ctx = PricingContext::new();
        let result = evaluator.evaluate(&UnregisteredTrade, &[Request::Value], &ctx);
        assert!(
            result.is_err(),
            "expected error for unregistered trade type"
        );
    }

    #[test]
    fn mismatched_registration_surfaces_downcast_error() {
        // Register the pricer under the wrong trade type id: dispatch succeeds
        // but the blanket ErasedPricer downcast must fail with a clear error.
        let mut pricers: HashMap<TypeId, Box<dyn ErasedPricer>> = HashMap::new();
        pricers.insert(TypeId::of::<UnregisteredTrade>(), Box::new(DummyPricer));
        let evaluator = Evaluator::new(pricers);

        let ctx = PricingContext::new();
        let result = evaluator.evaluate(&UnregisteredTrade, &[Request::Value], &ctx);
        let err = match result {
            Ok(_) => panic!("expected downcast failure"),
            Err(err) => err,
        };
        assert!(
            err.to_string().contains("DummyTrade"),
            "error should name the expected trade type, got: {err}"
        );
    }
}