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
34
35
36
37
38
39
40
41
42
43
44
45

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

use hackdose_sml_parser::application::{domain::AnyValue, obis::Obis};
use tokio::sync::Mutex;
use warp::Filter;

use crate::{data::EnergyData, Configuration};

use self::visualisation::render_image;

mod visualisation;

pub(crate) async fn serve_rest_endpoint(
    mutex: Arc<Mutex<HashMap<Obis, AnyValue>>>,
    energy_data: EnergyData,
    config: &Configuration,
) {
    let energy = warp::path("energy")
        .map(move || mutex.clone())
        .and_then(return_energy);
    let image = warp::path("day")
        .and(warp::any().map(move || energy_data.clone()))
        .and_then(image);
    warp::serve(
        energy
            .or(image)
            .or(warp::path("log").and(warp::fs::file(config.log_location.clone()))),
    )
    .run(([0, 0, 0, 0], 8080))
    .await;
}

async fn return_energy(
    m: Arc<Mutex<HashMap<Obis, AnyValue>>>,
) -> Result<Box<dyn warp::Reply>, warp::Rejection> {
    Ok(Box::new(warp::reply::json(&*m.lock().await)))
}

async fn image(energy_data: EnergyData) -> Result<Box<dyn warp::Reply>, warp::Rejection> {
    let svg_image = render_image(energy_data).await;
    Ok(Box::new(warp::reply::html(format!(
        "<html>{}</html>",
        svg_image
    ))))
}