Loom_MQTT.h

#pragma once
 
#include <ArduinoMqttClient.h>
 
#include "Loom_Manager.h"
#include "Module.h"
 
#include "../../../Hardware/Loom_BatchSD/Loom_BatchSD.h"
 
 
 
class Loom_MQTT : public Module{
    protected:
 
        /* These aren't used with the MQTT */
        void measure() override {};                               
        
        void initialize() override {};    
        void power_up() override {};
        void power_down() override {}; 
        void package() override {};
 
    public: 
 
        Loom_MQTT(
                Manager& man,
                Client& internet_client, 
                const char* broker_address, 
                int broker_port, 
                const char* database_name, 
                const char* broker_user = "", 
                const char* broker_pass = "",
                const char* projectServer = ""
            );
 
        Loom_MQTT(Manager& man, Client& internet_client);
        
        void publish();
 
        void publish(Loom_BatchSD& batchSD);
 
        void setKeepAlive(int time) { keep_alive = time; };
        
        void setMaxRetries(int retries) { maxRetries = retries; };
 
        void loadConfigFromJSON(char* json);
    
    private:
        Manager* manInst;                       // Instance of the manager
 
        Client* internetClient;                  // Client to supply to the MQTT client to handle internet communication
        MqttClient mqttClient;                  // MQTT Client to manage interactions with the MQTT broker
 
        const char* getMQTTError();                  // Get the string representation of the MQTT error codes
    
        int keep_alive = 60000;                 // How long the broker should keep the connection open, defaults to a minute
        int maxRetries = 4;                         // How many times we want to retry the connection
 
        char address[100];                         // Domain that the broker is running on
        char database_name[100];                   // Database to publish the data to
        char projectServer[100];                   // Project 
        int port;                                  // Port the broker is listening on
        char topic[100];                           // Where to publish the data to
        char username[100];                        // Username to log into the broker
        char password[100];                        // Password to log into the broker
 
        
 
};