58 lines
2.5 KiB
C++
58 lines
2.5 KiB
C++
#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();
|
|
void publishReport();
|
|
void subscribe();
|
|
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;
|
|
}; |