/****************************************************************************** * Icinga 2 * * Copyright (C) 2012-2014 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 "config/applyrule.hpp" #include "base/logger.hpp" #include #include using namespace icinga; ApplyRule::RuleMap ApplyRule::m_Rules; ApplyRule::CallbackMap ApplyRule::m_Callbacks; ApplyRule::ApplyRule(const String& targetType, const String& name, const Expression::Ptr& expression, const Expression::Ptr& filter, const DebugInfo& di, const Dictionary::Ptr& scope) : m_TargetType(targetType), m_Name(name), m_Expression(expression), m_Filter(filter), m_DebugInfo(di), m_Scope(scope) { } String ApplyRule::GetTargetType(void) const { return m_TargetType; } String ApplyRule::GetName(void) const { return m_Name; } Expression::Ptr ApplyRule::GetExpression(void) const { return m_Expression; } Expression::Ptr ApplyRule::GetFilter(void) const { return m_Filter; } DebugInfo ApplyRule::GetDebugInfo(void) const { return m_DebugInfo; } Dictionary::Ptr ApplyRule::GetScope(void) const { return m_Scope; } void ApplyRule::AddRule(const String& sourceType, const String& targetType, const String& name, const Expression::Ptr& expression, const Expression::Ptr& filter, const DebugInfo& di, const Dictionary::Ptr& scope) { m_Rules[sourceType].push_back(ApplyRule(targetType, name, expression, filter, di, scope)); } bool ApplyRule::EvaluateFilter(const Dictionary::Ptr& scope) const { scope->Set("__parent", m_Scope); bool result = m_Filter->Evaluate(scope); scope->Remove("__parent"); return result; } void ApplyRule::EvaluateRules(bool clear) { std::set completedTypes; while (completedTypes.size() < m_Callbacks.size()) { std::pair > > kv; BOOST_FOREACH(kv, m_Callbacks) { const String& sourceType = kv.first; if (completedTypes.find(sourceType) != completedTypes.end()) continue; const Callback& callback = kv.second.first; const std::vector& targetTypes = kv.second.second; bool cont = false; BOOST_FOREACH(const String& targetType, targetTypes) { if (IsValidSourceType(targetType) && completedTypes.find(targetType) == completedTypes.end()) { cont = true; break; } } if (cont) continue; completedTypes.insert(sourceType); RuleMap::const_iterator it = m_Rules.find(kv.first); if (it == m_Rules.end()) continue; callback(it->second); } } if (clear) m_Rules.clear(); } void ApplyRule::RegisterType(const String& sourceType, const std::vector& targetTypes, const ApplyRule::Callback& callback) { m_Callbacks[sourceType] = make_pair(callback, targetTypes); } bool ApplyRule::IsValidSourceType(const String& sourceType) { return m_Callbacks.find(sourceType) != m_Callbacks.end(); } bool ApplyRule::IsValidTargetType(const String& sourceType, const String& targetType) { CallbackMap::const_iterator it = m_Callbacks.find(sourceType); if (it == m_Callbacks.end()) return false; if (it->second.second.size() == 1 && targetType == "") return true; BOOST_FOREACH(const String& type, it->second.second) { if (type == targetType) return true; } return false; } std::vector ApplyRule::GetTargetTypes(const String& sourceType) { CallbackMap::const_iterator it = m_Callbacks.find(sourceType); if (it == m_Callbacks.end()) return std::vector(); return it->second.second; }