Restructure source files into 'src' subfolderHEADmaster

Signed-off-by: Michele Calgaro <[email protected]>

1 files changed, 122 insertions, 0 deletions

diff --git a/src/libktorrent/util/httprequest.cpp b/src/libktorrent/util/httprequest.cpp
new file mode 100644
index 0000000..ff40e4c
--- /dev/null
+++ b/src/libktorrent/util/httprequest.cpp
@@ -0,0 +1,122 @@
+/***************************************************************************
+ *   Copyright (C) 2005 by Joris Guisson                                   *
+ *   [email protected]                                               *
+ *                                                                         *
+ *   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 <tqstringlist.h>
+#include <torrent/globals.h>
+#include "httprequest.h"
+#include "array.h"
+#include "log.h"
+
+
+namespace bt 
+{
+
+	HTTPRequest::HTTPRequest(const TQString & hdr,const TQString & payload,const TQString & host,Uint16 port,bool verbose) : hdr(hdr),payload(payload),verbose(verbose)
+	{
+		sock = new KNetwork::KStreamSocket(host,TQString::number(port),this,0);
+		sock->enableRead(true);
+		sock->enableWrite(true);
+		sock->setTimeout(30000);
+		sock->setBlocking(false);
+		connect(sock,TQ_SIGNAL(readyRead()),this,TQ_SLOT(onReadyRead()));
+		connect(sock,TQ_SIGNAL(gotError(int)),this,TQ_SLOT(onError(int )));
+		connect(sock,TQ_SIGNAL(timedOut()),this,TQ_SLOT(onTimeout()));
+		connect(sock,TQ_SIGNAL(connected(const KResolverEntry&)),
+				this, TQ_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)
+		{
+			Out(SYS_PNP|LOG_DEBUG) << "Sending " << endl;
+			Out(SYS_PNP|LOG_DEBUG) << 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)
+		{
+			Out(SYS_PNP|LOG_DEBUG) << "Got reply : " << endl;
+			Out(SYS_PNP|LOG_DEBUG) << strdata << endl;
+		}
+		
+		if (sl.first().contains("HTTP") && sl.first().contains("200"))
+		{
+			// emit reply OK
+			replyOK(this,sl.last());
+		}
+		else
+		{
+			// emit reply error
+			replyError(this,sl.last());
+		}
+		operationFinished(this);
+	}
+	
+	void HTTPRequest::onError(int)
+	{
+		Out() << "HTTPRequest error : " << sock->TDESocketBase::errorString() << endl;
+		error(this,false);
+		sock->close();
+		operationFinished(this);
+	}
+	
+	void HTTPRequest::onTimeout()
+	{
+		Out() << "HTTPRequest timeout" << endl;
+		error(this,true);
+		sock->close();
+		operationFinished(this);
+	}
+
+
+}
+#include "httprequest.moc"