RocServer.h

Go to the documentation of this file.

#ifndef ROC_SERVER_H
#define ROC_SERVER_H

#include <zmq.hpp>
#include <json/json.h>

#include <string>
#include <list>
#include <thread>
#include <exception>

#define ROC_JSON_PARSE_ERROR (-32700)
#define ROC_JSON_INVALID_REQUEST (-32600)
#define ROC_JSON_METHOD_NOT_FOUND (-32601)
#define ROC_JSON_INVALID_PARAMS (-32602)
#define ROC_JSON_INTERNAL_ERROR (-32603)

class RocNotImplementedError: public std::exception {
};

class RocIsCallable: public std::exception {
};

class RocServer {
public:
    RocServer(zmq::context_t & _ctx,
              const std::string & _brokerEndpoint,
              const std::string & _serviceName);
    virtual ~RocServer();
protected:
    virtual void startup();
    virtual void teardown();
    virtual void onRequest(std::list<zmq::message_t*>* envelope, std::list<zmq::message_t*>* data);
    virtual Json::Value call(const std::string & name, const Json::Value & arguments);
    virtual Json::Value getattr(const std::string & name);
    virtual void setattr(const std::string & name, const Json::Value & value);
    void reply(std::list<zmq::message_t*>* envelope, std::list<zmq::message_t*>* data = nullptr);
    void replyValue(std::list<zmq::message_t*>* envelope, const Json::Value & value, const std::string & id = "");
    void replyError(std::list<zmq::message_t*>* envelope, int errorNo, const std::string & id = "");
    
    zmq::context_t & ctx;
private:
    void serve();
    
    void send(char _command, const std::string & _option = "");
    void _onRequest();
    Json::Value rocCall(const std::string & name, const Json::Value & arguments);
    
    zmq::socket_t * sock;
    std::string brokerEndpoint;
    std::string serviceName;
    std::thread serverThread;
    
    long timeout;
    volatile bool keepGoing;
    int liveness;
};

#endif /* ROC_SERVER_H */