IClient.hpp

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

#include <samchon/protocol/IProtocol.hpp>

#include <samchon/protocol/Socket.hpp>
#include <string>

namespace std
{
    class mutex;
};
namespace samchon
{
    class ByteArray;
};

namespace samchon
{
namespace protocol
{
    class Invoke;

    class SAMCHON_FRAMEWORK_API IClient
        : public virtual IProtocol
    {
    protected:
        Socket *socket;

        std::mutex *sendMtx;

        virtual auto BUFFER_SIZE() const->size_t;

    private:


    public:
        IClient();
        virtual ~IClient();

        virtual void listen();

        virtual void sendData(std::shared_ptr<Invoke>);

    protected:
        virtual void _replyData(std::shared_ptr<Invoke>);

    private:
        void handleString(ByteArray &, std::string &, std::shared_ptr<Invoke> &, size_t);
        void handleBinary(ByteArray &, std::string &, std::shared_ptr<Invoke> &, size_t);
    };
};
};