tomahawk/thirdparty/qxt/qxtweb-standalone/web/qxthttpserverconnector.cpp

/****************************************************************************
** Copyright (c) 2006 - 2011, the LibQxt project.
** See the Qxt AUTHORS file for a list of authors and copyright holders.
** All rights reserved.
**
** Redistribution and use in source and binary forms, with or without
** modification, are permitted provided that the following conditions are met:
**     * Redistributions of source code must retain the above copyright
**       notice, this list of conditions and the following disclaimer.
**     * Redistributions in binary form must reproduce the above copyright
**       notice, this list of conditions and the following disclaimer in the
**       documentation and/or other materials provided with the distribution.
**     * Neither the name of the LibQxt project nor the
**       names of its contributors may be used to endorse or promote products
**       derived from this software without specific prior written permission.
**
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
** ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
** WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
** DISCLAIMED. IN NO EVENT SHALL <COPYRIGHT HOLDER> BE LIABLE FOR ANY
** DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
** (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
** LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
** ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
** SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
**
** <http://libqxt.org>  <foundation@libqxt.org>
*****************************************************************************/

/*!
\class QxtHttpServerConnector

\inmodule QxtWeb

\brief The QxtHttpServerConnector class provides a built-in HTTP server for QxtHttpSessionManager

QxtHttpSessionManager does the work of managing sessions and state for the
otherwise stateless HTTP protocol, but it relies on QxtAbstractHttpConnector
subclasses to implement the protocol used to communicate with the web server.

QxtHttpServerConnector implements a complete HTTP server internally and does
not require an external web server to function. However, it provides very
little control over the behavior of the web server and may not suitable for
high traffic scenarios or virtual hosting configurations.

\sa QxtHttpSessionManager
*/

/*!
\class QxtHttpsServerConnector

\inmodule QxtWeb

\brief The QxtHttpsServerConnector class provides a built-in HTTPS server for QxtHttpSessionManager

QxtHttpSessionManager does the work of managing sessions and state for the
otherwise stateless HTTP protocol, but it relies on QxtAbstractHttpConnector
subclasses to implement the protocol used to communicate with the web server.

QxtHttpsServerConnector is a convenience subclass of QxtHttpServerConnector
that adds HTTPS handling to the internal web server by delegating the
incoming connection handling to QxtSslServer.

QxtHttpsServerConnector is only available if Qt was compiled with OpenSSL support.

\sa QxtHttpSessionManager
\sa QxtHttpServerConnector
\sa QxtSslServer
*/

#include "qxthttpsessionmanager.h"
#include "qxtwebevent.h"
#include "qxtsslserver.h"
#include <QTcpServer>
#include <QHash>
#include <QTcpSocket>
#include <QString>

#ifndef QXT_DOXYGEN_RUN
class QxtHttpServerConnectorPrivate : public QxtPrivate<QxtHttpServerConnector>
{
public:
    QTcpServer* server;
};
#endif

/*!
 * Creates a QxtHttpServerConnector with the given \a parent and \a server.
 *
 * You may pass a QTcpServer subclass to the \a server parameter to enable customized behaviors, for
 * instance to use QSslSocket like QxtHttpsServerConnector does. Pass 0 (the default) to \a server
 * to allow QxtHttpServerConnector to create its own QTcpServer.
 */
QxtHttpServerConnector::QxtHttpServerConnector(QObject* parent, QTcpServer* server) : QxtAbstractHttpConnector(parent)
{
    QXT_INIT_PRIVATE(QxtHttpServerConnector);
    if(server)
        qxt_d().server = server;
    else
        qxt_d().server = new QTcpServer(this);
    QObject::connect(qxt_d().server, SIGNAL(newConnection()), this, SLOT(acceptConnection()));
}

/*!
 * \reimp
 */
bool QxtHttpServerConnector::listen(const QHostAddress& iface, quint16 port)
{
    return qxt_d().server->listen(iface, port);
}

/*!
 * \reimp
 */
bool QxtHttpServerConnector::shutdown()
{
    if(qxt_d().server->isListening()){
	qxt_d().server->close();
	return true;
    }
    return false;
}

/*!
 * \reimp
 */
quint16 QxtHttpServerConnector::serverPort() const
{
    return qxt_d().server->serverPort();
}

/*!
 * Returns the QTcpServer used by this QxtHttpServerConnector. Use this pointer
 * to adjust the maxPendingConnections or QNetworkProxy properties of the
 * server.
 */
QTcpServer* QxtHttpServerConnector::tcpServer() const
{
    return qxt_d().server;
}

/*!
 * \internal
 */
void QxtHttpServerConnector::acceptConnection()
{
    QTcpSocket* socket = qxt_d().server->nextPendingConnection();
    addConnection(socket);
}

/*!
 * \reimp
 */
bool QxtHttpServerConnector::canParseRequest(const QByteArray& buffer)
{
    if (buffer.indexOf("\r\n\r\n") >= 0) return true; // 1.0+
    if (buffer.indexOf("\r\n") >= 0 && buffer.indexOf("HTTP/") == -1) return true; // 0.9
    return false;
}

/*!
 * \reimp
 */
QHttpRequestHeader QxtHttpServerConnector::parseRequest(QByteArray& buffer)
{
    int pos = buffer.indexOf("\r\n\r\n"), endpos = pos + 3;
    if (pos == -1)
    {
        pos = buffer.indexOf("\r\n"); // 0.9
        endpos = pos + 1;
    }

    QHttpRequestHeader header(QString::fromUtf8(buffer.left(endpos)));
    QByteArray firstLine = buffer.left(buffer.indexOf('\r'));
    if (firstLine.indexOf("HTTP/") == -1)
    {
        header.setRequest(header.method(), header.path(), 0, 9);
    }
    buffer.remove(0, endpos + 1);
    return header;
}

/*!
 * \reimp
 */
void QxtHttpServerConnector::writeHeaders(QIODevice* device, const QHttpResponseHeader& header)
{
    if (header.majorVersion() == 0) return; // 0.9 doesn't have headers
    device->write(header.toString().toUtf8());
}

#ifndef QT_NO_OPENSSL
/*!
 * Creates a QxtHttpsServerConnector with the given \a parent.
 */
QxtHttpsServerConnector::QxtHttpsServerConnector(QObject* parent) 
: QxtHttpServerConnector(parent, new QxtSslServer)
{
    // initializers only
    // Reparent the SSL server
    tcpServer()->setParent(this);
}

/*!
 * \reimp
 */
bool QxtHttpsServerConnector::listen(const QHostAddress& iface, quint16 port)
{
    return QxtHttpServerConnector::listen(iface, port);
}

/*!
 * Returns the QxtSslServer used by this QxtHttpsServerConnector. Use this
 * pointer to adjust the maxPendingConnections or QNetworkProxy properties of the
 * server or the SSL properties assigned to incoming connections.
 */
QxtSslServer* QxtHttpsServerConnector::tcpServer() const
{
    return static_cast<QxtSslServer*>(QxtHttpServerConnector::tcpServer());
}

/*!
 *  Handles peer verification errors during SSL negotiation. This method may
 *  be overridden to tear-down the connection.
 */
void QxtHttpsServerConnector::peerVerifyError(const QSslError &error)
{
    qWarning() << "QxtHttpsServerConnector::peerVerifyError(): " << error.errorString();
}

/*!
 *  Handles errors with SSL negotiation. This method may be overridden to
 *  examine the errors and take appropriate action. The default behavior
 *  is to terminate the connection (ie: ignoreSslErrors() is NOT called).
 */
void QxtHttpsServerConnector::sslErrors(const QList<QSslError> &errors)
{
    for(int i = 0; i < errors.size(); ++i)
	qWarning() << "QxtHttpsServerConnector::sslErrors(): " << errors.at(i).errorString();
}
#endif /* QT_NO_OPENSSL */