action.hpp

Go to the documentation of this file.

#ifndef OCM_SERVER_DAQ_TASKS_HPP
#define OCM_SERVER_DAQ_TASKS_HPP

#include <typeinfo>
#include <functional>

#include <rad/Logger.hpp>
#include <rad/ActionMgr.hpp>

#include "daq/events.rad.hpp"
#include "daq/tasks.rad.hpp"


namespace daq {

class Context;

template<typename EVENT>
std::function<void(rad::AnyEvent const&)>
WrapAction(std::function<void(EVENT const&)> action) {
    return [action](rad::AnyEvent const& ev) {
        if (typeid(ev) == typeid(EVENT)) {
            return action(reinterpret_cast<EVENT const&>(ev));
        } else {
            // @todo: Log something
            RAD_LOG_ERROR() << "WrapAction called with unexpected event. Expected "
                            << typeid(EVENT).name() << " but got " << typeid(ev).name();
        }
    };
}

class Tasks : public Action {
public:
    Tasks();

    void PrepareDaq(daq::PrepareDaq const& ev) override;

    void Test(rad::AnyEvent const& ev) override{};
};

//void CreateTasks(rad::ActionMgr&, DaqContext& ctx, Tasks&);

} // namespace daq
#endif // #ifndef OCM_SERVER_DAQ_TASKS_HPP