businessLogic.hpp

Go to the documentation of this file.

 
#ifndef DDT_SERVER_BUSINESSLOGIC_HPP
#define DDT_SERVER_BUSINESSLOGIC_HPP
 
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/rtcComponent.hpp>
#include <rtctk/componentFramework/runnable.hpp>
#include <rtctk/componentFramework/stopToken.hpp>
 
#include <rtctk/ddtServer/ddtForwarder.hpp>
 
#include <memory>
 
namespace rtctk::ddtServer {
 
using namespace rtctk::componentFramework;
using LifeCycle = Runnable<RtcComponent>;
 
class BusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
    using StopToken = rtctk::componentFramework::StopToken;
    using JsonPayload = rtctk::componentFramework::JsonPayload;
    using ServiceContainer = rtctk::componentFramework::ServiceContainer;
 
    BusinessLogic(const std::string& name,
                  ServiceContainer& services,
                  DdtForwarderFactoryType factory);
    virtual ~BusinessLogic() = default;
 
    void ActivityStarting(StopToken st) override;
    void ActivityInitialising(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:
    std::string m_name;
    ServiceContainer& m_services;
    ComponentMetricsIf& m_metrics;
 
    DdtForwarderFactoryType m_factory;
    DdtForwarderListType m_ddt_forwarders;
};
 
}  // namespace rtctk::ddtServer
 
#endif  // DDT_SERVER_BUSINESSLOGIC_HPP