use crate::{
driver,
types::{device, Error},
Result,
};
use chrono::*;
use tokio::sync::{mpsc, oneshot};
#[derive(Debug, PartialEq)]
pub struct DevInfoReply {
pub name: device::Name,
pub units: Option<String>,
pub settable: bool,
pub total_points: u32,
pub first_point: Option<device::Reading>,
pub last_point: Option<device::Reading>,
pub driver: driver::Name,
}
#[doc(hidden)]
pub enum Request {
QueryDeviceInfo {
pattern: Option<String>,
rpy_chan: oneshot::Sender<Result<Vec<DevInfoReply>>>,
},
SetDevice {
name: device::Name,
value: device::Value,
rpy_chan: oneshot::Sender<Result<device::Value>>,
},
GetSettingChan {
name: device::Name,
_own: bool,
rpy_chan: oneshot::Sender<Result<driver::TxDeviceSetting>>,
},
MonitorDevice {
name: device::Name,
start: Option<DateTime<Utc>>,
end: Option<DateTime<Utc>>,
rpy_chan: oneshot::Sender<Result<device::DataStream<device::Reading>>>,
},
}
#[derive(Clone)]
pub struct RequestChan {
req_chan: mpsc::Sender<Request>,
}
impl RequestChan {
pub fn new(req_chan: mpsc::Sender<Request>) -> Self {
RequestChan { req_chan }
}
pub async fn monitor_device(
&self,
name: device::Name,
start: Option<DateTime<Utc>>,
end: Option<DateTime<Utc>>,
) -> Result<device::DataStream<device::Reading>> {
let (tx, rx) = oneshot::channel();
let msg = Request::MonitorDevice {
name,
rpy_chan: tx,
start,
end,
};
self.req_chan.send(msg).await?;
rx.await?
}
pub async fn set_device<
T: Into<device::Value> + TryFrom<device::Value, Error = Error>,
>(
&self,
name: device::Name,
value: T,
) -> Result<T> {
let (tx, rx) = oneshot::channel();
let msg = Request::SetDevice {
name,
value: value.into(),
rpy_chan: tx,
};
self.req_chan.send(msg).await?;
rx.await?.and_then(T::try_from)
}
pub async fn get_setting_chan(
&self,
name: device::Name,
own: bool,
) -> Result<driver::TxDeviceSetting> {
let (tx, rx) = oneshot::channel();
let msg = Request::GetSettingChan {
name,
_own: own,
rpy_chan: tx,
};
self.req_chan.send(msg).await?;
rx.await?
}
pub async fn get_device_info(
&self,
pattern: Option<String>,
) -> Result<Vec<DevInfoReply>> {
let (rpy_chan, rx) = oneshot::channel();
self.req_chan
.send(Request::QueryDeviceInfo { pattern, rpy_chan })
.await?;
rx.await.map_err(|e| e.into()).and_then(|v| v)
}
}