WsFsDaemon.h

Go to the documentation of this file.

#ifndef WS_FSDAEMON_H__
#define WS_FSDAEMON_H__
#include <FileSystemTree/WsFileSystemTree.h>
#include <Updater/WsFsTreeUpdater.h>
#include <ConfigManager/WsGlobalProperties.h>
#include <Auth/WsAuthenticator.h>
#include <Compression/WsCompressor.h>
#include <Compression/WsDecompressor.h>
#include <FsTreeOp/WsFsTreeOperations.h>

#include "WsUserSession.h"

#include <json/json.h>
#include <json/reader.h>
#include <json/writer.h>
#include <json/value.h>

#include <boost/lexical_cast.hpp>

#include <zmq.hpp>

#include <iostream>
#include <set>
#include <vector>

class WsFsDaemon {
public:

  enum DaemonStatus {
    Success,
    Failure,
    NotLogged,
    NoAccess
  };
  WsFsDaemon(WsGlobalProperties* props);

  ~WsFsDaemon();

  DaemonStatus bind(unsigned int numWorkers = 1);

  DaemonStatus workerRoutine();

private:

  DaemonStatus send(zmq::socket_t& sock, const std::string& s);

  DaemonStatus receive(zmq::socket_t& sock, std::string& receivedData);

  DaemonStatus parse(const std::string& s, Json::Value& root);

  DaemonStatus handleRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleAuthRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleGetLockRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handlePutLockRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleIsLockedRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleAccessTreeRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handlePermRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handlePropRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleAllGroupsRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handlePropsRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleSearchRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleClearCache(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleIsAdminRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleIsEditorRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleSavePropertiesRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleSavePropertyRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleCreateNodeRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleRenameNodeRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleDeleteNodeRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleRootPathRequest(zmq::socket_t& sock, Json::Value& root);

  DaemonStatus handleGetTreeVersion(zmq::socket_t& sock, Json::Value& root);

  string rawDataToString(zmq::message_t& msg);

  bool isActiveSession(const std::string& uid, const std::string& pass, const std::string& ip);

  WsGlobalProperties* m_conf;

  bool m_listening;

  WsFsTreeOperations* m_operation;

  map<string, WsUserSession* > m_userMap;

  set<string> m_allGroups;

  bool m_compress;

  WsCompressor* m_compressor;

  WsDecompressor* m_decompressor;

  zmq::context_t* m_context;
};

#endif