use anyhow::{Context, Result};
use bairelay_neolink_core::bc_protocol::CameraDriver;
use super::output::Outcome;
pub async fn run(cam: &dyn CameraDriver, set: Option<bool>) -> Result<Outcome> {
if let Some(on) = set {
cam.led_light_set(on)
.await
.context("led_light_set failed")?;
}
let led = cam.get_ledstate().await.context("get_ledstate failed")?;
let state = matches!(led.light_state.as_str(), "open");
Ok(Outcome::StatusLight { state })
}
#[cfg(test)]
mod tests {
use super::*;
use bairelay_neolink_core::bc::xml::LedState;
use bairelay_neolink_core::bc_protocol::{Error, FakeCameraBuilder};
fn led_with(light_state: &str) -> LedState {
LedState {
light_state: light_state.into(),
..Default::default()
}
}
#[tokio::test]
async fn status_light_read_open_is_on() {
let fake = FakeCameraBuilder::new()
.with_ledstate(|| Ok(led_with("open")))
.build();
let outcome = run(&*fake, None).await.unwrap();
assert_eq!(outcome, Outcome::StatusLight { state: true });
}
#[tokio::test]
async fn status_light_read_close_is_off() {
let fake = FakeCameraBuilder::new()
.with_ledstate(|| Ok(led_with("close")))
.build();
let outcome = run(&*fake, None).await.unwrap();
assert_eq!(outcome, Outcome::StatusLight { state: false });
}
#[tokio::test]
async fn status_light_set_true_then_reads_back() {
let fake = FakeCameraBuilder::new()
.with_ledstate(|| Ok(led_with("open")))
.build();
let outcome = run(&*fake, Some(true)).await.unwrap();
assert_eq!(outcome, Outcome::StatusLight { state: true });
assert_eq!(*fake.calls().led_light_set.lock().unwrap(), vec![true]);
}
#[tokio::test]
async fn status_light_read_error_propagates() {
let fake = FakeCameraBuilder::new()
.with_ledstate(|| Err(Error::Other("boom")))
.build();
let err = run(&*fake, None).await.unwrap_err();
assert!(format!("{:#}", err).contains("get_ledstate failed"));
}
}