|
1 | 1 | use embedded_hal::{ |
2 | 2 | delay::DelayNs, |
3 | | - digital::{ErrorType, InputPin, OutputPin, PinState}, |
| 3 | + digital::{InputPin, OutputPin, PinState}, |
4 | 4 | }; |
5 | 5 |
|
6 | 6 | use crate::SensorError; |
7 | 7 |
|
| 8 | +#[cfg(test)] |
| 9 | +const DEFAULT_MAX_ATTEMPTS: usize = 10; |
| 10 | +#[cfg(not(test))] |
8 | 11 | const DEFAULT_MAX_ATTEMPTS: usize = 10_000; |
9 | 12 |
|
10 | 13 | /// Common base struct for DHT11, DHT22 sensors. |
@@ -93,9 +96,13 @@ impl<P: InputPin + OutputPin, D: DelayNs> Dht<P, D> { |
93 | 96 |
|
94 | 97 | #[cfg(test)] |
95 | 98 | mod tests { |
| 99 | + extern crate std; |
| 100 | + use std::io::ErrorKind; |
| 101 | + |
96 | 102 | use super::*; |
97 | 103 | use embedded_hal_mock::eh1::delay::NoopDelay as MockNoop; |
98 | 104 | use embedded_hal_mock::eh1::digital::{Mock, State, Transaction as PinTransaction}; |
| 105 | + use embedded_hal_mock::eh1::MockError; |
99 | 106 |
|
100 | 107 | #[test] |
101 | 108 | fn test_read_byte() { |
@@ -163,4 +170,45 @@ mod tests { |
163 | 170 |
|
164 | 171 | dht.pin.done(); |
165 | 172 | } |
| 173 | + |
| 174 | + #[test] |
| 175 | + fn test_wait_until_state_timeout_error() { |
| 176 | + let expectations: [PinTransaction; DEFAULT_MAX_ATTEMPTS] = [ |
| 177 | + PinTransaction::get(State::Low), |
| 178 | + PinTransaction::get(State::Low), |
| 179 | + PinTransaction::get(State::Low), |
| 180 | + PinTransaction::get(State::Low), |
| 181 | + PinTransaction::get(State::Low), |
| 182 | + PinTransaction::get(State::Low), |
| 183 | + PinTransaction::get(State::Low), |
| 184 | + PinTransaction::get(State::Low), |
| 185 | + PinTransaction::get(State::Low), |
| 186 | + PinTransaction::get(State::Low), |
| 187 | + ]; |
| 188 | + |
| 189 | + let mock_pin = Mock::new(&expectations); |
| 190 | + let mock_delay = MockNoop::new(); |
| 191 | + |
| 192 | + let mut dht = Dht::new(mock_pin, mock_delay); |
| 193 | + |
| 194 | + let result = dht.wait_until_state(PinState::High); |
| 195 | + assert!(matches!(result, Err(SensorError::Timeout))); |
| 196 | + |
| 197 | + dht.pin.done(); |
| 198 | + } |
| 199 | + |
| 200 | + #[test] |
| 201 | + fn test_wait_until_state_pin_error() { |
| 202 | + let err = MockError::Io(ErrorKind::NotConnected); |
| 203 | + let expectations = [PinTransaction::get(State::High).with_error(err)]; |
| 204 | + let mock_pin = Mock::new(&expectations); |
| 205 | + let mock_delay = MockNoop::new(); |
| 206 | + |
| 207 | + let mut dht = Dht::new(mock_pin, mock_delay); |
| 208 | + |
| 209 | + let result = dht.wait_until_state(PinState::High); |
| 210 | + assert!(matches!(result, Err(SensorError::PinError))); |
| 211 | + |
| 212 | + dht.pin.done(); |
| 213 | + } |
166 | 214 | } |
0 commit comments