MQTTCommunication.h

Go to the documentation of this file.

#ifndef MQTTCOMMUNICATION_H__
#define MQTTCOMMUNICATION_H__

#include "Arduino.h"

#include "CommunicationConfiguration.h"

#include <CircularBuffer.h>
#include "Network/Network.h"
#include "myJSON/myJSON.h"
#include "myMQTT/myMQTT.h"

void callback(char* topic, byte* payload, unsigned int length);

extern myJSON _myjson;

extern CircularBuffer<myJSONStr, MAX_JSON_MESSAGES_SAVED> _buffer;

class Communication {
   public:
    Communication(String Hostname);

    //==INTERFACE===================================
    inline void init() {
        pNetwork.init();
        pMymqtt.init(&pClient, funcPointer);
    }

    inline bool loop() {
        return pMymqtt.loop();
    }

    //=======NETWORK============
    // inline void connectToWiFi() {
    //     pNetwork.connectToWiFi();
    // }

    inline void printNetworkInfo() {
        pNetwork.printNetworkInfo();
    }

    //=======myMQTT============
    inline bool subscribe(const String topic) {
        pNetwork.connectToWiFi();
        return pMymqtt.subscribe(topic);
    }

    inline bool unsubscribe(const String topic) {
        pNetwork.connectToWiFi();
        return pMymqtt.unsubscribe(topic);
    }

    inline bool publishMessage(const String topic, const String msg) {
        pNetwork.connectToWiFi();
        return pMymqtt.publishMessage(topic, msg);
    }

    //=======myJSON/Buffer============
    //https://github.com/rlogiacco/CircularBuffer
    inline myJSONStr last() {
        return _buffer.last();
    }

    inline myJSONStr getElement(int x) {
        return _buffer[x];
    }

    inline myJSONStr pop() {
        return _buffer.pop();
    }

    inline bool isEmpty() {
        return _buffer.isEmpty();
    }

    inline myJSONStr first() {
        return _buffer.first();
    }
    inline myJSONStr shift() {
        return _buffer.shift();
    }

    inline int size() {
        return _buffer.size();
    }

    inline void clear() {
        _buffer.clear();
    }

   private:
    String pHostname;
    WiFiClient pClient = WiFiClient();  
    Network pNetwork = Network(DEFAULT_WIFI_SSID,
                               DEFAULT_WIFI_PASSWORD,
                               DEFAULT_WIFI_CS,
                               DEFAULT_WIFI_IRQ,
                               DEFAULT_WIFI_RST,
                               DEFAULT_WIFI_EN);  
    myMQTT pMymqtt = myMQTT(pHostname,
                            DEFAULT_MQTT_BROKER_IP1,
                            DEFAULT_MQTT_BROKER_IP2,
                            DEFAULT_MQTT_BROKER_IP3,
                            DEFAULT_MQTT_BROKER_IP4,
                            DEFAULT_MQTT_PORT);  

    void (*funcPointer)(char*, unsigned char*, unsigned int) = callback;  
};
#endif