summaryrefslogtreecommitdiff
path: root/webproxytrans.cc
diff options
context:
space:
mode:
authorJavier <dev.git@javispedro.com>2016-01-01 22:05:42 +0100
committerJavier <dev.git@javispedro.com>2016-01-01 22:05:42 +0100
commita45977185a485624095bff1a15024e9199eee676 (patch)
tree6cc57d085bdd01e493477c870dbe0548137998e1 /webproxytrans.cc
parenta24034bdfea259cdc09c74217be75d4f9de0dce5 (diff)
downloadsapd-a45977185a485624095bff1a15024e9199eee676.tar.gz
sapd-a45977185a485624095bff1a15024e9199eee676.zip
reorganize source files into SAP and agents
Diffstat (limited to 'webproxytrans.cc')
-rw-r--r--webproxytrans.cc74
1 files changed, 0 insertions, 74 deletions
diff --git a/webproxytrans.cc b/webproxytrans.cc
deleted file mode 100644
index 23b41b7..0000000
--- a/webproxytrans.cc
+++ /dev/null
@@ -1,74 +0,0 @@
-#include <QtCore/QDebug>
-#include <QtCore/QUrl>
-
-#include "webproxyconn.h"
-#include "webproxytrans.h"
-
-static const QByteArray connectResponse("HTTP/1.1 200 Connection established\r\n\r\n");
-
-WebProxyTrans::WebProxyTrans(int transactionId, bool tunnel, const QString &host, int port, WebProxyConn *conn)
- : QObject(conn), _transactionId(transactionId), _tunnel(tunnel), _socket(new QTcpSocket(this))
-{
- connect(_socket, SIGNAL(connected()), this, SLOT(handleSocketConnected()));
- connect(_socket, SIGNAL(bytesWritten(qint64)), this, SLOT(handleSocketDataWritten(qint64)));
- connect(_socket, SIGNAL(readyRead()), this, SLOT(handleSocketDataReady()));
- connect(_socket, SIGNAL(disconnected()), this, SLOT(handleSocketDisconnected()));
-
- _socket->connectToHost(host, port);
-}
-
-int WebProxyTrans::transactionId() const
-{
- return _transactionId;
-}
-
-void WebProxyTrans::write(const QByteArray &data)
-{
- if (!_outBuf.isEmpty() || !_socket->isValid()) {
- _outBuf.append(data);
- } else if (_socket->isValid()) {
- // Write directly to socket
- _socket->write(data);
- }
-}
-
-void WebProxyTrans::handleSocketConnected()
-{
- qDebug() << "Transaction" << _transactionId << "Connected";
- if (_tunnel) {
- emit dataReceived(connectResponse);
- }
- writeFromBuffer();
-}
-
-void WebProxyTrans::handleSocketDataWritten(qint64 written)
-{
- Q_UNUSED(written);
- writeFromBuffer();
-}
-
-void WebProxyTrans::handleSocketDataReady()
-{
- emit dataReceived(_socket->readAll());
-}
-
-void WebProxyTrans::handleSocketDisconnected()
-{
- qDebug() << "Transaction" << _transactionId << "Disconnected";
- emit disconnected();
-}
-
-WebProxyConn* WebProxyTrans::conn()
-{
- return static_cast<WebProxyConn*>(parent());
-}
-
-void WebProxyTrans::writeFromBuffer()
-{
- if (!_outBuf.isEmpty()) {
- qint64 written = _socket->write(_outBuf);
- if (written > 0) {
- _outBuf.remove(0, written);
- }
- }
-}