GwOutput_mqtt.h

Go to the documentation of this file.

 
#ifndef _GWOUTPUT_MQTT_h
#define _GWOUTPUT_MQTT_h
 
#if defined(ARDUINO) && ARDUINO >= 100
#include "Arduino.h"
#else
#include "WProgram.h"
#endif
 
#include <GwOutput_generic.h>
#include <ESPAsyncWiFiManager.h>
#include <EnigmaIOTGateway.h>
#include <PubSubClient.h>
#include <queue>
#include "dstrootca.h"
#ifdef SECURE_MQTT
#include <WiFiClientSecure.h>
#else
#include <WiFiClient.h>
#endif // SECURE_MQTT
 
#define MQTT_BUFFER_SIZE 2048
 
// DOWNLINK MESSAGES
#define GET_VERSION      "get/version"
#define GET_VERSION_ANS  "result/version"
#define GET_SLEEP        "get/sleeptime"
#define GET_SLEEP_ANS    "result/sleeptime"
#define SET_SLEEP        "set/sleeptime"
#define SET_OTA          "set/ota"
#define SET_OTA_ANS      "result/ota"
#define SET_IDENTIFY     "set/identify"
#define SET_RESET_CONFIG "set/reset"
#define SET_RESET_ANS    "result/reset"
#define GET_RSSI         "get/rssi"
#define GET_RSSI_ANS     "result/rssi"
#define GET_NAME         "get/name"
#define SET_NAME         "set/name"
#define GET_NAME_ANS     "result/name"
#define SET_USER_DATA    "set/data"
#define GET_USER_DATA    "get/data"
#define RESTART_NOTIF    "restart"
#define NODE_DATA        "data"
#define LOST_MESSAGES    "debug/lostmessages"
#define NODE_STATUS      "status"
#define GW_STATUS        "/gateway/status"
#define SET_RESTART_MCU  "set/restart"
 
const time_t STATUS_SEND_PERIOD = 300000;
 
constexpr auto CONFIG_FILE = "/mqtt.json"; 
 
typedef struct {
    char mqtt_server[41]; 
#ifdef SECURE_MQTT
    int mqtt_port = 8883; 
#else
    int mqtt_port = 1883; 
#endif //SECURE_MQTT
    char mqtt_user[21]; 
    char mqtt_pass[41]; 
} mqttgw_config_t;
 
constexpr auto MAX_MQTT_TOPIC_LEN = 100;
constexpr auto MAX_MQTT_PLD_LEN = 2048;
 
typedef struct {
    char topic[MAX_MQTT_TOPIC_LEN]; 
    char payload[MAX_MQTT_PLD_LEN]; 
    size_t payload_len; 
    bool retain; 
} mqtt_queue_item_t;
 
 
class GwOutput_MQTT : public GatewayOutput_generic {
protected:
    AsyncWiFiManagerParameter* mqttServerParam = NULL; 
    AsyncWiFiManagerParameter* mqttPortParam = NULL; 
    AsyncWiFiManagerParameter* mqttUserParam = NULL; 
    AsyncWiFiManagerParameter* mqttPassParam = NULL; 
 
    //std::queue<mqtt_queue_item_t*> mqtt_queue; ///< @brief Output MQTT messages queue. It acts as a FIFO queue
    EnigmaIOTRingBuffer<mqtt_queue_item_t> mqtt_queue;
 
    mqttgw_config_t mqttgw_config; 
    bool shouldSaveConfig = false; 
 
#ifdef SECURE_MQTT
    WiFiClientSecure espClient; 
#ifdef ESP8266
    BearSSL::X509List certificate; 
#endif // ESP8266
#else
    WiFiClient espClient; 
#endif // SECURE_MQTT
    PubSubClient mqtt_client; 
    
    bool saveConfig ();
//#ifdef SECURE_MQTT
    void setClock ();
//#endif // SECURE_MQTT
    void reconnect ();
 
    bool addMQTTqueue (const char* topic, char* payload, size_t len, bool retain = false);
 
    mqtt_queue_item_t* getMQTTqueue ();
 
    void popMQTTqueue ();
 
    bool publishMQTT (const char* topic, const char* payload, size_t len, bool retain = false);
 
    static void onDlData (char* topic, uint8_t* data, unsigned int len);
 
public:
    GwOutput_MQTT () :
        mqtt_queue (MAX_MQTT_QUEUE_SIZE),
#if defined ESP8266 && defined SECURE_MQTT
        certificate (DSTroot_CA),
#endif // ESP8266 && SECURE_MQTT
        mqtt_client (espClient) {}
 
    void configManagerStart (EnigmaIOTGatewayClass* enigmaIotGw);
 
    void configManagerExit (bool status);
 
    bool begin ();
 
    bool loadConfig ();
 
    bool outputControlSend (char* address, uint8_t* data, size_t length);
 
    bool newNodeSend (char* address, uint16_t node_id);
 
    bool nodeDisconnectedSend (char* address, gwInvalidateReason_t reason);
 
    bool outputDataSend (char* address, char* data, size_t length, GwOutput_data_type_t type = data);
 
#if SUPPORT_HA_DISCOVERY
 
    bool rawMsgSend (const char* topic, char* payload, size_t len, bool retain);
#endif
    
    void loop ();
};
 
extern GwOutput_MQTT GwOutput;
 
#endif // _GWOUTPUT_MQTT_h