wickra_core/indicators/
auto_fib.rs1use crate::indicators::pattern_swing::{SwingTracker, SWING_THRESHOLD};
4use crate::ohlcv::Candle;
5use crate::traits::Indicator;
6
7const PIVOT_HISTORY: usize = 6;
9
10const RATIOS: [f64; 7] = [0.0, 0.236, 0.382, 0.5, 0.618, 0.786, 1.0];
12
13#[derive(Debug, Clone, Copy, PartialEq)]
15pub struct AutoFibOutput {
16 pub level_0: f64,
18 pub level_236: f64,
20 pub level_382: f64,
22 pub level_500: f64,
24 pub level_618: f64,
26 pub level_786: f64,
28 pub level_1000: f64,
30}
31
32#[derive(Debug, Clone)]
59pub struct AutoFib {
60 swing: SwingTracker,
61}
62
63impl AutoFib {
64 #[must_use]
66 pub const fn new() -> Self {
67 Self {
68 swing: SwingTracker::new(SWING_THRESHOLD, PIVOT_HISTORY),
69 }
70 }
71
72 fn levels(&self) -> Option<AutoFibOutput> {
73 let dominant = self.swing.pivots().windows(2).max_by(|x, y| {
74 (x[0].price - x[1].price)
75 .abs()
76 .total_cmp(&(y[0].price - y[1].price).abs())
77 })?;
78 let (start, end) = (dominant[0].price, dominant[1].price);
79 let level = |r: f64| end + r * (start - end);
80 Some(AutoFibOutput {
81 level_0: level(RATIOS[0]),
82 level_236: level(RATIOS[1]),
83 level_382: level(RATIOS[2]),
84 level_500: level(RATIOS[3]),
85 level_618: level(RATIOS[4]),
86 level_786: level(RATIOS[5]),
87 level_1000: level(RATIOS[6]),
88 })
89 }
90}
91
92impl Default for AutoFib {
93 fn default() -> Self {
94 Self::new()
95 }
96}
97
98impl Indicator for AutoFib {
99 type Input = Candle;
100 type Output = AutoFibOutput;
101
102 #[inline]
103 fn update(&mut self, candle: Candle) -> Option<AutoFibOutput> {
104 self.swing.update(candle);
105 self.levels()
106 }
107
108 fn reset(&mut self) {
109 self.swing.reset();
110 }
111
112 #[inline]
113 fn warmup_period(&self) -> usize {
114 2
115 }
116
117 #[inline]
118 fn is_ready(&self) -> bool {
119 self.swing.pivots().len() >= 2
120 }
121
122 #[inline]
123 fn name(&self) -> &'static str {
124 "AutoFib"
125 }
126}
127
128#[cfg(test)]
129mod tests {
130 use super::*;
131 use crate::indicators::pattern_swing::candles_for_pivots;
132 use crate::traits::BatchExt;
133 use approx::assert_relative_eq;
134
135 #[test]
136 fn accessors_and_metadata() {
137 let indicator = AutoFib::new();
138 assert_eq!(indicator.name(), "AutoFib");
139 assert_eq!(indicator.warmup_period(), 2);
140 assert!(!indicator.is_ready());
141 assert!(!AutoFib::default().is_ready());
142 }
143
144 #[test]
145 fn no_output_before_two_pivots() {
146 let mut indicator = AutoFib::new();
147 let outputs: Vec<_> = candles_for_pivots(&[120.0])
148 .into_iter()
149 .map(|c| indicator.update(c))
150 .collect();
151 assert!(outputs.iter().all(Option::is_none));
152 }
153
154 #[test]
155 fn anchors_on_the_largest_leg() {
156 let mut indicator = AutoFib::new();
159 let mut last = None;
160 for candle in candles_for_pivots(&[130.0, 120.0, 220.0, 200.0]) {
161 last = indicator.update(candle);
162 }
163 let v = last.unwrap();
164 assert!(indicator.is_ready());
165 assert_relative_eq!(v.level_0, 220.0);
167 assert_relative_eq!(v.level_1000, 120.0);
168 assert_relative_eq!(v.level_500, 170.0);
169 assert_relative_eq!(v.level_618, 220.0 + 0.618 * (120.0 - 220.0));
170 }
171
172 #[test]
173 fn reset_clears_state() {
174 let mut indicator = AutoFib::new();
175 for candle in candles_for_pivots(&[200.0, 100.0]) {
176 let _ = indicator.update(candle);
177 }
178 assert!(indicator.is_ready());
179 indicator.reset();
180 assert!(!indicator.is_ready());
181 let c = Candle::new(99.5, 100.0, 99.5, 99.5, 1.0, 0).unwrap();
182 assert!(indicator.update(c).is_none());
183 }
184
185 #[test]
186 fn batch_equals_streaming() {
187 let candles = candles_for_pivots(&[130.0, 120.0, 220.0, 200.0]);
188 let mut a = AutoFib::new();
189 let mut b = AutoFib::new();
190 assert_eq!(
191 a.batch(&candles),
192 candles.iter().map(|x| b.update(*x)).collect::<Vec<_>>()
193 );
194 }
195}