sMQTTBroker.h

 
#ifndef SMQTTBROKER_FILE
#define SMQTTBROKER_FILE
 
#include"sMQTTplatform.h"
#include"sMQTTClient.h"
#include"sMQTTTopic.h"
#include"sMQTTEvent.h"
 
class sMQTTBroker
{
public:
    bool init(unsigned short port, bool checkWifiConnection=false);
    void update();
    void publish(const std::string &topic, const std::string &payload,unsigned char qos=0,bool retain=false);
    void restart();
    virtual bool onEvent(sMQTTEvent *event) = 0;
 
    unsigned long getRetainedTopicCount();
    std::string getRetaiedTopicName(unsigned long index);
private:
    // inner function
    void publish(sMQTTClient *client, sMQTTTopic *topic, sMQTTMessage *msg);
 
    bool subscribe(sMQTTClient *client, const char *topic);
    void unsubscribe(sMQTTClient *client, const char *topic);
 
    bool isTopicValidName(const char *filter);
    void updateRetainedTopic(sMQTTTopic *topic);
 
    bool isClientConnected(sMQTTClient *client);
 
    void findRetainTopic(sMQTTTopic *topic, sMQTTClient *client);
 
    TCPServer *_server;
    sMQTTClientList clients;
    sMQTTTopicList subscribes, retains;
    bool isCheckWifiConnection;
    friend class sMQTTClient;
};
 
class sMQTTBrokerWithoutEvent:public sMQTTBroker
{
public:
    bool onEvent(sMQTTEvent *event) { return true; }
};
#endif