// $Id$
//
//    File: JEventProcessor_ps_skim.cc
// Created: Mon May 18 09:52:08 EDT 2015
// Creator: nsparks (on Linux cua2.jlab.org 2.6.32-431.5.1.el6.x86_64 x86_64)
//

#include "JEventProcessor_ps_skim.h"
using namespace jana;

#include "evio_writer/DEventWriterEVIO.h"
#include "DAQ/DEPICSvalue.h"
#include <PAIR_SPECTROMETER/DPSCPair.h>
#include <PAIR_SPECTROMETER/DPSPair.h>

// Routine used to create our JEventProcessor
#include <JANA/JApplication.h>
#include <JANA/JFactory.h>
extern "C"{
  void InitPlugin(JApplication *app){
    InitJANAPlugin(app);
    app->AddProcessor(new JEventProcessor_ps_skim());
  }
} // "C"


//------------------
// JEventProcessor_ps_skim (Constructor)
//------------------
JEventProcessor_ps_skim::JEventProcessor_ps_skim()
{

}

//------------------
// ~JEventProcessor_ps_skim (Destructor)
//------------------
JEventProcessor_ps_skim::~JEventProcessor_ps_skim()
{

}

//------------------
// init
//------------------
jerror_t JEventProcessor_ps_skim::init(void)
{

  return NOERROR;
}

//------------------
// brun
//------------------
jerror_t JEventProcessor_ps_skim::brun(JEventLoop *eventLoop, int runnumber)
{
  // This is called whenever the run number changes
  return NOERROR;
}

//------------------
// evnt
//------------------
jerror_t JEventProcessor_ps_skim::evnt(JEventLoop *loop, int eventnumber)
{

  const DEventWriterEVIO* locEventWriterEVIO = NULL;
  loop->GetSingle(locEventWriterEVIO);

  //Save EPICS events
  vector<const DEPICSvalue*> locEPICSValues;
  loop->Get(locEPICSValues);
  if(!locEPICSValues.empty()) {
    locEventWriterEVIO->Write_EVIOEvent(loop, "ps");
    return NOERROR;
  }

  // coarse PS pairs
  vector<const DPSCPair*> cpairs;
  loop->Get(cpairs);
  // fine PS pairs
  vector<const DPSPair*> fpairs;
  loop->Get(fpairs);
  // skim events with at least 1 PSC or PS left-right coincidence
  if (cpairs.size()>=1||fpairs.size()>=1) {
    locEventWriterEVIO->Write_EVIOEvent(loop, "ps");
    return NOERROR;
  }
  
  return NOERROR;
}

//------------------
// erun
//------------------
jerror_t JEventProcessor_ps_skim::erun(void)
{
  // This is called whenever the run number changes, before it is
  // changed to give you a chance to clean up before processing
  // events from the next run number.
  return NOERROR;
}

//------------------
// fini
//------------------
jerror_t JEventProcessor_ps_skim::fini(void)
{
  // Called before program exit after event processing is finished.
  return NOERROR;
}