ESPMegaPRO-v3-SDK/Template Project/lib/ESPMegaPRO/AnalogIoT.hpp

#pragma once
#include <IoTComponent.hpp>
#include <AnalogCard.hpp>

#define DAC_SET_STATE_TOPIC "/set/state"
#define DAC_SET_VALUE_TOPIC "/set/value"
#define DAC_STATE_TOPIC "/dac/00/state"
#define DAC_VALUE_TOPIC "/dac/00/value"
#define DAC_PUBLISH_ENABLE_TOPIC "/publish_enable"
#define REQUEST_STATE_TOPIC "requeststate"

class AnalogIoT : public IoTComponent {
    public:
        AnalogIoT();
        ~AnalogIoT();
        bool begin(uint8_t card_id, ExpansionCard *card, PubSubClient *mqtt, char *base_topic);
        void handleMqttMessage(char *topic, char *payload);
        void handleDACChange(uint8_t pin, uint16_t value);
        void publishADCs();
        void publishADC(uint8_t pin);
        void publishDACs();
        void publishDAC(uint8_t pin);
        void publishDACState(uint8_t pin);
        void publishDACValue(uint8_t pin);
        void setADCsPublishInterval(uint32_t interval);
        void setADCsPublishEnabled(bool enabled);
        void registerDACChangeCallback(std::function<void(uint8_t, uint16_t)> callback);
        void deregisterDACChangeCallback();
        void registerADCConversionCallback(std::function<void(uint8_t, uint16_t)> callback);
        void deregisterADCConversionCallback();
        void setADCConversionInterval(uint8_t pin, uint16_t interval);
        void setADCConversionEnabled(uint8_t pin, bool enabled);
        bool processADCSetConversionIntervalMessage(char *topic, char *payload, uint8_t topic_length);
        bool processADCSetConversionEnabledMessage(char *topic, char *payload, uint8_t topic_length);
        bool processDACSetStateMessage(char *topic, char *payload, uint8_t topic_length);
        bool processDACSetValueMessage(char *topic, char *payload, uint8_t topic_length);
        bool processRequestStateMessage(char *topic, char *payload, uint8_t topic_length);
        void publishReport();
        void subscribe();
        void loop();
        uint8_t getType();
    private:
        uint8_t dac_set_state_length;
        uint8_t dac_set_value_length;
        uint8_t dac_state_length;
        uint8_t dac_value_length;
        uint8_t request_state_length;
        uint8_t dac_publish_enable_length;
        uint32_t last_adc_publish = 0;
        AnalogCard *card;
        bool adc_publish_enabled[8];
        uint16_t adc_conversion_interval[8];
        uint32_t last_adc_conversion[8];
        std::function<void(uint8_t, uint16_t)> dac_change_callback;
        std::function<void(uint8_t, uint16_t)> adc_conversion_callback;
};