mup_binary_sensor.h

// mup_binary_sensor.h
#pragma once
 
#include "scheduler.h"
#include "sensors.h"
 
namespace ustd {
 
// clang-format off
// clang-format on
class BinarySensor {
  private:
    String BinarySensor_VERSION = "0.1.0";
    Scheduler *pSched;
    int tID;
    String name;
    uint8_t digitalPort;
    bool inverseLogic;
    String topicName;
    bool logicalState;
    bool physicalState;
    unsigned long basePollRate = 500000L;
    uint32_t pollRateMs = 2000;
    uint32_t lastPollMs = 0;
    bool bActive = false;
    bool initialPublish = false;
 
  public:
    BinarySensor(String name, uint8_t digitalPort, bool inverseLogic = false, String topicName = "state")
        : name(name), digitalPort(digitalPort), inverseLogic(inverseLogic), topicName(topicName) {
    }
 
    ~BinarySensor() {
    }
 
    bool getPhysicalState() {
        physicalState = digitalRead(digitalPort);
        return physicalState;
    }
 
    bool getBinarySensorLogicalState() {
        physicalState = digitalRead(digitalPort);
        if (inverseLogic) {
            logicalState = !physicalState;
        } else {
            logicalState = physicalState;
        }
        return logicalState;
    }
 
    void begin(Scheduler *_pSched, uint32_t _pollRateMs = 2000) {
        pSched = _pSched;
        pollRateMs = _pollRateMs;
 
        auto ft = [=]() { this->loop(); };
        tID = pSched->add(ft, name, basePollRate);
 
        pinMode(digitalPort, INPUT_PULLUP);
        logicalState = getBinarySensorLogicalState();
        initialPublish = false;
 
        auto fnall = [=](String topic, String msg, String originator) {
            this->subsMsg(topic, msg, originator);
        };
        pSched->subscribe(tID, name + "/sensor/#", fnall);
        pSched->subscribe(tID, name + "/binary_sensor/#", fnall);
        pSched->subscribe(tID, name + "/mqtt/state", fnall);
        bActive = true;
    }
 
  private:
    void publishPhysicalState() {
        char buf[32];
        if (getPhysicalState()) {
            strcpy(buf, "ON");
        } else {
            strcpy(buf, "OFF");
        }
        pSched->publish(name + "/sensor/physical/" + topicName, buf);
        pSched->publish(name + "/binary_sensor/physical/" + topicName, buf);
    }
 
    void publishBinarySensor() {
        char buf[32];
        if (getBinarySensorLogicalState()) {
            strcpy(buf, "ON");
        } else {
            strcpy(buf, "OFF");
        }
        pSched->publish(name + "/sensor/" + topicName, buf);
        pSched->publish(name + "/binary_sensor/" + topicName, buf);
    }
 
    void loop() {
        if (bActive) {
            if (timeDiff(lastPollMs, millis()) >= pollRateMs || !initialPublish) {
                bool hasChanged = false;
                lastPollMs = millis();
                bool oldLogicalState = logicalState;
                bool st = getBinarySensorLogicalState();
                if (st != oldLogicalState || !initialPublish) {
                    hasChanged = true;
                }
                if (hasChanged) {
                    publishBinarySensor();
                    initialPublish = true;
                }
            }
        }
    }
 
    void subsMsg(String topic, String msg, String originator) {
        if (topic == name + "/sensor/" + topicName + "/get" || topic == name + "/binary_sensor/" + topicName + "/get") {
            publishBinarySensor();
        } else if (topic == name + "/sensor/physical/" + topicName + "/get" || topic == name + "/binary_sensor/physical/" + topicName + "/get") {
            publishBinarySensor();
        } else if (topic == name + "mqtt/state") {
            if (msg == "connected") {
                initialPublish = false;  // republish for mqtt.
            }
        }
    }
};  // rainAD
 
}  // namespace ustd