ju6ge
db401aac55
this involved adding a lot of code from the develop branch step by step there are still some bugs, but at least i can get into the web interface and configure stuff again \o/ … measuring and pumping is working as well
115 lines
3.6 KiB
Rust
115 lines
3.6 KiB
Rust
use crate::config::PlantControllerConfig;
|
|
use crate::fat_error::FatResult;
|
|
use crate::webserver::read_up_to_bytes_from_request;
|
|
use crate::{do_secure_pump, BOARD_ACCESS};
|
|
use alloc::borrow::ToOwned;
|
|
use alloc::string::{String, ToString};
|
|
use alloc::vec::Vec;
|
|
use chrono::DateTime;
|
|
use edge_http::io::server::Connection;
|
|
use edge_nal::io::{Read, Write};
|
|
use esp_radio::wifi::ap::AccessPointInfo;
|
|
use log::info;
|
|
use serde::{Deserialize, Serialize};
|
|
|
|
#[derive(Deserialize)]
|
|
pub struct NightLampCommand {
|
|
active: bool,
|
|
}
|
|
#[derive(Serialize, Debug)]
|
|
struct SSIDList {
|
|
ssids: Vec<String>,
|
|
}
|
|
#[derive(Deserialize, Debug)]
|
|
struct SetTime<'a> {
|
|
time: &'a str,
|
|
}
|
|
|
|
#[derive(Serialize, Deserialize, Clone, Debug, PartialEq)]
|
|
pub struct TestPump {
|
|
pump: usize,
|
|
}
|
|
|
|
pub(crate) async fn wifi_scan<T, const N: usize>(
|
|
_request: &mut Connection<'_, T, N>,
|
|
) -> FatResult<Option<String>> {
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
info!("start wifi scan");
|
|
let mut ssids: Vec<String> = Vec::new();
|
|
let scan_result: Vec<AccessPointInfo> = board.board_hal.get_esp().wifi_scan().await?;
|
|
scan_result
|
|
.iter()
|
|
.for_each(|s| ssids.push(s.ssid.as_str().to_owned()));
|
|
let ssid_json = serde_json::to_string(&SSIDList { ssids })?;
|
|
info!("Sending ssid list {}", &ssid_json);
|
|
Ok(Some(ssid_json))
|
|
}
|
|
|
|
pub(crate) async fn board_test() -> FatResult<Option<String>> {
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
board.board_hal.test().await?;
|
|
Ok(None)
|
|
}
|
|
|
|
pub(crate) async fn pump_test<T, const N: usize>(
|
|
request: &mut Connection<'_, T, N>,
|
|
) -> FatResult<Option<String>>
|
|
where
|
|
T: Read + Write,
|
|
{
|
|
let actual_data = read_up_to_bytes_from_request(request, None).await?;
|
|
let pump_test: TestPump = serde_json::from_slice(&actual_data)?;
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
|
|
let config = &board.board_hal.get_config().plants[pump_test.pump].clone();
|
|
let pump_result = do_secure_pump(&mut board, pump_test.pump, config, false).await;
|
|
//ensure it is disabled before unwrapping
|
|
board.board_hal.pump(pump_test.pump, false).await?;
|
|
|
|
Ok(Some(serde_json::to_string(&pump_result?)?))
|
|
}
|
|
|
|
pub(crate) async fn night_lamp_test<T, const N: usize>(
|
|
request: &mut Connection<'_, T, N>,
|
|
) -> FatResult<Option<String>>
|
|
where
|
|
T: Read + Write,
|
|
{
|
|
let actual_data = read_up_to_bytes_from_request(request, None).await?;
|
|
let light_command: NightLampCommand = serde_json::from_slice(&actual_data)?;
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
board.board_hal.light(light_command.active).await?;
|
|
Ok(None)
|
|
}
|
|
|
|
pub(crate) async fn write_time<T, const N: usize>(
|
|
request: &mut Connection<'_, T, N>,
|
|
) -> FatResult<Option<String>>
|
|
where
|
|
T: Read + Write,
|
|
{
|
|
let actual_data = read_up_to_bytes_from_request(request, None).await?;
|
|
let time: SetTime = serde_json::from_slice(&actual_data)?;
|
|
let parsed = DateTime::parse_from_rfc3339(time.time)?;
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
board.board_hal.set_time(&parsed).await?;
|
|
Ok(None)
|
|
}
|
|
|
|
pub(crate) async fn set_config<T, const N: usize>(
|
|
request: &mut Connection<'_, T, N>,
|
|
) -> FatResult<Option<String>>
|
|
where
|
|
T: Read + Write,
|
|
{
|
|
let all = read_up_to_bytes_from_request(request, Some(4096)).await?;
|
|
let length = all.len();
|
|
let config: PlantControllerConfig = serde_json::from_slice(&all)?;
|
|
|
|
let mut board = BOARD_ACCESS.get().await.lock().await;
|
|
board.board_hal.get_esp().save_config(all).await?;
|
|
info!("Wrote config config {:?} with size {}", config, length);
|
|
board.board_hal.set_config(config);
|
|
Ok(Some("saved".to_string()))
|
|
}
|