Method MQTTTopic

src/backend/datasources/MQTTTopic.cpp:32–54

! \class MQTTTopic \brief Represents a topic of a subscription made in MQTTClient. \ingroup datasources */

  \ingroup datasources
*/
MQTTTopic::MQTTTopic(const QString& name, MQTTSubscription* subscription, bool loading)
	: Spreadsheet(name, loading, AspectType::MQTTTopic)
	, m_topicName(name)
	, m_MQTTClient(subscription->mqttClient())
	, m_filter(new AsciiFilter) {
	// Set topic name as column name
	auto properties = m_MQTTClient->filter()->properties();
	if (properties.columnModes.size() != 0) {
		properties.columnNames.clear();
		for (int i = 0; i < properties.columnModes.size(); i++) {
			if (properties.endColumn > 0 && i >= (properties.endColumn - properties.startColumn + 1))
				break;
			properties.columnNames.append(i18n("%1 %2").arg(m_topicName).arg(QString::number(i + 1)));
		}
	}

	m_filter->initialize(properties);
	m_filter->setDataSource(this);

	connect(m_MQTTClient, &MQTTClient::readFromTopics, this, &MQTTTopic::read);
	qDebug() << "New MqttTopic: " << m_topicName;
	initActions();
}

MQTTTopic::~MQTTTopic() {
	qDebug() << "MqttTopic destructor:" << m_topicName;