// modified  3-12-1998 D.B
// modified  15/3/99 by R. Holzmann
// modified  23/3/99 by D.B
//_HADES_CLASS_DESCRIPTION 
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//HLdremoteSource
//
//  This is a particular kind of "data source"  (see HDataSource) which takes 
//the event's data from  directly from a Data event builder.using RPC.
//
//  The data are accessed via a RPC buffer pointer and 
//  need to be unpacked.  For This user must specify the 
// node of the SERVER as argument in the constructor of this class. 
// Unpacking data is then similar to other data source.(see HldSource).
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
using namespace std;
#include "hldremotesource.h"
#include "hldremotevt.h"
#include "hrecevent.h"
#include "hruntimedb.h"
#include "hldevt.h"
#include "hldsubevt.h"
#include "hldunpack.h"  
#include "TDatime.h"
#include <iostream>
#include <iomanip>

ClassImp(HldRemoteSource)

HldRemoteSource::HldRemoteSource(void): HldSource()
{
    refId    = -1;
    runId    = -1;
    fileName = "no_yet_set";
}

HldRemoteSource::HldRemoteSource(const Text_t *nodeName): HldSource()
{
    // test Server IO

    fReadEvent = new HldRemotEvt(nodeName);
    currNodeName = nodeName;
    iter     = 0;
    iter     = fUnpackerList->MakeIterator();
    isDumped = kFALSE;
    refId    = -1;
    runId    = -1;
    fileName = "no_yet_set";
}


HldRemoteSource::~HldRemoteSource(void) {
    //Destructor for a remote data source
    if (fUnpackerList) fUnpackerList->Delete();
    fUnpackerList = 0;
    if (fReadEvent) delete fReadEvent;
    fReadEvent    = 0;
    if(iter) delete iter;
}


Bool_t HldRemoteSource::init(void) {
    //Calls the init() function for each unpacker.
    if (!(*fEventAddr)) {
	(*fEventAddr) = new HRecEvent;
    }
    if(isDumped || isScanned) return kTRUE;
    iter = fUnpackerList->MakeIterator();
    if (initUnpacker() == kFALSE) {
	printf(" problem init unpacker \n");
	return kFALSE;
    }
    HldUnpack* unpacker;
    while ( (unpacker = (HldUnpack *)iter->Next()) != NULL) {
	fReadEvent->appendSubEvtIdx(*unpacker);
    }
    return kTRUE;
}

Int_t HldRemoteSource::getCurrentRunId(void) {
    ((HldRemotEvt*)fReadEvent)->read();
    return fReadEvent->getRunNr();
}


EDsState HldRemoteSource::getNextEvent(Bool_t doUnpack) {
    // test Server IO
    if(isDumped)  return dumpEvt();
    if(isScanned) return scanEvt();

    iter->Reset();
    HldUnpack *unpacker;
    if (!fReadEvent) {
	fLastEventStatus = kDsError;
	return kDsError;
    }
    if (fReadEvent) fReadEvent->execute();
    if(doUnpack){
	decodeHeader((*fEventAddr)->getHeader());

	Int_t newId = (*fEventAddr)->getHeader()->getEventRunNumber();
	if(runId < 0 || newId != runId ){
            runId = newId;
            TDatime time;
	    fileName = Form("%s_%i.hld",time.AsString(),runId);
	    fileName.ReplaceAll(" ","_");
	}

	while ( (unpacker = (HldUnpack *)iter->Next()) != NULL) {
	    Int_t ret = unpacker->execute();
	    if(!ret) {
		fLastEventStatus = kDsError;
		return kDsError;
	    }
	    if(ret == kDsSkip) {
		fLastEventStatus = kDsSkip;
		return kDsSkip;

	    }
	}
    }

    fLastEventStatus = kDsOk;
    return kDsOk;
}