From f1b9e8defb5cbb5c9a0f9b65c06d40f925e19cb1 Mon Sep 17 00:00:00 2001 From: Kurt Pattyn Date: Fri, 1 Nov 2013 20:56:16 +0100 Subject: Rename autobahn to manual Change-Id: I82236190d8af0ef75c605ac662d217c2f3d94dc6 Reviewed-by: Kurt Pattyn --- tests/autobahn/autobahn.pro | 8 - tests/autobahn/compliance/compliance.pro | 14 -- tests/autobahn/compliance/tst_compliance.cpp | 169 --------------------- tests/autobahn/websockets/tst_websockets.cpp | 217 --------------------------- tests/autobahn/websockets/websockets.pro | 14 -- tests/manual/compliance/compliance.pro | 14 ++ tests/manual/compliance/tst_compliance.cpp | 169 +++++++++++++++++++++ tests/manual/manual.pro | 8 + tests/manual/websockets/tst_websockets.cpp | 217 +++++++++++++++++++++++++++ tests/manual/websockets/websockets.pro | 14 ++ 10 files changed, 422 insertions(+), 422 deletions(-) delete mode 100644 tests/autobahn/autobahn.pro delete mode 100644 tests/autobahn/compliance/compliance.pro delete mode 100644 tests/autobahn/compliance/tst_compliance.cpp delete mode 100644 tests/autobahn/websockets/tst_websockets.cpp delete mode 100644 tests/autobahn/websockets/websockets.pro create mode 100644 tests/manual/compliance/compliance.pro create mode 100644 tests/manual/compliance/tst_compliance.cpp create mode 100644 tests/manual/manual.pro create mode 100644 tests/manual/websockets/tst_websockets.cpp create mode 100644 tests/manual/websockets/websockets.pro (limited to 'tests') diff --git a/tests/autobahn/autobahn.pro b/tests/autobahn/autobahn.pro deleted file mode 100644 index 28961c4..0000000 --- a/tests/autobahn/autobahn.pro +++ /dev/null @@ -1,8 +0,0 @@ -TEMPLATE = subdirs - -SUBDIRS += \ - compliance \ - websockets - - - diff --git a/tests/autobahn/compliance/compliance.pro b/tests/autobahn/compliance/compliance.pro deleted file mode 100644 index 0fd32bc..0000000 --- a/tests/autobahn/compliance/compliance.pro +++ /dev/null @@ -1,14 +0,0 @@ -CONFIG += console -CONFIG += c++11 -CONFIG += testcase -CONFIG -= app_bundle - -TEMPLATE = app - -TARGET = tst_compliance - -QT = core network websockets testlib - -SOURCES += tst_compliance.cpp - -DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0 diff --git a/tests/autobahn/compliance/tst_compliance.cpp b/tests/autobahn/compliance/tst_compliance.cpp deleted file mode 100644 index 0140dcf..0000000 --- a/tests/autobahn/compliance/tst_compliance.cpp +++ /dev/null @@ -1,169 +0,0 @@ -/**************************************************************************** -** -** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies). -** Contact: http://www.qt-project.org/legal -** -** This file is part of the QtWebSockets module of the Qt Toolkit. -** -** $QT_BEGIN_LICENSE:LGPL$ -** Commercial License Usage -** Licensees holding valid commercial Qt licenses may use this file in -** accordance with the commercial license agreement provided with the -** Software or, alternatively, in accordance with the terms contained in -** a written agreement between you and Digia. For licensing terms and -** conditions see http://qt.digia.com/licensing. For further information -** use the contact form at http://qt.digia.com/contact-us. -** -** GNU Lesser General Public License Usage -** Alternatively, this file may be used under the terms of the GNU Lesser -** General Public License version 2.1 as published by the Free Software -** Foundation and appearing in the file LICENSE.LGPL included in the -** packaging of this file. Please review the following information to -** ensure the GNU Lesser General Public License version 2.1 requirements -** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. -** -** In addition, as a special exception, Digia gives you certain additional -** rights. These rights are described in the Digia Qt LGPL Exception -** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. -** -** GNU General Public License Usage -** Alternatively, this file may be used under the terms of the GNU -** General Public License version 3.0 as published by the Free Software -** Foundation and appearing in the file LICENSE.GPL included in the -** packaging of this file. Please review the following information to -** ensure the GNU General Public License version 3.0 requirements will be -** met: http://www.gnu.org/copyleft/gpl.html. -** -** -** $QT_END_LICENSE$ -** -****************************************************************************/ -#include -#include -#include -#include -#include -#include -#include - -class tst_ComplianceTest : public QObject -{ - Q_OBJECT - -public: - tst_ComplianceTest(); - -private Q_SLOTS: - void initTestCase(); - void cleanupTestCase(); - void init(); - void cleanup(); - /** - * @brief Runs the autobahn tests against our implementation - */ - void autobahnTest(); - -private: - QUrl m_url; - - void runTestCases(int startNbr, int stopNbr = -1); - void runTestCase(int nbr, int total); -}; - -tst_ComplianceTest::tst_ComplianceTest() : - m_url("wss://localhost:9001") -{ -} - -void tst_ComplianceTest::initTestCase() -{ -} - -void tst_ComplianceTest::cleanupTestCase() -{ -} - -void tst_ComplianceTest::init() -{ -} - -void tst_ComplianceTest::cleanup() -{ -} - -void tst_ComplianceTest::runTestCase(int nbr, int total) -{ - if (nbr == total) - { - return; - } - - QWebSocket *pWebSocket = new QWebSocket; - pWebSocket->ignoreSslErrors(); - QSignalSpy spy(pWebSocket, SIGNAL(disconnected())); - - //next for every case, connect to url - //ws://ipaddress:port/runCase?case=&agent= - //where agent name will be QWebSocket - QObject::connect(pWebSocket, &QWebSocket::textMessageReceived, [=](QString message) { - pWebSocket->write(message); - }); - QObject::connect(pWebSocket, &QWebSocket::binaryMessageReceived, [=](QByteArray message) { - pWebSocket->write(message); - }); - - qDebug() << "Executing test" << (nbr + 1) << "/" << total; - QUrl url = m_url; - url.setPath("/runCase?"); - QUrlQuery query; - query.addQueryItem("case", QString::number(nbr + 1)); - query.addQueryItem("agent", "QWebSockets/0.9"); - url.setQuery(query); - pWebSocket->open(url); - spy.wait(60000); - pWebSocket->close(); - delete pWebSocket; - pWebSocket = 0; - runTestCase(nbr + 1, total); -} - -void tst_ComplianceTest::runTestCases(int startNbr, int stopNbr) -{ - runTestCase(startNbr, stopNbr); -} - -void tst_ComplianceTest::autobahnTest() -{ - //connect to autobahn server at url ws://ipaddress:port/getCaseCount - QWebSocket *pWebSocket = new QWebSocket; - pWebSocket->ignoreSslErrors(); - QUrl url = m_url; - int numberOfTestCases = 0; - QSignalSpy spy(pWebSocket, SIGNAL(disconnected())); - QObject::connect(pWebSocket, &QWebSocket::textMessageReceived, [&](QString message) { - numberOfTestCases = message.toInt(); - }); - - url.setPath("/getCaseCount"); - pWebSocket->open(url); - spy.wait(60000); - QVERIFY(numberOfTestCases > 0); - - QObject::disconnect(pWebSocket, &QWebSocket::textMessageReceived, 0, 0); - - runTestCases(0, numberOfTestCases); - - url.setPath("/updateReports?"); - QUrlQuery query; - query.addQueryItem("agent", "QWebSockets"); - url.setQuery(query); - pWebSocket->open(url); - spy.wait(60000); - delete pWebSocket; - pWebSocket = 0; -} - -QTEST_MAIN(tst_ComplianceTest) - -#include "tst_compliance.moc" - diff --git a/tests/autobahn/websockets/tst_websockets.cpp b/tests/autobahn/websockets/tst_websockets.cpp deleted file mode 100644 index a0e6ec8..0000000 --- a/tests/autobahn/websockets/tst_websockets.cpp +++ /dev/null @@ -1,217 +0,0 @@ -/**************************************************************************** -** -** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies). -** Contact: http://www.qt-project.org/legal -** -** This file is part of the QtWebSockets module of the Qt Toolkit. -** -** $QT_BEGIN_LICENSE:LGPL$ -** Commercial License Usage -** Licensees holding valid commercial Qt licenses may use this file in -** accordance with the commercial license agreement provided with the -** Software or, alternatively, in accordance with the terms contained in -** a written agreement between you and Digia. For licensing terms and -** conditions see http://qt.digia.com/licensing. For further information -** use the contact form at http://qt.digia.com/contact-us. -** -** GNU Lesser General Public License Usage -** Alternatively, this file may be used under the terms of the GNU Lesser -** General Public License version 2.1 as published by the Free Software -** Foundation and appearing in the file LICENSE.LGPL included in the -** packaging of this file. Please review the following information to -** ensure the GNU Lesser General Public License version 2.1 requirements -** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. -** -** In addition, as a special exception, Digia gives you certain additional -** rights. These rights are described in the Digia Qt LGPL Exception -** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. -** -** GNU General Public License Usage -** Alternatively, this file may be used under the terms of the GNU -** General Public License version 3.0 as published by the Free Software -** Foundation and appearing in the file LICENSE.GPL included in the -** packaging of this file. Please review the following information to -** ensure the GNU General Public License version 3.0 requirements will be -** met: http://www.gnu.org/copyleft/gpl.html. -** -** -** $QT_END_LICENSE$ -** -****************************************************************************/ -#include -#include -#include -#include -#include -#include "qwebsocket.h" - -class tst_WebSocketsTest : public QObject -{ - Q_OBJECT - -public: - tst_WebSocketsTest(); - -private Q_SLOTS: - void initTestCase(); - void cleanupTestCase(); - void init(); - void cleanup(); - - /** - * @brief Test isValid() with an unoped socket - */ - void testInvalidWithUnopenedSocket(); - - /** - * @brief testTextMessage Tests sending and receiving a text message - */ - void testTextMessage(); - - void testBinaryMessage(); - - /** - * @brief Tests the method localAddress and localPort - */ - void testLocalAddress(); - - /** - * @brief Test the methods peerAddress, peerName and peerPort - */ - void testPeerAddress(); - - /** - * @brief Test the methods proxy() and setProxy() and check if it can be correctly set - */ - void testProxy(); - - /** - * @brief Runs the autobahn tests against our implementation - */ - //void autobahnTest(); - -private: - QWebSocket *m_pWebSocket; - QUrl m_url; -}; - -tst_WebSocketsTest::tst_WebSocketsTest() : - m_pWebSocket(0), - m_url("ws://localhost:9000") -{ -} - -void tst_WebSocketsTest::initTestCase() -{ - m_pWebSocket = new QWebSocket(); - /*m_pWebSocket->open(m_url, true); - QTRY_VERIFY_WITH_TIMEOUT(m_pWebSocket->state() == QAbstractSocket::ConnectedState, 1000); - QVERIFY(m_pWebSocket->isValid());*/ -} - -void tst_WebSocketsTest::cleanupTestCase() -{ - if (m_pWebSocket) - { - m_pWebSocket->close(); - //QVERIFY2(m_pWebSocket->waitForDisconnected(1000), "Disconnection failed."); - delete m_pWebSocket; - m_pWebSocket = 0; - } -} - -void tst_WebSocketsTest::init() -{ -} - -void tst_WebSocketsTest::cleanup() -{ -} - -void tst_WebSocketsTest::testTextMessage() -{ - const char *message = "Hello world!"; - - QSignalSpy spy(m_pWebSocket, SIGNAL(textMessageReceived(QString))); - - QCOMPARE(m_pWebSocket->write(message), (qint64)strlen(message)); - - QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); - QCOMPARE(spy.count(), 1); - QCOMPARE(spy.at(0).count(), 1); - QCOMPARE(spy.takeFirst().at(0).toString(), QString(message)); - - spy.clear(); - QString qMessage(message); - QCOMPARE(m_pWebSocket->write(qMessage), (qint64)qMessage.length()); - QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); - QCOMPARE(spy.count(), 1); - QCOMPARE(spy.at(0).count(), 1); - QCOMPARE(spy.takeFirst().at(0).toString(), qMessage); -} - -void tst_WebSocketsTest::testBinaryMessage() -{ - QSignalSpy spy(m_pWebSocket, SIGNAL(binaryMessageReceived(QByteArray))); - - QByteArray data("Hello world!"); - - QCOMPARE(m_pWebSocket->write(data), (qint64)data.size()); - - QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); - QCOMPARE(spy.count(), 1); - QCOMPARE(spy.at(0).count(), 1); - QCOMPARE(spy.takeFirst().at(0).toByteArray(), data); -} - -void tst_WebSocketsTest::testLocalAddress() -{ - QCOMPARE(m_pWebSocket->localAddress().toString(), QString("127.0.0.1")); - quint16 localPort = m_pWebSocket->localPort(); - QVERIFY2(localPort > 0, "Local port is invalid."); -} - -void tst_WebSocketsTest::testPeerAddress() -{ - QHostInfo hostInfo = QHostInfo::fromName(m_url.host()); - QList addresses = hostInfo.addresses(); - QVERIFY(addresses.length() > 0); - QHostAddress peer = m_pWebSocket->peerAddress(); - bool found = false; - Q_FOREACH(QHostAddress a, addresses) - { - if (a == peer) - { - found = true; - break; - } - } - - if (!found) - { - QFAIL("PeerAddress is not found as a result of a reverse lookup"); - } - QCOMPARE(m_pWebSocket->peerName(), m_url.host()); - QCOMPARE(m_pWebSocket->peerPort(), (quint16)m_url.port(80)); -} - -void tst_WebSocketsTest::testProxy() -{ - QNetworkProxy oldProxy = m_pWebSocket->proxy(); - QNetworkProxy proxy(QNetworkProxy::HttpProxy, QString("proxy.network.com"), 80); - m_pWebSocket->setProxy(proxy); - QCOMPARE(proxy, m_pWebSocket->proxy()); - m_pWebSocket->setProxy(oldProxy); - QCOMPARE(oldProxy, m_pWebSocket->proxy()); -} - -void tst_WebSocketsTest::testInvalidWithUnopenedSocket() -{ - QWebSocket qws; - QCOMPARE(qws.isValid(), false); -} - -QTEST_MAIN(tst_WebSocketsTest) - -#include "tst_websockets.moc" - diff --git a/tests/autobahn/websockets/websockets.pro b/tests/autobahn/websockets/websockets.pro deleted file mode 100644 index a8b2edb..0000000 --- a/tests/autobahn/websockets/websockets.pro +++ /dev/null @@ -1,14 +0,0 @@ -CONFIG += console -CONFIG += c++11 -CONFIG += testcase -CONFIG -= app_bundle - -TEMPLATE = app - -TARGET = tst_websockets - -QT = core network websockets testlib - -SOURCES += tst_websockets.cpp - -DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0 diff --git a/tests/manual/compliance/compliance.pro b/tests/manual/compliance/compliance.pro new file mode 100644 index 0000000..0fd32bc --- /dev/null +++ b/tests/manual/compliance/compliance.pro @@ -0,0 +1,14 @@ +CONFIG += console +CONFIG += c++11 +CONFIG += testcase +CONFIG -= app_bundle + +TEMPLATE = app + +TARGET = tst_compliance + +QT = core network websockets testlib + +SOURCES += tst_compliance.cpp + +DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0 diff --git a/tests/manual/compliance/tst_compliance.cpp b/tests/manual/compliance/tst_compliance.cpp new file mode 100644 index 0000000..0140dcf --- /dev/null +++ b/tests/manual/compliance/tst_compliance.cpp @@ -0,0 +1,169 @@ +/**************************************************************************** +** +** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies). +** Contact: http://www.qt-project.org/legal +** +** This file is part of the QtWebSockets module of the Qt Toolkit. +** +** $QT_BEGIN_LICENSE:LGPL$ +** Commercial License Usage +** Licensees holding valid commercial Qt licenses may use this file in +** accordance with the commercial license agreement provided with the +** Software or, alternatively, in accordance with the terms contained in +** a written agreement between you and Digia. For licensing terms and +** conditions see http://qt.digia.com/licensing. For further information +** use the contact form at http://qt.digia.com/contact-us. +** +** GNU Lesser General Public License Usage +** Alternatively, this file may be used under the terms of the GNU Lesser +** General Public License version 2.1 as published by the Free Software +** Foundation and appearing in the file LICENSE.LGPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU Lesser General Public License version 2.1 requirements +** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Digia gives you certain additional +** rights. These rights are described in the Digia Qt LGPL Exception +** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU +** General Public License version 3.0 as published by the Free Software +** Foundation and appearing in the file LICENSE.GPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU General Public License version 3.0 requirements will be +** met: http://www.gnu.org/copyleft/gpl.html. +** +** +** $QT_END_LICENSE$ +** +****************************************************************************/ +#include +#include +#include +#include +#include +#include +#include + +class tst_ComplianceTest : public QObject +{ + Q_OBJECT + +public: + tst_ComplianceTest(); + +private Q_SLOTS: + void initTestCase(); + void cleanupTestCase(); + void init(); + void cleanup(); + /** + * @brief Runs the autobahn tests against our implementation + */ + void autobahnTest(); + +private: + QUrl m_url; + + void runTestCases(int startNbr, int stopNbr = -1); + void runTestCase(int nbr, int total); +}; + +tst_ComplianceTest::tst_ComplianceTest() : + m_url("wss://localhost:9001") +{ +} + +void tst_ComplianceTest::initTestCase() +{ +} + +void tst_ComplianceTest::cleanupTestCase() +{ +} + +void tst_ComplianceTest::init() +{ +} + +void tst_ComplianceTest::cleanup() +{ +} + +void tst_ComplianceTest::runTestCase(int nbr, int total) +{ + if (nbr == total) + { + return; + } + + QWebSocket *pWebSocket = new QWebSocket; + pWebSocket->ignoreSslErrors(); + QSignalSpy spy(pWebSocket, SIGNAL(disconnected())); + + //next for every case, connect to url + //ws://ipaddress:port/runCase?case=&agent= + //where agent name will be QWebSocket + QObject::connect(pWebSocket, &QWebSocket::textMessageReceived, [=](QString message) { + pWebSocket->write(message); + }); + QObject::connect(pWebSocket, &QWebSocket::binaryMessageReceived, [=](QByteArray message) { + pWebSocket->write(message); + }); + + qDebug() << "Executing test" << (nbr + 1) << "/" << total; + QUrl url = m_url; + url.setPath("/runCase?"); + QUrlQuery query; + query.addQueryItem("case", QString::number(nbr + 1)); + query.addQueryItem("agent", "QWebSockets/0.9"); + url.setQuery(query); + pWebSocket->open(url); + spy.wait(60000); + pWebSocket->close(); + delete pWebSocket; + pWebSocket = 0; + runTestCase(nbr + 1, total); +} + +void tst_ComplianceTest::runTestCases(int startNbr, int stopNbr) +{ + runTestCase(startNbr, stopNbr); +} + +void tst_ComplianceTest::autobahnTest() +{ + //connect to autobahn server at url ws://ipaddress:port/getCaseCount + QWebSocket *pWebSocket = new QWebSocket; + pWebSocket->ignoreSslErrors(); + QUrl url = m_url; + int numberOfTestCases = 0; + QSignalSpy spy(pWebSocket, SIGNAL(disconnected())); + QObject::connect(pWebSocket, &QWebSocket::textMessageReceived, [&](QString message) { + numberOfTestCases = message.toInt(); + }); + + url.setPath("/getCaseCount"); + pWebSocket->open(url); + spy.wait(60000); + QVERIFY(numberOfTestCases > 0); + + QObject::disconnect(pWebSocket, &QWebSocket::textMessageReceived, 0, 0); + + runTestCases(0, numberOfTestCases); + + url.setPath("/updateReports?"); + QUrlQuery query; + query.addQueryItem("agent", "QWebSockets"); + url.setQuery(query); + pWebSocket->open(url); + spy.wait(60000); + delete pWebSocket; + pWebSocket = 0; +} + +QTEST_MAIN(tst_ComplianceTest) + +#include "tst_compliance.moc" + diff --git a/tests/manual/manual.pro b/tests/manual/manual.pro new file mode 100644 index 0000000..28961c4 --- /dev/null +++ b/tests/manual/manual.pro @@ -0,0 +1,8 @@ +TEMPLATE = subdirs + +SUBDIRS += \ + compliance \ + websockets + + + diff --git a/tests/manual/websockets/tst_websockets.cpp b/tests/manual/websockets/tst_websockets.cpp new file mode 100644 index 0000000..a0e6ec8 --- /dev/null +++ b/tests/manual/websockets/tst_websockets.cpp @@ -0,0 +1,217 @@ +/**************************************************************************** +** +** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies). +** Contact: http://www.qt-project.org/legal +** +** This file is part of the QtWebSockets module of the Qt Toolkit. +** +** $QT_BEGIN_LICENSE:LGPL$ +** Commercial License Usage +** Licensees holding valid commercial Qt licenses may use this file in +** accordance with the commercial license agreement provided with the +** Software or, alternatively, in accordance with the terms contained in +** a written agreement between you and Digia. For licensing terms and +** conditions see http://qt.digia.com/licensing. For further information +** use the contact form at http://qt.digia.com/contact-us. +** +** GNU Lesser General Public License Usage +** Alternatively, this file may be used under the terms of the GNU Lesser +** General Public License version 2.1 as published by the Free Software +** Foundation and appearing in the file LICENSE.LGPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU Lesser General Public License version 2.1 requirements +** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Digia gives you certain additional +** rights. These rights are described in the Digia Qt LGPL Exception +** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU +** General Public License version 3.0 as published by the Free Software +** Foundation and appearing in the file LICENSE.GPL included in the +** packaging of this file. Please review the following information to +** ensure the GNU General Public License version 3.0 requirements will be +** met: http://www.gnu.org/copyleft/gpl.html. +** +** +** $QT_END_LICENSE$ +** +****************************************************************************/ +#include +#include +#include +#include +#include +#include "qwebsocket.h" + +class tst_WebSocketsTest : public QObject +{ + Q_OBJECT + +public: + tst_WebSocketsTest(); + +private Q_SLOTS: + void initTestCase(); + void cleanupTestCase(); + void init(); + void cleanup(); + + /** + * @brief Test isValid() with an unoped socket + */ + void testInvalidWithUnopenedSocket(); + + /** + * @brief testTextMessage Tests sending and receiving a text message + */ + void testTextMessage(); + + void testBinaryMessage(); + + /** + * @brief Tests the method localAddress and localPort + */ + void testLocalAddress(); + + /** + * @brief Test the methods peerAddress, peerName and peerPort + */ + void testPeerAddress(); + + /** + * @brief Test the methods proxy() and setProxy() and check if it can be correctly set + */ + void testProxy(); + + /** + * @brief Runs the autobahn tests against our implementation + */ + //void autobahnTest(); + +private: + QWebSocket *m_pWebSocket; + QUrl m_url; +}; + +tst_WebSocketsTest::tst_WebSocketsTest() : + m_pWebSocket(0), + m_url("ws://localhost:9000") +{ +} + +void tst_WebSocketsTest::initTestCase() +{ + m_pWebSocket = new QWebSocket(); + /*m_pWebSocket->open(m_url, true); + QTRY_VERIFY_WITH_TIMEOUT(m_pWebSocket->state() == QAbstractSocket::ConnectedState, 1000); + QVERIFY(m_pWebSocket->isValid());*/ +} + +void tst_WebSocketsTest::cleanupTestCase() +{ + if (m_pWebSocket) + { + m_pWebSocket->close(); + //QVERIFY2(m_pWebSocket->waitForDisconnected(1000), "Disconnection failed."); + delete m_pWebSocket; + m_pWebSocket = 0; + } +} + +void tst_WebSocketsTest::init() +{ +} + +void tst_WebSocketsTest::cleanup() +{ +} + +void tst_WebSocketsTest::testTextMessage() +{ + const char *message = "Hello world!"; + + QSignalSpy spy(m_pWebSocket, SIGNAL(textMessageReceived(QString))); + + QCOMPARE(m_pWebSocket->write(message), (qint64)strlen(message)); + + QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); + QCOMPARE(spy.count(), 1); + QCOMPARE(spy.at(0).count(), 1); + QCOMPARE(spy.takeFirst().at(0).toString(), QString(message)); + + spy.clear(); + QString qMessage(message); + QCOMPARE(m_pWebSocket->write(qMessage), (qint64)qMessage.length()); + QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); + QCOMPARE(spy.count(), 1); + QCOMPARE(spy.at(0).count(), 1); + QCOMPARE(spy.takeFirst().at(0).toString(), qMessage); +} + +void tst_WebSocketsTest::testBinaryMessage() +{ + QSignalSpy spy(m_pWebSocket, SIGNAL(binaryMessageReceived(QByteArray))); + + QByteArray data("Hello world!"); + + QCOMPARE(m_pWebSocket->write(data), (qint64)data.size()); + + QTRY_VERIFY_WITH_TIMEOUT(spy.count() != 0, 1000); + QCOMPARE(spy.count(), 1); + QCOMPARE(spy.at(0).count(), 1); + QCOMPARE(spy.takeFirst().at(0).toByteArray(), data); +} + +void tst_WebSocketsTest::testLocalAddress() +{ + QCOMPARE(m_pWebSocket->localAddress().toString(), QString("127.0.0.1")); + quint16 localPort = m_pWebSocket->localPort(); + QVERIFY2(localPort > 0, "Local port is invalid."); +} + +void tst_WebSocketsTest::testPeerAddress() +{ + QHostInfo hostInfo = QHostInfo::fromName(m_url.host()); + QList addresses = hostInfo.addresses(); + QVERIFY(addresses.length() > 0); + QHostAddress peer = m_pWebSocket->peerAddress(); + bool found = false; + Q_FOREACH(QHostAddress a, addresses) + { + if (a == peer) + { + found = true; + break; + } + } + + if (!found) + { + QFAIL("PeerAddress is not found as a result of a reverse lookup"); + } + QCOMPARE(m_pWebSocket->peerName(), m_url.host()); + QCOMPARE(m_pWebSocket->peerPort(), (quint16)m_url.port(80)); +} + +void tst_WebSocketsTest::testProxy() +{ + QNetworkProxy oldProxy = m_pWebSocket->proxy(); + QNetworkProxy proxy(QNetworkProxy::HttpProxy, QString("proxy.network.com"), 80); + m_pWebSocket->setProxy(proxy); + QCOMPARE(proxy, m_pWebSocket->proxy()); + m_pWebSocket->setProxy(oldProxy); + QCOMPARE(oldProxy, m_pWebSocket->proxy()); +} + +void tst_WebSocketsTest::testInvalidWithUnopenedSocket() +{ + QWebSocket qws; + QCOMPARE(qws.isValid(), false); +} + +QTEST_MAIN(tst_WebSocketsTest) + +#include "tst_websockets.moc" + diff --git a/tests/manual/websockets/websockets.pro b/tests/manual/websockets/websockets.pro new file mode 100644 index 0000000..a8b2edb --- /dev/null +++ b/tests/manual/websockets/websockets.pro @@ -0,0 +1,14 @@ +CONFIG += console +CONFIG += c++11 +CONFIG += testcase +CONFIG -= app_bundle + +TEMPLATE = app + +TARGET = tst_websockets + +QT = core network websockets testlib + +SOURCES += tst_websockets.cpp + +DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0 -- cgit v1.2.1