mup_digital_out.h

// mup_digital_out.h - muwerk digital out applet
#pragma once
 
#include "scheduler.h"
#include "mupplet_core.h"
 
namespace ustd {
 
// clang-format off
// clang-format on
class DigitalOut {
  public:
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
    static const char *version;  // = "0.2.0";
#endif
 
  private:
    Scheduler *pSched;
    int tID;
    String name;
    uint8_t port;
    bool activeLogic = false;
    const char *topic;
    bool state;
 
  public:
    DigitalOut(String name, uint8_t port, bool activeLogic = false, const char *topic = "relay")
        : name(name), port(port), activeLogic(activeLogic), topic(topic) {
    }
 
    ~DigitalOut() {
    }
 
    void begin(Scheduler *_pSched) {
        pSched = _pSched;
        pinMode(port, OUTPUT);
 
        setOff();
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
        auto ft = [=]() { this->loop(); };
        tID = pSched->add(ft, name, 50000);
        auto fnall = [=](String topic, String msg, String originator) {
            this->subsMsg(topic, msg, originator);
        };
        pSched->subscribe(tID, name + "/" + topic + "/#", fnall);
        pSched->subscribe(tID, "mqtt/state");
        publishState();
#endif
    }
 
    void set(bool state) {
        if (this->state == state)
            return;
        if (state)
            setOn();
        else
            setOff();
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
        publishState();
#endif
    }
 
  private:
    void setOn() {
        state = true;
        if (activeLogic) {
            digitalWrite(port, true);
        } else {
            digitalWrite(port, false);
        }
    }
    void setOff() {
        state = false;
        if (activeLogic) {
            digitalWrite(port, false);
        } else {
            digitalWrite(port, true);
        }
    }
 
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
    void publishState() {
        if (state) {
            pSched->publish(name + "/" + topic + "/state", "on");
        } else {
            pSched->publish(name + "/" + topic + "/state", "off");
        }
    }
#endif
 
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
    void loop() {
    }
#endif
 
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
    void subsMsg(String topic, String msg, String originator) {
        char msgbuf[128];
        memset(msgbuf, 0, 128);
        strncpy(msgbuf, msg.c_str(), 127);
        msg.toLowerCase();
        if (topic == name + "/" + topic + "/set") {
            set((msg == "on" || msg == "1"));
        } else if (topic == "mqtt/state") {
            publishState();
        }
    }
#endif
};  // DigitalOut
 
// version
#if USTD_FEATURE_MEMORY > USTD_FEATURE_MEM_512B
const char *DigitalOut::version = "0.2.0";
#endif
 
}  // namespace ustd