We now have a current svn snapshot of libqxt in our contrib dir, and

[quassel.git] / src / contrib / libqxt-2007-10-24 / src / web / qxtfcgiconnector.cpp

diff --git a/src/contrib/libqxt-2007-10-24/src/web/qxtfcgiconnector.cpp b/src/contrib/libqxt-2007-10-24/src/web/qxtfcgiconnector.cpp
new file mode 100644 (file)
index 0000000..51a8180
--- /dev/null
+++ b/src/contrib/libqxt-2007-10-24/src/web/qxtfcgiconnector.cpp
@@ -0,0 +1,189 @@
+/****************************************************************************
+**
+** 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 "qxtfcgiconnector.h"
+#include "qxtfcgiconnector_p.h"
+#include <QTcpSocket>
+#include <QTcpServer>
+#include <QTextStream>
+#include "qxtstdstreambufdevice.h"
+#include "qxtsignalwaiter.h"
+
+
+QxtFcgiConnector::QxtFcgiConnector():QxtAbstractWebConnector()
+{
+    qRegisterMetaType<server_t>("server_t");
+    qRegisterMetaTypeStreamOperators<server_t>("server_t");
+    QXT_INIT_PRIVATE(QxtFcgiConnector);
+}
+
+int QxtFcgiConnector::start (quint16 ,const QHostAddress & )
+{
+    qxt_d().start();
+    return QxtSignalWaiter::wait(&qxt_d(),SIGNAL(started()),20000);
+
+}
+
+QIODevice * QxtFcgiConnector::socket()
+{
+    return qxt_d().io;
+}
+
+
+QByteArray QxtFcgiConnector::content(quint64 maxsize)
+{
+    char * clenstr = FCGX_GetParam("CONTENT_LENGTH", qxt_d().request.envp);
+    quint64 clen = maxsize;
+    QByteArray content;
+    if (clenstr)
+    {
+        clen = strtol(clenstr, &clenstr, 10);
+        if (*clenstr)
+        {
+            qDebug()<< "can't parse \"CONTENT_LENGTH="
+                 << FCGX_GetParam("CONTENT_LENGTH", qxt_d().request.envp)
+                 << "\"\n";
+            clen = maxsize;
+        }
+
+        // *always* put a cap on the amount of data that will be read
+        if (clen > maxsize) clen = maxsize;
+
+
+
+        content.resize(clen+200);
+        std::cin.read(content.data(), clen+200);
+
+        clen = std::cin.gcount();
+    }
+    else
+    {
+        // *never* read stdin when CONTENT_LENGTH is missing or unparsable
+        clen = 0;
+    }
+
+    // Chew up any remaining stdin - this shouldn't be necessary
+    // but is because mod_fastcgi doesn't handle it correctly.
+
+    // ignore() doesn't set the eof bit in some versions of glibc++
+    // so use gcount() instead of eof()...
+    do std::cin.ignore(1024); while (std::cin.gcount() == 1024);
+
+    return content;
+
+}
+
+
+void QxtFcgiConnector::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().io->write(i.key()+": "+i.value()+"\r\n");
+        ++i;
+    }
+    qxt_d().io->write("\r\n");
+}
+
+void  QxtFcgiConnector::close()
+{
+    emit(aboutToClose());
+    qxt_d().open=false;
+    emit(qxt_d().close_ss());
+}
+
+
+/* ********** IMPL ***********/
+
+
+QxtFcgiConnectorPrivate::QxtFcgiConnectorPrivate()
+{
+    open=false;
+    io=0;
+    qRegisterMetaType<server_t>("server_t");
+    qRegisterMetaTypeStreamOperators<server_t>("server_t");
+}
+
+void QxtFcgiConnectorPrivate::run()
+{
+    qRegisterMetaType<server_t>("server_t");
+    qRegisterMetaTypeStreamOperators<server_t>("server_t");
+
+    
+    FCGX_Init();
+    FCGX_InitRequest(&request, 0, 0);
+
+    ///FIXME: i just need a damn fd to use select() on. arrg
+    while (FCGX_Accept_r(&request) == 0)
+    {
+        open=true;
+        fcgi_streambuf   fio_in(request.in);
+        fcgi_streambuf   fio_out(request.out);
+        fcgi_streambuf   fio_err(request.err);
+
+
+#if HAVE_IOSTREAM_WITHASSIGN_STREAMBUF
+        std::cin  = &fio_in;
+        std::cout = &fio_out;
+        std::cerr = &fio_err;
+#else
+        std::cin.rdbuf(&fio_in);
+        std::cout.rdbuf(&fio_out);
+        std::cerr.rdbuf(&fio_err);
+#endif
+
+        io= new QxtStdStreambufDevice (&fio_in,&fio_out);
+
+        server_t SERVER;
+        const char * const * envp=request.envp;
+        for ( ; *envp; ++envp)
+        {
+            QByteArray ee(*envp);
+            SERVER[ee.left(ee.indexOf('='))]=ee.mid(ee.indexOf('=')+1);
+        }
+        emit(qxt_p().incomming(SERVER));
+        /// heck this is a frikin waste of RAM, cpu and my nerves.
+        /// I hope those arrogants retards burn in hell for it.
+        if (open)
+            QxtSignalWaiter::wait(this,SIGNAL(close_ss()));
+        open=false;
+        delete(io);
+        io=0;
+
+    }
+}
+
+
+
+
+
+
+
+
+
+