hackdose-server 0.10.0

A server to control smart plugs using data from smart meters
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use std::{collections::HashMap, sync::Arc};

use hackdose_sml_parser::application::{
    domain::{AnyValue, SmlMessages},
    obis::Obis,
};
use tokio::sync::{mpsc::Sender, Mutex};
use tokio_stream::Stream;
use tokio_stream::StreamExt;

use crate::{data::EnergyData, smart_meter::body::find_watts};

pub(crate) async fn handle_power_events(
    tx: &mut Sender<i32>,
    mutex: Arc<Mutex<HashMap<Obis, AnyValue>>>,
    mut power_events: impl Stream<Item = SmlMessages> + Unpin + Send + 'static,
    mut energy_data: EnergyData,
) {
    while let Some(message) = power_events.next().await {
        let watts = find_watts(&message, mutex.clone()).await;

        match watts {
            Some(watts) => {
                let data = (chrono::Local::now(), watts);
                energy_data.put(data).await;
                energy_data.log_data(data).await;

                tx.send(watts).await.unwrap();
            }
            None => {}
        }
    }
}