Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions core/src/indicators/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ mod sonar;
mod stochf;
mod stochrsi;
mod stochs;
mod trix;
mod ultosc;
mod vr;
mod willr;
Expand Down Expand Up @@ -81,6 +82,7 @@ pub use sonar::*;
pub use stochf::*;
pub use stochrsi::*;
pub use stochs::*;
pub use trix::*;
pub use ultosc::*;
pub use vr::*;
pub use willr::*;
Expand Down
164 changes: 164 additions & 0 deletions core/src/indicators/trix.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,164 @@
use crate::indicators::ema::ema;

pub fn trix(
data: &[Option<f64>],
period: usize,
signal_period: usize,
) -> (Vec<Option<f64>>, Vec<Option<f64>>) {
let line = trix_line(data, period);
let signal = ema(&line, signal_period);

(line, signal)
}

pub fn trix_line(data: &[Option<f64>], period: usize) -> Vec<Option<f64>> {
let ema_values = ema(data, period);
let double_ema = ema(&ema_values, period);
let triple_ema = ema(&double_ema, period);

triple_ema
.iter()
.enumerate()
.map(|(idx, &current)| {
if idx == 0 {
return None;
}

match (current, triple_ema[idx - 1]) {
(Some(current), Some(previous)) if previous != 0.0 => {
Some((current - previous) * 100.0 / previous)
}
_ => None,
}
})
.collect()
}

pub fn trix_signal(data: &[Option<f64>], period: usize, signal_period: usize) -> Vec<Option<f64>> {
let line = trix_line(data, period);
ema(&line, signal_period)
}

#[cfg(test)]
Comment thread
sjquant marked this conversation as resolved.
mod tests {
use super::*;
use crate::indicators::ema::ema;
use crate::testutils;
use crate::utils::round_vec;

#[test]
fn test_trix() {
// Given
let test_cases = vec!["005930", "TSLA"];

// When
for symbol in test_cases {
let input = testutils::load_data(&format!("../data/{}.json", symbol), "c")
.into_iter()
.map(Some)
.collect::<Vec<_>>();
let (line, signal) = trix(&input, 12, 9);

let expected_line = testutils::load_expected::<Option<f64>>(&format!(
"../data/expected/trix_line_{}.json",
symbol
));
let expected_signal = testutils::load_expected::<Option<f64>>(&format!(
"../data/expected/trix_signal_{}.json",
symbol
));

// Then
assert_eq!(
round_vec(line, 8),
round_vec(expected_line, 8),
"TRIX line test failed for symbol {}.",
symbol
);
assert_eq!(
round_vec(signal, 8),
round_vec(expected_signal, 8),
"TRIX signal test failed for symbol {}.",
symbol
);
}
}

#[test]
fn test_trix_matches_composed_ema_across_gaps() {
// Given
let input = vec![
Some(1.0),
Some(2.0),
Some(3.0),
Some(4.0),
None,
Some(5.0),
Some(6.0),
Some(7.0),
Some(8.0),
Some(9.0),
];

// When
let line = trix_line(&input, 2);
let single = ema(&input, 2);
let double = ema(&single, 2);
let triple = ema(&double, 2);
let expected = triple
.iter()
.enumerate()
.map(|(idx, &current)| {
if idx == 0 {
return None;
}

match (current, triple[idx - 1]) {
(Some(current), Some(previous)) if previous != 0.0 => {
Some((current - previous) * 100.0 / previous)
}
_ => None,
}
})
.collect::<Vec<_>>();

// Then
assert_eq!(round_vec(line, 8), round_vec(expected, 8));
}

#[test]
fn test_trix_signal_follows_base_ema_contract_across_gaps() {
// Given
let input = vec![
Some(1.0),
Some(2.0),
Some(3.0),
Some(4.0),
None,
Some(5.0),
Some(6.0),
Some(7.0),
Some(8.0),
Some(9.0),
];

// When
let (line, signal) = trix(&input, 2, 2);

// Then
assert_eq!(signal, ema(&line, 2));
assert_eq!(signal, trix_signal(&input, 2, 2));
}

#[test]
fn test_trix_returns_none_when_previous_triple_ema_is_zero() {
// Given
let input = vec![Some(0.0), Some(0.0), Some(1.0), Some(2.0)];

// When
let line = trix_line(&input, 1);

// Then
assert_eq!(line, vec![None, None, None, Some(100.0)]);
}
}
Loading