DRCEFunctionalObject.hpp

Go to the documentation of this file.

#ifndef DRCE_FUNCTIONAL_OBJECT_HPP
#define DRCE_FUNCTIONAL_OBJECT_HPP

#include <iostream>

#include "DRCEInputJsonMessage.hpp"
#include "DRCEOutputJsonMessage.hpp"
#include "DRCEFunctionalObjectBase.hpp"
#include "DRCEResultData.hpp"
#include "CustomMessage.hpp"

namespace HCE
{
namespace drce
{
//-----------------------------------------------------------------------------
class DRCEFunctionalObject : public DRCEFunctionalObjectBase
{
public:
  explicit DRCEFunctionalObject(const std::string& nodeName_, const std::string& homeDir_);
  virtual ~DRCEFunctionalObject(void) {}

  std::string Process(const std::string& json);
  DRCEOutputJsonMessage Process(DRCEInputJsonMessage& inputJsonMessage);

  void setNodeName(const std::string& nodeName_) {nodeName=nodeName_;}
  std::string getNodeName(void) const {return nodeName;}

  bool setHomeDir(const std::string& homeDir_);
  std::string getHomeDir(void) const {return homeDir;}

  void resetError(void);
protected:
  std::string getDefaultJSON(void);
  void makeFilesBefore(DRCEFilesList& filesList) throw (Poco::Exception);
  void makeFilesAfter(DRCEFilesList& filesList, DRCEResultDataItem& resultDataItem) throw (Poco::Exception);
  void makeSetEnviroment(const std::vector<std::pair<std::string, std::string> >& enviroments) throw (Poco::Exception);
private:
  std::string getFullFileName(const std::string& fileName);
  void applyInputStream(std::stringstream& cmd, std::stringstream& istr);

  std::string nodeName;
  std::string homeDir;

  MessagesCollection messagesCollection;
  CustomMessage message;
protected:
  void makeProcessHostShell(DRCEInputJsonMessage& inputJsonMessage, DRCEResultDataItem& resultDataItem) throw (Poco::Exception);
  void makeProcessSsh(DRCEInputJsonMessage& inputJsonMessage, DRCEResultDataItem& resultDataItem) throw (Poco::Exception);

  typedef DRCEFunctionalObjectBase inherited;
};
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
} // namespace drce
} // namespace HCE

#endif // DRCE_FUNCTIONAL_OBJECT_HPP