#ifndef PROCESS_LIBPROCESS_EXT_INCLUDE_DEFINITION_RECEIVER_HPP
#define PROCESS_LIBPROCESS_EXT_INCLUDE_DEFINITION_RECEIVER_HPP

#include <asap/asap.hpp>

#include <process/process_collection.hpp>
#include "process_definition.hpp"

namespace process::controller {
class DefinitionListener;

class DefinitionReceiver {
public:
    DefinitionReceiver(std::shared_ptr<ProcessCollection> collection, std::shared_ptr<asap::Participant> participant, const std::string& topic_name);
    virtual ~DefinitionReceiver() = default;

protected: //for testing purposes
    std::shared_ptr<DefinitionListener> m_def_listener;
    std::shared_ptr<asap::Participant> m_participant;
    std::shared_ptr<asap::Subscriber<ProcessDefinition>> m_subscriber;
};
}

#endif //PROCESS_LIBPROCESS_EXT_INCLUDE_DEFINITION_RECEIVER_HPP