mgmt: added subscription-based configuration file parser
Modules subscribe to configuration sections they are interested
in by name and provide a callback function. After parsing
the configuration file, ConfigFile will iterate through the
top level tree and invoke all subscribed callbacks for each
section it comes across.
ConfigFile has no concept of the specific tags or structure of the file
other than there being a single root tag (not a specific name) under which
all sections fall.
refs: #1120
Change-Id: Ic06fbdc85a9ac9740d46a6c2457ff5a9bd38e8a5
diff --git a/daemon/mgmt/config-file.cpp b/daemon/mgmt/config-file.cpp
new file mode 100644
index 0000000..a55650e
--- /dev/null
+++ b/daemon/mgmt/config-file.cpp
@@ -0,0 +1,116 @@
+/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
+/**
+ * Copyright (C) 2014 Named Data Networking Project
+ * See COPYING for copyright and distribution information.
+ */
+
+
+#include "config-file.hpp"
+
+#include <boost/property_tree/info_parser.hpp>
+
+namespace nfd {
+
+NFD_LOG_INIT("ConfigFile");
+
+ConfigFile::ConfigFile()
+{
+
+}
+
+void
+ConfigFile::addSectionHandler(const std::string& sectionName,
+ OnConfig subscriber)
+{
+ m_subscriptions[sectionName] = subscriber;
+}
+
+void
+ConfigFile::parse(const char* filename, bool isDryRun)
+{
+ std::ifstream inputFile;
+ inputFile.open(filename);
+ if (!inputFile.is_open())
+ {
+ std::string msg = "Failed to read configuration file: ";
+ msg += filename;
+ throw Error(filename);
+ }
+ parse(inputFile, isDryRun, filename);
+ inputFile.close();
+}
+
+void
+ConfigFile::parse(const std::string& input, bool isDryRun, const char* filename)
+{
+ std::istringstream inputStream(input);
+ parse(inputStream, isDryRun, filename);
+}
+
+
+void
+ConfigFile::parse(std::istream& input, bool isDryRun, const char* filename)
+{
+ try
+ {
+ boost::property_tree::read_info(input, m_global);
+ }
+ catch (const boost::property_tree::info_parser_error& error)
+ {
+ std::stringstream msg;
+ msg << "Failed to parse configuration file";
+ if (filename != 0)
+ {
+ msg << " " << filename;
+ }
+ msg << " " << error.message() << " line " << error.line();
+ throw Error(msg.str());
+ }
+
+ process(isDryRun, filename);
+}
+
+void
+ConfigFile::process(bool isDryRun, const char* filename)
+{
+ // NFD_LOG_DEBUG("processing..." << ((isDryRun)?("dry run"):("")));
+
+ if (m_global.begin() == m_global.end())
+ {
+ std::string msg = "Error processing configuration file";
+ if (filename != 0)
+ {
+ msg += ": ";
+ msg += filename;
+ }
+ msg += " no data";
+ throw Error(msg);
+ }
+
+ for (ConfigSection::const_iterator i = m_global.begin(); i != m_global.end(); ++i)
+ {
+ const std::string& sectionName = i->first;
+ const ConfigSection& section = i->second;
+
+ SubscriptionTable::iterator subscriberIt = m_subscriptions.find(sectionName);
+ if (subscriberIt != m_subscriptions.end())
+ {
+ OnConfig subscriber = subscriberIt->second;
+ subscriber(section, isDryRun);
+ }
+ else
+ {
+ std::string msg = "Error processing configuration file";
+ if (filename != 0)
+ {
+ msg += " ";
+ msg += filename;
+ }
+ msg += " no module subscribed for section: " + sectionName;
+ throw Error(msg);
+ }
+ }
+}
+
+}
+