GmMQTT.hpp

/*
 * GmMQTT.hpp
 *
 *  Created on: Jun 6, 2016
 *      Author: rcram
 */
 
#ifndef GMMQTT_HPP_
#define GMMQTT_HPP_
 
#if GEO_MQTT == GEO_TRUE
 
#if GEO_NET_NDK == GEO_TRUE
#include <netmain.h>
#endif
//#if GEO_NET_3100 == GEO_TRUE
//#include "../GeometricsEthernet/http-port/usertype.h"
//#include <simplelink.h>
//#else
//#include <socket.h>
//#endif
 
#include <GmStorage.hpp>
 
 
namespace Geometrics
{
 
extern "C" int StartupMQTT (void);
 
#define GEO_MAX_TOPICS 20
#define GEO_MAX_TOPIC_NAME_LENGTH 20
 
class GmMqttPublisher : public GmStorage
{
 
public:
   GmMqttPublisher      ();
   GmMqttPublisher      (int           iBufferSize);
 
   ~GmMqttPublisher     ();
   int CheckInitialized (char         *szServerName,
                         char         *szPortNumberAsString,
                         char         *szClientName,
                         Bool          bIsKnownIp);
   int ConnectToBroker  (const char         *brokerAddress);
   int Subscribe        (const char   *szTopicName);
   int Shutdown         ();
   int PrepTopic        (char         *szTopicName,
                         UInt32        iDataSize,
                         int           iBufferCount);
   int Close            (int           iFileIndex) { return 0;};
   int WriteData        (const char*   pcData,
                         unsigned int  iDataSize,
                         UInt32        uiTopic);
   int SetTopicString   (UInt32        iTopicId,
                         char         *strTopic);
   int PushData         (const char   *pData,
                         const int     iDataSize);
   int StartPushData    ();
   int StopPushData     ();
   int PublishSelf      (const char   *szTopic,
                         const char   *pcData,
                         int           iDataSize);
   static bool          sDaemonsHaveBeenSetUp;
 
private:
   Bool                       m_bInitialized,
                              m_bFailed;
   int                        m_iLastBuffer,
                              m_iBufferMax,
                              m_iItemSize,
                              m_iTotalSerialized;
   UInt32                     m_iBufferSize;
   char                       m_aacTopicIdToStringMap[GEO_MAX_TOPICS][GEO_MAX_TOPIC_NAME_LENGTH+1];
};
 
} // End geometrics namespace
 
#endif
#endif /* GMMQTT_HPP_ */