-/*
-QWebSockets implements the WebSocket protocol as defined in RFC 6455.
-Copyright (C) 2013 Kurt Pattyn (pattyn.kurt@gmail.com)
-
-This library is free software; you can redistribute it and/or
-modify it under the terms of the GNU Lesser General Public
-License as published by the Free Software Foundation; either
-version 2.1 of the License, or (at your option) any later version.
-
-This library 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 library; if not, write to the Free Software
-Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
-*/
+/****************************************************************************
+**
+** Copyright (C) 2014 Kurt Pattyn <pattyn.kurt@gmail.com>.
+** 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$
+**
+****************************************************************************/
/*!
\class QWebSocket
\inmodule QtWebSockets
\brief Implements a TCP socket that talks the websocket protocol.
- WebSockets is a web technology providing full-duplex communications channels over a single TCP connection.
- The WebSocket protocol was standardized by the IETF as RFC 6455 in 2011 (see http://tools.ietf.org/html/rfc6455).
- It can both be used in a client application and server application.
+ WebSockets is a web technology providing full-duplex communications channels over
+ a single TCP connection.
+ The WebSocket protocol was standardized by the IETF as
+ \l {http://tools.ietf.org/html/rfc6455} {RFC 6455} in 2011.
+ QWebSocket can both be used in a client application and server application.
This class was modeled after QAbstractSocket.
+ QWebSocket currently does not support
+ \l {http://tools.ietf.org/html/rfc6455#page-39} {extensions} and
+ \l {http://tools.ietf.org/html/rfc6455#page-12} {subprotocols}.
+
+ QWebSocket only supports version 13 of the WebSocket protocol, as outlined in
+ \l {http://tools.ietf.org/html/rfc6455}{RFC 6455}.
+
+ \note Some proxies do not understand certain HTTP headers used during a web socket handshake.
+ In that case, non-secure web socket connections fail. The best way to mitigate against
+ this problem is to use web sockets over a secure connection.
+
+ \warning To generate masks, this implementation of WebSockets uses the cryptographically
+ insecure qrand() function.
+ For more information about the importance of good masking,
+ see \l {http://w2spconf.com/2011/papers/websocket.pdf}.
+ The best measure against attacks mentioned in the document above,
+ is to use QWebSocket over a secure connection (\e wss://).
+ In general, always be careful to not have 3rd party script access to
+ a QWebSocket in your application.
+
\sa QAbstractSocket, QTcpSocket
- \sa echoclient.html
+ \sa {QWebSocket client example}
*/
/*!
\page echoclient.html example
\title QWebSocket client example
- \brief A sample websocket client that sends a message and displays the message that it receives back.
+ \brief A sample websocket client that sends a message and displays the message that
+ it receives back.
\section1 Description
- The EchoClient example implements a web socket client that sends a message to a websocket server and dumps the answer that it gets back.
+ The EchoClient example implements a web socket client that sends a message to a websocket server
+ and dumps the answer that it gets back.
This example should ideally be used with the EchoServer example.
\section1 Code
We start by connecting to the `connected()` signal.
- \snippet echoclient.cpp constructor
+ \snippet echoclient/echoclient.cpp constructor
After the connection, we open the socket to the given \a url.
- \snippet echoclient.cpp onConnected
- When the client is connected successfully, we connect to the `onTextMessageReceived()` signal, and send out "Hello, world!".
+ \snippet echoclient/echoclient.cpp onConnected
+ When the client is connected successfully, we connect to the `onTextMessageReceived()` signal,
+ and send out "Hello, world!".
If connected with the EchoServer, we will receive the same message back.
- \snippet echoclient.cpp onTextMessageReceived
+ \snippet echoclient/echoclient.cpp onTextMessageReceived
Whenever a message is received, we write it out.
*/
/*!
\fn void QWebSocket::connected()
\brief Emitted when a connection is successfully established.
+ A connection is successfully established when the socket is connected
+ and the handshake was successful.
\sa open(), disconnected()
*/
/*!
This signal is emitted whenever QWebSocket's state changes.
The \a state parameter is the new state.
+ \note QAbstractSocket::ConnectedState is emitted after the handshake
+ with the server has succeeded.
+
QAbstractSocket::SocketState is not a registered metatype, so for queued
connections, you will have to register it with Q_REGISTER_METATYPE() and
qRegisterMetaType().
/*!
\fn void QWebSocket::readChannelFinished()
- This signal is emitted when the input (reading) stream is closed in this device. It is emitted as soon as the closing is detected.
+ This signal is emitted when the input (reading) stream is closed in this device.
+ It is emitted as soon as the closing is detected.
\sa close()
*/
The \a bytes argument is set to the number of bytes that were written in this payload.
\note This signal has the same meaning both for secure and non-secure websockets.
- As opposed to QSslSocket, bytesWritten() is only emitted when encrypted data is effectively written (\sa QSslSocket:encryptedBytesWritten()).
+ As opposed to QSslSocket, bytesWritten() is only emitted when encrypted data is effectively
+ written (see QSslSocket::encryptedBytesWritten()).
\sa close()
*/
/*!
- \fn void QWebSocket::textFrameReceived(QString frame, bool isLastFrame);
+ \fn void QWebSocket::textFrameReceived(const QString &frame, bool isLastFrame);
This signal is emitted whenever a text frame is received. The \a frame contains the data and
\a isLastFrame indicates whether this is the last frame of the complete message.
- This signal can be used to process large messages frame by frame, instead of waiting for the complete
- message to arrive.
+ This signal can be used to process large messages frame by frame, instead of waiting for the
+ complete message to arrive.
\sa binaryFrameReceived()
*/
/*!
- \fn void QWebSocket::binaryFrameReceived(QByteArray frame, bool isLastFrame);
+ \fn void QWebSocket::binaryFrameReceived(const QByteArray &frame, bool isLastFrame);
This signal is emitted whenever a binary frame is received. The \a frame contains the data and
\a isLastFrame indicates whether this is the last frame of the complete message.
- This signal can be used to process large messages frame by frame, instead of waiting for the complete
- message to arrive.
+ This signal can be used to process large messages frame by frame, instead of waiting for the
+ complete message to arrive.
\sa textFrameReceived()
*/
/*!
- \fn void QWebSocket::textMessageReceived(QString message);
+ \fn void QWebSocket::textMessageReceived(const QString &message);
- This signal is emitted whenever a text message is received. The \a message contains the received text.
+ This signal is emitted whenever a text message is received. The \a message contains the
+ received text.
\sa binaryMessageReceived()
*/
/*!
- \fn void QWebSocket::binaryMessageReceived(QByteArray message);
+ \fn void QWebSocket::binaryMessageReceived(const QByteArray &message);
- This signal is emitted whenever a binary message is received. The \a message contains the received bytes.
+ This signal is emitted whenever a binary message is received. The \a message contains the
+ received bytes.
\sa textMessageReceived()
*/
\sa error(), errorString()
*/
/*!
- \fn void QWebSocket::pong(quint64 elapsedTime, QByteArray payload)
+ \fn void QWebSocket::sslErrors(const QList<QSslError> &errors)
+ QWebSocket emits this signal after the SSL handshake to indicate that one or more errors have
+ occurred while establishing the identity of the peer.
+ The errors are usually an indication that QWebSocket is unable to securely identify the peer.
+ Unless any action is taken, the connection will be dropped after this signal has been emitted.
+ If you want to continue connecting despite the errors that have occurred, you must call
+ QWebSocket::ignoreSslErrors() from inside a slot connected to this signal.
+ If you need to access the error list at a later point, you can call sslErrors()
+ (without arguments).
+
+ \a errors contains one or more errors that prevent QWebSocket from verifying the identity of
+ the peer.
+
+ \note You cannot use Qt::QueuedConnection when connecting to this signal, or calling
+ QWebSocket::ignoreSslErrors() will have no effect.
+*/
+/*!
+ \fn void QWebSocket::pong(quint64 elapsedTime, const QByteArray &payload)
Emitted when a pong message is received in reply to a previous ping.
- \a elapsedTime contains the roundtrip time in milliseconds and \a payload contains an optional payload that was sent with the ping.
+ \a elapsedTime contains the roundtrip time in milliseconds and \a payload contains an optional
+ payload that was sent with the ping.
\sa ping()
*/
#include "qwebsocket.h"
#include "qwebsocket_p.h"
-#include <QUrl>
-#include <QTcpSocket>
-#include <QByteArray>
-#include <QHostAddress>
-#include <QDebug>
+#include <QtCore/QUrl>
+#include <QtNetwork/QTcpSocket>
+#include <QtCore/QByteArray>
+#include <QtNetwork/QHostAddress>
+
+#include <QtCore/QDebug>
#include <limits>
QT_BEGIN_NAMESPACE
/*!
- * \brief Creates a new QWebSocket with the given \a origin, the \a version of the protocol to use and \a parent.
+ * \brief Creates a new QWebSocket with the given \a origin,
+ * the \a version of the protocol to use and \a parent.
*
- * The \a origin of the client is as specified in http://tools.ietf.org/html/rfc6454.
- * (The \a origin is not required for non-web browser clients (see RFC 6455)).
- * \note Currently only V13 (RFC 6455) is supported
- */
-QWebSocket::QWebSocket(const QString &origin, QWebSocketProtocol::Version version, QObject *parent) :
- QObject(parent),
- d_ptr(new QWebSocketPrivate(origin, version, this, this))
+ * The \a origin of the client is as specified in \l {http://tools.ietf.org/html/rfc6454}{RFC 6454}.
+ * (The \a origin is not required for non-web browser clients
+ * (see \l {http://tools.ietf.org/html/rfc6455}{RFC 6455})).
+ * The \a origin may not contain new line characters, otherwise the connection will be
+ * aborted immediately during the handshake phase.
+ * \note Currently only V13 (\l {http://tools.ietf.org/html/rfc6455} {RFC 6455}) is supported
+ */
+QWebSocket::QWebSocket(const QString &origin,
+ QWebSocketProtocol::Version version,
+ QObject *parent) :
+ QObject(*(new QWebSocketPrivate(origin, version, this)), parent)
{
+ Q_D(QWebSocket);
+ d->init();
}
/*!
- * \brief Destroys the QWebSocket. Closes the socket if it is still open, and releases any used resources.
+ * \brief Destroys the QWebSocket. Closes the socket if it is still open,
+ * and releases any used resources.
*/
QWebSocket::~QWebSocket()
{
- delete d_ptr;
}
/*!
- * \brief Aborts the current socket and resets the socket. Unlike close(), this function immediately closes the socket, discarding any pending data in the write buffer.
+ * \brief Aborts the current socket and resets the socket.
+ * Unlike close(), this function immediately closes the socket,
+ * discarding any pending data in the write buffer.
*/
void QWebSocket::abort()
{
/*!
\internal
*/
-QWebSocket::QWebSocket(QTcpSocket *pTcpSocket, QWebSocketProtocol::Version version, QObject *parent) :
- QObject(parent),
- d_ptr(new QWebSocketPrivate(pTcpSocket, version, this, this))
+QWebSocket::QWebSocket(QTcpSocket *pTcpSocket,
+ QWebSocketProtocol::Version version, QObject *parent) :
+ QObject(*(new QWebSocketPrivate(pTcpSocket, version, this)), parent)
{
+ Q_D(QWebSocket);
+ d->init();
}
/*!
}
/*!
- This function writes as much as possible from the internal write buffer to the underlying network socket, without blocking.
+ This function writes as much as possible from the internal write buffer
+ to the underlying network socket, without blocking.
If any data was written, this function returns true; otherwise false is returned.
Call this function if you need QWebSocket to start sending buffered data immediately.
The number of bytes successfully written depends on the operating system.
- In most cases, you do not need to call this function, because QWebSocket will start sending data automatically once control goes back to the event loop.
- In the absence of an event loop, call waitForBytesWritten() instead.
+ In most cases, you do not need to call this function,
+ because QWebSocket will start sending data automatically
+ once control goes back to the event loop.
*/
bool QWebSocket::flush()
{
}
/*!
- Sends the given \a message over the socket as a text message and returns the number of bytes actually sent.
- \a message must be '\\0' terminated.
- */
-qint64 QWebSocket::write(const char *message)
-{
- Q_D(QWebSocket);
- return d->write(message);
-}
+ \brief Sends the given \a message over the socket as a text message and
+ returns the number of bytes actually sent.
-/*!
- Sends the most \a maxSize bytes of the given \a message over the socket as a text message and returns the number of bytes actually sent.
+ \sa sendBinaryMessage()
*/
-qint64 QWebSocket::write(const char *message, qint64 maxSize)
+qint64 QWebSocket::sendTextMessage(const QString &message)
{
Q_D(QWebSocket);
- return d->write(message, maxSize);
+ return d->sendTextMessage(message);
}
/*!
- \brief Sends the given \a message over the socket as a text message and returns the number of bytes actually sent.
- */
-qint64 QWebSocket::write(const QString &message)
-{
- Q_D(QWebSocket);
- return d->write(message);
-}
+ \brief Sends the given \a data over the socket as a binary message and
+ returns the number of bytes actually sent.
-/*!
- \brief Sends the given \a data over the socket as a binary message and returns the number of bytes actually sent.
+ \sa sendTextMessage()
*/
-qint64 QWebSocket::write(const QByteArray &data)
+qint64 QWebSocket::sendBinaryMessage(const QByteArray &data)
{
Q_D(QWebSocket);
- return d->write(data);
+ return d->sendBinaryMessage(data);
}
/*!
- \brief Gracefully closes the socket with the given \a closeCode and \a reason. Any data in the write buffer is flushed before the socket is closed.
+ \brief Gracefully closes the socket with the given \a closeCode and \a reason.
+
+ Any data in the write buffer is flushed before the socket is closed.
The \a closeCode is a QWebSocketProtocol::CloseCode indicating the reason to close, and
\a reason describes the reason of the closure more in detail
*/
/*!
\brief Opens a websocket connection using the given \a url.
- If \a mask is true, all frames will be masked; this is only necessary for client side sockets; servers should never mask
- \note A client socket must *always* mask its frames; servers may *never* mask its frames
+
+ If the url contains newline characters (\\r\\n), then the error signal will be emitted
+ with QAbstractSocket::ConnectionRefusedError as error type.
*/
-void QWebSocket::open(const QUrl &url, bool mask)
+void QWebSocket::open(const QUrl &url)
{
Q_D(QWebSocket);
- d->open(url, mask);
+ d->open(url, true);
}
/*!
\brief Pings the server to indicate that the connection is still alive.
Additional \a payload can be sent along the ping message.
- The size of the \a payload cannot be bigger than 125. If it is larger, the \a payload is clipped to 125 bytes.
+ The size of the \a payload cannot be bigger than 125.
+ If it is larger, the \a payload is clipped to 125 bytes.
\sa pong()
*/
void QWebSocket::ping(const QByteArray &payload)
{
Q_D(QWebSocket);
- if (payload.length() > 125)
- {
- payload.left(125);
- }
d->ping(payload);
}
If, for instance, you want to connect to a server that uses
a self-signed certificate, consider the following snippet:
- \snippet src_websockets_ssl_qwebsocket 6
+ \snippet src_websockets_ssl_qwebsocket.cpp 6
Multiple calls to this function will replace the list of errors that
were passed in previous calls.
d->ignoreSslErrors(errors);
}
+/*!
+ Sets the socket's SSL configuration to be the contents of \a sslConfiguration.
+
+ This function sets the local certificate, the ciphers, the private key and
+ the CA certificates to those stored in \a sslConfiguration.
+ It is not possible to set the SSL-state related fields.
+ \sa sslConfiguration()
+ */
+void QWebSocket::setSslConfiguration(const QSslConfiguration &sslConfiguration)
+{
+ Q_D(QWebSocket);
+ d->setSslConfiguration(sslConfiguration);
+}
+
+/*!
+ Returns the socket's SSL configuration state.
+ The default SSL configuration of a socket is to use the default ciphers,
+ default CA certificates, no local private key or certificate.
+ The SSL configuration also contains fields that can change with time without notice.
+
+ \sa setSslConfiguration()
+ */
+QSslConfiguration QWebSocket::sslConfiguration() const
+{
+ Q_D(const QWebSocket);
+ return d->sslConfiguration();
+}
+
#endif //not QT_NO_SSL
/*!
- \brief Returns the version the socket is currently using
+ \brief Returns the version the socket is currently using.
*/
QWebSocketProtocol::Version QWebSocket::version() const
{
}
/*!
- \brief Returns the current origin
+ \brief Returns the current origin.
*/
QString QWebSocket::origin() const
{
}
/*!
- \brief Returns the currently used protocol.
+ \brief Returns the code indicating why the socket was closed.
+ \sa QWebSocketProtocol::CloseCode, closeReason()
*/
-QString QWebSocket::protocol() const
+QWebSocketProtocol::CloseCode QWebSocket::closeCode() const
{
Q_D(const QWebSocket);
- return d->protocol();
+ return d->closeCode();
}
/*!
- \brief Returns the currently used extension.
+ \brief Returns the reason why the socket was closed.
+ \sa closeCode()
*/
-QString QWebSocket::extension() const
+QString QWebSocket::closeReason() const
{
Q_D(const QWebSocket);
- return d->extension();
+ return d->closeReason();
}
/*!
- \brief Returns the current state of the socket
+ \brief Returns the current state of the socket.
*/
QAbstractSocket::SocketState QWebSocket::state() const
{
}
/*!
- \brief Waits until the socket is connected, up to \a msecs milliseconds. If the connection has been established, this function returns true; otherwise it returns false. In the case where it returns false, you can call error() to determine the cause of the error.
- The following example waits up to one second for a connection to be established:
-
- ~~~{.cpp}
- socket->open("ws://localhost:1234", false);
- if (socket->waitForConnected(1000))
- {
- qDebug("Connected!");
- }
- ~~~
-
- If \a msecs is -1, this function will not time out.
- @note This function may wait slightly longer than msecs, depending on the time it takes to complete the host lookup.
- @note Multiple calls to this functions do not accumulate the time. If the function times out, the connecting process will be aborted.
-
- \sa connected(), open(), state()
- */
-bool QWebSocket::waitForConnected(int msecs)
-{
- Q_D(QWebSocket);
- return d->waitForConnected(msecs);
-}
-
-/*!
- Waits \a msecs for the socket to be disconnected.
- If the socket was successfully disconnected within time, this method returns true.
- Otherwise false is returned.
- When \a msecs is -1, this function will block until the socket is disconnected.
-
- \sa close(), state()
-*/
-bool QWebSocket::waitForDisconnected(int msecs)
-{
- Q_D(QWebSocket);
- return d->waitForDisconnected(msecs);
-}
-
-/*!
Returns the local address
*/
QHostAddress QWebSocket::localAddress() const
#endif
/*!
+ Sets the generator to use for creating masks to \a maskGenerator.
+ The default QWebSocket generator can be reset by supplying a \e Q_NULLPTR.
+ The mask generator can be changed at any time, even while the connection is open.
+ */
+void QWebSocket::setMaskGenerator(const QMaskGenerator *maskGenerator)
+{
+ Q_D(QWebSocket);
+ d->setMaskGenerator(maskGenerator);
+}
+
+/*!
+ Returns the mask generator that is currently used by this QWebSocket.
+ */
+const QMaskGenerator *QWebSocket::maskGenerator() const
+{
+ Q_D(const QWebSocket);
+ return d->maskGenerator();
+}
+
+/*!
Returns the size in bytes of the readbuffer that is used by the socket.
*/
qint64 QWebSocket::readBufferSize() const
/*!
Controls whether to pause upon receiving a notification. The \a pauseMode parameter specifies
the conditions in which the socket should be paused.
+
The only notification currently supported is sslErrors().
If set to PauseOnSslErrors, data transfer on the socket will be paused
and needs to be enabled explicitly again by calling resume().
/*!
Sets the size of QWebSocket's internal read buffer to be \a size bytes.
- If the buffer size is limited to a certain size, QWebSocket won't buffer more than this size of data.
- Exceptionally, a buffer size of 0 means that the read buffer is unlimited and all incoming data is buffered. This is the default.
- This option is useful if you only read the data at certain points in time (e.g., in a real-time streaming application) or if you want to protect your socket against receiving too much data, which may eventually cause your application to run out of memory.
+
+ If the buffer size is limited to a certain size, QWebSocket won't buffer more than
+ this size of data.
+ Exceptionally, a buffer size of 0 means that the read buffer is unlimited and
+ all incoming data is buffered. This is the default.
+ This option is useful if you only read the data at certain points in time
+ (for example, in a real-time streaming application) or if you want to protect your socket against
+ receiving too much data, which may eventually cause your application to run out of memory.
+
\sa readBufferSize()
*/
void QWebSocket::setReadBufferSize(qint64 size)
}
/*!
- Sets the given \a option to the value described by \a value.
- \sa socketOption()
-*/
-void QWebSocket::setSocketOption(QAbstractSocket::SocketOption option, const QVariant &value)
-{
- Q_D(QWebSocket);
- d->setSocketOption(option, value);
-}
-
-/*!
- Returns the value of the option \a option.
- \sa setSocketOption()
-*/
-QVariant QWebSocket::socketOption(QAbstractSocket::SocketOption option)
-{
- Q_D(QWebSocket);
- return d->socketOption(option);
-}
-
-/*!
- Returns true if the QWebSocket is valid.
+ Returns \c true if the socket is ready for reading and writing; otherwise
+ returns \c false.
*/
bool QWebSocket::isValid() const
{
projects / contrib / qtwebsockets.git / blobdiff