icinga2/lib/livestatus/attributefilter.cpp

140 lines
5.3 KiB
C++
Raw Normal View History

2013-03-10 15:11:32 +01:00
/******************************************************************************
* Icinga 2 *
2015-01-22 12:00:23 +01:00
* Copyright (C) 2012-2015 Icinga Development Team (http://www.icinga.org) *
2013-03-10 15:11:32 +01:00
* *
* This program 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 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
******************************************************************************/
2014-05-25 16:23:35 +02:00
#include "livestatus/attributefilter.hpp"
#include "base/convert.hpp"
#include "base/array.hpp"
#include "base/objectlock.hpp"
2014-10-19 14:21:12 +02:00
#include "base/logger.hpp"
2013-03-16 21:18:53 +01:00
#include <boost/foreach.hpp>
#include <boost/regex.hpp>
#include <boost/algorithm/string/predicate.hpp>
2013-03-10 15:11:32 +01:00
using namespace icinga;
AttributeFilter::AttributeFilter(const String& column, const String& op, const String& operand)
: m_Column(column), m_Operator(op), m_Operand(operand)
{ }
bool AttributeFilter::Apply(const Table::Ptr& table, const Value& row)
2013-03-10 15:11:32 +01:00
{
2013-03-10 18:49:14 +01:00
Column column = table->GetColumn(m_Column);
2013-03-10 15:11:32 +01:00
Value value = column.ExtractValue(row);
2013-03-10 15:11:32 +01:00
if (value.IsObjectType<Array>()) {
Array::Ptr array = value;
if (m_Operator == ">=" || m_Operator == "<") {
bool negate = (m_Operator == "<");
ObjectLock olock(array);
2013-03-10 15:11:32 +01:00
BOOST_FOREACH(const String& item, array) {
if (item == m_Operand)
return !negate; /* Item found in list. */
2013-03-10 15:11:32 +01:00
}
return negate; /* Item not found in list. */
} else if (m_Operator == "=") {
return (array->GetLength() == 0);
2013-03-10 15:11:32 +01:00
} else {
BOOST_THROW_EXCEPTION(std::invalid_argument("Invalid operator for column '" + m_Column + "': " + m_Operator + " (expected '>=' or '=')."));
2013-03-10 15:11:32 +01:00
}
} else {
if (m_Operator == "=") {
if (value.GetType() == ValueNumber || value.GetType() == ValueBoolean)
2013-03-10 15:11:32 +01:00
return (static_cast<double>(value) == Convert::ToDouble(m_Operand));
else
return (static_cast<String>(value) == m_Operand);
} else if (m_Operator == "~") {
bool ret;
try {
boost::regex expr(m_Operand.GetData());
String operand = value;
boost::smatch what;
ret = boost::regex_search(operand.GetData(), what, expr);
} catch (boost::exception&) {
2014-10-19 17:52:17 +02:00
Log(LogWarning, "AttributeFilter")
<< "Regex '" << m_Operand << " " << m_Operator << " " << value << "' error.";
ret = false;
}
2014-10-19 17:52:17 +02:00
//Log(LogDebug, "LivestatusListener/AttributeFilter")
// << "Attribute filter '" << m_Operand + " " << m_Operator << " "
// << value << "' " << (ret ? "matches" : "doesn't match") << ".";
return ret;
2013-03-10 15:11:32 +01:00
} else if (m_Operator == "=~") {
bool ret;
try {
String operand = value;
ret = boost::iequals(operand, m_Operand.GetData());
} catch (boost::exception&) {
Log(LogWarning, "AttributeFilter")
<< "Case-insensitive equality '" << m_Operand << " " << m_Operator << " " << value << "' error.";
ret = false;
}
return ret;
2013-03-10 15:11:32 +01:00
} else if (m_Operator == "~~") {
bool ret;
try {
boost::regex expr(m_Operand.GetData(), boost::regex::icase);
String operand = value;
boost::smatch what;
ret = boost::regex_search(operand.GetData(), what, expr);
} catch (boost::exception&) {
2014-10-19 17:52:17 +02:00
Log(LogWarning, "AttributeFilter")
<< "Regex '" << m_Operand << " " << m_Operator << " " << value << "' error.";
ret = false;
}
2014-10-19 17:52:17 +02:00
//Log(LogDebug, "LivestatusListener/AttributeFilter")
// << "Attribute filter '" << m_Operand << " " << m_Operator << " "
// << value << "' " << (ret ? "matches" : "doesn't match") << ".";
2013-03-10 15:11:32 +01:00
return ret;
2013-03-10 15:11:32 +01:00
} else if (m_Operator == "<") {
if (value.GetType() == ValueNumber)
return (static_cast<double>(value) < Convert::ToDouble(m_Operand));
else
return (static_cast<String>(value) < m_Operand);
} else if (m_Operator == ">") {
if (value.GetType() == ValueNumber)
return (static_cast<double>(value) > Convert::ToDouble(m_Operand));
else
return (static_cast<String>(value) > m_Operand);
} else if (m_Operator == "<=") {
if (value.GetType() == ValueNumber)
return (static_cast<double>(value) <= Convert::ToDouble(m_Operand));
else
return (static_cast<String>(value) <= m_Operand);
} else if (m_Operator == ">=") {
if (value.GetType() == ValueNumber)
return (static_cast<double>(value) >= Convert::ToDouble(m_Operand));
else
return (static_cast<String>(value) >= m_Operand);
} else {
2013-03-16 21:18:53 +01:00
BOOST_THROW_EXCEPTION(std::invalid_argument("Unknown operator for column '" + m_Column + "': " + m_Operator));
2013-03-10 15:11:32 +01:00
}
}
return false;
}