// $Id$
//
//    File: JEventProcessor_L3proc.h
// Created: Wed Aug 21 17:22:31 EDT 2013
// Creator: davidl (on Darwin harriet.local 11.4.2 i386)
//

#ifndef _JEventProcessor_L3proc_
#define _JEventProcessor_L3proc_

#include <pthread.h>
#include <stdint.h>
#include <fstream>

#include <JANA/JEventProcessor.h>
#include <JANA/JEventLoop.h>

#include <DAQ/Df250Config.h>
#include <DAQ/Df250PulseData.h>
#include <DAQ/Df250PulseIntegral.h>
#include <DAQ/Df250TriggerTime.h>
#include <DAQ/Df250WindowRawData.h>
#include <DAQ/Df250Config.h>
#include <DAQ/Df125PulseIntegral.h>
#include <DAQ/Df125TriggerTime.h>
#include <DAQ/Df125WindowRawData.h>
#include <DAQ/Df125CDCPulse.h>
#include <DAQ/Df125FDCPulse.h>
#include <DAQ/Df125Config.h>
#include <DAQ/DF1TDCTriggerTime.h>
#include <DAQ/DF1TDCHit.h>
#include <DAQ/DF1TDCConfig.h>
#include <DAQ/DCAEN1290TDCConfig.h>
#include <DAQ/DCAEN1290TDCHit.h>
#include <DAQ/DEPICSvalue.h>
#include <DAQ/DEventTag.h>
#include <DAQ/DL1Info.h>

#include "L3farm_out.h"

class JEventProcessor_L3proc:public jana::JEventProcessor{
	public:
		JEventProcessor_L3proc(L3farm_out *l3out);
		~JEventProcessor_L3proc();
		const char* className(void){return "JEventProcessor_L3proc";}
		
		bool COMPACT;
		bool PREFER_EMULATED;
		bool DEBUG_FILES;
		bool APPLY_HIT_FILTERS;
		vector<uint64_t> SAVE_EVENTS;
		
		void WriteEventToBuffer(JEventLoop *loop, vector<uint32_t> &buff);

		void ApplyHitFilters(JEventLoop *loop
			, vector<const Df250PulseData*    > &f250pds
			, vector<const Df250PulseIntegral*> &f250pis
			, vector<const Df250WindowRawData*> &f250wrds
			, vector<const Df125CDCPulse*     > &f125cdcpulses
			, vector<const Df125FDCPulse*     > &f125fdcpulses
			, vector<const DCAEN1290TDCHit*   > &caen1290hits
			, vector<const DF1TDCHit*         > &F1hits);

		void WriteCAEN1290Data(vector<uint32_t> &buff
		  , vector<const DCAEN1290TDCHit*>    &caen1290hits
		  , vector<const DCAEN1290TDCConfig*> &caen1290configs);

		void WriteF1Data(vector<uint32_t> &buff
		  , vector<const DF1TDCHit*>          &F1hits
		  , vector<const DF1TDCTriggerTime*>  &F1tts
		  , vector<const DF1TDCConfig*>       &F1configs);

		void Writef250Data(vector<uint32_t> &buff
		  , vector<const Df250PulseData*>     &f250pds
		  , vector<const Df250PulseIntegral*> &f250pis
		  , vector<const Df250TriggerTime*>   &f250tts
		  , vector<const Df250WindowRawData*> &f250wrds
		  , vector<const Df250Config*>        &f250configs);

		void Writef125Data(vector<uint32_t> &buff
		  , vector<const Df125PulseIntegral*> &f125pis
		  , vector<const Df125CDCPulse*>      &f125cdcpulses
		  , vector<const Df125FDCPulse*>      &f125fdcpulses
		  , vector<const Df125TriggerTime*>   &f125tts
		  , vector<const Df125WindowRawData*> &f125wrds
		  , vector<const Df125Config*>        &f125configs);

		void WriteEPICSData(vector<uint32_t> &buff
		  , vector<const DEPICSvalue*> epicsValues);

		void WriteBORData(vector<uint32_t> &buff, JEventLoop *loop);

		void WriteTSSyncData(vector<uint32_t> &buff, const DL1Info *l1info);

		void WriteEventTagData(vector<uint32_t> &buff
		  , uint64_t event_status
		  , const DL3Trigger* l3trigger);

	protected:
		jerror_t init(void);                        ///< Called once at program start.
		jerror_t brun(jana::JEventLoop *loop, int32_t runnumber);    ///< Called everytime a new run number is detected.
		jerror_t evnt(jana::JEventLoop *loop, uint64_t eventnumber);  ///< Called every event.
		jerror_t erun(void){return NOERROR;}        ///< Called everytime run number changes, provided brun has been called.
		jerror_t fini(void);	                    ///< Called after last event of last event source has been processed.

		L3farm_out *l3out;
		uint32_t Nevents;
		
		std::ofstream *ofs_debug_input;
		std::ofstream *ofs_debug_output;
		
		double FDC_T_MIN;
		double FDC_T_MAX;
		double CDC_T_MIN;
		double CDC_T_MAX;
		double TOF_T_MIN;
		double TOF_T_MAX;
		double TAG_T_MIN;
		double TAG_T_MAX;
		double BCAL_T_MIN;
		double BCAL_T_MAX;
		double FCAL_T_MIN;
		double FCAL_T_MAX;
		double PS_T_MIN;
		double PS_T_MAX;
		double ST_T_MIN;
		double ST_T_MAX;
		double L1_BCAL_FAC;
		double L1_FCAL_FAC;
		double L1_THRESH;
		double f250_PEAK_MIN;
		double TOF_PEAK_MIN;
		double TAGM_PEAK_MIN;
		double TAGH_PEAK_MIN;
		uint32_t TAGH_MAX_FADC_CHANNEL; // slot*100 + channel
		uint32_t TAGH_MAX_TDC_CHANNEL;  // slot*100 + channel
		uint32_t SYSTEMS_TO_CUT;
		bool   CUT_UNKNOWNS;
		
		set<int> ROCIDS_TO_REMOVE;
		set<int> SLOTS_TO_REMOVE;
};

#endif // _JEventProcessor_L3proc_