MQTTPublisher.h

/*
 * Copyright (c) 2015 Pavel Vainerman.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, version 2.1.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Lesser Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
// -----------------------------------------------------------------------------
#ifndef _MQTTPublisher_H_
#define _MQTTPublisher_H_
// -----------------------------------------------------------------------------
#include <unordered_map>
#include <list>
#include <memory>
#include <mosquittopp.h>
#include "UObject_SK.h"
#include "SMInterface.h"
#include "SharedMemory.h"
#include "extensions/Extensions.h"
// -------------------------------------------------------------------------
namespace uniset
{
    // -----------------------------------------------------------------------------
    // -----------------------------------------------------------------------------
    class MQTTPublisher:
        protected mosqpp::mosquittopp,
        public UObject_SK
    {
        public:
            MQTTPublisher( uniset::ObjectId objId, xmlNode* cnode, uniset::ObjectId shmID, const std::shared_ptr<SharedMemory>& ic = nullptr,
                           const std::string& prefix = "mqtt" );
            virtual ~MQTTPublisher();
 
            static std::shared_ptr<MQTTPublisher> init_mqttpublisher( int argc, const char* const* argv,
                    uniset::ObjectId shmID, const std::shared_ptr<SharedMemory>& ic = nullptr,
                    const std::string& prefix = "mqtt" );
 
            static void help_print( int argc, const char* const* argv );
 
            virtual void on_connect(int rc) override;
            virtual void on_message(const struct mosquitto_message* message) override;
            virtual void on_subscribe(int mid, int qos_count, const int* granted_qos) override;
 
        protected:
            MQTTPublisher();
 
            virtual void askSensors( UniversalIO::UIOCommand cmd ) override;
            virtual void sensorInfo( const uniset::SensorMessage* sm ) override;
            virtual bool deactivateObject() override;
            virtual void sysCommand( const uniset::SystemMessage* sm ) override;
 
            std::shared_ptr<SMInterface> shm;
 
            struct MQTTInfo
            {
                uniset::ObjectId sid;
                std::string pubname;
 
                MQTTInfo( uniset::ObjectId id, const std::string& name ):
                    sid(id), pubname(name) {}
            };
 
            typedef std::unordered_map<uniset::ObjectId, MQTTInfo> MQTTMap;
 
            struct RangeInfo
            {
                RangeInfo( long min, long max, const std::string& t ): rmin(min), rmax(max), text(t) {}
 
                long rmin;
                long rmax;
                std::string text;
                bool check( long val ) const;
            };
 
            struct MQTTTextInfo
            {
                uniset::ObjectId sid;
                std::string pubname;
                UniXML::iterator xmlnode;
 
                MQTTTextInfo( const std::string& rootsec, UniXML::iterator s, UniXML::iterator i );
 
                // одиночные сообщения просто имитируются min=max=val
                std::list<RangeInfo> rlist; // список сообщений..
 
                void check( mosqpp::mosquittopp* serv, long value, std::shared_ptr<DebugStream>& log, const std::string& myname );
 
                std::string replace( RangeInfo* ri, long value );
            };
 
            typedef std::unordered_map<uniset::ObjectId, MQTTTextInfo> MQTTTextMap;
 
            MQTTMap publist;
            MQTTTextMap textpublist;
 
        private:
 
            std::string prefix;
            std::string topic; // "топик" для публикации датчиков
            bool connectOK = { false };
            std::string host = { "localhost" };
            int port = { 1883 };
            int keepalive = { 60 };
    };
    // ----------------------------------------------------------------------------------
} // end of namespace uniset
// -----------------------------------------------------------------------------
#endif // _MQTTPublisher_H_
// -----------------------------------------------------------------------------