ServerConnector.hpp

#pragma once
#include <samchon/API.hpp>

#include <samchon/protocol/Communicator.hpp>

namespace samchon
{
namespace protocol
{
    class ServerConnector
        : public virtual Communicator
    {
    protected:
        std::unique_ptr<boost::asio::io_service> io_service;

        std::unique_ptr<boost::asio::ip::tcp::endpoint> endpoint;

    public:
        /* -----------------------------------------------------------
            CONSTRUCTORS
        ----------------------------------------------------------- */
        ServerConnector(IProtocol *listener)
        {
            this->listener = listener;
        };
        
        virtual ~ServerConnector() = default;

        /* -----------------------------------------------------------
            CONNECTOR
        ----------------------------------------------------------- */
        virtual void connect(const std::string &ip, int port)
        {
            _Connect(ip, port);

            listen_message();
        };

    protected:
        void _Connect(const std::string &ip, int port)
        {
            if (socket != nullptr && socket->is_open() == true)
                throw std::logic_error("Already connected");

            io_service.reset(new boost::asio::io_service());
            endpoint.reset(new boost::asio::ip::tcp::endpoint(boost::asio::ip::address::from_string(ip), port));

            socket.reset(new boost::asio::ip::tcp::socket(*io_service, boost::asio::ip::tcp::v4()));
            socket->connect(*endpoint);
        };
    };
};
};