/****************************************************************************** * Icinga 2 * * Copyright (C) 2012-present Icinga Development Team (http://www.icinga.org) * * * * 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. * ******************************************************************************/ #include "livestatus/attributefilter.h" #include "base/convert.h" #include "base/array.h" #include "base/objectlock.h" #include "base/logger_fwd.h" #include #include 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) { Column column = table->GetColumn(m_Column); Value value = column.ExtractValue(row); if (value.IsObjectType()) { Array::Ptr array = value; if (m_Operator == ">=") { ObjectLock olock(array); BOOST_FOREACH(const String& item, array) { if (item == m_Operand) return true; /* Item found in list. */ } return false; /* Item not found in list. */ } else if (m_Operator == "=") { return (array->GetLength() == 0); } else { BOOST_THROW_EXCEPTION(std::invalid_argument("Invalid operator for column '" + m_Column + "': " + m_Operator + " (expected '>=' or '=').")); } } else { if (m_Operator == "=") { if (value.GetType() == ValueNumber) return (static_cast(value) == Convert::ToDouble(m_Operand)); else return (static_cast(value) == m_Operand); } else if (m_Operator == "~") { boost::regex expr(m_Operand.GetData()); String operand = value; boost::smatch what; bool ret = boost::regex_search(operand.GetData(), what, expr); //Log(LogDebug, "livestatus", "Attribute filter '" + m_Operand + " " + m_Operator + " " + // static_cast(value) + "' " + (ret ? "matches" : "doesn't match") + "." ); return ret; } else if (m_Operator == "=~") { return string_iless()(value, m_Operand); } else if (m_Operator == "~~") { boost::regex expr(m_Operand.GetData(), boost::regex::icase); String operand = value; boost::smatch what; bool ret = boost::regex_search(operand.GetData(), what, expr); //Log(LogDebug, "livestatus", "Attribute filter '" + m_Operand + " " + m_Operator + " " + // static_cast(value) + "' " + (ret ? "matches" : "doesn't match") + "." ); return ret; } else if (m_Operator == "<") { if (value.GetType() == ValueNumber) return (static_cast(value) < Convert::ToDouble(m_Operand)); else return (static_cast(value) < m_Operand); } else if (m_Operator == ">") { if (value.GetType() == ValueNumber) return (static_cast(value) > Convert::ToDouble(m_Operand)); else return (static_cast(value) > m_Operand); } else if (m_Operator == "<=") { if (value.GetType() == ValueNumber) return (static_cast(value) <= Convert::ToDouble(m_Operand)); else return (static_cast(value) <= m_Operand); } else if (m_Operator == ">=") { if (value.GetType() == ValueNumber) return (static_cast(value) >= Convert::ToDouble(m_Operand)); else return (static_cast(value) >= m_Operand); } else { BOOST_THROW_EXCEPTION(std::invalid_argument("Unknown operator for column '" + m_Column + "': " + m_Operator)); } } return false; }