JDatalogString.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <sstream>
#include <fstream>
#include <iomanip>
#include <vector>
#include <set>
#include <algorithm>

#include "JLang/JPredicate.hh"
#include "JLang/JComparator.hh"
#include "JLang/JComparison.hh"

#include "JLogger/JMessageLogger.hh"

#include "JDAQ/JDAQTags.hh"

#include "JTools/JRange.hh"

#include "JDB/JDatalogString.hh"
#include "JDB/JLoggerMessage.hh"
#include "JDB/JReplyMessage.hh"

#include "Jeep/JeepToolkit.hh"
#include "Jeep/JProperties.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"


namespace {

  using namespace JPP;

  /**
   * Print.
   *
   * \param  out           output stream
   * \param  object        object
   */
  inline void print(std::ostream& out, const JDatalogString& object)
  {
    using namespace std;
    using namespace JPP;

    static int row = 0;

    out << FILL(6,'0') << ++row << FILL() << ' ' << object << endl;
  }
}


/**
 * \file
 * Auxiliary application to examine datalog file.
 *
 * \author mdejong
 */
int main(int argc, char **argv)
{
  using namespace std;
  using namespace JPP;
  using namespace KM3NETDAQ;

  typedef JRange<long int>  JRange_t;

  vector<string> datalogstringFile;
  string         egrep;
  JLoggerMessage message;
  JReplyMessage  reply;
  JDatalogString datalog;
  JRange_t       UTC;
  int            debug;

  try { 

    JProperties fMessage;
    JProperties fDatalog;
    JProperties fReply;

    fMessage.insert(gmake_property(message.tag));
    fMessage.insert(gmake_property(message.process));
    fMessage.insert(gmake_property(message.nickname));
    fMessage.insert(gmake_property(message.ip));
    fMessage.insert(gmake_property(message.fullname));
    fMessage.insert(gmake_property(message.level));
    fMessage.insert(gmake_property(message.data));

    fDatalog.insert(gmake_property(datalog.source));
    fDatalog.insert(gmake_property(datalog.parameter));
    fDatalog.insert(gmake_property(datalog.data));

    fReply  .insert(gmake_property(reply.nickname));
    fReply  .insert(gmake_property(reply.ip));
    fReply  .insert(gmake_property(reply.event));
    fReply  .insert(gmake_property(reply.state));

    JParser<> zap("Auxiliary application to examine datalog file.");
    
    zap['f'] = make_field(datalogstringFile,    "datalog file");
    zap['e'] = make_field(egrep,                "filter, precede with '!' to invert") = "";
    zap['M'] = make_field(fMessage,             "filter for logger message") =  JPARSER::initialised();
    zap['D'] = make_field(fDatalog,             "filter for datalog string") =  JPARSER::initialised();
    zap['R'] = make_field(fReply,               "filter for reply message")  =  JPARSER::initialised();
    zap['T'] = make_field(UTC,                  "UTC time range [s]")        =  JRange_t();
    zap['d'] = make_field(debug)                                             = 2;
    
    zap(argc, argv);
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }


  JDatalogs_t datalogs;

  try {
    for (const auto& filename : datalogstringFile) {
      datalogs.load(filename);
    }
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }

  {
    JDatalogs_t::iterator __end = datalogs.end();

    for (JDatalogs_t::iterator i = datalogs.begin(); i != __end; ) {

      bool status = UTC(i->utc);

      if (!egrep.empty()) {

        if (egrep[0] != '!' && !regex_match(i->data, regex(".*" + egrep.substr(0) + ".*"))) { status = false; }
        if (egrep[0] == '!' &&  regex_match(i->data, regex(".*" + egrep.substr(1) + ".*"))) { status = false; }
      }

      if (status) {

        if      (i->source == MESSAGE_TAG)

          status = JLoggerMessage(*i).match(message);

        else if (i->source == RC_REPLY.toString())

          status = JReplyMessage (*i).match(reply);

        else

          status = i->match(datalog);
      }

      if (status)
        ++i;
      else
        iter_swap(i, --__end);
    }

    datalogs.erase(__end, datalogs.end());
  }

  sort(datalogs.begin(), datalogs.end(), make_comparator(&JDatalogString::utc, JComparison::lt()));

  for (const auto& datalog : datalogs) {
    print(cout, datalog);
  }
}