Method testNumericMessage

tests/import_export/MQTT/MQTTTest.cpp:262–391

}

void MQTTTest::testNumericMessage() {
	QSKIP("Unstable", QTest::SkipSingle);

	auto* filter = new AsciiFilter();

	auto properties = filter->properties();
	properties.automaticSeparatorDetection = false;
	properties.headerEnabled = false;
	properties.columnModesString = QStringLiteral("Double");
	properties.intAsDouble = false;
	QCOMPARE(filter->initialize(properties), AsciiFilter::Status::Success); // Livedata must be initialized!

	Project* project = new Project();

	auto* mqttClient = new MQTTClient(QStringLiteral("test"));
	project->addChild(mqttClient);
	mqttClient->setFilter(filter);
	mqttClient->setReadingType(MQTTClient::ReadingType::TillEnd);
	mqttClient->setKeepNValues(100); // At least 8!
	mqttClient->setUpdateType(MQTTClient::UpdateType::NewData);
	mqttClient->setMQTTClientHostPort(mqttHostName, mqttPort);
	mqttClient->setMQTTUseAuthentication(false);
	mqttClient->setMQTTUseID(false);
	QMqttTopicFilter topicFilter{QStringLiteral("labplot/mqttUnitTest")};
	mqttClient->addInitialMQTTSubscriptions(topicFilter, 0);
	mqttClient->read();
	mqttClient->ready();

	auto* client = new QMqttClient();
	client->setHostname(mqttHostName);
	client->setPort(mqttPort);
	client->connectToHost();

	bool wait = QTest::qWaitFor(
		[&]() {
			return (client->state() == QMqttClient::Connected);
		},
		5000);
	QCOMPARE(wait, true);

	auto* subscription = client->subscribe(topicFilter, 0);
	if (subscription) {
		{
			const QStringList data = {
				QStringLiteral("1.5"),
				QStringLiteral(""),
				QStringLiteral(""),
				QStringLiteral("2.7"),
				QStringLiteral(""),
				QStringLiteral(""),
				QStringLiteral("3.9"),
			};
			QString savePath;
			SAVE_FILE("testfile", data);
			QFile file(savePath);

			if (file.open(QIODevice::ReadOnly)) {
				QTextStream in(&file);