deploymentDaemonBusinessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP
#define RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP
 
#include "deploymentDaemonLifeCycle.hpp"
#include "rtctk/componentFramework/serviceContainer.hpp"
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/persistentRepoIf.hpp>
#include <rtctk/componentFramework/serviceDiscovery.hpp>
 
namespace rtctk::deploymentDaemon {
 
using LifeCycle = DeploymentDaemonLifeCycle;
 
class DeploymentDaemonBusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
    DeploymentDaemonBusinessLogic(const std::string& name,
                                  ServiceContainer& services,
                                  const elt::mal::Uri& sde);
 
    virtual ~DeploymentDaemonBusinessLogic() = default;
 
    void ActivityDeploying(StopToken st, std::string args) override;
    void ActivityUndeploying(StopToken st) override;
 
    std::string ActionGetActiveDeployment() override;
    std::string ActionGetDescription() override;
 
    std::vector<std::string> ActionGetDeploymentSets() override;
 
    std::vector<std::string> ActionGetComponents() override;
 
    std::vector<std::string> ActionGetActiveComponents() override;
 
    void ActionStartComponent(std::string component_name) override;
    void ActionStopComponent(std::string component_name) override;
 
    void ActivityStarting(cfw::StopToken st) override;
 
protected:
    void StartComponent(const std::string& component_name, const DataPointPath& depl_set_path);
 
    void StopComponent(const std::string& component_name, const bool check_error = true);
 
    void GetDeploymentSets();
 
    log4cplus::Logger& m_logger;
 
    const std::string m_name;
 
    rtctk::componentFramework::ServiceContainer& m_services;
 
    rtctk::componentFramework::ServiceDiscovery& m_service_discovery;
 
    std::unique_ptr<rtctk::componentFramework::PersistentRepoIf> m_persistent_repo;
 
    rtctk::componentFramework::ComponentMetricsIf& m_component_metrics;  // TBD if we really need
 
    std::vector<std::string> m_deployment_sets;
 
    std::string m_active_deployment_set;
 
    std::string m_description;
 
    std::vector<std::string> m_components;
 
    elt::mal::Uri m_sde;
};
 
}  // namespace rtctk::deploymentDaemon
 
#endif  // RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP