businessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_TELEMETRYRECORDER_BUSINESSLOGIC_HPP
#define RTCTK_TELEMETRYRECORDER_BUSINESSLOGIC_HPP
 
#include "rtctk/componentFramework/stopToken.hpp"
#include <chrono>
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/logger.hpp>
#include <rtctk/componentFramework/oldbIf.hpp>
#include <rtctk/componentFramework/recordingUnit.hpp>
#include <rtctk/componentFramework/rtcComponent.hpp>
#include <rtctk/componentFramework/runnable.hpp>
 
namespace rtctk::telemetryRecorder {
 
using namespace rtctk::componentFramework;
 
using LifeCycle = Runnable<RtcComponent>;

class BusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
    BusinessLogic(const std::string& name, ServiceContainer& services, RecUnitFactoryType factory);
    virtual ~BusinessLogic() = default;
 
    // activities
    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:
    void WaitForStart(StopToken st);
 
    log4cplus::Logger& m_logger;
    std::string m_name;
    ServiceContainer& m_services;
    OldbIf& m_oldb;
    ComponentMetricsIf& m_metrics;
    RecUnitFactoryType m_rec_unit_factory;
    RecUnitListType m_rec_units;
 
    std::string m_session_id;
    std::chrono::utc_clock::time_point m_start_time{};
    std::filesystem::path m_fs_path;
 
    DataPointPath m_dpp_session_id;
    DataPointPath m_dpp_session_files;
    DataPointPath m_dpp_session_files_size;
    DataPointPath m_dpp_session_total_size;
    DataPointPath m_dpp_session_space_info_cap;
    DataPointPath m_dpp_session_space_info_free;
    DataPointPath m_dpp_session_space_info_avail;
};
 
}  // namespace rtctk::telemetryRecorder
 
#endif  // RTCTK_TELEMETRYRECORDER_BUSINESSLOGIC_HPP