opendeviationbar-core 13.75.0

Core open deviation bar construction algorithm with temporal integrity guarantees
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132

//! Processing error types
//!
//! Extracted from processor.rs (Phase 2a refactoring)

#[cfg(feature = "python")]
use pyo3::prelude::*;
use thiserror::Error;

/// Processing errors
#[derive(Error, Debug)]
pub enum ProcessingError {
    #[error(
        "Trades not sorted at index {index}: prev=({prev_time}, {prev_id}), curr=({curr_time}, {curr_id})"
    )]
    UnsortedTrades {
        index: usize,
        prev_time: i64,
        prev_id: i64,
        curr_time: i64,
        curr_id: i64,
    },

    #[error("Empty trade data")]
    EmptyData,

    #[error(
        "Invalid threshold: {threshold_decimal_bps} dbps. Valid range: 1-100,000 dbps (0.001%-100%)"
    )]
    InvalidThreshold { threshold_decimal_bps: u32 },
}

#[cfg(feature = "python")]
impl From<ProcessingError> for PyErr {
    fn from(err: ProcessingError) -> PyErr {
        match err {
            ProcessingError::UnsortedTrades {
                index,
                prev_time,
                prev_id,
                curr_time,
                curr_id,
            } => pyo3::exceptions::PyValueError::new_err(format!(
                "Trades not sorted at index {}: prev=({}, {}), curr=({}, {})",
                index, prev_time, prev_id, curr_time, curr_id
            )),
            ProcessingError::EmptyData => {
                pyo3::exceptions::PyValueError::new_err("Empty trade data")
            }
            ProcessingError::InvalidThreshold {
                threshold_decimal_bps,
            } => pyo3::exceptions::PyValueError::new_err(format!(
                "Invalid threshold: {} dbps. Valid range: 1-100,000 dbps (0.001%-100%)",
                threshold_decimal_bps
            )),
        }
    }
}

// Issue #96 Task #87: Test coverage for error Display formatting
#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_unsorted_trades_display() {
        let err = ProcessingError::UnsortedTrades {
            index: 42,
            prev_time: 1000,
            prev_id: 100,
            curr_time: 999,
            curr_id: 101,
        };
        let msg = err.to_string();
        assert!(msg.contains("index 42"));
        assert!(msg.contains("prev=(1000, 100)"));
        assert!(msg.contains("curr=(999, 101)"));
    }

    #[test]
    fn test_empty_data_display() {
        let err = ProcessingError::EmptyData;
        assert_eq!(err.to_string(), "Empty trade data");
    }

    #[test]
    fn test_invalid_threshold_display() {
        let err = ProcessingError::InvalidThreshold {
            threshold_decimal_bps: 0,
        };
        let msg = err.to_string();
        assert!(msg.contains("0 dbps"));
        assert!(msg.contains("Valid range"));
    }

    #[test]
    fn test_invalid_threshold_large_value() {
        let err = ProcessingError::InvalidThreshold {
            threshold_decimal_bps: 999_999,
        };
        assert!(err.to_string().contains("999999 dbps"));
    }

    #[test]
    fn test_error_is_send_sync() {
        fn assert_send<T: Send>() {}
        fn assert_sync<T: Sync>() {}
        // ProcessingError must be Send+Sync for cross-thread use
        assert_send::<ProcessingError>();
        assert_sync::<ProcessingError>();
    }

    #[test]
    fn test_error_debug_impl() {
        let err = ProcessingError::EmptyData;
        let debug = format!("{:?}", err);
        assert!(debug.contains("EmptyData"));
    }

    #[test]
    fn test_unsorted_trades_boundary_values() {
        let err = ProcessingError::UnsortedTrades {
            index: usize::MAX,
            prev_time: i64::MIN,
            prev_id: i64::MAX,
            curr_time: 0,
            curr_id: 0,
        };
        // Should not panic on extreme values
        let msg = err.to_string();
        assert!(!msg.is_empty());
    }
}