#ifndef HADAQ_SUBPROCESSOR_H
#define HADAQ_SUBPROCESSOR_H

#include "base/StreamProc.h"

#include "hadaq/definess.h"

#include <map>


namespace hadaq {

   class SubProcessor;
   class TrbProcessor;
   class HldProcessor;

   /** map of sub processors */
   typedef std::map<unsigned,SubProcessor*> SubProcMap;

   /** \brief Abstract processor of HADAQ sub-sub-event
     *
     * \ingroup stream_hadaq_classes
     *
     * Defines some basic API and introduces several common histograms **/

   class SubProcessor : public base::StreamProc {

      friend class TrbProcessor;

      protected:
         TrbProcessor *fTrb{nullptr};   ///<! pointer on TRB processor
         unsigned fSeqeunceId{0}; ///<! sequence number of processor in TRB
         bool fIsTDC{false};          ///<! indicate when it is TDC, to avoid dynamic_cast

         base::H1handle *fMsgPerBrd{nullptr};  ///<! messages per board - from TRB
         base::H1handle *fErrPerBrd{nullptr};  ///<! errors per board - from TRB
         base::H1handle *fHitsPerBrd{nullptr}; ///<! data hits per board - from TRB
         base::H2handle *fCalHitsPerBrd{nullptr}; ///<! calibration hits per board - from TRB
         base::H2handle *fToTPerBrd{nullptr};  ///<! ToT per board - from TRB

         bool fNewDataFlag{false};  ///<! flag used by TRB processor to indicate if new data was added
         bool fPrintRawData{false}; ///<! if true, raw data will be printed
         bool fCrossProcess{false}; ///<! if true, AfterFill will be called by Trb processor

         SubProcessor(TrbProcessor *trb, const char* nameprefix, unsigned subid);

         /** Before fill,
          * used to fill different raw histograms during first scan */
         virtual void BeforeFill() {}

         /** After fill,
          * used to fill different raw histograms during first scan */
         virtual void AfterFill(SubProcMap* = nullptr) {}

         /** Method will be called by TRB processor if SYNC message was found
          * One should change 4 first bytes in the last buffer in the queue */
         virtual void AppendTrbSync(uint32_t) {}

         /** Set new data flag, used by TrbProcessor */
         void SetNewDataFlag(bool on) { fNewDataFlag = on; }
         /** is new data flag, used by TrbProcessor */
         bool IsNewDataFlag() const { return fNewDataFlag; }

         void AssignPerBrdHistos(TrbProcessor *trb, unsigned seqid);

      public:

         /** destructor */
         virtual ~SubProcessor() {}

         void UserPreLoop() override;

         /** is TDC */
         inline bool IsTDC() const { return fIsTDC; }

         /** set print raw data */
         void SetPrintRawData(bool on = true) { fPrintRawData = on; }
         /** is print raw data */
         bool IsPrintRawData() const { return fPrintRawData; }

         /** is cross process */
         bool IsCrossProcess() const { return fCrossProcess; }

         HldProcessor *GetHLD() const;

   };

}

#endif