#[cfg(feature = "mock")]
use crate::protocol::FrameType;
use crate::protocol::command::imperfect_payload;
use crate::protocol::{Resp, parse_resp};
use crate::types::ImperfectStatus;
#[test]
fn imperfect_payload_bytes() {
assert_eq!(imperfect_payload(true), [1]);
assert_eq!(imperfect_payload(false), [0]);
}
#[test]
fn decode_imperfect_through_parse_resp() {
let Some(Resp::Imperfect(i)) = parse_resp(&[9, 1, 1, 1]) else {
panic!("expected Imperfect");
};
assert_eq!(
i,
ImperfectStatus {
allowed: true,
over_capacity: true,
clone_imperfect: true
}
);
let Some(Resp::Imperfect(none)) = parse_resp(&[9, 0, 0, 0]) else {
panic!("expected Imperfect");
};
assert_eq!(none, ImperfectStatus::default());
assert!(parse_resp(&[9, 0, 0]).is_none()); }
#[cfg(feature = "mock")]
#[test]
fn allow_imperfect_clones_sends_an_imperfect_frame() {
use crate::{Device, MockBox};
let mock = MockBox::new();
let device = Device::with_mock(mock.clone());
device.allow_imperfect_clones(true).unwrap();
let frame = mock
.recorded_frames()
.into_iter()
.find(|f| f.ty == FrameType::Imperfect)
.expect("an IMPERFECT frame was recorded");
assert_eq!(frame.payload, vec![1]);
}
#[cfg(feature = "mock")]
#[test]
fn imperfect_query_roundtrips_the_status() {
use crate::{Device, MockBox};
let status = ImperfectStatus {
allowed: true,
over_capacity: true,
clone_imperfect: true,
};
let mock = MockBox::new().with_imperfect_status(status);
let device = Device::with_mock(mock);
assert_eq!(device.query_imperfect().unwrap(), status);
}
#[cfg(all(feature = "async", feature = "mock"))]
#[test]
fn async_imperfect_query_roundtrips_the_status() {
use crate::{Device, MockBox};
use futures::executor::block_on;
let status = ImperfectStatus {
allowed: true,
over_capacity: true,
clone_imperfect: true,
};
let mock = MockBox::new().with_imperfect_status(status);
let device = Device::with_mock(mock).into_async();
assert_eq!(block_on(device.query_imperfect()).unwrap(), status);
}