nautilus_analysis/statistics/
expectancy.rs1use std::fmt::Display;
17
18use nautilus_model::position::Position;
19
20use super::{loser_avg::AvgLoser, winner_avg::AvgWinner};
21use crate::{Returns, statistic::PortfolioStatistic};
22
23#[repr(C)]
38#[derive(Debug, Clone)]
39#[cfg_attr(
40 feature = "python",
41 pyo3::pyclass(module = "nautilus_trader.core.nautilus_pyo3.analysis", from_py_object)
42)]
43#[cfg_attr(
44 feature = "python",
45 pyo3_stub_gen::derive::gen_stub_pyclass(module = "nautilus_trader.analysis")
46)]
47pub struct Expectancy {}
48
49impl Display for Expectancy {
50 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
51 write!(f, "Expectancy")
52 }
53}
54
55impl PortfolioStatistic for Expectancy {
56 type Item = f64;
57
58 fn name(&self) -> String {
59 self.to_string()
60 }
61
62 fn calculate_from_realized_pnls(&self, realized_pnls: &[f64]) -> Option<Self::Item> {
63 if realized_pnls.is_empty() {
64 return Some(f64::NAN);
65 }
66
67 let avg_winner = AvgWinner {}
69 .calculate_from_realized_pnls(realized_pnls)
70 .map_or(0.0, |v| if v.is_nan() { 0.0 } else { v });
71 let avg_loser = AvgLoser {}
72 .calculate_from_realized_pnls(realized_pnls)
73 .map_or(0.0, |v| if v.is_nan() { 0.0 } else { v });
74
75 let winners: Vec<f64> = realized_pnls
77 .iter()
78 .filter(|&&pnl| pnl > 0.0)
79 .copied()
80 .collect();
81 let losers: Vec<f64> = realized_pnls
82 .iter()
83 .filter(|&&pnl| pnl < 0.0)
84 .copied()
85 .collect();
86
87 let total_trades = winners.len() + losers.len();
88 if total_trades == 0 {
89 return Some(0.0);
90 }
91
92 let win_rate = winners.len() as f64 / total_trades as f64;
93 let loss_rate = losers.len() as f64 / total_trades as f64;
94
95 Some(avg_winner.mul_add(win_rate, avg_loser * loss_rate))
96 }
97 fn calculate_from_returns(&self, _returns: &Returns) -> Option<Self::Item> {
98 None
99 }
100
101 fn calculate_from_positions(&self, _positions: &[Position]) -> Option<Self::Item> {
102 None
103 }
104}
105
106#[cfg(test)]
107mod tests {
108 use nautilus_core::approx_eq;
109 use rstest::rstest;
110
111 use super::*;
112
113 #[rstest]
114 fn test_empty_pnl_list() {
115 let expectancy = Expectancy {};
116 let result = expectancy.calculate_from_realized_pnls(&[]);
117 assert!(result.is_some());
118 assert!(result.unwrap().is_nan());
119 }
120
121 #[rstest]
122 fn test_all_winners() {
123 let expectancy = Expectancy {};
124 let pnls = vec![10.0, 20.0, 30.0];
125 let result = expectancy.calculate_from_realized_pnls(&pnls);
126
127 assert!(result.is_some());
128 assert!(approx_eq!(f64, result.unwrap(), 20.0, epsilon = 1e-9));
131 }
132
133 #[rstest]
134 fn test_all_losers() {
135 let expectancy = Expectancy {};
136 let pnls = vec![-10.0, -20.0, -30.0];
137 let result = expectancy.calculate_from_realized_pnls(&pnls);
138
139 assert!(result.is_some());
140 assert!(approx_eq!(f64, result.unwrap(), -20.0, epsilon = 1e-9));
143 }
144
145 #[rstest]
146 fn test_mixed_pnls() {
147 let expectancy = Expectancy {};
148 let pnls = vec![10.0, -5.0, 15.0, -10.0];
149 let result = expectancy.calculate_from_realized_pnls(&pnls);
150
151 assert!(result.is_some());
152 assert!(approx_eq!(f64, result.unwrap(), 2.5, epsilon = 1e-9));
159 }
160
161 #[rstest]
162 fn test_single_trade() {
163 let expectancy = Expectancy {};
164 let pnls = vec![10.0];
165 let result = expectancy.calculate_from_realized_pnls(&pnls);
166
167 assert!(result.is_some());
168 assert!(approx_eq!(f64, result.unwrap(), 10.0, epsilon = 1e-9));
171 }
172
173 #[rstest]
174 fn test_zeros_excluded_from_win_loss_rates() {
175 let expectancy = Expectancy {};
176 let pnls = vec![10.0, 0.0, -10.0];
177 let result = expectancy.calculate_from_realized_pnls(&pnls);
178
179 assert!(result.is_some());
180 assert!(approx_eq!(f64, result.unwrap(), 0.0, epsilon = 1e-9));
185 }
186
187 #[rstest]
188 fn test_only_zeros() {
189 let expectancy = Expectancy {};
190 let pnls = vec![0.0, 0.0, 0.0];
191 let result = expectancy.calculate_from_realized_pnls(&pnls);
192
193 assert!(result.is_some());
194 assert!(approx_eq!(f64, result.unwrap(), 0.0, epsilon = 1e-9));
196 }
197
198 #[rstest]
199 fn test_name() {
200 let expectancy = Expectancy {};
201 assert_eq!(expectancy.name(), "Expectancy");
202 }
203}