665faca358
This commit adds support for connecting via the websocket transport protocol on both, client and server parts. In addition, the standalone server implemention is more complete, allowing to manage policies and server ports via command line arguments as well as adding a command line client tool for subscribing to a broker and/or publishing messages to it.
109 lines
3.9 KiB
C++
109 lines
3.9 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
*
|
|
* Copyright 2013 - 2020, nymea GmbH
|
|
* Contact: contact@nymea.io
|
|
*
|
|
* This file is part of nymea.
|
|
* This project including source code and documentation is protected by copyright law, and
|
|
* remains the property of nymea GmbH. All rights, including reproduction, publication,
|
|
* editing and translation, are reserved. The use of this project is subject to the terms of a
|
|
* license agreement to be concluded with nymea GmbH in accordance with the terms
|
|
* of use of nymea GmbH, available under https://nymea.io/license
|
|
*
|
|
* GNU Lesser General Public License Usage
|
|
* Alternatively, this project may be redistributed and/or modified under the terms of the GNU
|
|
* Lesser General Public License as published by the Free Software Foundation; version 3.
|
|
* this project is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
|
|
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
* See the GNU Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License along with this project.
|
|
* If not, see <https://www.gnu.org/licenses/>.
|
|
*
|
|
* For any further details and any questions please contact us under contact@nymea.io
|
|
* or see our FAQ/Licensing Information on https://nymea.io/license/faq
|
|
*
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#include "mqttserver.h"
|
|
#include "mqttclient.h"
|
|
#include "mqttclient_p.h"
|
|
|
|
#include <QTest>
|
|
#include <QSignalSpy>
|
|
|
|
|
|
class MqttTests: public QObject
|
|
{
|
|
Q_OBJECT
|
|
|
|
#if (QT_VERSION >= QT_VERSION_CHECK(5, 7, 0))
|
|
|
|
private slots:
|
|
void initTestCase();
|
|
void cleanup();
|
|
void cleanupTestCase();
|
|
void connectAndDisconnect();
|
|
void keepAliveTimesOut();
|
|
|
|
void subscribeAndPublish_data();
|
|
void subscribeAndPublish();
|
|
|
|
void willIsSentOnClientDisappearing();
|
|
void willIsNotSentOnClientDisconnecting();
|
|
|
|
void testWillRetain();
|
|
|
|
void testAutoReconnect();
|
|
|
|
void testQoS1Retransmissions();
|
|
|
|
void testMultiSubscription();
|
|
|
|
void testSubscriptionTopicFilters_data();
|
|
void testSubscriptionTopicFilters();
|
|
|
|
void testSubscriptionTopicMatching_data();
|
|
void testSubscriptionTopicMatching();
|
|
|
|
void testSessionManagementDropOldSession();
|
|
void testSessionManagementResumeOldSession();
|
|
void testSessionManagementFailResumeOldSession();
|
|
|
|
void testQoS1PublishToServerIsAckedOnSessionResume();
|
|
void testQoS1PublishToClientIsDeliveredOnSessionResume();
|
|
|
|
void testQoS2PublishToServerIsCompletedOnSessionResume();
|
|
|
|
void testQoS2PublishToClientIsCompletedOnSessionResume();
|
|
|
|
void testRetain();
|
|
|
|
void testUnsubscribe();
|
|
|
|
void testEmptyClientId();
|
|
|
|
void testBinaryPaylaod();
|
|
#endif
|
|
|
|
private:
|
|
// Connects and waits for the MQTT CONNECT to be finished
|
|
MqttClient *connectAndWait(const QString &clientId, bool cleanSession = true, quint16 keepAlive = 300, const QString &willTopic = QString(), const QString &willMessage = QString(), Mqtt::QoS willQoS = Mqtt::QoS0, bool willRetain = false);
|
|
|
|
// Just connects, returns the client and signalspy which has been created before calling connect. You must delete the spy yourself!
|
|
QPair<MqttClient*, QSignalSpy*> connectToServer(const QString &clientId, bool cleanSession = true, quint16 keepAlive = 300, const QString &willTopic = QString(), const QString &willMessage = QString(), Mqtt::QoS willQoS = Mqtt::QoS0, bool willRetain = false);
|
|
|
|
void disconnectAndWait(MqttClient* client);
|
|
|
|
bool subscribeAndWait(MqttClient* client, const QString &topic, Mqtt::QoS qos = Mqtt::QoS1);
|
|
|
|
virtual int startServer(MqttServer *server) = 0;
|
|
virtual void connectClientToServer(MqttClient *client, bool cleanSession) = 0;
|
|
|
|
private:
|
|
MqttServer *m_server = nullptr;
|
|
int m_serverId = -1;
|
|
|
|
QList<MqttClient*> m_clients;
|
|
};
|