mqtt-client.hpp

#pragma once
 
#include "wifi-dependent.hpp"
#include <AsyncMqttClient.hpp>
 
class MqttClient : public WifiDependent
{
 
public:
  void init();
  void onWifiConnectionEstablished() override;
  void onWifiConnectionLost() override;
 
  auto publish(char *channel, char *payload) -> void;
 
private:
  char *connectionStatusTopic;
 
  void connect();
  void onConnect(boolean sessionPresent);
  void onDisconnect(AsyncMqttClientDisconnectReason reason);
  void onMessage(char *topic, char *payload, AsyncMqttClientMessageProperties properties, size_t len, size_t index, size_t total);
};