qclientMQTT.hpp

#pragma once
#include<QDebug>
#include <QMqttClient>
#include<QJsonValue>
#include "client/qwebsocketiodevice.hpp"
#include"block/qblock.hpp"
 
namespace qiota{
 
    class QCMQTT_EXPORT ResponseMqtt: public QObject
    {
        Q_OBJECT
        public:
            ResponseMqtt(QMqttSubscription * thesub);
            public slots:
                void fill(QMqttMessage msg);
            void unsubscribe(void);
        signals:
            void returned( QJsonValue data );
        private:
            QMqttSubscription * sub_;
 
    };
 
 
    class QCMQTT_EXPORT ClientMqtt: public QMqttClient
    {
 
        Q_OBJECT
        public:
            ClientMqtt(QObject *parent = nullptr);
 
            ResponseMqtt* get_subscription(const QString& topic);
            ResponseMqtt* get_outputs_unlock_condition_address(const QString& condition_address);
 
            template<qblocks::Output::types outtype>
                ResponseMqtt* get_outputs_by_chain_id(const QString& id)
                {
                    return get_subscription("outputs/"+qblocks::Output::typesstr[outtype]+"/"+id);
                }
            ResponseMqtt* get_outputs_outputId(const QString& outid);
            ResponseMqtt* get_blocks(void);
            void set_node_address(const QUrl &url){
                   auto node_addr_wss_=url;
                if(url.scheme()!="wss")
                {
                    node_addr_wss_.setScheme("wss");
                    node_addr_wss_.setPort(443);
                    node_addr_wss_.setPath("/api/mqtt/v1");
                }
                if(node_address_!=node_addr_wss_&&node_addr_wss_.isValid())
                {
                    node_address_=node_addr_wss_;emit node_address_changed();
                }
            }
 
        signals:
            void node_address_changed();
        private:
            void restart(void);
            void openDevice();
            QUrl  node_address_;
            quint16 port_;
            WebSocketIODevice* m_device;
    };
 
};