/**
 * CbmDeviceMonitorTof.h
 *
 * @since 2020-04-15
 * @author P.-A Loizeau
 */

#ifndef CBMDEVICEMONITORTOF_H_
#define CBMDEVICEMONITORTOF_H_

#include "FairMQDevice.h"

#include "Timeslice.hpp"

#include "TMessage.h"
#include "Rtypes.h"
#include "TObjArray.h"

#include <vector>
#include <map>
#include <chrono>

class TList;
class CbmMcbm2018MonitorAlgoTof;

class CbmDeviceMonitorTof: public FairMQDevice
{
   public:
      CbmDeviceMonitorTof();
      virtual ~CbmDeviceMonitorTof();

   protected:
      virtual void InitTask();
      bool HandleData(FairMQMessagePtr&, int);

   private:
      /// Constants
      static const uint16_t kusSysIdTof = 0x60;
      static const uint16_t kusSysIdT0  = 0x90;

      /// Control flags
      Bool_t fbIgnoreOverlapMs       = kFALSE;      //! Ignore Overlap Ms: all fuOverlapMsNb MS at the end of timeslice
      Bool_t fbDebugMonitorMode      = kFALSE; //! Switch ON the filling of a additional set of histograms
      Bool_t fbIgnoreCriticalErrors  = kTRUE; //! If ON not printout at all for critical errors
      Bool_t fbComponentsAddedToList = kFALSE;

      /// User settings parameters
      std::string fsChannelNameDataInput = "tofcomponent";
      std::string fsChannelNameHistosInput  = "histogram-in";
      std::string fsChannelNameHistosConfig = "histo-conf";
      std::string fsChannelNameCanvasConfig = "canvas-conf";
      uint32_t    fuHistoryHistoSize = 3600;
      uint32_t    fuMinTotPulser     =  185;
      uint32_t    fuMaxTotPulser     =  195;
      int32_t     fiGdpbIndex        =   -1;
      uint32_t    fuPublishFreqTs    =  100;
      double_t    fdMinPublishTime   =    0.5;
      double_t    fdMaxPublishTime   =    5.0;

      /// List of MQ channels names
      std::vector< std::string > fsAllowedChannels = { fsChannelNameDataInput };

      /// Parameters management
      TList* fParCList = nullptr;

      /// Statistics & first TS rejection
      uint64_t fulNumMessages = 0;
      uint64_t fulTsCounter   = 0;
      std::chrono::system_clock::time_point fLastPublishTime = std::chrono::system_clock::now();

      /// Processing algo
      CbmMcbm2018MonitorAlgoTof * fMonitorAlgo;

      /// Array of histograms to send to the histogram server
      TObjArray fArrayHisto = {};
      /// Vector of string pairs with ( HistoName, FolderPath ) to send to the histogram server
      std::vector< std::pair< std::string, std::string > > fvpsHistosFolder = {};
      /// Vector of string pairs with ( CanvasName, CanvasConfig ) to send to the histogram server
      /// Format of Can config is "NbPadX(U);NbPadY(U);ConfigPad1(s);....;ConfigPadXY(s)"
      /// Format of Pad config is "GrixX(b),GridY(b),LogX(b),LogY(b),LogZ(b),HistoName(s),DrawOptions(s)"
      std::vector< std::pair< std::string, std::string > > fvpsCanvasConfig = {};

      bool IsChannelNameAllowed(std::string channelName);
      Bool_t InitContainers();
      Bool_t DoUnpack(const fles::Timeslice& ts, size_t component);
      void Finish();
      bool SendHistograms();
};

// special class to expose protected TMessage constructor
class CbmMQTMessage : public TMessage
{
  public:
    CbmMQTMessage(void* buf, Int_t len)
        : TMessage(buf, len)
    {
        ResetBit(kIsOwner);
    }
};


#endif /* CBMDEVICEMONITORTOF_H_ */