User.hpp

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

#include <samchon/Map.hpp>
#include <samchon/SmartPointer.hpp>
#include <samchon/protocol/IProtocol.hpp>

#include <string>
#include <memory>
#include <samchon/library/RWMutex.hpp>
#include <samchon/protocol/service/ServiceKeeper.hpp>
#include <samchon/protocol/Socket.hpp>

#define KEEP_USER_ALIVE auto &keeper = SmartPointer<User>(this);

namespace samchon
{
namespace library
{
    class Semaphore;
};
namespace protocol
{
    class Invoke;

namespace service
{
    class Server;
    class Client;

    class IPUserPair;

    class SAMCHON_FRAMEWORK_API User
        : private Map<size_t, SmartPointer<Client>>,
        public IProtocol
    {
        friend class Server;
        friend class Client;

    private:
        typedef Map<size_t, SmartPointer<Client>> super;

    private:
        /* =========================================================
            BASIC VARIABLES
        ========================================================= */
        Server *server;

        std::string sessionID;

        IPUserPair *ipPair;

        /* =========================================================
            VARIABLES FOR CRITICAL SECTION
        ========================================================= */
        library::RWMutex mtx;

        library::Semaphore *semaphore;

        size_t sequence;

        /* =========================================================
            ACCOUNT VARIABLES
        ========================================================= */
        std::string id;

        int authority;

    public:
        User(Server*);
        virtual ~User();

        /* =========================================================
            ACCESSORS OF MAP
        ========================================================= */
        auto size() const->size_t;
        auto begin() const->const_iterator;
        auto end() const->const_iterator;

        /* =========================================================
            GETTERS
        ========================================================= */
        auto getServer() const->Server*;

        auto getSemaphore() const->library::Semaphore*;

        auto getID() const->std::string;

        auto getAuthority() const -> int;

    protected:
        /* =========================================================
            CLIENT FACTORY
        ========================================================= */
        virtual auto createClient()->Client* = 0;
        //void setMember(const std::string &id, int authority);

    private:
        void addClient(Socket*);

        void eraseClient(size_t);


        /* =========================================================
            LOGIN AND JOIN
        ========================================================= */
        void goLogin(std::shared_ptr<Invoke>);

        void goJoin(std::shared_ptr<Invoke>);

        virtual void goLogout();

    protected:
        virtual auto doLogin(std::shared_ptr<Invoke>) -> bool = 0;

        virtual auto doJoin(std::shared_ptr<Invoke>) -> bool = 0;

    public:
        /* =========================================================
            MESSAGE CHAIN
        ========================================================= */
        virtual void sendData(std::shared_ptr<Invoke>) override;
        virtual void replyData(std::shared_ptr<Invoke>) override;
    };
};
};
};