datastream_mqtt.h

Go to the documentation of this file.

#ifndef DATASTREAM_MQTT_H
#define DATASTREAM_MQTT_H
 
#include <QDialog>
#include <QtPlugin>
#include <QTimer>
#include <thread>
#include "PlotJuggler/datastreamer_base.h"
#include "PlotJuggler/messageparser_base.h"
#include "ui_datastream_mqtt.h"
#include "mqtt_dialog.h"
 
using namespace PJ;
 
class DataStreamMQTT : public PJ::DataStreamer
{
  Q_OBJECT
  Q_PLUGIN_METADATA(IID "facontidavide.PlotJuggler3.DataStreamer")
  Q_INTERFACES(PJ::DataStreamer)
 
public:
  DataStreamMQTT();
 
  ~DataStreamMQTT() override;
 
  virtual bool start(QStringList*) override;
 
  virtual void shutdown() override;
 
  virtual bool isRunning() const override;
 
  virtual const char* name() const override
  {
    return "MQTT Subscriber (Mosquitto)";
  }
 
  virtual bool isDebugPlugin() override
  {
    return false;
  }
 
  std::pair<QAction*, int> notificationAction() override
  {
    return { _notification_action, _failed_parsing };
  }
 
private slots:
 
  void onComboProtocolChanged(const QString&);
 
  void onMessageReceived(const mosquitto_message* message);
 
private:
  bool _running;
 
  std::unordered_map<std::string, PJ::MessageParserPtr> _parsers;
 
  MQTTClient::Ptr _mosq;
 
  std::thread _mqtt_thread;
  QString _protocol;
 
  QString _topic_to_parse;
 
  QAction* _notification_action;
  int _failed_parsing = 0;
 
  MQTT_Dialog* _dialog;
  ParserFactoryPlugin::Ptr _current_parser_creator;
};
 
#endif  // DATASTREAM_MQTT_H