MediatorWebClient.hpp

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

#include <samchon/templates/parallel/MediatorClient.hpp>
#include <samchon/protocol/WebServerConnector.hpp>

namespace samchon
{
namespace templates
{
namespace parallel
{
    class MediatorWebClient
        : public MediatorClient
    {
    private:
        typedef MediatorClient super;

    protected:
        std::string path_;

    public:
        /* ---------------------------------------------------------
            CONSTRUCTORS
        --------------------------------------------------------- */
        MediatorWebClient(external::base::ExternalSystemArrayBase *system_array_, const std::string &ip, int port)
            : MediatorWebClient(system_array_, ip, port, "")
        {
        };

        MediatorWebClient(external::base::ExternalSystemArrayBase *system_array_, const std::string &ip, int port, const std::string &path)
            : super(system_array_, ip, port)
        {
            this->path_ = path;
        };
        virtual ~MediatorWebClient() = default;

    protected:
        virtual auto createServerConnector() -> protocol::ServerConnector*
        {
            return new protocol::WebServerConnector(this);
        };

    public:
        /* ---------------------------------------------------------
            METHOD OF CONNECTOR
        --------------------------------------------------------- */
        virtual void start() override
        {
            if (communicator_ != nullptr)
                return;

            protocol::WebServerConnector *connector = dynamic_cast<protocol::WebServerConnector*>(createServerConnector());
            communicator_.reset(connector);

            connector->connect(ip_, port_, path_);
        };
    };
};
};
};