ChatServer.hpp

#pragma once
#include <samchon/protocol/IServer.hpp>
#include <samchon/protocol/IProtocol.hpp>

#include <set>
#include <samchon/library/RWMutex.hpp>

namespace samchon
{
    namespace example
    {
        namespace console_chat_server
        {
            class ChatClient;

            class ChatServer
                : public protocol::IServer,
                public protocol::IProtocol
            {
            private:
                typedef protocol::IServer super;

                std::set<ChatClient*> clientSet;

                library::RWMutex rwMutex;

            public:
                ChatServer();
                virtual ~ChatServer() = default;

                void eraseClient(ChatClient *client);

            protected:
                virtual auto PORT() const -> int override
                {
                    return 37749;
                };

                virtual void addClient(protocol::Socket *socket) override;

            public:
                virtual void replyData(std::shared_ptr<protocol::Invoke>) override;

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