GetValuesCommand.h

#ifndef EA4_PVRPC_GET_VALUES_COMMAND_H
#define EA4_PVRPC_GET_VALUES_COMMAND_H

#include <sstream>

#include "storage/ReaderFactory.h"
#include "storage/SpreadsheetReader.h"

#include "pvrpc/ArchiveCommand.h"

namespace ea4 { namespace pvrpc {

class GetValuesCommand : public ArchiveCommand {

public:

  GetValuesCommand();

  public:

  // ArchiveCommand API

  virtual const char* getName()const { return commandName.c_str(); }

  virtual epics::pvData::PVStructurePtr createRequest();

  virtual epics::pvData::PVStructurePtr 
    process(epics::pvData::PVStructurePtr const & request);

protected:

  void createRequestType();

  epics::pvData::StructureConstPtr 
    createResultType(epics::pvData::StructureConstPtr& metaType, 
                     epics::pvData::ScalarType pv_type, 
                     int pv_count);

protected:

  epics::pvData::PVStructurePtr 
    createDataResponse(int key, 
                       const std::vector<std::string>& pvNames, 
                       const epicsTime& start, 
                       const epicsTime& end, 
                       int actual_count, 
                       int how);

  DataReader*  
    createDataReader(Index& index,
                     const epicsTime& start, 
                     const epicsTime& end,
                     int count, 
                     int how);

  epics::pvData::StructureConstPtr 
    createDataResponseType(DataReader* reader, 
                           const std::vector<std::string>& pvNames,
                           const epicsTime& start);

  void getDataResult(epics::pvData::PVStructurePtr& result,
                     DataReader* reader,
                     const std::string& name, 
                     const epicsTime& start, 
                     const epicsTime& end, 
                     int actual_count,
                     int how);

  void getChannelData(epics::pvData::PVStructureArrayPtr& values, 
                      DataReader* reader,
                      const epicsTime& end,
                      const RawValue::Data* data,
                      epics::pvData::ScalarType pv_type,
                      int pv_count,
                      int count,
                      ReaderFactory::How how);

protected:

  epics::pvData::PVStructurePtr 
    createSheetResponse(int key, 
                        const std::vector<std::string>& pvNames, 
                        const epicsTime& start, 
                        const epicsTime& end, 
                        int actual_count, 
                        int how);

  SpreadsheetReader* 
    createSheetReader(Index& index,
                      const epicsTime& start, 
                      const epicsTime& end,
                      int count, 
                      int how);

  epics::pvData::StructureConstPtr 
    createSheetResponseType(SpreadsheetReader* sheet,
                            const epicsTime& start);

  void getSheetData(epics::pvData::PVStructurePtr& response,
                    SpreadsheetReader* sheet,  
                    const epicsTime& start, 
                    const epicsTime& end, 
                    int actual_count);

protected:

  static std::string commandName;

  // {string command, 
  //  int key, string[] name, 
  //  int32 start_sec, int32 start_nano, 
  //  int32 end_sec, int32 end_nano, 
  //  int32 count, int32 how }
  epics::pvData::StructureConstPtr requestType;  

};

}}

#endif