/****************************************************************************** * Icinga 2 * * Copyright (C) 2012-2018 Icinga Development Team (https://www.icinga.com/) * * * * 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/commandstable.hpp" #include "icinga/icingaapplication.hpp" #include "icinga/checkcommand.hpp" #include "icinga/eventcommand.hpp" #include "icinga/notificationcommand.hpp" #include "icinga/compatutility.hpp" #include "base/configtype.hpp" #include "base/objectlock.hpp" #include "base/convert.hpp" #include using namespace icinga; CommandsTable::CommandsTable() { AddColumns(this); } void CommandsTable::AddColumns(Table *table, const String& prefix, const Column::ObjectAccessor& objectAccessor) { table->AddColumn(prefix + "name", Column(&CommandsTable::NameAccessor, objectAccessor)); table->AddColumn(prefix + "line", Column(&CommandsTable::LineAccessor, objectAccessor)); table->AddColumn(prefix + "custom_variable_names", Column(&CommandsTable::CustomVariableNamesAccessor, objectAccessor)); table->AddColumn(prefix + "custom_variable_values", Column(&CommandsTable::CustomVariableValuesAccessor, objectAccessor)); table->AddColumn(prefix + "custom_variables", Column(&CommandsTable::CustomVariablesAccessor, objectAccessor)); table->AddColumn(prefix + "modified_attributes", Column(&Table::ZeroAccessor, objectAccessor)); table->AddColumn(prefix + "modified_attributes_list", Column(&Table::ZeroAccessor, objectAccessor)); } String CommandsTable::GetName() const { return "commands"; } String CommandsTable::GetPrefix() const { return "command"; } void CommandsTable::FetchRows(const AddRowFunction& addRowFn) { for (const ConfigObject::Ptr& object : ConfigType::GetObjectsByType()) { if (!addRowFn(object, LivestatusGroupByNone, Empty)) return; } for (const ConfigObject::Ptr& object : ConfigType::GetObjectsByType()) { if (!addRowFn(object, LivestatusGroupByNone, Empty)) return; } for (const ConfigObject::Ptr& object : ConfigType::GetObjectsByType()) { if (!addRowFn(object, LivestatusGroupByNone, Empty)) return; } } Value CommandsTable::NameAccessor(const Value& row) { Command::Ptr command = static_cast(row); return CompatUtility::GetCommandName(command); } Value CommandsTable::LineAccessor(const Value& row) { Command::Ptr command = static_cast(row); if (!command) return Empty; return CompatUtility::GetCommandLine(command); } Value CommandsTable::CustomVariableNamesAccessor(const Value& row) { Command::Ptr command = static_cast(row); if (!command) return Empty; Dictionary::Ptr vars = command->GetVars(); ArrayData keys; if (vars) { ObjectLock xlock(vars); for (const auto& kv : vars) { keys.push_back(kv.first); } } return new Array(std::move(keys)); } Value CommandsTable::CustomVariableValuesAccessor(const Value& row) { Command::Ptr command = static_cast(row); if (!command) return Empty; Dictionary::Ptr vars = command->GetVars(); ArrayData keys; if (vars) { ObjectLock xlock(vars); for (const auto& kv : vars) { keys.push_back(kv.second); } } return new Array(std::move(keys)); } Value CommandsTable::CustomVariablesAccessor(const Value& row) { Command::Ptr command = static_cast(row); if (!command) return Empty; Dictionary::Ptr vars = command->GetVars(); ArrayData result; if (vars) { ObjectLock xlock(vars); for (const auto& kv : vars) { result.push_back(new Array({ kv.first, kv.second })); } } return new Array(std::move(result)); }