sems/apps/dsm/mods/mod_monitoring/ModMonitoring.cpp

/*
 * Copyright (C) 2008 iptego GmbH
 *
 * This file is part of SEMS, a free SIP media server.
 *
 * SEMS is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version. This program is released under
 * the GPL with the additional exemption that compiling, linking,
 * and/or using OpenSSL is allowed.
 *
 * For a license to use the SEMS software under conditions
 * other than those described here, or to purchase support for this
 * software, please contact iptel.org by e-mail at the following addresses:
 *    info@iptel.org
 *
 * SEMS is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License 
 * along with this program; if not, write to the Free Software 
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
#include "log.h"

#include "AmUtils.h"
#include "AmSessionContainer.h"
#include "ampi/MonitoringAPI.h"

#include "DSMSession.h"
#include "AmSession.h"

#include "ModMonitoring.h"

SC_EXPORT(MonitoringModule);

void splitCmd(const string& from_str, 
	      string& cmd, string& params) {
  size_t b_pos = from_str.find('(');
  if (b_pos != string::npos) {
    cmd = from_str.substr(0, b_pos);
    params = from_str.substr(b_pos + 1, from_str.rfind(')') - b_pos -1);
  } else 
    cmd = from_str;  
}

DSMAction* MonitoringModule::getAction(const string& from_str) {
  string cmd;
  string params;
  splitCmd(from_str, cmd, params);

#define DEF_CMD(cmd_name, class_name) \
				      \
  if (cmd == cmd_name) {	      \
    class_name * a =		      \
      new class_name(params);	      \
    a->name = from_str;		      \
    return a;			      \
  }

  DEF_CMD("monitoring.log", MonLogAction);
  DEF_CMD("monitoring.set", MonLogAction);
  DEF_CMD("monitoring.add", MonLogAddAction);
  DEF_CMD("monitoring.logAdd", MonLogAddAction);
  DEF_CMD("monitoring.logVars", MonLogVarsAction);

  DEF_CMD("monitoring.setGlobal", MonLogGlobalAction);
  DEF_CMD("monitoring.addGlobal", MonLogAddGlobalAction);

  DEF_CMD("monitoring.inc", MonLogIncAction);
  DEF_CMD("monitoring.dec", MonLogDecAction);

  return NULL;
}

DSMCondition* MonitoringModule::getCondition(const string& from_str) {
  return NULL;
}

CONST_ACTION_2P(MonLogAction, ',', true);
bool MonLogAction::execute(AmSession* sess, DSMSession* sc_sess,
			   DSMCondition::EventType event,
			   map<string,string>* event_params) {

  string prop = resolveVars(par1, sess, sc_sess, event_params);
  string val  = resolveVars(par2, sess, sc_sess, event_params);
  
  MONITORING_LOG(sess->getLocalTag().c_str(), prop.c_str(), val.c_str());

  return false;
}

CONST_ACTION_2P(MonLogAddAction, ',', true);
bool MonLogAddAction::execute(AmSession* sess,  DSMSession* sc_sess,
			   DSMCondition::EventType event,
			   map<string,string>* event_params) {

  string prop = resolveVars(par1, sess, sc_sess, event_params);
  string val  = resolveVars(par2, sess, sc_sess, event_params);
  
  MONITORING_LOG_ADD(sess->getLocalTag().c_str(), prop.c_str(), val.c_str());

  return false;
}

bool MonLogVarsAction::execute(AmSession* sess,   DSMSession* sc_sess,
			       DSMCondition::EventType event,
			       map<string,string>* event_params) {
  AmArg di_args,ret;
  di_args.push(AmArg(sess->getLocalTag().c_str()));

  for (map<string,string>::iterator it=
	 sc_sess->var.begin(); it != sc_sess->var.end();it++) {
    di_args.push(it->first.c_str());
    di_args.push(it->second.c_str());
  }
  AmSessionContainer::monitoring_di->invoke("log", di_args, ret);

  return false;
}


CONST_ACTION_2P(MonLogGlobalAction, ',', true);
EXEC_ACTION_START(MonLogGlobalAction) {
  string id = resolveVars(par1, sess, sc_sess, event_params);
  string prop;
  string val;

  size_t c = par2.find(',');
  if (c != string::npos) {
    prop = resolveVars(par2.substr(0, c), sess, sc_sess, event_params);
    val = resolveVars(par2.substr(c+1), sess, sc_sess, event_params);
  } else {
    prop = resolveVars(par2, sess, sc_sess, event_params);
  }

  MONITORING_LOG(id.c_str(), prop.c_str(), val.c_str());

} EXEC_ACTION_END;


CONST_ACTION_2P(MonLogAddGlobalAction, ',', true);
EXEC_ACTION_START(MonLogAddGlobalAction) {
  string id = resolveVars(par1, sess, sc_sess, event_params);
  string prop;
  string val;

  size_t c = par2.find(',');
  if (c != string::npos) {
    prop = resolveVars(par2.substr(0, c), sess, sc_sess, event_params);
    val = resolveVars(par2.substr(c+1), sess, sc_sess, event_params);
  } else {
    prop = resolveVars(par2, sess, sc_sess, event_params);
  }

  MONITORING_LOG_ADD(id.c_str(), prop.c_str(), val.c_str());

} EXEC_ACTION_END;

CONST_ACTION_2P(MonLogIncAction, ',', true);
bool MonLogIncAction::execute(AmSession* sess,  DSMSession* sc_sess,
			   DSMCondition::EventType event,
			   map<string,string>* event_params) {
  string type = resolveVars(par1, sess, sc_sess, event_params);
  string name  = resolveVars(par2, sess, sc_sess, event_params);
  MONITORING_INC(type.c_str(), name.c_str());
  return false;
}

CONST_ACTION_2P(MonLogDecAction, ',', true);
bool MonLogDecAction::execute(AmSession* sess,  DSMSession* sc_sess,
			   DSMCondition::EventType event,
			   map<string,string>* event_params) {
  string type = resolveVars(par1, sess, sc_sess, event_params);
  string name  = resolveVars(par2, sess, sc_sess, event_params);
  MONITORING_DEC(type.c_str(), name.c_str());
  return false;
}