mup_illuminance_ldr.h

// mup_illuminance_ldr.h
#pragma once
 
#include "scheduler.h"
#include "sensors.h"
 
namespace ustd {
 
// clang-format off
// clang-format on
class IlluminanceLdr {
  private:
    String LDR_VERSION = "0.1.0";
    Scheduler *pSched;
    int tID;
    String name;
    uint8_t port;
    double ldrvalue;
    unsigned long basePollRate = 500000L;
    uint32_t pollRateMs = 2000;
    uint32_t lastPollMs = 0;
    bool bActive = false;
#ifdef __ESP32__
    double adRange = 4096.0;  // 12 bit default
#else
    double adRange = 1024.0;  // 10 bit default
#endif
 
  public:
    enum FilterMode { FAST,
                      MEDIUM,
                      LONGTERM };
    FilterMode filterMode;
    ustd::sensorprocessor illuminanceSensor = ustd::sensorprocessor(4, 600, 0.005);
 
    IlluminanceLdr(String name, uint8_t port, FilterMode filterMode = FilterMode::MEDIUM)
        : name(name), port(port), filterMode(filterMode) {
        setFilterMode(filterMode, true);
    }
 
    ~IlluminanceLdr() {
    }
 
    double getUnitIlluminance() {
        return ldrvalue;
    }
 
    void begin(Scheduler *_pSched, uint32_t _pollRateMs = 2000) {
        pSched = _pSched;
        pollRateMs = _pollRateMs;
 
        auto ft = [=]() { this->loop(); };
        tID = pSched->add(ft, name, basePollRate);
 
        auto fnall = [=](String topic, String msg, String originator) {
            this->subsMsg(topic, msg, originator);
        };
        pSched->subscribe(tID, name + "/sensor/#", fnall);
        bActive = true;
    }
 
    void setFilterMode(FilterMode mode, bool silent = false) {
        switch (mode) {
        case FAST:
            filterMode = FAST;
            illuminanceSensor.update(1, 15, 0.001);
            break;
        case MEDIUM:
            filterMode = MEDIUM;
            illuminanceSensor.update(4, 300, 0.005);
            break;
        case LONGTERM:
        default:
            filterMode = LONGTERM;
            illuminanceSensor.update(50, 600, 0.01);
            break;
        }
        if (!silent)
            publishFilterMode();
    }
 
  private:
    void publishIlluminance() {
        char buf[32];
        sprintf(buf, "%5.3f", ldrvalue);
        pSched->publish(name + "/sensor/unitilluminance", buf);
    }
 
    void publishFilterMode() {
        switch (filterMode) {
        case FilterMode::FAST:
            pSched->publish(name + "/sensor/mode", "FAST");
            break;
        case FilterMode::MEDIUM:
            pSched->publish(name + "/sensor/mode", "MEDIUM");
            break;
        case FilterMode::LONGTERM:
            pSched->publish(name + "/sensor/mode", "LONGTERM");
            break;
        }
    }
 
    void loop() {
        if (bActive) {
            if (timeDiff(lastPollMs, millis()) >= pollRateMs) {
                lastPollMs = millis();
                double val = 1.0 - (analogRead(port) / (adRange - 1.0));
                if (illuminanceSensor.filter(&val)) {
                    ldrvalue = val;
                    publishIlluminance();
                }
            }
        }
    }
 
    void subsMsg(String topic, String msg, String originator) {
        if (topic == name + "/sensor/unitilluminance/get") {
            publishIlluminance();
        } else if (topic == name + "/sensor/mode/get") {
            publishFilterMode();
        } else if (topic == name + "/sensor/mode/set") {
            if (msg == "fast" || msg == "FAST") {
                setFilterMode(FilterMode::FAST);
            } else {
                if (msg == "medium" || msg == "MEDIUM") {
                    setFilterMode(FilterMode::MEDIUM);
                } else {
                    setFilterMode(FilterMode::LONGTERM);
                }
            }
        }
    };
};  // IlluminanceLdr
 
}  // namespace ustd