// -----------------------------------------------------------------------------
// -----                                                                   -----
// -----                        CbmTSUnpackMuch                            -----
// -----                 Created 11.11.2016 by V. Singhal and A. Kumar     -----
// -----                                                                   -----
// -----------------------------------------------------------------------------

#ifndef CBMTSUNPACKMUCH_H
#define CBMTSUNPACKMUCH_H

#include "Timeslice.hpp"
#include "rocMess_wGet4v1.h"

#include "CbmTSUnpack.h"
#include "CbmNxyterRawMessage.h"
//#include "CbmSpsMuchDigi.h" //Created a new Much Digi File for the SPS beamtime2016

#include "CbmMuchBeamTimeDigi.h" //Created a new Much Digi File for the SPS beamtime2016
#include "CbmTbDaqBuffer.h"

#include "TClonesArray.h"

#include <vector>
#include <map>

//class CbmFHodoUnpackPar;
class CbmMuchUnpackPar; // Unpaker Class which will read the MuchUnpackPar.par
//class CbmMuchBeamTimeDigi;
class CbmTSUnpackMuch: public CbmTSUnpack
{
 public:
  
  CbmTSUnpackMuch();
  virtual ~CbmTSUnpackMuch();
  
  virtual Bool_t Init();

  virtual Bool_t DoUnpack(const fles::Timeslice& ts, size_t component);

  virtual void Reset();
  
  virtual void Finish();
  
  void SetParContainers();
  
  Bool_t InitContainers();
  
  Bool_t ReInitContainers();
  
  void FillOutput(boost::any);
  
  void CreateRawMessageOutput(Bool_t val) {fCreateRawMessage=val;}
  
  //  Int_t CreateAddress(Int_t rocId, Int_t febId, Int_t stationId, Int_t layerId, Int_t sideId, Int_t moduleId, Int_t channelId);

  void SetMsOverlap(size_t uOverlapMsNb = 1) { fuOverlapMsNb = uOverlapMsNb; }
  size_t GetMsOverlap()                      { return fuOverlapMsNb; }
  
 private:
  size_t fuOverlapMsNb;      /** Ignore Overlap Ms: all fuOverlapMsNb MS at the end of timeslice **/
  
  std::vector<int> fMsgCounter;
  std::map<UInt_t, UInt_t> fNdpbIdIndexMapA;
  std::map<UInt_t, UInt_t> fNdpbIdIndexMapB;

  Int_t fMuchStationMapX[16][128]; //fMuchStationMap for map of row number via getX
  Int_t fMuchStationMapY[16][128]; // For map of column number via getY>
  
  //CbmHistManager* fHM;  ///< Histogram manager
  std::map<Int_t, std::map<Int_t, UInt_t> > fCurrentEpoch; // Current epoch (first epoch in the stream initialises the map item)
  //  std::map<Int_t, UInt_t> fCurrentEpoch; // Current epoch (first epoch in the stream initialises the map item)
  Int_t fNofEpochs; /** Current epoch marker for each ROC **/
  ULong_t fCurrentEpochTime;     /** Time stamp of current epoch **/
  Double_t fdStartTime; /** Time of first valid hit (epoch available), used as reference for evolution plots**/
  
  Int_t fEquipmentId;
  
  TClonesArray* fMuchRaw;
  std::vector<CbmMuchBeamTimeDigi>* fMuchDigi;
  CbmNxyterRawMessage* fRawMessage;  
  //CbmSpsMuchDigi* fDigi;  //If CbmSpsMuchDigi will not work then will use this.
  CbmMuchBeamTimeDigi* fDigi;  
  CbmTbDaqBuffer* fBuffer;
  
  Bool_t fCreateRawMessage;
  
  CbmMuchUnpackPar* fUnpackPar;    //!
  
  void FillHitInfo(ngdpb::Message);
  void FillEpochInfo(ngdpb::Message);
  
  CbmTSUnpackMuch(const CbmTSUnpackMuch&);
  CbmTSUnpackMuch operator=(const CbmTSUnpackMuch&);
  
  ClassDef(CbmTSUnpackMuch, 1)
    };

#endif