businessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_EXAMPLEDATATASK_BUSINESSLOGIC_HPP
#define RTCTK_EXAMPLEDATATASK_BUSINESSLOGIC_HPP
 
#include "computation.hpp"
 
#include <rtctk/componentFramework/eventServiceIf.hpp>
#include <rtctk/componentFramework/rtcComponent.hpp>
#include <rtctk/componentFramework/runnable.hpp>
#include <rtctk/componentFramework/runtimeRepoIf.hpp>
 
namespace rtctk::exampleDataTask {
 
using namespace rtctk::componentFramework;
 
using LifeCycle = Runnable<RtcComponent>;
 
class BusinessLogic : public LifeCycle::BizLogicIf, public Computation::ResultIf {
public:
    using ComponentType = LifeCycle;
 
    BusinessLogic(const std::string& name, ServiceContainer& services);
 
    // activities
    void ActivityStarting(StopToken st) override;
    void ActivityInitialising(StopToken st) override;
    void ActivityEnabling(StopToken st) override;
    void ActivityDisabling(StopToken st) override;
    void ActivityGoingRunning(StopToken st) override;
    void ActivityGoingIdle(StopToken st) override;
    void ActivityRunning(StopToken st) override;
    void ActivityRecovering(StopToken st) override;
    void ActivityUpdating(StopToken st, const JsonPayload& args) override;
 
private:
    void OnResultAvailable(const Computation::Result& result) override;
 
    std::string m_name;
    ServiceContainer& m_services;
    RuntimeRepoIf& m_rtr;
    EventServiceIf& m_esv;
 
    // event publisher for all kinds of configuration events
    std::unique_ptr<EventPublisherIf> m_ev_pub;
 
    // rtr datapoints (inputs)
    DataPointPath m_dp_queue_name;
    DataPointPath m_dp_thread_policies;
    DataPointPath m_dp_samples_to_read;
    DataPointPath m_dp_samples_to_skip;
    DataPointPath m_dp_sample_timeout;
    DataPointPath m_dp_slopes;
    DataPointPath m_dp_modes;
    DataPointPath m_dp_s2m;
 
    // rtr datapoints (outputs)
    DataPointPath m_dp_avg_slopes;
    DataPointPath m_dp_avg_modes;
 
    std::unique_ptr<Computation> m_computation;
};
 
}  // namespace rtctk::exampleDataTask
 
#endif  // RTCTK_EXAMPLEDATATASK_BUSINESSLOGIC_HPP