mirror of
https://github.com/valitydev/osquery-1.git
synced 2024-11-07 18:08:53 +00:00
88 lines
2.3 KiB
C++
88 lines
2.3 KiB
C++
// Copyright 2004-present Facebook. All Rights Reserved.
|
|
|
|
#include "osquery/config.h"
|
|
#include "osquery/config/plugin.h"
|
|
|
|
#include <algorithm>
|
|
#include <future>
|
|
#include <sstream>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
#include <boost/property_tree/ptree.hpp>
|
|
#include <boost/property_tree/json_parser.hpp>
|
|
#include <boost/thread/shared_mutex.hpp>
|
|
|
|
#include <gflags/gflags.h>
|
|
#include <glog/logging.h>
|
|
|
|
#include "osquery/status.h"
|
|
|
|
using osquery::Status;
|
|
|
|
namespace pt = boost::property_tree;
|
|
|
|
namespace osquery {
|
|
|
|
const std::string kDefaultConfigRetriever = "filesystem";
|
|
|
|
DEFINE_string(config_retriever,
|
|
kDefaultConfigRetriever,
|
|
"The config mechanism to retrieve config content via.");
|
|
|
|
boost::shared_mutex rw_lock;
|
|
|
|
std::shared_ptr<Config> Config::getInstance() {
|
|
static std::shared_ptr<Config> config = std::shared_ptr<Config>(new Config());
|
|
return config;
|
|
}
|
|
|
|
Config::Config() {
|
|
boost::unique_lock<boost::shared_mutex> lock(rw_lock);
|
|
OsqueryConfig conf;
|
|
auto s = Config::genConfig(conf);
|
|
if (!s.ok()) {
|
|
LOG(ERROR) << "error retrieving config: " << s.toString();
|
|
}
|
|
cfg_ = conf;
|
|
}
|
|
|
|
Status Config::genConfig(OsqueryConfig& conf) {
|
|
std::stringstream json;
|
|
pt::ptree tree;
|
|
|
|
if (REGISTERED_CONFIG_PLUGINS.find(FLAGS_config_retriever) ==
|
|
REGISTERED_CONFIG_PLUGINS.end()) {
|
|
LOG(ERROR) << "Config retriever " << FLAGS_config_retriever << " not found";
|
|
return Status(1, "Config retriever not found");
|
|
}
|
|
auto config_data =
|
|
REGISTERED_CONFIG_PLUGINS.at(FLAGS_config_retriever)->genConfig();
|
|
if (!config_data.first.ok()) {
|
|
return config_data.first;
|
|
}
|
|
json << config_data.second;
|
|
pt::read_json(json, tree);
|
|
|
|
try {
|
|
for (const pt::ptree::value_type& v : tree.get_child("scheduledQueries")) {
|
|
OsqueryScheduledQuery q;
|
|
q.name = (v.second).get<std::string>("name");
|
|
q.query = (v.second).get<std::string>("query");
|
|
q.interval = (v.second).get<int>("interval");
|
|
conf.scheduledQueries.push_back(q);
|
|
}
|
|
} catch (const std::exception& e) {
|
|
LOG(ERROR) << "Error parsing config JSON: " << e.what();
|
|
return Status(1, e.what());
|
|
}
|
|
|
|
return Status(0, "OK");
|
|
}
|
|
|
|
std::vector<OsqueryScheduledQuery> Config::getScheduledQueries() {
|
|
boost::shared_lock<boost::shared_mutex> lock(rw_lock);
|
|
return cfg_.scheduledQueries;
|
|
}
|
|
}
|