moonsock 0.1.0

Moonsock is a simple way to connect to a klipper/moonraker 3D printer websocket from anywhere where tokio can be ran and your printer is accessible from the internet.
Documentation 
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use moonsock::{MoonMSG, MoonResultData, TemperatureStore, TempStoreData, HeaterNames};
use std::{
    string::String,
    fs::File,
    io::Read,
};

#[test]
fn temperature_store_parse() {
    let bed = TempStoreData::TempTgtsPowers {
        temperatures: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        targets: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        powers: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
    };
    let extruder = TempStoreData::TempTgtsPowers {
        temperatures: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        targets: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        powers: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
    };
    // let mut temp_store = HashMap::new();
    let mut temp_store = TemperatureStore::new();
    temp_store.add_to_hashmap(HeaterNames::HeaterBed, bed);
    temp_store.add_to_hashmap(HeaterNames::Extruder, extruder);
    let msg_two = MoonMSG::new_result(MoonResultData::TemperatureStore(temp_store), 1); 

    // let msg_string = serde_json::to_string(&msg_two).unwrap();
    // println!("{}", msg_string);

    let message = r##"{
        "jsonrpc": "2.0", 
        "result": {
            "heater_bed": {
                "temperatures": [80.04, 80.05, 80.04, 80.03, 80.04], 
                "targets": [ 80.0, 80.0, 80.0, 80.0, 80.0, 80.0], 
                "powers": [0.6396684663343952, 0.45537880698021727]
            },
            "extruder": {
                "temperatures": [229.99, 229.94, 229.89, 229.95, 229.96, 230.07], 
                "targets": [0.0, 230.0, 230.0, 230.0, 230.0, 230.0, 230.0, 230.0], 
                "powers": [0.07110582186476708, 0.1597490186929997, 0.079685480023094]
            }
        }, 
        "id": 2043
    }"##;

    let msg: MoonMSG = serde_json::from_str(message).unwrap();
    // println!("Parsed: {:#?}", msg);
    match msg {
        MoonMSG::MoonResult { id, result, .. } => {
            // println!("Received Result: {}", id);
            // println!("Result: {:?}", result);
            match result {
                MoonResultData::TemperatureStore ( temp_store ) => {
                    let bed_contents = temp_store.items.get(&HeaterNames::HeaterBed).unwrap();
                    let extruder_contents = temp_store.items.get(&HeaterNames::Extruder).unwrap();
                    assert_eq!(
                        bed_contents, 
                        &TempStoreData::TempTgtsPowers {
                            temperatures: vec![80.04, 80.05, 80.04, 80.03, 80.04], 
                            targets: vec![80.0, 80.0, 80.0, 80.0, 80.0, 80.0], 
                            powers: vec![0.6396684663343952, 0.45537880698021727]
                        }
                    );
                    assert_eq!(
                        extruder_contents, 
                        &TempStoreData::TempTgtsPowers {
                            temperatures: vec![229.99, 229.94, 229.89, 229.95, 229.96, 230.07],
                            targets: vec![0.0, 230.0, 230.0, 230.0, 230.0, 230.0, 230.0, 230.0],
                            powers: vec![0.07110582186476708, 0.1597490186929997, 0.079685480023094]
                        }
                    );
                },
                _ => panic!("Message is MoonResult, but it's result is not ServerTemperatureStore: {:?}", result),
            }
        },
        _ => panic!("Unexpected Message: {:?}", msg),
    }
}


const TEMP_STORE_JSON_PATH: &str = "tests/temp_store.json";
#[test]
fn temp_store_serialize() {
    let bed = TempStoreData::TempTgtsPowers {
        temperatures: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        targets: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        powers: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
    };
    let extruder = TempStoreData::TempTgtsPowers {
        temperatures: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        targets: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
        powers: vec![22.66, 22.65, 22.58, 22.6, 22.6, 22.59, 22.63, 22.62, 22.62, 22.59, 22.57, 22.55, 22.62],
    };
    // let mut temp_store = HashMap::new();
    let mut temp_store = TemperatureStore::new();
    temp_store.add_to_hashmap(HeaterNames::Extruder, extruder);
    temp_store.add_to_hashmap(HeaterNames::HeaterBed, bed);
    let msg_two = MoonMSG::new_result(MoonResultData::TemperatureStore(temp_store), 1); 

    let mut file = File::open(TEMP_STORE_JSON_PATH).unwrap();
    let mut contents = String::new();
    file.read_to_string(&mut contents).unwrap();
    let file_parsed = serde_json::from_str::<MoonMSG>(&contents).unwrap();
    
    assert_eq!(msg_two, file_parsed);
}