You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
tork/src/upnp/httprequest.cpp

124 lines
3.7 KiB

/***************************************************************************
* Copyright (C) 2005 by Joris Guisson *
* joris.guisson@gmail.com *
* *
* This program is 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 2 of the License, or *
* (at your option) 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, write to the *
* Free Software Foundation, Inc., *
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
#include <ntqstringlist.h>
#include "httprequest.h"
#include "../functions.h"
#include <kdebug.h>
#include <ksocks.h>
namespace bt
{
HTTPRequest::HTTPRequest(const TQString & hdr,const TQString & payload,const TQString & host,Uint16 port,bool verbose, bool fwd) : hdr(hdr),payload(payload),verbose(verbose),fwd(fwd)
{
KSocks::self()->disableSocks();
sock = new KNetwork::KStreamSocket(host,TQString::number(port),this,0);
sock->enableRead(true);
sock->enableWrite(true);
sock->setTimeout(30000);
sock->setBlocking(false);
connect(sock,SIGNAL(readyRead()),this,SLOT(onReadyRead()));
connect(sock,SIGNAL(gotError(int)),this,SLOT(onError(int )));
connect(sock,SIGNAL(timedOut()),this,SLOT(onTimeout()));
connect(sock,SIGNAL(connected(const KResolverEntry&)),
this, SLOT(onConnect( const KResolverEntry& )));
}
HTTPRequest::~HTTPRequest()
{
sock->close();
delete sock;
}
void HTTPRequest::start()
{
sock->connect();
}
void HTTPRequest::onConnect(const KResolverEntry&)
{
payload = payload.replace("$LOCAL_IP",sock->localAddress().nodeName());
hdr = hdr.replace("$CONTENT_LENGTH",TQString::number(payload.length()));
TQString req = hdr + payload;
/* if (verbose)
{
KdDebug() << "Sending " << endl;
KdDebug() << hdr << payload << endl;
}*/
sock->writeBlock(req.ascii(),req.length());
}
void HTTPRequest::onReadyRead()
{
Uint32 ba = sock->bytesAvailable();
if (ba == 0)
{
error(this,false);
sock->close();
return;
}
Array<char> data(ba);
ba = sock->readBlock(data,ba);
TQString strdata((const char*)data);
TQStringList sl = TQStringList::split("\r\n",strdata,false);
/* if (verbose)
{
KdDebug() << "Got reply : " << endl;
KdDebug() << strdata << endl;
}*/
if (sl.first().contains("HTTP") && sl.first().contains("200"))
{
// emit reply OK
replyOK(this,sl.last(),fwd);
}
else
{
// emit reply error
replyError(this,sl.last(),fwd);
}
operationFinished(this);
}
void HTTPRequest::onError(int)
{
kdDebug() << "HTTPRequest error : " << sock->errorString() << endl;
error(this,false);
sock->close();
operationFinished(this);
}
void HTTPRequest::onTimeout()
{
kdDebug() << "HTTPRequest timeout" << endl;
error(this,true);
sock->close();
operationFinished(this);
}
}
#include "httprequest.moc"