Module_PMSDS011/Module_PMSDS011.ino at master · ModularMonitor/Module_PMSDS011 · GitHub

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
#include "mpmsd.h"
#include "Serial/packaging.h"
#include "Serial/flags.h"

using namespace CS;

PackagedWired* wire;
mPMSD* psd = nullptr;
const auto this_device = device_id::PMSDS011_SENSOR;

void callback(void*, const uint8_t, const char*, const uint8_t);

void setup() {
    Serial.begin(115200);

    psd = new mPMSD();

    wire = new PackagedWired(config()
        .set_slave(this_device)
        .set_slave_callback(callback)
        .set_led(2)
    );
}

void callback(void* rw, const uint8_t expects, const char* received, const uint8_t length)
{
    if (length != sizeof(Requester)) return;

    PackagedWired& w = *(PackagedWired*) rw;
    Requester req(received);

    switch(req.get_offset()) {
    case 0:
    {
        FlagWrapper fw;
        if (psd->has_issues())              fw |= device_flags::HAS_ISSUES;
        if (psd->has_new_data_autoreset())  fw |= device_flags::HAS_NEW_DATA;

        Command cmd("#FLAGS", (uint64_t)fw);
        w.slave_reply_from_callback(cmd);
    }
    break;
    case 1:
    {
        const float val = psd->get_pm10();
        Command cmd("/pmsds011/pm10", val);
        w.slave_reply_from_callback(cmd);
    }
    break;
    case 2:
    {
        const float val = psd->get_pm25();
        Command cmd("/pmsds011/pm25", val);
        w.slave_reply_from_callback(cmd);
    }
    break;
    default:
    {
        Command cmd; // invalid
        w.slave_reply_from_callback(cmd);
    }
    }
}

// unused
void loop() { vTaskDelete(NULL); }