/*

* All rights reserved.

* See the COPYING file for more information.

*/

#pragma once

#include <vector>

#include <Swiften/Base/API.h>

#include <Swiften/Base/SafeString.h>

#include <Swiften/Network/BOSHConnection.h>

#include <Swiften/TLS/CertificateWithKey.h>

#include <Swiften/TLS/TLSOptions.h>

namespace Swift {

class CachingDomainNameResolver;

class EventLoop;

class HTTPTrafficFilter;

class TLSContextFactory;

class CachingDomainNameResolver;

class EventLoop;

class SWIFTEN_API BOSHConnectionPool : public boost::signals2::trackable {

public:

BOSHConnectionPool(const URL& boshURL, DomainNameResolver* resolver, ConnectionFactory* connectionFactory, XMLParserFactory* parserFactory, TLSContextFactory* tlsFactory, TimerFactory* timerFactory, EventLoop* eventLoop, const std::string& to, unsigned long long initialRID, const URL& boshHTTPConnectProxyURL, const SafeString& boshHTTPConnectProxyAuthID, const SafeString& boshHTTPConnectProxyAuthPassword, const TLSOptions& tlsOptions, std::shared_ptr<HTTPTrafficFilter> trafficFilter = std::shared_ptr<HTTPTrafficFilter>());

~BOSHConnectionPool();

void open();

void write(const SafeByteArray& data);

void writeFooter();

void close();

void restartStream();

void setTLSCertificate(CertificateWithKey::ref certWithKey);

bool isTLSEncrypted() const;

Certificate::ref getPeerCertificate() const;

std::vector<Certificate::ref> getPeerCertificateChain() const;

std::shared_ptr<CertificateVerificationError> getPeerCertificateVerificationError() const;

boost::signals2::signal<void ()> onTLSConnectionEstablished;

boost::signals2::signal<void (BOSHError::ref)> onSessionTerminated;

boost::signals2::signal<void ()> onSessionStarted;

boost::signals2::signal<void (const SafeByteArray&)> onXMPPDataRead;

boost::signals2::signal<void (const SafeByteArray&)> onBOSHDataRead;

boost::signals2::signal<void (const SafeByteArray&)> onBOSHDataWritten;

private: