DataSourcePlugin.h

Go to the documentation of this file.

#ifndef MARLINMT_DATASOURCEPLUGIN_h
#define MARLINMT_DATASOURCEPLUGIN_h 1

// -- marlinmt headers
#include <marlinmt/Component.h>
#include <marlinmt/Logging.h>

// -- std headers
#include <functional>
#include <memory>
#include <string>

namespace marlinmt {

  class Application ;
  class EventStore ;
  class RunHeader ;

  class DataSourcePlugin : public Component {
  public:
    using EventFunction = std::function<void(std::shared_ptr<EventStore>)> ;
    using RunHeaderFunction = std::function<void(std::shared_ptr<RunHeader>)> ;

  public:
    virtual ~DataSourcePlugin() = default ;

    DataSourcePlugin( const std::string &dstype ) ;

    const std::string &type() const ;

    const std::string &description() const ;

    virtual bool readOne() = 0 ;

    virtual void readAll() ;

    void onEventRead( EventFunction func ) ;

    void onRunHeaderRead( RunHeaderFunction func ) ;

  protected:
    void processRunHeader( std::shared_ptr<RunHeader> rhdr ) ;

    void processEvent( std::shared_ptr<EventStore> event ) ;
    
    virtual void initialize() override ;

  protected:
    std::string              _description {"No description"} ;

  private:
    EventFunction            _onEventRead {nullptr} ;
    RunHeaderFunction        _onRunHeaderRead {nullptr} ;
  };

}

#endif