rover_pahomqtt.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2017 FH Dortmund and others
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Description:
 *    Rover PahoMQTT API - Interfaces for Rover PahoMQTT cloud application development - Header file
 *
 * Contributors:
 *    M.Ozcelikors <mozcelikors@gmail.com>, created PahoMQTT API 07.12.2017
 *                                          improved PahoMQTT API 10.12.2017
 *
 */

#ifndef ROVERAPI_ROVER_PAHOMQTT_HPP_
#define ROVERAPI_ROVER_PAHOMQTT_HPP_

#include <roverapi/rover_cloud.hpp>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

#include "MQTTClient.h"
#include "MQTTAsync.h"

using namespace std;

namespace rover
{

    typedef struct
    {
        char * clientID;
        char * topic;
        char * payload;
        char * username;
        char * password;
        int         qos;        // 1
        long int    timeout;    // Such as 10000L usec
    } RoverMQTT_Configure_t;

    typedef struct
    {
        int data_ready;
        char * data;
    } RoverMQTT_SubscribeData_t;

    typedef struct
    {
        int f_mqtt_disconnect_finished;
        int f_mqtt_finished;
        int f_mqtt_subscribed;
        int f_mqtt_publish_successful;
                int f_mqtt_connected;
    } RoverMQTT_StatusFlags_t;

    typedef struct
    {
        int rc_publish;
        int rc_subscribe;
        int rc_unsubscribe;
    } RoverMQTT_ReturnCodes_t;

    class RoverPahoMQTT : public RoverCloud
    {
        protected:
            char * HOST_NAME;

            int PORT;

            RoverMQTT_SubscribeData_t defaultRoverSubscribeData;

            RoverMQTT_Configure_t defaultRoverMQTTConfigure;

            RoverMQTT_StatusFlags_t defaultRoverMQTTFlags;

            RoverMQTT_ReturnCodes_t defaultReturnCodes;

                        MQTTAsync client = NULL;

            MQTTClient client2;

            MQTTAsync_connectOptions conn_opts;

            MQTTAsync_disconnectOptions disc_opts;

            volatile MQTTAsync_token deliveredtoken;

            void createClient(void);
            
            void destroyClient(void);


                public:
            ~RoverPahoMQTT ();

            RoverPahoMQTT();


            RoverPahoMQTT (char * host_name, int port, RoverMQTT_Configure_t MQTT_Configure);

            void setHostName (char * host_name);

            void setPort (const int port);

            void setPayload (const char * payload, int payloadLen);

            void setTopic (char * topic);

            int read (char * data);

            int isDataReady (void);

            int publish (void);

                        int connect (void);

            int subscribe (void);

            int unsubscribe (void);

                        int getConnected(void);

        protected:
            void flushFlags (void);

            void constructAddress (void);

            /* Internal callbacks */
            /* Related to publisher */
                        static void onConnect_Redirect (void* context, MQTTAsync_successData* response);

            static void onPublisherSend_Redirect (void* context, MQTTAsync_successData* response);

                        void onConnect (MQTTAsync_successData* response);


            void onPublisherSend (MQTTAsync_successData* response);


            /* Related to subscriber */
            static int onSubscriberMessageArrived_Redirect (void *context, char *topicName, int topicLen, MQTTAsync_message *message);

            static void onSubscribe_Redirect (void* context, MQTTAsync_successData* response);

            static void onSubscribeFailure_Redirect (void* context, MQTTAsync_failureData* response);


            int onSubscriberMessageArrived (char *topicName, int topicLen, MQTTAsync_message *message);

            void onSubscribe (MQTTAsync_successData* response);

            void onSubscribeFailure (MQTTAsync_failureData* response);

            /* Related to both */
            static void onConnectFailure_Redirect (void* context, MQTTAsync_failureData* response);

            static void onConnectionLost_Redirect (void* context, char *cause);

            void onConnectFailure (MQTTAsync_failureData* response);

            static void onDisconnect_Redirect (void* context, MQTTAsync_successData* response);

            void onConnectionLost (char *cause);

            void onDisconnect (MQTTAsync_successData* response);

    private:
            char * payload = {};
            
                        char my_address[100] = {};

                        int connected = 0;

    };
}



#endif /* ROVERAPI_ROVER_PAHOMQTT_HPP_ */