//
//    Example monitor
//
#include "exmon.hh"

#ifndef __CINT__

//-->  The next three lines are needed if you are going to generate triggers.
//     The text in PIDTITLE should describe the monitor function.
#define PIDCVSHDR "$Header: /ldcg_server/common/repository_gds/gds/DMT/Templates/DatTemplate.cc,v 1.8 2006/07/11 23:18:34 jzweizig Exp $"
#define PIDTITLE  "Data monitor template"
#include "ProcIdent.hh"

#include "Dacc.hh"
#include <iostream>
#include <string>
#include <stdlib.h>

using namespace std;

//======================================  Generate the main routine.
EXECDAT(exmon)
#endif               // !def(__CINT__)

//======================================  Skeleton object constructor.
exmon::exmon(int argc, const char *argv[]) 
: DatEnv(argc, argv), maxFrame(999999), mStep(2.0), mHistory(43200),
  mDataArrayAssigned(false), mpdata(0x0)
{
    //----------------------------------  Look for arguments
    bool dvIndex = false;

    bool syntax  = false;
    for (int i=1 ; i<argc ; i++) {
        string argi = argv[i];
        if (argi == "-channel") {
	    mChannel = argv[++i];
	} else if (argi == "-dvindex") {
	    dvIndex = true;
	} else if (argi == "-frame") {
	    maxFrame = strtol(argv[++i], 0, 0);
	} else if (argi == "-stride") {
	    mStep = strtod(argv[++i], 0);
	} else if (argi == "-settle") {
	    mSettle = strtod(argv[++i], 0);
 	} else if (isDatEnvArg(argv[i])) {
	    i++;
	} else {
	    syntax = true;
	    cerr << "Unrecognized argument: " << argi << endl;
	}
    }

    //----------------------------------  Bail out if command line not correct
    if (syntax) {
        cerr << "Command syntax:" << endl;
	cerr << argv[0] 
	     << " [-channel <nMax>] [-frames <nMax>] [-stride <time>] \\" 
	     << endl
	     << "      [-filter <filter>] [-settle <s-time>] [-dvIndex] \\"
	     << endl
	     << "      [<DatEnv-args>]" 
	     << endl;
	finish();
	return;
    }

    //----------------------------------  Make sure there's a valid channel
    if (mChannel.empty()) mChannel = "H1:LSC-AS_Q";

    //----------------------------------  set the data accessor
    getDacc().setStride(mStep);       // in before calling ProcessData
    getDacc().addChannel(mChannel.c_str());

}

//======================================  Skeleton object destructor.
exmon::~exmon() 
{
    if( mDataArrayAssigned ) {
      delete [] mpdata;
    }
    cout << "exmon is finished" << endl;
}

//======================================  Frame processing function.
void
exmon::ProcessData(void) {
    //----------------------------------  Get pointers to the current data.
    const TSeries* ts = getDacc().refData(mChannel.c_str());
    if (!ts || ts->isEmpty()) {
        cout << "Channel: " << mChannel << " was not found." << endl;
        return;
    }
    // get the number of data points in the frame
    unsigned long ndata_per_frame = ts->getNSample();
    // allocate memory from free store to copy data into, converting
    // the data to doubles.
    if( !mDataArrayAssigned ) {
      
      std::cout << "acquired " 
		<< ndata_per_frame 
		<< " samples"
		<< std::endl;
      
      // get a pointer the data
      mpdata = new double [ndata_per_frame];
      mDataArrayAssigned = true;
    }
    // copy data to array
    ts->getData(ndata_per_frame, mpdata);
    // print the 100th data element
    std::cout << "data element 100 is "
	      << mpdata[99]
	      << std::endl;
}


//======================================  Handle Messages
void
exmon::Attention(void) {
    MonServer::Attention();
}