interfacehttp.cpp

/*
    This file is part of RTBroker
    Made by Buzzing Light 2014-2015 — Buzzing Light

    Development:     Guillaume Jacquemin (https://www.buzzinglight.com)

    This file was written by Guillaume Jacquemin.

    HTTP2OSC is a free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    any later version.

    This program 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 General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

#include "interfacehttp.h"

InterfaceHttp::InterfaceHttp(QWidget *_uiFeedback, QObject *parent) :
    QObject(parent), SenderInterface(_uiFeedback) {
    //HTTP server
    httpServer = new InterfaceHttpServer(uiFeedback, this);
    connect(httpServer, SIGNAL(parseRequest(QNetworkReply*)), SLOT(parseRequest(QNetworkReply*)));
    connect(httpServer, SIGNAL(parseSocket(QTcpSocket*)),     SLOT(parseSocket(QTcpSocket*)));
}

void InterfaceHttp::setPort(quint16 port) {
    httpServer->setPort(port);
}
QString InterfaceHttp::send(const QVariantList &valeurs, const QString &, quint16, const QString &, void *) {
    return httpServer->send(valeurs);
}


InterfaceHttpServer::InterfaceHttpServer(QWidget *_uiFeedback, QObject *parent) :
    QTcpServer(parent), SenderInterface(_uiFeedback) {
    http = new QNetworkAccessManager(this);
    connect(http, SIGNAL(finished(QNetworkReply*)), SLOT(parse(QNetworkReply*)));
}
void InterfaceHttpServer::setPort(quint16 port) {
    if(port != serverPort()) {
        setUiFeedback(false);
        if((isListening()) && (serverPort())) {
            qDebug("Fermeture de HTTP sur %d", serverPort());
            close();
        }
        if(listen(QHostAddress::Any, port)) {
            qDebug("Ouverture de HTTP sur %d", port);
            setUiFeedback(true);
        }
        else
            qDebug("Echec de l'ouverture de HTTP sur %d", port);
    }
    else
        qDebug("Port HTTP déjà ouvert sur %d (%d)", serverPort(), isListening());
}
QString InterfaceHttpServer::send(const QVariantList &valeurs, const QString &, quint16, const QString &, void *) {
    Q_UNUSED(valeurs);
    /*
    QUrl url;
    url.setScheme("http");
    url.setHost(ip);
    url.setPort(port);
    url.setPath(destination);
    QUrlQuery query;
    for(quint16 i = 0 ; i < valeurs.count() ; i++)
        query.addQueryItem(QString("value%1").arg(i), valeurs.at(i).toString());
    url.setQuery(query);
    http->get(QNetworkRequest(url));
    return QString("%2: HTTP sent on %1\n").arg(url.toString()).arg(QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss.zzz"));
    */
    return QString();
}

void InterfaceHttpServer::parse(QNetworkReply *reply) {
    emit(parseRequest(reply));
}
void InterfaceHttp::parseRequest(QNetworkReply *reply) {
    //QString(reply->readAll());
    QString replyStr = reply->readAll();
}


//HTTP reception
void InterfaceHttpServer::incomingConnection(qintptr socketDescriptor) {
    QTcpSocket *socket = new QTcpSocket(this);
    connect(socket, SIGNAL(readyRead()),    this, SLOT(readClient()));
    connect(socket, SIGNAL(disconnected()), this, SLOT(discardClient()));
    socket->setSocketDescriptor(socketDescriptor);
}
void InterfaceHttpServer::readClient() {
    QTcpSocket *socket = (QTcpSocket*)sender();
    if(socket->canReadLine())
        emit(parseSocket(socket));
}

void InterfaceHttp::parseSocket(QTcpSocket *socket) {
    QStringList tokens = QString(socket->readLine()).split(QRegExp("[ \r\n][ \r\n]*"));
    if((tokens.count() > 1) && (tokens.at(0) == "GET")) {
#ifdef QT4
        QUrl url(tokens.at(1));
#else
        QUrlQuery url(QUrl(tokens.at(1)));
#endif

        QTextStream os(socket);

        os.setAutoDetectUnicode(true);
        os << "HTTP/1.0 200 Ok\r\n"
              "Content-Type: text/plain; charset=\"utf-8\"\r\n"
              "Access-Control-Allow-Origin: *\r\n"
              "Access-Control-Allow-Credentials: true\r\n"
              "Access-Control-Allow-Headers: origin, content-type, accept\r\n"
              "\r\n";

        QStringList message;
        for(quint16 index = 0 ; index < url.queryItems().count() ; index++)
            message.append(url.queryItems().at(index).second);
        os << MainWindowInterface::main->dispatch(message, QVariantList() << "/osc" << "127.0.0.1" << MainWindowInterface::defaultUdpPort);
        os.flush();
        socket->close();
        if(socket->state() == QTcpSocket::UnconnectedState)
            delete socket;
    }
}
void InterfaceHttpServer::discardClient() {
    QTcpSocket* socket = (QTcpSocket*)sender();
    socket->deleteLater();
}

InterfaceHttp::~InterfaceHttp() {
}