Swiftdiff options
| author | Thilo Cestonaro <thilo@cestona.ro> | 2011-09-28 22:03:14 (GMT) |
|---|---|---|
| committer | Kevin Smith <git@kismith.co.uk> | 2011-12-13 08:17:58 (GMT) |
| commit | fd17fe0d239f97cedebe4ceffa234155bd299b68 (patch) | |
| tree | 010ae5155e6e807b548861304657a25699487e1f /Swiften/Network/BOSHConnection.cpp | |
| parent | 7d19f0d81371d86d530d0e7083a04db914ce6745 (diff) | |
| download | swift-fd17fe0d239f97cedebe4ceffa234155bd299b68.zip swift-fd17fe0d239f97cedebe4ceffa234155bd299b68.tar.bz2 | |
BOSH implementation started
License: This patch is BSD-licensed, see http://www.opensource.org/licenses/bsd-license.php
Diffstat (limited to 'Swiften/Network/BOSHConnection.cpp')
| -rw-r--r-- | Swiften/Network/BOSHConnection.cpp | 132 |
1 files changed, 132 insertions, 0 deletions
diff --git a/Swiften/Network/BOSHConnection.cpp b/Swiften/Network/BOSHConnection.cpp new file mode 100644 index 0000000..549c652 --- /dev/null +++ b/Swiften/Network/BOSHConnection.cpp @@ -0,0 +1,132 @@ +/* + * Copyright (c) 2011 Thilo Cestonaro + * Licensed under the simplified BSD license. + * See Documentation/Licenses/BSD-simplified.txt for more information. + */ + +#include "BOSHConnection.h" +#include <boost/bind.hpp> +#include <boost/thread.hpp> +#include <string> + +#include <Swiften/Network/ConnectionFactory.h> +#include <Swiften/Base/Log.h> +#include <Swiften/Base/String.h> +#include <Swiften/Base/ByteArray.h> +#include <Swiften/Network/HostAddressPort.h> +#include <Swiften/Parser/BOSHParser.h> + +namespace Swift { + + BOSHConnection::BOSHConnection(ConnectionFactory* connectionFactory) + : connectionFactory_(connectionFactory), server_(HostAddressPort(HostAddress("0.0.0.0"), 0)), sid_() + { + reopenAfterAction = true; + } + + BOSHConnection::~BOSHConnection() { + if (newConnection_) { + newConnection_->onDataRead.disconnect(boost::bind(&BOSHConnection::handleDataRead, shared_from_this(), _1)); + newConnection_->onDisconnected.disconnect(boost::bind(&BOSHConnection::handleDisconnected, shared_from_this(), _1)); + } + if (currentConnection_) { + currentConnection_->onDataRead.disconnect(boost::bind(&BOSHConnection::handleDataRead, shared_from_this(), _1)); + currentConnection_->onDisconnected.disconnect(boost::bind(&BOSHConnection::handleDisconnected, shared_from_this(), _1)); + } + } + + void BOSHConnection::connect(const HostAddressPort& server) { + server_ = server; + newConnection_ = connectionFactory_->createConnection(); + newConnection_->onConnectFinished.connect(boost::bind(&BOSHConnection::handleConnectionConnectFinished, shared_from_this(), _1)); + newConnection_->onDataRead.connect(boost::bind(&BOSHConnection::handleDataRead, shared_from_this(), _1)); + newConnection_->onDisconnected.connect(boost::bind(&BOSHConnection::handleDisconnected, shared_from_this(), _1)); + SWIFT_LOG(debug) << "connect to server " << server.getAddress().toString() << ":" << server.getPort() << std::endl; + newConnection_->connect(HostAddressPort(HostAddress("85.10.192.88"), 5280)); + } + + void BOSHConnection::listen() { + assert(false); + } + + void BOSHConnection::disconnect() { + if(newConnection_) + newConnection_->disconnect(); + + if(currentConnection_) + currentConnection_->disconnect(); + } + + void BOSHConnection::write(const SafeByteArray& data) { + SWIFT_LOG(debug) << "write data: " << safeByteArrayToString(data) << std::endl; + } + + void BOSHConnection::handleConnectionConnectFinished(bool error) { + newConnection_->onConnectFinished.disconnect(boost::bind(&BOSHConnection::handleConnectionConnectFinished, shared_from_this(), _1)); + if(error) { + onConnectFinished(true); + return; + } + + if(sid_.size() == 0) { + // Session Creation Request + std::stringstream content; + std::stringstream header; + + content << "<body content='text/xml; charset=utf-8'" + << " from='ephraim@0x10.de'" + << " hold='1'" + << " to='0x10.de'" + << " ver='1.6'" + << " wait='60'" + << " ack='1'" + << " xml:lang='en'" + << " xmlns='http://jabber.org/protocol/httpbind' />\r\n"; + + header << "POST /http-bind HTTP/1.1\r\n" + << "Host: 0x10.de:5280\r\n" + << "Accept-Encoding: deflate\r\n" + << "Content-Type: text/xml; charset=utf-8\r\n" + << "Content-Length: " << content.str().size() << "\r\n\r\n" + << content.str(); + + SWIFT_LOG(debug) << "request: "; + newConnection_->write(createSafeByteArray(header.str())); + } + } + + void BOSHConnection::handleDataRead(const SafeByteArray& data) { + std::string response = safeByteArrayToString(data); + assert(response.find("\r\n\r\n") != std::string::npos); + + SWIFT_LOG(debug) << "response: " << response.substr(response.find("\r\n\r\n") + 4) << std::endl; + + BOSHParser parser; + if(parser.parse(response.substr(response.find("\r\n\r\n") + 4))) { + sid_ = parser.getAttribute("sid"); + onConnectFinished(false); + int bodyStartElementLength = 0; + bool inQuote = false; + for(size_t i= 0; i < response.size(); i++) { + if(response.c_str()[i] == '\'' || response.c_str()[i] == '"') { + inQuote = !inQuote; + } + else if(!inQuote && response.c_str()[i] == '>') { + bodyStartElementLength = i + 1; + break; + } + } + SafeByteArray payload = createSafeByteArray(response.substr(bodyStartElementLength, response.size() - bodyStartElementLength - 7)); + SWIFT_LOG(debug) << "payload: " << safeByteArrayToString(payload) << std::endl; + onDataRead(payload); + } + } + + void BOSHConnection::handleDisconnected(const boost::optional<Error>& error) { + onDisconnected(error); + } + + HostAddressPort BOSHConnection::getLocalAddress() const { + return newConnection_->getLocalAddress(); + } +} |