businessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_EXAMPLEDATATASK_MEASURETEL_BUSINESSLOGIC_HPP
#define RTCTK_EXAMPLEDATATASK_MEASURETEL_BUSINESSLOGIC_HPP
 
#include "computation.hpp"
 
#include "rtctk/componentFramework/measurable.hpp"
#include "rtctk/componentFramework/rtcComponent.hpp"
#include "rtctk/componentFramework/runtimeRepoIf.hpp"
 
namespace rtctk::exampleDataTask {
 
using namespace rtctk::componentFramework;
 
using LifeCycle = Measurable<RtcComponent>;
 
class BusinessLogic : public LifeCycle::BizLogicIf, public Computation::ResultIf {
public:
    using ComponentType = LifeCycle;
 
    BusinessLogic(const std::string& name, ServiceContainer& services);
 
    void ActivityInitialising(StopToken st) override;
    void ActivityEnabling(StopToken st) override;
    void ActivityDisabling(StopToken st) override;
    void ActivityUpdating(StopToken st, const JsonPayload& args) override;
    JsonPayload ActivityMeasuring(StopToken st, const JsonPayload& arg) override;
 
private:
    void OnResultAvailable(const Computation::Result& result) override;
    Computation::Algorithm ParseAlgorithm(const JsonPayload& arg);
 
    // used services
    ServiceContainer& m_services;
    RuntimeRepoIf& m_rtr;
 
    // rtr datapoints
    DataPointPath m_dp_queue_name;
    DataPointPath m_dp_thread_policies;
    DataPointPath m_dp_samples_to_read;
    DataPointPath m_dp_sample_timeout;
    DataPointPath m_dp_result;
 
    std::unique_ptr<Computation> m_computation;
};
 
}  // namespace rtctk::exampleDataTask
 
#endif  // RTCTK_EXAMPLEDATATASK_MEASURETEL_BUSINESSLOGIC_HPP