X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcontrib%2Flibqxt-2007-10-24%2Fsrc%2Fweb%2Fqxtscgiconnector.cpp;fp=src%2Fcontrib%2Flibqxt-2007-10-24%2Fsrc%2Fweb%2Fqxtscgiconnector.cpp;h=72abdd4bd68228f8f9092a77133d183a028c7e43;hp=0000000000000000000000000000000000000000;hb=a634acadbcf6017474f68a3eaf7cb632660e9e49;hpb=cd122ca8e0d2c0ffc5397e0a813c75d791a7e6e3

diff --git a/src/contrib/libqxt-2007-10-24/src/web/qxtscgiconnector.cpp b/src/contrib/libqxt-2007-10-24/src/web/qxtscgiconnector.cpp
new file mode 100644
index 00000000..72abdd4b
--- /dev/null
+++ b/src/contrib/libqxt-2007-10-24/src/web/qxtscgiconnector.cpp
@@ -0,0 +1,232 @@
+/****************************************************************************
+**
+** Copyright (C) Qxt Foundation. Some rights reserved.
+**
+** This file is part of the QxtWeb  module of the Qt eXTension library
+**
+** This library is free software; you can redistribute it and/or modify it
+** under the terms of th Common Public License, version 1.0, as published by
+** IBM.
+**
+** This file is provided "AS IS", without WARRANTIES OR CONDITIONS OF ANY
+** KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT LIMITATION, ANY
+** WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT, MERCHANTABILITY OR
+** FITNESS FOR A PARTICULAR PURPOSE.
+**
+** You should have received a copy of the CPL along with this file.
+** See the LICENSE file and the cpl1.0.txt file included with the source
+** distribution for more information. If you did not receive a copy of the
+** license, contact the Qxt Foundation.
+**
+** <http://libqxt.org>  <foundation@libqxt.org>
+**
+****************************************************************************/
+#include "qxtscgiconnector.h"
+#include <QTcpSocket>
+#include <QTcpServer>
+#include <QtDebug>
+#include <ctime>
+#include <QDebug>
+
+class QxtScgiConnectorPrivate : public QTcpServer,public QxtPrivate<QxtScgiConnector>
+{
+    QXT_DECLARE_PUBLIC(QxtScgiConnector);
+
+protected:
+
+    void incomingConnection ( int socketDescriptor )
+    {
+        qDebug("%i, -> incomming",(int)time(NULL));
+        QTcpSocket * tcpSocket = new QTcpSocket;
+        if (!tcpSocket->setSocketDescriptor(socketDescriptor))
+        {
+            delete tcpSocket;
+            socket_m=0;
+            return;
+        }
+        socket_m=tcpSocket;
+        connect(tcpSocket,SIGNAL(disconnected()),tcpSocket,SLOT(deleteLater())); ///TODO:right. and what id the client disconnects earlier?
+        SERVER.clear();
+        int eee1=readHeaderFromSocket(tcpSocket,SERVER);
+        if (eee1)
+        {
+            tcpSocket->write("Status: 500 INTERNAL SERVER ERROR\r\ncontent-type: text/html\r\n\r\nHEADER NOT READABLE");
+        }
+
+        emit(qxt_p().incomming(SERVER));
+    }
+
+    QTcpSocket * socket_m;
+    server_t SERVER;
+
+
+    int readHeaderFromSocket(QTcpSocket * tcpSocket,server_t & SERVER)
+    {
+        if (!tcpSocket)
+            return 5012;
+
+
+        ///--------------get the header size----------------
+
+        QByteArray size_in;
+        while (!size_in.endsWith(':'))
+        {
+            if (!tcpSocket->bytesAvailable ())
+                if (!tcpSocket->waitForReadyRead (200))
+                    return 50033;
+
+            char a[4]; ///4? yes, i know i'm paranoid about bounds.
+
+
+            if (!tcpSocket->read (a, 1 ))
+                return 50034;
+
+            size_in+=a[0];
+
+            if (size_in.size()>20)/// after the 20ths char is an attack atemp for sure
+                return 50034;
+
+        }
+
+
+        size_in.chop(1);
+        int size=size_in.toInt()+1;
+
+
+        if (size>10240)  ///do not accept headers over 10kb
+            return 50037;
+
+
+        ///--------------read the header------------------
+
+        while (tcpSocket->bytesAvailable ()<size)
+        {
+            if (!tcpSocket->waitForReadyRead (200))
+                return 50033;
+        }
+        QByteArray header_in;
+        header_in.resize(size);
+
+        if (tcpSocket->read (header_in.data(), size )!=size)
+            return 50034;
+
+        if (!header_in.endsWith(','))
+            return 50090;
+        ///--------------parse the header------------------
+
+
+        int i=0;
+        QByteArray name="";
+        QByteArray a =header_in;
+        while ((i=a.indexOf('\0'))>-1)
+        {
+            if (name=="")
+            {
+                name= a.left(i).replace('\0',"");
+            }
+            else
+            {
+                SERVER[name]=a.left(i).replace('\0',"").replace("%20"," ");
+                name="";
+            }
+
+            a=a.mid(i+1);
+        }
+
+
+        return 0;
+    }
+
+
+
+
+
+
+};
+
+QxtScgiConnector::QxtScgiConnector():QxtAbstractWebConnector()
+{
+    QXT_INIT_PRIVATE(QxtScgiConnector);
+    qxt_d().socket_m=0;
+}
+
+int QxtScgiConnector::start (quint16 port,const QHostAddress & address)
+{
+    return qxt_d().listen(address,port);
+}
+
+QIODevice * QxtScgiConnector::socket()
+{
+    return qxt_d().socket_m;
+}
+void QxtScgiConnector::sendHeader(server_t & answer)
+{
+    if (!answer.contains("Status"))
+        answer["Status"]="200 OK";
+    if (!answer.contains("Content-Type"))
+        answer["Content-Type"]="text/html; charset=utf-8";
+
+    server_t::const_iterator i = answer.constBegin();
+    while (i != answer.constEnd())
+    {
+        qxt_d().socket_m->write(i.key()+": "+i.value()+"\r\n");
+        ++i;
+    }
+    qxt_d().socket_m->write("\r\n");
+}
+
+void  QxtScgiConnector::close()
+{
+    emit(aboutToClose());
+    qxt_d().socket_m->close();
+}
+
+
+QByteArray QxtScgiConnector::content(quint64 maxsize)
+{
+    QIODevice * tcpSocket=  qxt_d().socket_m;
+
+    if (!tcpSocket)
+        return QByteArray();
+
+
+    unsigned int content_size= qxt_d().SERVER["CONTENT_LENGTH"].toUInt();
+
+    qDebug()<<"receiving content"<<content_size;
+
+
+    if (content_size<1)
+    {
+        return QByteArray();
+    }
+
+    if (content_size>maxsize)
+        content_size=maxsize;
+
+    ///--------------read the content------------------
+
+
+
+
+
+    while (tcpSocket->bytesAvailable ()<content_size)
+    {
+        if (!tcpSocket->waitForReadyRead (2000))
+            return QByteArray();
+    }
+
+    QByteArray content_in;
+    content_in.resize(content_size);
+
+
+    if (tcpSocket->read (content_in.data(), content_size )!=content_size)
+        return QByteArray();
+
+
+    tcpSocket->readAll(); //fix apache fcgi bug
+    return content_in;
+}
+
+
+
+