VrbClientRegistry.h

Go to the documentation of this file.

/* This file is part of COVISE.

   You can use it under the terms of the GNU Lesser General Public License
   version 2.1 or later, see lgpl-2.1.txt.

 * License: LGPL 2+ */

#ifndef VrbClientRegistry_H
#define VrbClientRegistry_H

#include <net/tokenbuffer.h>
#include <map>
#include "regClass.h"
#include <util/coExport.h>
#include "VrbRegistry.h"
#include "SessionID.h"
namespace covise
{
class VRBClient;
}
namespace vrb
{
class VrbMessageSenderInterface;
class VRBEXPORT VrbClientRegistry : public VrbRegistry<clientRegClass, clientRegVar>
{
public:
    static VrbClientRegistry *instance;
    VrbClientRegistry(int id, VrbMessageSenderInterface *sender);
    void setID(int clID, const SessionID &session);
    void resubscribe(const SessionID &sessionID, const SessionID &oldSession = SessionID());

    clientRegClass *subscribeClass(const SessionID &sessionID, const std::string &clName, regClassObserver *ob);

    clientRegVar *subscribeVar(const SessionID &sessionID, const std::string &cl, const std::string &var, covise::TokenBuffer &&value, regVarObserver *ob);

    void unsubscribeClass(const SessionID &sessionID, const std::string &cl);

    void unsubscribeVar(const std::string &cl, const std::string &var, bool unsubscribeServerOnly = false);

    void createVar(const SessionID sessionID, const std::string &cl, const std::string &var, covise::TokenBuffer &value, bool isStatic = false);

    void setVar(const SessionID sessionID, const std::string &cl, const std::string &var, covise::TokenBuffer &&val, bool muted = false);

    void destroyVar(const SessionID sessionID, const std::string &cl, const std::string &var);

    clientRegClass *getClass(const std::string &name);

    void update(covise::TokenBuffer &tb, int reason);

    virtual ~VrbClientRegistry();
    void sendMsg(covise::TokenBuffer &tb, covise::covise_msg_type type);

    int getID() override
    {
        return clientID;
    }
    SessionID getSession()
    {
        return sessionID;
    }

    std::shared_ptr<clientRegClass> createClass(const std::string &name, int id) override;
private:
    int clientID = -1;
    SessionID sessionID;
    VrbMessageSenderInterface *m_sender;

};
}


#endif