Revision control
Copy as Markdown
// Copyright (C) 2017 Witekio.
// Copyright (C) 2018 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only
#include <QtTest>
#include <QCoreApplication>
#include <QtCore/qglobal.h>
#include <QtCoap/qcoapnamespace.h>
#include <QtCore/qbuffer.h>
#include <QtNetwork/qudpsocket.h>
#include <QtNetwork/qnetworkdatagram.h>
#include <QtCoap/qcoapglobal.h>
#include <QtCoap/qcoaprequest.h>
#include <private/qcoapqudpconnection_p.h>
#include <private/qcoapinternalrequest_p.h>
#include <private/qcoaprequest_p.h>
#include "../coapnetworksettings.h"
using namespace QtCoapNetworkSettings;
class tst_QCoapQUdpConnection : public QObject
{
Q_OBJECT
private Q_SLOTS:
void initTestCase();
void ctor();
void connectToHost();
void reconnect();
void sendRequest_data();
void sendRequest();
};
class QCoapQUdpConnectionForTest : public QCoapQUdpConnection
{
Q_OBJECT
public:
QCoapQUdpConnectionForTest(QObject *parent = nullptr) :
QCoapQUdpConnection(QtCoap::SecurityMode::NoSecurity, parent)
{}
void bindSocketForTest() { d_func()->bindSocket(); }
void sendRequest(const QByteArray &request, const QString &host, quint16 port)
{
d_func()->sendRequest(request, host, port);
}
};
void tst_QCoapQUdpConnection::initTestCase()
{
#if defined(COAP_TEST_SERVER_IP) || defined(QT_TEST_SERVER)
QVERIFY2(waitForHost(QUrl{testServerHost()}), "Failed to connect to Californium plugtest server.");
#endif
}
void tst_QCoapQUdpConnection::ctor()
{
QCoapQUdpConnection connection;
QVERIFY(connection.socket());
}
void tst_QCoapQUdpConnection::connectToHost()
{
QCoapQUdpConnectionForTest connection;
QUdpSocket *socket = qobject_cast<QUdpSocket*>(connection.socket());
QSignalSpy spyConnectionBound(&connection, SIGNAL(bound()));
QSignalSpy spySocketStateChanged(socket , SIGNAL(stateChanged(QAbstractSocket::SocketState)));
QCOMPARE(connection.state(), QCoapQUdpConnection::ConnectionState::Unconnected);
// This will trigger connection.bind()
connection.sendRequest(QByteArray(), QString(), 0);
QTRY_COMPARE(spySocketStateChanged.size(), 1);
QTRY_COMPARE(spyConnectionBound.size(), 1);
QCOMPARE(connection.state(), QCoapQUdpConnection::ConnectionState::Bound);
}
void tst_QCoapQUdpConnection::reconnect()
{
QCoapQUdpConnectionForTest connection;
// This will trigger connection.bind()
QSignalSpy connectionBoundSpy(&connection, SIGNAL(bound()));
connection.sendRequest(QByteArray(), QString(), 0);
QTRY_COMPARE(connectionBoundSpy.size(), 1);
QCOMPARE(connection.state(), QCoapQUdpConnection::ConnectionState::Bound);
connection.disconnect();
QCOMPARE(connection.state(), QCoapQUdpConnection::ConnectionState::Unconnected);
// Make sure that we are able to connect again
connection.sendRequest(QByteArray(), QString(), 0);
QTRY_COMPARE(connectionBoundSpy.size(), 2);
QCOMPARE(connection.state(), QCoapQUdpConnection::ConnectionState::Bound);
}
void tst_QCoapQUdpConnection::sendRequest_data()
{
QTest::addColumn<QString>("protocol");
QTest::addColumn<QString>("host");
QTest::addColumn<QString>("path");
QTest::addColumn<quint16>("port");
QTest::addColumn<QtCoap::Method>("method");
QTest::addColumn<QString>("dataHexaHeader");
QTest::addColumn<QString>("dataHexaPayload");
QTest::newRow("simple_get_request")
<< "coap://"
<< testServerHost()
<< "/test"
<< quint16(QtCoap::DefaultPort)
<< QtCoap::Method::Get
<< "5445"
<< "61626364c0211eff547970653a203120284e4f4e290a436f64653a2031202847"
"4554290a4d49443a2032343830360a546f6b656e3a203631363236333634";
QTest::newRow("simple_put_request")
<< "coap://"
<< testServerHost()
<< "/test"
<< quint16(QtCoap::DefaultPort)
<< QtCoap::Method::Put
<< "5444"
<< "61626364";
QTest::newRow("simple_post_request")
<< "coap://"
<< testServerHost()
<< "/test"
<< quint16(QtCoap::DefaultPort)
<< QtCoap::Method::Post
<< "5441"
<< "61626364896c6f636174696f6e31096c6f636174696f6e32096c6f636174696f"
"6e33";
QTest::newRow("simple_delete_request")
<< "coap://"
<< testServerHost()
<< "/test"
<< quint16(QtCoap::DefaultPort)
<< QtCoap::Method::Delete
<< "5442"
<< "61626364";
}
void tst_QCoapQUdpConnection::sendRequest()
{
CHECK_FOR_COAP_SERVER;
QFETCH(QString, protocol);
QFETCH(QString, host);
QFETCH(QString, path);
QFETCH(quint16, port);
QFETCH(QtCoap::Method, method);
QFETCH(QString, dataHexaHeader);
QFETCH(QString, dataHexaPayload);
QCoapQUdpConnectionForTest connection;
QSignalSpy spySocketReadyRead(connection.socket(), &QUdpSocket::readyRead);
QSignalSpy spyConnectionReadyRead(&connection, &QCoapQUdpConnection::readyRead);
QCoapRequest request =
QCoapRequestPrivate::createRequest(QCoapRequest(QUrl{protocol + host + path}), method);
request.setMessageId(24806);
request.setToken(QByteArray("abcd"));
QVERIFY(connection.socket() != nullptr);
QCoapInternalRequest internalRequest(request);
connection.sendRequest(internalRequest.toQByteArray(), host, port);
QTRY_COMPARE(spySocketReadyRead.size(), 1);
QTRY_COMPARE(spyConnectionReadyRead.size(), 1);
QByteArray data = spyConnectionReadyRead.first().first().value<QByteArray>();
QVERIFY(QString(data.toHex()).startsWith(dataHexaHeader));
QVERIFY(QString(data.toHex()).endsWith(dataHexaPayload));
}
QTEST_MAIN(tst_QCoapQUdpConnection)
#include "tst_qcoapqudpconnection.moc"