#ifndef __JSUPPORT__JDAQFILEREADER__
#define __JSUPPORT__JDAQFILEREADER__

#include <vector>
#include <string.h>

#include "JIO/JBinaryFileReader.hh"
#include "JIO/JByteArrayIO.hh"
#include "JDAQ/JDAQPreambleIO.hh"
#include "km3net-dataformat/online/JDAQDataTypes.hh"
#include "JLang/JObjectIterator.hh"
#include "JLang/JConversion.hh"


/**
 * \author mdejong
 */

namespace JSUPPORT {}
namespace JPP { using namespace JSUPPORT; }

namespace JSUPPORT {

  using JIO::JBinaryFileReader;
  using KM3NETDAQ::JDAQPreamble;
  using JLANG::JAccessibleObjectIterator;
  using JLANG::JNullIterator;
  using JLANG::JNullAccess;


  /**
   * DAQ object reading from binary file (i.e.\ .dat).
   */
  template<class T, bool = JLANG::JConversion<T,JDAQPreamble>::is_derived>
  class JDAQFileReader;


  /**
   * Template specialisation of JDAQFileReader for DAQ compatible data types.
   *
   * This class provides for an implementation of the JLANG::JAccessibleObjectIterator interface.
   * It overwrites the method setObject of the JLANG::JAbstractObjectIterator interface so that
   * the desired object is read from the file which may contain also other objects.
   */
  template<class T>
  class JDAQFileReader<T,true> :
    public JBinaryFileReader<T>
  {
  public:
    /**
     * Set object.
     *
     * \param  object     reference to object to be set
     * \return            true if set; else false
     */
    virtual bool setObject(T& object) override 
    {
      using namespace std;
      using namespace KM3NETDAQ;
      using namespace JIO;

      for (JStreamReader& in = static_cast<JStreamReader&>(*this); in >> preamble; ) {

	if        (preamble.getLength() < (int) getSizeof<JDAQPreamble>()) {
	      
	  this->setstate(ios::badbit);
	  
	  return false;
	  
	} else if (preamble.getDataType() == getDataType<T>()) {
	    
	  buffer.resize(preamble.getLength());

	  memcpy(buffer.data(), static_cast<JDAQAbstractPreamble*>(&preamble), getSizeof<JDAQPreamble>());
	  
	  in.read(buffer.data()        + getSizeof<JDAQPreamble>(),
		  preamble.getLength() - getSizeof<JDAQPreamble>());
	  
	  JByteArrayReader bin(buffer.data(), buffer.size());

	  bin >> object;
	  
	  return (bool) in;
	  
	} else {
	    
	  this->ignore((streamsize) (preamble.getLength() - getSizeof<JDAQPreamble>()));
	}
      }  

      return false;
    }
 
  private:
    mutable JDAQPreamble      preamble;
    mutable std::vector<char> buffer;
  };


  /**
   * Template specialisation of JDAQFileReader for DAQ incompatible data types.
   *
   * This class provides for a null implementation of the JLANG::JAccessibleObjectIterator interface.
   */
  template<class T>
  class JDAQFileReader<T,false> :
    public JAccessibleObjectIterator<T>,
    public JNullAccess,
    public JNullIterator<T>
  {};
}

#endif