codec.hpp

#pragma once
 
#include "telnetpp/core.hpp"
 
#include <boost/exception/exception.hpp>
 
#include <functional>
#include <stdexcept>
 
namespace telnetpp::options::mccp {
 
//* =========================================================================
//* =========================================================================
class TELNETPP_EXPORT codec
{
public:
    using continuation =
        std::function<void(telnetpp::bytes data, bool continuation_ended)>;
 
    //* =====================================================================
    //* =====================================================================
    virtual ~codec() = default;
 
    //* =====================================================================
    //* =====================================================================
    void start();
 
    //* =====================================================================
    //* =====================================================================
    void finish(continuation const &cont);
 
    //* =====================================================================
    //* =====================================================================
    void operator()(telnetpp::bytes data, continuation const &cont);
 
private:
    //* =====================================================================
    //* =====================================================================
    virtual void do_start() {};
 
    //* =====================================================================
    //* =====================================================================
    virtual void do_finish(continuation const & /*cont*/) {};
 
    //* =====================================================================
    //* =====================================================================
    virtual telnetpp::bytes transform_chunk(
        telnetpp::bytes data, continuation const &continuation) = 0;
 
    bool engaged_{false};
};
 
//* =========================================================================
//* =========================================================================
class TELNETPP_EXPORT corrupted_stream_error : virtual std::domain_error,
                                               virtual boost::exception
{
public:
    //* =====================================================================
    //* =====================================================================
    explicit corrupted_stream_error(char const *what_arg);
};
 
}  // namespace telnetpp::options::mccp