wickra_core/indicators/
inverted_hammer.rs1use crate::ohlcv::Candle;
4use crate::traits::Indicator;
5
6#[derive(Debug, Clone, Default)]
44pub struct InvertedHammer {
45 has_emitted: bool,
46}
47
48impl InvertedHammer {
49 pub const fn new() -> Self {
51 Self { has_emitted: false }
52 }
53}
54
55impl Indicator for InvertedHammer {
56 type Input = Candle;
57 type Output = f64;
58
59 fn update(&mut self, candle: Candle) -> Option<f64> {
60 self.has_emitted = true;
61 let range = candle.high - candle.low;
62 if range <= 0.0 {
63 return Some(0.0);
64 }
65 let body = (candle.close - candle.open).abs();
66 if body <= 0.0 {
67 return Some(0.0);
68 }
69 let upper = candle.high - candle.open.max(candle.close);
70 let lower = candle.open.min(candle.close) - candle.low;
71 Some(if upper >= 2.0 * body && lower <= body {
72 1.0
73 } else {
74 0.0
75 })
76 }
77
78 fn reset(&mut self) {
79 self.has_emitted = false;
80 }
81
82 fn warmup_period(&self) -> usize {
83 1
84 }
85
86 fn is_ready(&self) -> bool {
87 self.has_emitted
88 }
89
90 fn name(&self) -> &'static str {
91 "InvertedHammer"
92 }
93}
94
95#[cfg(test)]
96mod tests {
97 use super::*;
98 use crate::traits::BatchExt;
99
100 fn c(open: f64, high: f64, low: f64, close: f64, ts: i64) -> Candle {
101 Candle::new(open, high, low, close, 1.0, ts).unwrap()
102 }
103
104 #[test]
105 fn accessors_and_metadata() {
106 let h = InvertedHammer::new();
107 assert_eq!(h.name(), "InvertedHammer");
108 assert_eq!(h.warmup_period(), 1);
109 assert!(!h.is_ready());
110 }
111
112 #[test]
113 fn clean_inverted_hammer_is_one() {
114 let mut h = InvertedHammer::new();
115 assert_eq!(h.update(c(10.0, 15.0, 9.9, 10.5, 0)), Some(1.0));
117 }
118
119 #[test]
120 fn hammer_shape_is_not_inverted() {
121 let mut h = InvertedHammer::new();
122 assert_eq!(h.update(c(10.0, 10.6, 5.0, 10.5, 0)), Some(0.0));
123 }
124
125 #[test]
126 fn doji_is_not_inverted_hammer() {
127 let mut h = InvertedHammer::new();
128 assert_eq!(h.update(c(10.0, 11.0, 9.0, 10.0, 0)), Some(0.0));
129 }
130
131 #[test]
132 fn zero_range_yields_zero() {
133 let mut h = InvertedHammer::new();
134 assert_eq!(h.update(c(10.0, 10.0, 10.0, 10.0, 0)), Some(0.0));
135 }
136
137 #[test]
138 fn batch_equals_streaming() {
139 let candles: Vec<Candle> = (0..40)
140 .map(|i| {
141 let base = 100.0 + i as f64;
142 c(base, base + 4.0, base - 0.1, base + 0.5, i)
143 })
144 .collect();
145 let mut a = InvertedHammer::new();
146 let mut b = InvertedHammer::new();
147 assert_eq!(
148 a.batch(&candles),
149 candles.iter().map(|x| b.update(*x)).collect::<Vec<_>>()
150 );
151 }
152
153 #[test]
154 fn reset_clears_state() {
155 let mut h = InvertedHammer::new();
156 h.update(c(10.0, 15.0, 9.9, 10.5, 0));
157 assert!(h.is_ready());
158 h.reset();
159 assert!(!h.is_ready());
160 }
161}