TxEventLogFile.h

/*
 * @file TxEventLogFile.h
 * @author Roopa Pundaleeka
 *
 * @(#)cpp/api:$Id: TxEventLogFile.h,v 1.5 2010/09/17 19:34:54 fine Exp $
 *
 * TxEventLogFile provides an interface for applications so that they can write
 * event information into a CEDPS formated file.
 */
 
#ifndef TX_EVENT_LOG_FILE_H
#define TX_EVENT_LOG_FILE_H

#include "TxEventLog.h"

#include <string>
#include <cstdlib>
#include <vector>
#include <sys/types.h>
#include <unistd.h>
#include <ctime>
#include <sstream>
#include <iostream>
#include <fstream>
#include <map>

#include "TxUCMUtils.h"

namespace TxLogging {
  class TxEventLogFile: public TxEventLog {
  protected:
    virtual void writeDown(const std::string& message);
    virtual void writeDown(const char *message);

  public:
    TxEventLogFile ();

    virtual ~TxEventLogFile ();

    virtual void setEnvBrokerTaskID (const std::string& envBrokerTaskID);
    
    virtual void setEnvBrokerJobID (const std::string& envBrokerJobID);
    
    virtual void setBrokerTaskID (const std::string& brokerTaskID);
    
    virtual void setBrokerJobID (int brokerJobID);
    
    virtual void setRequesterName (const std::string& requester);
    
    virtual void setContext (const std::string& context);

    virtual void logStart (const std::string& key, const std::string& value);

    virtual void logJobAttribute (const std::string& key, const std::string& value);
    virtual void logJobSubmitLocation (const std::string& url);
    virtual void setJobSubmitLocation (const std::string& url);

     virtual void logJobSubmitState (State state);
     virtual void setJobSubmitState (State state);

    virtual void logTask (unsigned int size=1);

    virtual void logTask (const std::string& taskAttributes);

    virtual void logJobSubmitID (const std::string& ID);
    virtual void setJobSubmitID (const std::string& ID);

    virtual void logEvent (const std::string& logMsg, 
                   Level level = LEVEL_INFO, 
                   Stage stage = STATUS, 
                   const std::string& msgContext = TxUCMConstants::defaultContext);
    
    virtual void logEvent (const std::string& userKey, 
                   const std::string& userValue, 
                   Level level = LEVEL_INFO, 
                   Stage stage = STATUS, 
                   const std::string& msgContext = TxUCMConstants::defaultContext);

   virtual  void logEnd (const std::string& key,
                 const std::string& value);

  private:
    virtual void readProperties ();
  
    void setDefaults ();

    const char* createHeader ();

    void writeMessage (const std::string& event,
                       const std::string& context,
                       const Level& level,
                       const Stage& stage,
                       const std::string& key,
                       const std::string& value);

    std::string brokerJobID, brokerTaskID, requester, context;
    std::map <std::string, std::string> ucmLogProps;
    std::string timestamp, logFilePath;
    std::string username, hostname;
    bool startMsgWritten;
        

      virtual  StUcmTasks  *getTaskList ();
      virtual  StUcmTasks  *getTaskList (int limit);
      virtual  StUcmTasks  *getTaskList (int limit, int offset); 
          
      virtual  StUcmJobs   *getJobList();
      virtual  StUcmJobs   *getJobList(StRecord *task);
      virtual  StUcmJobs   *getJobList(StRecord *task, int limit);
      virtual  StUcmJobs   *getJobList(int limit);
      virtual  StUcmJobs   *getJobList(int limit, int offset);
      virtual  StUcmJobs   *getJobList(StRecord *task, int limit, int offset);
      virtual  int          getJobId(const char *reqName,const char *taskBrokerId, int jobBrokerId);

      virtual  StUcmEvents *getEventList();
      virtual  StUcmEvents *getEventList(StRecord *job);
      virtual  StUcmEvents *getEventList(StRecord *job,int limit);
      virtual  StUcmEvents *getEventList(int limit);
      virtual  StUcmEvents *getEventList(int limit, int offset);
      virtual  StUcmEvents *getEventList(StRecord *job,int limit, int offset);

         virtual  void setDbJobID (int bJobID);

    virtual  int  queryTableSize(const char *tableName);
    virtual  int  queryTableSize(const char *tableName, const char *where);
    virtual  int  queryTableSize(const char *tableName, const StRecord   *where);

  };
}
#endif