+++ /dev/null
-/****************************************************************************
-**
-** 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;
-}
-
-
-
-
projects / quassel.git / blobdiff