#ifndef CBMTRDRAWBUCHDATA_H
#define CBMTRDRAWBUCHDATA_H

#include "FairTask.h"
#include "CbmHistManager.h"
#include "CbmSpadicRawMessage.h"
#include "CbmTrbRawMessage.h"
#include "TClonesArray.h"

class CbmTrdRawBuchData : public FairTask
{
  public:

    /** Default constructor **/
    CbmTrdRawBuchData();

    /** Constructor with parameters (Optional) **/
    //  CbmTrdRawBuchData(Int_t verbose);


    /** Destructor **/
    ~CbmTrdRawBuchData();


    /** Initiliazation of task at the beginning of a run **/
    virtual InitStatus Init();

    /** ReInitiliazation of task when the runID changes **/
    virtual InitStatus ReInit();

    /** Executed for each event. **/
    virtual void Exec(Option_t* opt);

    /** Load the parameter container from the runtime database **/
    virtual void SetParContainers();

    /** Finish task called at the end of the run **/
    virtual void Finish();
    virtual Int_t GetSysCoreID(CbmSpadicRawMessage* raw);
    virtual Int_t GetSpadicID(CbmSpadicRawMessage* raw);
    virtual Int_t GetModuleID(CbmSpadicRawMessage* raw);
    virtual Int_t GetLayerID(CbmSpadicRawMessage* raw);
    virtual Int_t GetSectorID(CbmSpadicRawMessage* raw);
    virtual Int_t GetRowID(CbmSpadicRawMessage* raw);
    virtual Int_t GetColumnID(CbmSpadicRawMessage* raw);
    virtual Int_t GetCombiID(CbmSpadicRawMessage* raw);
    virtual Int_t GetChannelOnPadPlane(Int_t SpadicChannel);
    virtual Bool_t FragmentedPulseTest(CbmSpadicRawMessage* raw);
    virtual Int_t GetMaximumAdc(CbmSpadicRawMessage* raw);

  private:

    /** Input array from previous already existing data level **/
    TClonesArray* fRawSpadic;
    TClonesArray* fNxyterRaw;
    TClonesArray* fTrbRaw;
   /** Output array **/
    TClonesArray* fDigis; //! TRD digis
    TClonesArray* fClusters;
    Int_t fiDigi;
    Int_t fiCluster;
    CbmHistManager* fHM;
    Int_t fmaxTimeGlobal;
    Int_t fmaxTimeGroup[3][6];
    ULong_t fmaxFullTimeGlobal;
    ULong_t fmaxFullTimeGroup[3][6];
    ULong_t flastDlmTriggerTime[3][6][15];
    Int_t fEpoch;
    Int_t flastEpoch;
    Int_t fSuperEpoch;
    Int_t flastSuperEpoch;
    Int_t fSpadicMessageCounter;
    Int_t fNxyterMessageCounter;
    Int_t fTrbMessageCounter;
    Int_t fContainerCounter;
    Int_t fInfoCounter;
    Int_t fHitCounter;
    Int_t fMultiHitCounter;
    Int_t fErrorCounter;
    Int_t fLostHitCounter;
    Int_t fDoubleCounter;
    Int_t fFragmentedCounter;
    std::map<Int_t, std::map<Int_t, std::map<Int_t, CbmSpadicRawMessage*> > > fSys0Spa0Buffer;//<SuperEpoch <Epoch <Time, SpadicMessage> > > > 
    std::map<Int_t, std::map<Int_t, std::map<Int_t, CbmSpadicRawMessage*> > > fSys0Spa1Buffer;//<SuperEpoch <Epoch <Time, SpadicMessage> > > > 
    std::map<TString, std::map<Int_t, std::map<Int_t, CbmSpadicRawMessage*> > > fTimeBuffer;//<ASIC ID "Syscore%d_Spadic%d"  <Time, <CombiId, SpadicMessage> > > > 
    std::map<TString, std::map<ULong_t, std::map<Int_t, CbmSpadicRawMessage*> > > fFullTimeBuffer;// <ASIC ID "Syscore%d_Spadic%d"<Time, <CombiId, SpadicMessage> > >
    std::map<TString, std::map<ULong_t, std::multimap<Int_t, CbmSpadicRawMessage*> > > fFullTimeBufferAll;// <ASIC ID "Syscore%d_Spadic%d"<Time, <CombiId, SpadicMessage> > >
    //std::map<Int_t, 
     std::map<Int_t, std::map<Int_t, std::map<Int_t, std::map<Int_t, CbmTrbRawMessage*> > > > fTrbBuffer;// sourceA < epoch < chId < Coarse, TrbMessage > > > > >
    //std::map<Int_t, CbmTrbRawMessage*> fTrbBuffer;
    /** Output array to  new data level**/
    //  TClonesArray* <OutputDataLevel>;

     void CleanUpBuffers();

    void CreateHistograms();

    void Clusterizer();

    void TimeClustering2015CernSPS();

    CbmTrdRawBuchData(const CbmTrdRawBuchData&);
    CbmTrdRawBuchData operator=(const CbmTrdRawBuchData&);

    ClassDef(CbmTrdRawBuchData,2);
};

#endif