nautilus_indicators/python/average/
ema.rs1use nautilus_core::python::to_pyvalue_err;
17use nautilus_model::{
18 data::{Bar, QuoteTick, TradeTick},
19 enums::PriceType,
20};
21use pyo3::prelude::*;
22
23use crate::{
24 average::ema::ExponentialMovingAverage,
25 indicator::{Indicator, MovingAverage},
26 python::float_precision,
27};
28
29#[pyo3_stub_gen::derive::gen_stub_pymethods]
30#[pymethods]
31impl ExponentialMovingAverage {
32 #[new]
34 #[pyo3(signature = (period, price_type=None))]
35 fn py_new(period: usize, price_type: Option<PriceType>) -> PyResult<Self> {
36 Self::new_checked(period, price_type).map_err(to_pyvalue_err)
37 }
38
39 fn __repr__(&self) -> String {
40 format!("ExponentialMovingAverage({})", self.period)
41 }
42
43 #[getter]
44 #[pyo3(name = "name")]
45 fn py_name(&self) -> String {
46 self.name()
47 }
48
49 #[getter]
50 #[pyo3(name = "period")]
51 const fn py_period(&self) -> usize {
52 self.period
53 }
54
55 #[getter]
56 #[pyo3(name = "price_type")]
57 const fn py_price_type(&self) -> PriceType {
58 self.price_type
59 }
60
61 #[getter]
62 #[pyo3(name = "alpha")]
63 const fn py_alpha(&self) -> f64 {
64 self.alpha
65 }
66
67 #[getter]
68 #[pyo3(name = "count")]
69 const fn py_count(&self) -> usize {
70 self.count
71 }
72
73 #[getter]
74 #[pyo3(name = "value")]
75 const fn py_value(&self) -> f64 {
76 self.value
77 }
78
79 #[getter]
80 #[pyo3(name = "has_inputs")]
81 fn py_has_inputs(&self) -> bool {
82 self.has_inputs()
83 }
84
85 #[getter]
86 #[pyo3(name = "initialized")]
87 const fn py_initialized(&self) -> bool {
88 self.initialized
89 }
90
91 #[pyo3(name = "handle_quote_tick")]
92 fn py_handle_quote_tick(&mut self, quote: &QuoteTick) -> PyResult<()> {
93 float_precision::check_quote(quote)?;
94 self.handle_quote(quote).map_err(to_pyvalue_err)
95 }
96
97 #[pyo3(name = "handle_trade_tick")]
98 fn py_handle_trade_tick(&mut self, trade: &TradeTick) -> PyResult<()> {
99 float_precision::check_trade(trade)?;
100 self.handle_trade(trade);
101 Ok(())
102 }
103
104 #[pyo3(name = "handle_bar")]
105 fn py_handle_bar(&mut self, bar: &Bar) -> PyResult<()> {
106 float_precision::check_bar(bar)?;
107 self.handle_bar(bar);
108 Ok(())
109 }
110
111 #[pyo3(name = "reset")]
112 fn py_reset(&mut self) {
113 self.reset();
114 }
115
116 #[pyo3(name = "update_raw")]
117 fn py_update_raw(&mut self, value: f64) {
118 self.update_raw(value);
119 }
120}