pressure.h

// pressure.h
// adapted from:
// https://github.com/adafruit/Adafruit_BMP085_Unified/blob/master/examples/sensorapi/sensorapi.pde
#pragma once

#include "scheduler.h"
#include "sensors.h"

#include <Adafruit_Sensor.h>
#include <Adafruit_BMP085_U.h>
#include <home_assistant.h>

namespace ustd {
class Pressure {
  public:
    String PRESSURE_VERSION = "0.1.0";
    Scheduler *pSched;
    int tID;
    String name;
    double temperatureSensorVal;
    double pressureSensorVal;
    bool bActive = false;
    ustd::sensorprocessor temperatureSensor = ustd::sensorprocessor(4, 600, 0.1);
    ustd::sensorprocessor pressureSensor = ustd::sensorprocessor(4, 600, 1.0);
    Adafruit_BMP085_Unified *pPressure;
#ifdef __ESP__
    HomeAssistant *pHA;
#endif

    Pressure(String name) : name(name) {
        pPressure = new Adafruit_BMP085_Unified(10085);
    }

    ~Pressure() {
    }

    double getTemp() {
        return temperatureSensorVal;
    }

    double getPressure() {
        return pressureSensorVal;
    }

    void begin(Scheduler *_pSched) {
        pSched = _pSched;

        if (pPressure->begin()) {
            bActive = true;
        }

        // give a c++11 lambda as callback scheduler task registration of
        // this.loop():
        /* std::function<void()> */
        auto ft = [=]() { this->loop(); };
        tID = pSched->add(ft, name, 5000000);

        /* std::function<void(String, String, String)> */
        auto fnall = [=](String topic, String msg, String originator) {
            this->subsMsg(topic, msg, originator);
        };
        pSched->subscribe(tID, name + "/sensor/temperature/get", fnall);
        pSched->subscribe(tID, name + "/sensor/pressure/get", fnall);
    }

#ifdef __ESP__
    void registerHomeAssistant(String homeAssistantFriendlyName, String projectName = "",
                               String homeAssistantDiscoveryPrefix = "homeassistant") {
        pHA = new HomeAssistant(name, tID, homeAssistantFriendlyName, projectName, PRESSURE_VERSION,
                                homeAssistantDiscoveryPrefix);
        pHA->addSensor("temperature", "Temperature", "\\u00B0C", "temperature", "mdi:thermometer");
        pHA->addSensor("pressure", "Pressure", "hPa", "pressure", "mdi:altimeter");
        pHA->begin(pSched);
    }
#endif

    void publishPressure() {
        char buf[32];
        pSched->publish(name + "/sensor/result", "OK");
        sprintf(buf, "%5.1f", pressureSensorVal);
        pSched->publish(name + "/sensor/pressure", buf);
    }

    void publishTemperature() {
        char buf[32];
        pSched->publish(name + "/sensor/result", "OK");
        sprintf(buf, "%5.1f", temperatureSensorVal);
        pSched->publish(name + "/sensor/temperature", buf);
    }

    void loop() {
        if (bActive) {
            sensors_event_t event;
            pPressure->getEvent(&event);
            if (event.pressure) {
                double p, t;
                float tf;
                /* Display atmospheric pressue in hPa */
                p = event.pressure;  // hPa
                pPressure->getTemperature(&tf);
                t = (double)tf;

                if (temperatureSensor.filter(&t)) {
                    temperatureSensorVal = t;
                    publishTemperature();
                }
                if (pressureSensor.filter(&p)) {
                    pressureSensorVal = p;
                    publishPressure();
                }
            }
        } else {
            pSched->publish(name + "/sensor/result", "hardware not initialized");
        }
    }

    void subsMsg(String topic, String msg, String originator) {
        if (topic == name + "/sensor/temperature/get") {
            publishTemperature();
        }
        if (topic == name + "/sensor/pressure/get") {
            publishPressure();
        }
    };
};  // Pressure

}  // namespace ustd