#include "MbsFile.h"
//paolo 28032011
#include <iostream>
#include <fstream>
#include <string>
#include <sstream>
#include <iomanip>


#include <stdlib.h>

using namespace std;

//paolo 28032011


MbsFile::MbsFile(const char* name, Int_t* status) :
    fName(name),
    fCurrentMbsRunNo(0),
    fCurrentMbsEventNo(0)
{
    OpenFile(status);
}

Int_t* MbsFile::OpenFile(Int_t* status)
{
 int inputmode=1;
 fxInputChannel=new s_evt_channel;
 void* headptr=&fxInfoHeader; // some new compilers may warn if we directly dereference member

 *status = f_evt_get_open(inputmode,const_cast<char*>(fName.Data()),fxInputChannel,
                                    (Char_t**) headptr, 1,1);
 cout << "status OpenFile="<< *status<<endl;
 if(!status)PrintFileHeader(fxInfoHeader);
 if( status ){
   /// fCurrentMbsRunNo = (Int_t) atoi(fxInfoHeader->file_run);  ///That didn't work - fileld file_run is empty
   fCurrentMbsRunNo = GetRunNumberFromFileName( fName );
 }
 
 if(*status)cout << "Error opening file: " << fName.Data() << endl;
 return status;
}

MbsFile::~MbsFile()
{
   CloseFile();
}

Int_t MbsFile::CloseFile()
{
  if(!fxInputChannel)cout << "file not opened!"<<endl;
  Int_t status = f_evt_get_close(fxInputChannel);
  cout << "status CloseFile="<<status<< endl; 
  if (!status) {return kTRUE;}
  else {
   cout << "Error closing file: " << fName.Data() << endl;
   return kFALSE;}
}

Int_t MbsFile::GetEvent()
{
 void* evtptr =&fxEvent; 
 void* buffptr=&fxBuffer; 

 Int_t status=f_evt_get_event(fxInputChannel, (Int_t**)evtptr,(Int_t**) buffptr);
//02062011 PrintEventHeader();
// PrintBufferHeader();
 fuEventCounter=fxEvent->l_count;
 fCurrentMbsEventNo = fuEventCounter;
 
 if (status==0) {
  //cout << "got an event, it's nr: "<<fuEventCounter<<endl;
  return status;}
 else if (status==3){
   cout << "This is last event"<<endl;
   return status;
 }
 else{
  cout << "Error getting event: "<< endl;
  return status;}
}

Int_t MbsFile::GetNrSubEvent()
{
 Int_t status=f_evt_get_subevent(fxEvent, 0, NULL, NULL, NULL);
 if (status) {
//  cout << "Found "<<status<<" subevents"<<endl;
  return status;}
 else {
  cout << "No subevents found: "<< endl;
  return 0;}
}

Int_t* MbsFile::GetSubEvent(Int_t n, Int_t *sebuflenght,Short_t *setype,Short_t *sesubtype,Char_t *sesubcrate)
{
 void* SubEvtptr=&fxSubEvent; 
 void* EvtDataptr=&fxEventData;
 Int_t* nrlongwords=new Int_t;
 Int_t status=f_evt_get_subevent(fxEvent, n, (Int_t**)SubEvtptr, (Int_t**)EvtDataptr, nrlongwords);
 *sebuflenght=fxSubEvent->l_dlen;
 *setype   =fxSubEvent->i_type;
 *sesubtype=fxSubEvent->i_subtype;
 *sesubcrate=fxSubEvent->h_subcrate;
 // PrintSubEvent(fxSubEvent,fxEventData);
 if (!status) {
  //  cout << "got a subevent nr "<<n<< " with "<< *nrlongwords << " longwords pointing to "<< fxEventData<< endl;
  delete nrlongwords;
  return fxEventData;}
 else {
  cout << "No sub event got: "<< endl;
  delete nrlongwords;
  return NULL;
 }
}

void MbsFile::PrintSubEvent(s_ves10_1* SEH, Int_t* ED){
// if((*ED)==256){
 cout << "This is Subevent header:"<<endl;
 cout <<SEH->l_dlen<<endl;
 cout <<SEH->i_subtype<<endl;
 cout <<SEH->i_type<<endl;
 cout <<SEH->h_control<<endl;
 cout <<SEH->h_subcrate<<endl;
 cout <<SEH->i_procid<<endl;
 cout <<"########################"<<endl;     // 256 for CHIMERA 
/* cout <<*ED<<endl;     // 256 for CHIMERA 
 cout <<*(ED+1)<<endl; //TimeStamp 
 cout <<*(ED+2)<<endl; //TimeStamp
 cout <<*(ED+3)<<endl; //TimeStamp
 cout <<hex<<*(ED+4)<<dec<<endl; //TimeStamp
 cout <<hex<<*(ED+5)<<dec<<endl; //TimeStamp
 cout <<hex<<*(ED+6)<<dec<<endl; //TimeStamp
 cout <<hex<<*(ED+7)<<dec<<endl; //TimeStamp
// cout <<*(ED+7)<<endl; //TimeStamp
 cout << "@@@@@@@@@@@@@@@@@@@@@@@"<<endl;
 }*/
}

void MbsFile::PrintBufferHeader(){
 cout << "This is Buffer header:"<<endl;
 cout <<  fxBuffer->l_dlen << endl;
 cout <<  fxBuffer->l_evt << endl;
 cout <<  fxBuffer->h_begin << endl;
 cout <<  fxBuffer->h_end << endl;
}

void MbsFile::PrintEventHeader(){
 cout << "This is Event header:"<<endl;
 cout << "lenght= "<< fxEvent->l_dlen << endl;
 cout << "subtyp= "<<fxEvent->i_subtype << endl;
 cout << "type  = "<<fxEvent->i_type << endl;
 cout << "trigg = "<<fxEvent->i_trigger << endl;
 cout << "count = "<<fxEvent->l_count << endl;
}

 void MbsFile::PrintFileHeader()
{
  cout << "This is File Header:"<<endl;
  cout << "lenght "<<fxInfoHeader->filhe_dlen << endl;
  cout << "evt    "<<fxInfoHeader->filhe_evt << endl;
  cout << "label  "<<fxInfoHeader->filhe_label << endl;
  cout << "run    "<<fxInfoHeader->filhe_run << endl;
  cout << "time   "<<fxInfoHeader->filhe_time << endl;
  cout << "curr i "<<fxInfoHeader->filhe_current_i << endl;
  cout << "file   "<<fxInfoHeader->filhe_file << endl;
}

void MbsFile::PrintFileHeader(s_filhe* FH)
{
  cout << "This is File Header:"<<endl;
  cout << FH->filhe_dlen << endl;
  cout << FH->filhe_evt << endl;
  cout << FH->filhe_label << endl;
  cout << FH->filhe_run << endl;
  cout << FH->filhe_time << endl;
  cout << FH->filhe_current_i << endl;
  cout << FH->filhe_file << endl;
}

Int_t MbsFile::GetRunNumberFromFileName( TString A_string )
{
  /// This function extract the run number from the file name.
  /// The file name pattern is like the follow: /PATH/PREFIX_XXXX.lmd
  /// And we want extract the XXXX number
  
  int runNumber = 0;
  if ( A_string == NULL){
    return runNumber; ///Throw exception or print warning
  }
    if ( A_string.Length() == 0){
    return runNumber; ///Throw exception or print warning
  }
  string stlString( A_string.Data() );
  string fileExtension = ".lmd"; 
  int PositionOfTheFileExtensionInFileName = stlString.find( fileExtension );
    
  if (PositionOfTheFileExtensionInFileName < 4 ){
    return runNumber;
  }
  /// (pos -4, 4) because the run number should consist four digits.
  string strRunNumber = stlString.substr(PositionOfTheFileExtensionInFileName - 4, 4 );
  if (strRunNumber != NULL  )
  {
    runNumber = atoi( strRunNumber.c_str() );
     cout << "[MbsFile:] Extracted from file name " << A_string << " the run number: " << runNumber << endl; 
  
  }else{
    /// cout << " Warning: Couldn't extract run number from the file name" << endl;
    /// Throw exception or print warning
  }

	return runNumber;
}