read_atmosphere.rs

use crate::error::AtmosError;
use crate::shared_data::AccessSharedData;
use log::info;
use serde_json::Value;
use std::process::Command;
use time::macros::offset;
use time::OffsetDateTime;
use tokio::time::Duration;

fn get_atmosphere_from_sensor() -> Result<String, AtmosError> {
    let output = Command::new("python3").arg("dht.py").output()?;
    let str_output = String::from_utf8_lossy(&output.stdout).to_string();
    //println!("{}", str_output);
    info!("Sensor output: {}", str_output);
    Ok(str_output)
}

pub async fn read_atmosphere_from_sensors(sd: &AccessSharedData) -> Result<(), AtmosError> {
    const MAX_RETRIES: u8 = 10;
    let mut current_tries: u8 = 0;
    let mut output = get_atmosphere_from_sensor()?;
    let mut v: Value = serde_json::from_str(&output)?;

    loop {
        if v.get("error").is_some() {
            if current_tries < MAX_RETRIES {
                tokio::time::sleep(Duration::from_secs(4)).await;
                output = get_atmosphere_from_sensor()?;
                v = serde_json::from_str(&output)?;
                current_tries += 1;
            } else {
                return Err(AtmosError::SensorReadError(
                    "MAX_RETRIES reached! Couldn't get data from sensor!".into(),
                ));
            }
        } else {
            break;
        }
    }

    let t1: f32 = v["t1"]
        .as_f64()
        .ok_or(AtmosError::SensorReadError("Invalid t1 value".into()))? as f32;
    let h1: f32 = v["h1"]
        .as_f64()
        .ok_or(AtmosError::SensorReadError("Invalid h1 value".into()))? as f32;
    let t2: f32 = v["t2"]
        .as_f64()
        .ok_or(AtmosError::SensorReadError("Invalid t2 value".into()))? as f32;
    let h2: f32 = v["h2"]
        .as_f64()
        .ok_or(AtmosError::SensorReadError("Invalid h2 value".into()))? as f32;
    let now = OffsetDateTime::now_utc().to_offset(offset!(+1));

    //println!("t1:{}, h1:{}, t2:{}, h2:{}", t1, h1, t2, h2);

    sd.increment_polling_iterations();
    sd.set_temp_one(t1);
    sd.set_humidity_one(h1);
    sd.set_temp_two(t2);
    sd.set_humidity_two(h2);
    sd.set_last_reading_datetime(now);

    Ok(())
}