config_mqtt_obj.h

#ifndef  __CONFIG_MQTT_OBJ_H
#define  __CONFIG_MQTT_OBJ_H
 
#include <predef.h>
#include <config_obj.h>
#include <nbstring.h>
 
class config_MqttLWT : public config_obj
{
    public:
    config_string topic{"", "Topic", "Topic to publish Last Will & Testament message to"};
    config_string message{"", "Message", "LWT Message to publish on non-normal disconnect"};
    config_uint   sessExpIntvl{60, "SessExpIntvl", "Session Expirary delay (in seconds) between non-normal disconnect and broker invalidating session and publishing LWT"};
    config_bool   retain{true, "Retain", "Whether the broker will retain LWT to publish to future subscribers."};
    config_string connMessage{"", "Connect", "LWT Message to publish on Connect"};
    config_string normalDisconMessage{"", "NormalDisconnect", "Message to publish on normal disconnect"};
    ConfigEndMarker;
 
    config_MqttLWT(config_obj &owner, const char* name, const char *desc = NULL)
        : config_obj(owner, name, desc)
    {
    }
    config_MqttLWT(const char* name, const char *desc = NULL)
        : config_obj(name, desc)
    {
    }
 
    bool valid();
};
 
class config_x509Cert : public config_obj
{
public:
    config_fs_bulkstore cert{"/sys/mqtt/cert_", false, "ClientCert", "Certificate content"};
    config_fs_bulkstore privKey{"/sys/mqtt/key_", false, "PrivateKey", "Private Key associated with cert"};
    ConfigEndMarker;
 
    config_x509Cert(config_obj &owner, const char* name, const char *desc = NULL)
        : config_obj(owner, name, desc)
    {
        privKey.SetBulkstoreFlags(config_fs_bulkstore::FLAG_IS_SENSITIVE_HIDE_VALUE);
    }
    config_x509Cert(const char* name, const char *desc = NULL)
        : config_obj(name, desc)
    {
        privKey.SetBulkstoreFlags(config_fs_bulkstore::FLAG_IS_SENSITIVE_HIDE_VALUE);
    }
};
 
class config_MqttClient : public config_obj
{
    static int numConfigs;
    protected:
    static const char *createName();
    public:
    config_string brokerFqdn{"", "Hostname", ""};
    config_uint   brokerPort{MQTT_DEFAULT_PORT, "Port", ""};
#if NB_SSL_SUPPORTED
    config_bool   useTLS{false, "TLS_Enabled", "Encrypt Connection using TLS"};
#endif
    config_string cfgClientId{"", "ClientId", ""};
    config_string cfgUsername{"", "Username", ""};
    config_pass   cfgPassword{"", "Password", ""};
    config_bool   alwaysClean{true, "AlwayCleanStart", "Always start session with a clean slate of subscriptions."};
    config_bool   enableLWT{true, "LWT_Enabled", "Enable client use of LWT message"};
    config_uint   maxKeepAlive{MQTT_DEFAULT_KEEP_ALIVE, "KeepAlive", "The number of seconds when, after multiple failed MQTT keepalive messages, the connection will be automatically restarted (Note: the server may impose a different maximum keepalive)"};
#if NB_SSL_SUPPORTED
    config_x509Cert   clientCert{*this, "ClientCert", "Client Cert to use to authenticate to the server"};
#endif
    int configNum;
    ConfigEndMarker;
 
    NBString interpBroker;
 
    config_MqttClient(config_obj &owner, const char* name, const char *desc = NULL)
        : config_obj(owner, name, desc)
    {
    }
    config_MqttClient(const char* name, const char *desc = NULL)
        : config_obj(name, desc)
    {
    }
};
 
 
#endif   /* ----- #ifndef __CONFIG_MQTT_OBJ_H  ----- */