ddtDataStreamWidget.hpp

Go to the documentation of this file.

 
#ifndef DDT_DATAVISUALISATION_DDTWIDGETS_DATASTREAMWIDGET_HPP
#define DDT_DATAVISUALISATION_DDTWIDGETS_DATASTREAMWIDGET_HPP
 
#include <QtUiPlugin/QDesignerExportWidget>
#include <memory>
 
#include "ddt/ddtDataTransferLib.hpp"
#include "ddt/ddtDatavisualisationDefines.hpp"
#include "ddt/ddtDatavisualisationUtils.hpp"
#include "ddt/ddtLogger.hpp"
#include "ddt/widgets/ddtWidget.hpp"

class QDESIGNER_WIDGET_EXPORT DdtDataStreamWidget : public DdtWidget {
  Q_OBJECT
 
 public:
   static constexpr unsigned NEW_DATA_WATCHDOG_TIMEOUT = 1000;
  explicit DdtDataStreamWidget(QWidget* parent = nullptr);

  virtual ~DdtDataStreamWidget();

  void set_logger(ddt::DdtLogger* in_logger);
 
 protected:
  ddt::DdtLogger* logger;

  int last_index_selected;

  QString current_localbroker_uri;

  QString current_remotebroker_uri;
 
 private:
  QPushButton* button_refresh_datastreams;
  QPushButton* button_subscriber_attach;
  QPushButton* button_subscriber_detach;
  QRadioButton* status_led;
  QComboBox* combobox_publisher;
  InactiveLineEdit* edit_status;

  QCheckBox* checkbox_refresh_rate_enable;

  QDoubleSpinBox* spinbox_refresh_rate_seconds;

  QString stylesheet_attached;
  QString stylesheet_detached;
  QString stylesheet_reconnecting;
  QString stylesheet_no_new_data;
  QString stylesheet_error;
  QString stylesheet_publisher_lost;

  bool is_attached;

  std::unique_ptr<QTimer> new_data_watchdog;

  QString attached_status_text;

  void Init();

  void CreateWidget();
 
 signals:
  void AttachDataStream(QString data_stream_id);

  void DetachDataStream(QString data_stream_id);

  void LastBrokerConnection(QString data_stream_id);

  void RefreshRateChanged(bool enabled, double interval_seconds);
 
 public slots:
  bool PopulatePublisherListCombo(QString localbroker_uri, QString remotebroker_uri);
 
 protected slots:
  void AttachDataStream();

  void DetachDataStream();

  void SetDataStream(QString startup_data_stream);

  void CurrentStatus(QString stream_id, ConnectionStatus status);

  void FlickerStatus();

  void ConnectionLost();

  void DisplayURIsDialog();

  void EmitRefreshRateChanged();
};
 
#endif  // DDT_DATAVISUALISATION_DDTWIDGETS_DATASTREAMWIDGET_HPP