WsFsDaemonClient.h

Go to the documentation of this file.

//#ifdef HAS_DAEMON
#ifndef WS_FS_DAEMON_CLIENT_H__
#define WS_FS_DAEMON_CLIENT_H__
#include "WsAbstractFsClient.h"
#include <zmq.hpp>
#include <json/json.h>
#include <json/reader.h>
#include <json/writer.h>
#include <json/value.h>
#include <Compression/WsCompressor.h>
#include <Compression/WsDecompressor.h>

#include <boost/thread.hpp>


class WsFsDaemonClient: public WsAbstractFsClient {
public:
  WsFsDaemonClient(const std::string& id, const std::string& pass, const std::string& ip);

  ~WsFsDaemonClient();

  int clearServerCache();

  int load();

  int getPermissions(const std::string& p);

  const WsNodeProperties* getProperties(const std::string& p);

  std::string getProperty(const std::string& section, const std::string& p, const std::string& prop);

  const std::string& getSurname() const;

  const std::string& getFirstName() const;

  const std::string& getEmail() const;

  int getLock(const std::string& path);

  int putLock(const std::string& path);

  int isLocked(const std::string& path, std::string& uid);

  NodePtr getAccessRoot(const bool& forceUpdate = false);

  vector<WsResultItem> getSearchResults(const std::string& terms);

  std::set<string> getAllGroups();

  const std::string getRootPath();

  int saveProperties(WsNodeProperties* props, const std::string& path);

  int createNode(const string& path, int type);

  int deleteNode(const string& path);

  int renameNode(const string& path, const string& newPath);

  int saveProperty(const std::string& path, const std::string& section, const std::string& attr, const std::string& val);

  bool isEditor();

  bool isAdministrator();

  std::vector<std::string> getTemplatesList(const std::string& path);


private:
  int authentify();

  int send(const std::string&  message);

  int receive(std::string& receivedData);

  int receiveAuthAnswer();

  int receiveSuccessCode();

  int receivePermissions();

  bool receiveBoolean();

  int receiveInt();

  const std::string receiveString();

  const WsNodeProperties* receiveProperties();

  const std::string receiveProperty();

  NodePtr receiveAccessItems();

  vector<WsResultItem> receiveSearchResults();

  int receiveIsLockedStatus(std::string uid);

  std::set<string> receiveAllGroups();

  std::string rawDataToString(zmq::message_t& msg);

  int parse(const std::string& s);

  int threadUpdate();

  std::string m_uid;
  std::string m_pass;
  std::string m_ip;
  std::string m_email;
  std::string m_name;
  std::string m_surname;

  std::string m_host;
  std::string m_port;
  std::string m_proto;
  WsGlobalProperties* m_conf;
  Json::Reader m_reader;
  Json::Value m_root;

  bool m_compress;
  NodePtr m_accessRoot;
  NodePtr m_menuRoot;
  std::string m_accessTreeStamp;
  std::string m_menuTreeStamp;
  std::string m_rootPath;
  int m_isAdmin;
  int m_isEditor;

  bool m_listen;
  zmq::socket_t* m_sock;
  WsCompressor* m_compressor;
  WsDecompressor* m_decompressor;
  static zmq::context_t* m_context;
  boost::mutex* m_sendMutex;
  boost::thread* m_updateThread;

};

#endif
//#endif