Method testIntegerMessage

tests/import_export/MQTT/MQTTTest.cpp:143–260

############################################################################## ################# test handling of data received by messages ############### ##############################################################################

// #################  test handling of data received by messages  ###############
// ##############################################################################
void MQTTTest::testIntegerMessage() {
	QSKIP("Unstable", QTest::SkipSingle);

	auto* filter = new AsciiFilter();

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

	auto* 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"),
				QStringLiteral("2"),
				QStringLiteral("3"),
			};
			QString savePath;
			SAVE_FILE("testfile", data);
			QFile file(savePath);

			if (file.open(QIODevice::ReadOnly)) {
				QTextStream in(&file);
				QString message = in.readAll();
				client->publish(topicFilter.filter(), message.toUtf8(), 0);
			}
			file.close();