mirror of https://github.com/Icinga/icinga2.git
Michael Friedrich
parent
3d721236ae
commit
11c41cd747
|
|
@ -43,219 +43,6 @@
|
|||
|
||||
using namespace icinga;
|
||||
|
||||
String NodeUtility::GetRepositoryPath(void)
|
||||
{
|
||||
return Application::GetLocalStateDir() + "/lib/icinga2/api/repository";
|
||||
}
|
||||
|
||||
String NodeUtility::GetNodeRepositoryFile(const String& name)
|
||||
{
|
||||
return GetRepositoryPath() + "/" + SHA256(name) + ".repo";
|
||||
}
|
||||
|
||||
String NodeUtility::GetNodeSettingsFile(const String& name)
|
||||
{
|
||||
return GetRepositoryPath() + "/" + SHA256(name) + ".settings";
|
||||
}
|
||||
|
||||
void NodeUtility::CreateRepositoryPath(const String& path)
|
||||
{
|
||||
if (!Utility::PathExists(path))
|
||||
Utility::MkDirP(path, 0750);
|
||||
|
||||
String user = ScriptGlobal::Get("RunAsUser");
|
||||
String group = ScriptGlobal::Get("RunAsGroup");
|
||||
|
||||
if (!Utility::SetFileOwnership(path, user, group)) {
|
||||
Log(LogWarning, "cli")
|
||||
<< "Cannot set ownership for user '" << user << "' group '" << group << "' on path '" << path << "'. Verify it yourself!";
|
||||
}
|
||||
}
|
||||
|
||||
std::vector<String> NodeUtility::GetNodeCompletionSuggestions(const String& word)
|
||||
{
|
||||
std::vector<String> suggestions;
|
||||
|
||||
for (const Dictionary::Ptr& node : GetNodes()) {
|
||||
String node_name = node->Get("endpoint");
|
||||
|
||||
if (node_name.Find(word) == 0)
|
||||
suggestions.push_back(node_name);
|
||||
}
|
||||
|
||||
return suggestions;
|
||||
}
|
||||
|
||||
void NodeUtility::PrintNodes(std::ostream& fp)
|
||||
{
|
||||
bool first = true;
|
||||
|
||||
for (const Dictionary::Ptr& node : GetNodes()) {
|
||||
if (first)
|
||||
first = false;
|
||||
else
|
||||
fp << "\n";
|
||||
|
||||
fp << "Node '"
|
||||
<< ConsoleColorTag(Console_ForegroundBlue | Console_Bold) << node->Get("endpoint") << ConsoleColorTag(Console_Normal)
|
||||
<< "' (";
|
||||
|
||||
Dictionary::Ptr settings = node->Get("settings");
|
||||
|
||||
if (settings) {
|
||||
String host = settings->Get("host");
|
||||
String port = settings->Get("port");
|
||||
double log_duration = settings->Get("log_duration");
|
||||
|
||||
if (!host.IsEmpty() && !port.IsEmpty())
|
||||
fp << "host: " << host << ", port: " << port << ", ";
|
||||
|
||||
fp << "log duration: " << Utility::FormatDuration(log_duration) << ", ";
|
||||
}
|
||||
|
||||
fp << "last seen: " << Utility::FormatDateTime("%c", node->Get("seen")) << ")\n";
|
||||
|
||||
PrintNodeRepository(fp, node->Get("repository"));
|
||||
}
|
||||
}
|
||||
|
||||
void NodeUtility::PrintNodeRepository(std::ostream& fp, const Dictionary::Ptr& repository)
|
||||
{
|
||||
if (!repository)
|
||||
return;
|
||||
|
||||
ObjectLock olock(repository);
|
||||
for (const Dictionary::Pair& kv : repository) {
|
||||
fp << std::setw(4) << " "
|
||||
<< "* Host '" << ConsoleColorTag(Console_ForegroundGreen | Console_Bold) << kv.first << ConsoleColorTag(Console_Normal) << "'\n";
|
||||
|
||||
Array::Ptr services = kv.second;
|
||||
ObjectLock xlock(services);
|
||||
for (const String& service : services) {
|
||||
fp << std::setw(8) << " " << "* Service '" << ConsoleColorTag(Console_ForegroundGreen | Console_Bold) << service << ConsoleColorTag(Console_Normal) << "'\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
void NodeUtility::PrintNodesJson(std::ostream& fp)
|
||||
{
|
||||
Dictionary::Ptr result = new Dictionary();
|
||||
|
||||
for (const Dictionary::Ptr& node : GetNodes()) {
|
||||
result->Set(node->Get("endpoint"), node);
|
||||
}
|
||||
|
||||
fp << JsonEncode(result);
|
||||
}
|
||||
|
||||
void NodeUtility::AddNode(const String& name)
|
||||
{
|
||||
String path = GetNodeRepositoryFile(name);
|
||||
|
||||
if (Utility::PathExists(path) ) {
|
||||
Log(LogInformation, "cli")
|
||||
<< "Node '" << name << "' exists already.";
|
||||
}
|
||||
|
||||
Dictionary::Ptr node = new Dictionary();
|
||||
|
||||
node->Set("seen", Utility::GetTime());
|
||||
node->Set("endpoint", name);
|
||||
node->Set("zone", name);
|
||||
node->Set("repository", Empty);
|
||||
|
||||
CreateRepositoryPath();
|
||||
Utility::SaveJsonFile(path, 0600, node);
|
||||
}
|
||||
|
||||
void NodeUtility::AddNodeSettings(const String& name, const String& host,
|
||||
const String& port, double log_duration)
|
||||
{
|
||||
Dictionary::Ptr settings = new Dictionary();
|
||||
|
||||
settings->Set("host", host);
|
||||
settings->Set("port", port);
|
||||
settings->Set("log_duration", log_duration);
|
||||
|
||||
CreateRepositoryPath();
|
||||
Utility::SaveJsonFile(GetNodeSettingsFile(name), 0600, settings);
|
||||
}
|
||||
|
||||
void NodeUtility::RemoveNode(const String& name)
|
||||
{
|
||||
String repoPath = GetNodeRepositoryFile(name);
|
||||
|
||||
if (!Utility::PathExists(repoPath))
|
||||
return;
|
||||
|
||||
if (unlink(repoPath.CStr()) < 0) {
|
||||
Log(LogCritical, "cli")
|
||||
<< "Cannot remove file '" << repoPath
|
||||
<< "'. Failed with error code " << errno << ", \"" << Utility::FormatErrorNumber(errno) + "\".";
|
||||
BOOST_THROW_EXCEPTION(posix_error()
|
||||
<< boost::errinfo_api_function("unlink")
|
||||
<< boost::errinfo_errno(errno)
|
||||
<< boost::errinfo_file_name(repoPath));
|
||||
}
|
||||
|
||||
String settingsPath = GetNodeSettingsFile(name);
|
||||
|
||||
if (Utility::PathExists(settingsPath)) {
|
||||
if (unlink(settingsPath.CStr()) < 0) {
|
||||
Log(LogCritical, "cli")
|
||||
<< "Cannot remove file '" << settingsPath
|
||||
<< "'. Failed with error code " << errno << ", \"" << Utility::FormatErrorNumber(errno) + "\".";
|
||||
BOOST_THROW_EXCEPTION(posix_error()
|
||||
<< boost::errinfo_api_function("unlink")
|
||||
<< boost::errinfo_errno(errno)
|
||||
<< boost::errinfo_file_name(settingsPath));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
std::vector<Dictionary::Ptr> NodeUtility::GetNodes(void)
|
||||
{
|
||||
std::vector<Dictionary::Ptr> nodes;
|
||||
|
||||
Utility::Glob(GetRepositoryPath() + "/*.repo",
|
||||
boost::bind(&NodeUtility::CollectNodes, _1, boost::ref(nodes)), GlobFile);
|
||||
|
||||
return nodes;
|
||||
}
|
||||
|
||||
Dictionary::Ptr NodeUtility::LoadNodeFile(const String& node_file)
|
||||
{
|
||||
Dictionary::Ptr node = Utility::LoadJsonFile(node_file);
|
||||
|
||||
if (!node)
|
||||
return Dictionary::Ptr();
|
||||
|
||||
String settingsFile = GetNodeSettingsFile(node->Get("endpoint"));
|
||||
|
||||
if (Utility::PathExists(settingsFile))
|
||||
node->Set("settings", Utility::LoadJsonFile(settingsFile));
|
||||
else
|
||||
node->Remove("settings");
|
||||
|
||||
return node;
|
||||
}
|
||||
|
||||
void NodeUtility::CollectNodes(const String& node_file, std::vector<Dictionary::Ptr>& nodes)
|
||||
{
|
||||
Dictionary::Ptr node;
|
||||
|
||||
try {
|
||||
node = LoadNodeFile(node_file);
|
||||
} catch (const std::exception&) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (!node)
|
||||
return;
|
||||
|
||||
nodes.push_back(node);
|
||||
}
|
||||
|
||||
/*
|
||||
* Node Setup helpers
|
||||
*/
|
||||
|
|
@ -420,172 +207,6 @@ bool NodeUtility::WriteNodeConfigObjects(const String& filename, const Array::Pt
|
|||
return true;
|
||||
}
|
||||
|
||||
/*
|
||||
* Black/Whitelist helpers
|
||||
*/
|
||||
String NodeUtility::GetBlackAndWhiteListPath(const String& type)
|
||||
{
|
||||
return NodeUtility::GetRepositoryPath() + "/" + type + ".list";
|
||||
}
|
||||
|
||||
Array::Ptr NodeUtility::GetBlackAndWhiteList(const String& type)
|
||||
{
|
||||
String list_path = GetBlackAndWhiteListPath(type);
|
||||
|
||||
Array::Ptr lists = new Array();
|
||||
|
||||
if (Utility::PathExists(list_path)) {
|
||||
lists = Utility::LoadJsonFile(list_path);
|
||||
}
|
||||
|
||||
return lists;
|
||||
}
|
||||
|
||||
int NodeUtility::UpdateBlackAndWhiteList(const String& type, const String& zone_filter, const String& host_filter, const String& service_filter)
|
||||
{
|
||||
Array::Ptr lists = GetBlackAndWhiteList(type);
|
||||
|
||||
{
|
||||
ObjectLock olock(lists);
|
||||
|
||||
for (const Dictionary::Ptr& filter : lists) {
|
||||
|
||||
if (filter->Get("zone") == zone_filter) {
|
||||
if (filter->Get("host") == host_filter && service_filter.IsEmpty()) {
|
||||
Log(LogWarning, "cli")
|
||||
<< "Found zone filter '" << zone_filter << "' with host filter '" << host_filter << "'. Bailing out.";
|
||||
return 1;
|
||||
} else if (filter->Get("host") == host_filter && filter->Get("service") == service_filter) {
|
||||
Log(LogWarning, "cli")
|
||||
<< "Found zone filter '" << zone_filter << "' with host filter '" << host_filter << "' and service filter '"
|
||||
<< service_filter << "'. Bailing out.";
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Dictionary::Ptr new_filter = new Dictionary();
|
||||
|
||||
new_filter->Set("zone", zone_filter);
|
||||
new_filter->Set("host", host_filter);
|
||||
new_filter->Set("service", service_filter);
|
||||
|
||||
lists->Add(new_filter);
|
||||
|
||||
String list_path = GetBlackAndWhiteListPath(type);
|
||||
CreateRepositoryPath();
|
||||
Utility::SaveJsonFile(list_path, 0600, lists);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int NodeUtility::RemoveBlackAndWhiteList(const String& type, const String& zone_filter, const String& host_filter, const String& service_filter)
|
||||
{
|
||||
Array::Ptr lists = GetBlackAndWhiteList(type);
|
||||
|
||||
std::vector<int> remove_filters;
|
||||
int remove_idx = 0;
|
||||
{
|
||||
ObjectLock olock(lists);
|
||||
|
||||
for (const Dictionary::Ptr& filter : lists) {
|
||||
|
||||
if (filter->Get("zone") == zone_filter) {
|
||||
if (filter->Get("host") == host_filter && service_filter.IsEmpty()) {
|
||||
Log(LogInformation, "cli")
|
||||
<< "Found zone filter '" << zone_filter << "' with host filter '" << host_filter << "'. Removing from " << type << ".";
|
||||
remove_filters.push_back(remove_idx);
|
||||
} else if (filter->Get("host") == host_filter && filter->Get("service") == service_filter) {
|
||||
Log(LogInformation, "cli")
|
||||
<< "Found zone filter '" << zone_filter << "' with host filter '" << host_filter << "' and service filter '"
|
||||
<< service_filter << "'. Removing from " << type << ".";
|
||||
remove_filters.push_back(remove_idx);
|
||||
}
|
||||
}
|
||||
|
||||
remove_idx++;
|
||||
}
|
||||
}
|
||||
|
||||
/* if there are no matches for reomval, throw an error */
|
||||
if (remove_filters.empty()) {
|
||||
Log(LogCritical, "cli", "Cannot remove filter!");
|
||||
return 1;
|
||||
}
|
||||
|
||||
for (int remove : remove_filters) {
|
||||
lists->Remove(remove);
|
||||
}
|
||||
|
||||
String list_path = GetBlackAndWhiteListPath(type);
|
||||
CreateRepositoryPath();
|
||||
Utility::SaveJsonFile(list_path, 0600, lists);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int NodeUtility::PrintBlackAndWhiteList(std::ostream& fp, const String& type)
|
||||
{
|
||||
Array::Ptr lists = GetBlackAndWhiteList(type);
|
||||
|
||||
if (lists->GetLength() == 0)
|
||||
return 0;
|
||||
|
||||
fp << "Listing all " << type << " entries:\n";
|
||||
|
||||
ObjectLock olock(lists);
|
||||
for (const Dictionary::Ptr& filter : lists) {
|
||||
fp << type << " filter for Node: '" << filter->Get("zone") << "' Host: '"
|
||||
<< filter->Get("host") << "' Service: '" << filter->Get("service") << "'.\n";
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
bool NodeUtility::CheckAgainstBlackAndWhiteList(const String& type, const String& zone, const String& host, const String& service)
|
||||
{
|
||||
Array::Ptr lists = GetBlackAndWhiteList(type);
|
||||
|
||||
Log(LogNotice, "cli")
|
||||
<< "Checking object against " << type << ".";
|
||||
|
||||
ObjectLock olock(lists);
|
||||
for (const Dictionary::Ptr& filter : lists) {
|
||||
String zone_filter = filter->Get("zone");
|
||||
String host_filter = filter->Get("host");
|
||||
String service_filter;
|
||||
|
||||
if (filter->Contains("service"))
|
||||
service_filter = filter->Get("service");
|
||||
|
||||
Log(LogNotice, "cli")
|
||||
<< "Checking Node '" << zone << "' =~ '" << zone_filter << "', host '" << host << "' =~ '" << host_filter
|
||||
<< "', service '" << service << "' =~ '" << service_filter << "'.";
|
||||
|
||||
if (Utility::Match(zone_filter, zone)) {
|
||||
Log(LogNotice, "cli")
|
||||
<< "Node '" << zone << "' matches filter '" << zone_filter << "'";
|
||||
|
||||
if (Utility::Match(host_filter, host)) {
|
||||
Log(LogNotice, "cli")
|
||||
<< "Host '" << host << "' matches filter '" << host_filter << "'";
|
||||
|
||||
/* no service filter means host match */
|
||||
if (service_filter.IsEmpty())
|
||||
return true;
|
||||
|
||||
if (Utility::Match(service_filter, service)) {
|
||||
Log(LogNotice, "cli")
|
||||
<< "Host '" << service << "' matches filter '" << service_filter << "'";
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
/*
|
||||
* We generally don't overwrite files without backup before
|
||||
|
|
|
|||
|
|
@ -37,21 +37,6 @@ namespace icinga
|
|||
class I2_CLI_API NodeUtility
|
||||
{
|
||||
public:
|
||||
static String GetRepositoryPath(void);
|
||||
static String GetNodeRepositoryFile(const String& name);
|
||||
static String GetNodeSettingsFile(const String& name);
|
||||
static void CreateRepositoryPath(const String& path = GetRepositoryPath());
|
||||
static std::vector<String> GetNodeCompletionSuggestions(const String& word);
|
||||
|
||||
static void PrintNodes(std::ostream& fp);
|
||||
static void PrintNodesJson(std::ostream& fp);
|
||||
static void PrintNodeRepository(std::ostream& fp, const Dictionary::Ptr& repository);
|
||||
static void AddNode(const String& name);
|
||||
static void AddNodeSettings(const String& name, const String& host, const String& port, double log_duration);
|
||||
static void RemoveNode(const String& name);
|
||||
|
||||
static std::vector<Dictionary::Ptr> GetNodes(void);
|
||||
|
||||
static bool CreateBackupFile(const String& target, bool is_private = false);
|
||||
|
||||
static bool WriteNodeConfigObjects(const String& filename, const Array::Ptr& objects);
|
||||
|
|
@ -62,22 +47,8 @@ public:
|
|||
static int GenerateNodeIcingaConfig(const std::vector<std::string>& endpoints);
|
||||
static int GenerateNodeMasterIcingaConfig(void);
|
||||
|
||||
/* black/whitelist */
|
||||
static String GetBlackAndWhiteListPath(const String& type);
|
||||
static Array::Ptr GetBlackAndWhiteList(const String& type);
|
||||
static int UpdateBlackAndWhiteList(const String& type, const String& node_filter,
|
||||
const String& host_filter, const String& service_filter);
|
||||
static int RemoveBlackAndWhiteList(const String& type, const String& node_filter,
|
||||
const String& host_filter, const String& service_filter);
|
||||
static int PrintBlackAndWhiteList(std::ostream& fp, const String& type);
|
||||
|
||||
static bool CheckAgainstBlackAndWhiteList(const String& type, const String& node, const String& host, const String& service);
|
||||
|
||||
private:
|
||||
NodeUtility(void);
|
||||
static bool RemoveNodeFile(const String& path);
|
||||
static Dictionary::Ptr LoadNodeFile(const String& node_file);
|
||||
static void CollectNodes(const String& node_file, std::vector<Dictionary::Ptr>& nodes);
|
||||
|
||||
static void SerializeObject(std::ostream& fp, const Dictionary::Ptr& object);
|
||||
};
|
||||
|
|
|
|||
Loading…
Reference in New Issue