connectioncompression.h

/*
 * Copyright (c) 2009 by Jakob Schroeter <js@camaya.net>
 * This file is part of the gloox library. http://camaya.net/gloox
 *
 * This software is distributed under a license. The full license
 * agreement can be found in the file LICENSE in this distribution.
 * This software may not be copied, modified, sold or distributed
 * other than expressed in the named license agreement.
 *
 * This software is distributed without any warranty.
 */

#ifndef CONNECTIONCOMPRESSION_H__
#define CONNECTIONCOMPRESSION_H__

#include "gloox.h"
#include "logsink.h"
#include "connectionbase.h"
#include "connectiondatahandler.h"
#include "compressiondatahandler.h"

#include <string>

namespace gloox
{

  class CompressionDefault;

  class GLOOX_API ConnectionCompression : public CompressionDataHandler, public ConnectionBase, ConnectionDataHandler
  {
    public:
      ConnectionCompression( ConnectionDataHandler* cdh, ConnectionBase* conn, const LogSink& log );

      ConnectionCompression( ConnectionBase* conn, const LogSink& log );

      virtual ~ConnectionCompression();

      void setConnectionImpl( ConnectionBase* connection );

      // reimplemented from ConnectionBase
      virtual ConnectionError connect();

      // reimplemented from ConnectionBase
      virtual ConnectionError recv( int timeout = -1 );

      // reimplemented from ConnectionBase
      virtual bool send( const std::string& data );

      // reimplemented from ConnectionBase
      virtual ConnectionError receive();

      // reimplemented from ConnectionBase
      virtual void disconnect();

      // reimplemented from ConnectionBase
      virtual void cleanup();

      // reimplemented from ConnectionBase
      virtual void getStatistics( long int& totalIn, long int& totalOut );

      // reimplemented from ConnectionDataHandler
      virtual void handleReceivedData( const ConnectionBase* connection, const std::string& data );

      // reimplemented from ConnectionDataHandler
      virtual void handleConnect( const ConnectionBase* connection );

      // reimplemented from ConnectionDataHandler
      virtual void handleDisconnect( const ConnectionBase* connection, ConnectionError reason );

      // reimplemented from ConnectionDataHandler
      virtual ConnectionBase* newInstance() const;

      // reimplemented from CompressionDataHandler
      virtual void handleCompressedData( const std::string& data );

      // reimplemented from CompressionDataHandler
      virtual void handleDecompressedData( const std::string& data );


    private:
      ConnectionCompression& operator=( const ConnectionCompression& );
      ConnectionBase* m_connection;
      CompressionDefault* m_compression;
      const LogSink & m_log;

  };

}

#endif // CONNECTIONCOMPRESSION_H__