X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Frouter_flexml.cpp;h=a904d6efedde139d668b9fc49603ee200273c9d0;hb=1cdd720a9a3ba872aa092c80b28413d8b2579eed;hp=67a96769102a6a20d76e00b6e0c0d87f11a31dfc;hpb=bcb66e8e0d7fd2ce5ddc37eb0bc5ec1722ffefa6;p=metaproxy-moved-to-github.git diff --git a/src/router_flexml.cpp b/src/router_flexml.cpp index 67a9676..a904d6e 100644 --- a/src/router_flexml.cpp +++ b/src/router_flexml.cpp @@ -18,6 +18,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #include "config.hpp" #include +#include #include "router_flexml.hpp" #include "factory_filter.hpp" #include "factory_static.hpp" @@ -70,6 +71,7 @@ namespace metaproxy_1 { bool test_only, const char *file_include_path); void parse_xml_routes(xmlDocPtr doc, const xmlNode *node, bool test_only, const char *file_include_path); + void check_routes_in_filters(const xmlNode *n); bool m_xinclude; private: @@ -239,6 +241,43 @@ void mp::RouterFleXML::Rep::parse_xml_routes(xmlDocPtr doc, } } +void mp::RouterFleXML::Rep::check_routes_in_filters(const xmlNode *node) +{ + while (node) + { + if (mp::xml::is_element_mp(node, "filter")) + { + const xmlNode *n = + mp::xml::jump_to_children(node, XML_ELEMENT_NODE); + while (n) + { + const struct _xmlAttr *attr; + // we assume thar that route attribute is only at one level + // below filter.. At least that works for multi and virt_db. + for (attr = n->properties; attr; attr = attr->next) + { + if (!strcmp((const char *) attr->name, "route")) + { + std::string value; + + if (attr->children && attr->children->type == XML_TEXT_NODE) + value = std::string((const char *)attr->children->content); + + std::map::iterator it; + it = m_routes.find(value); + if (it == m_routes.end()) + { + throw mp::XMLError("Route '" + value + "' does not exist"); + } + } + } + n = mp::xml::jump_to_next(n, XML_ELEMENT_NODE); + } + } + node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE); + } +} + void mp::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc, bool test_only, const char *file_include_path) @@ -268,7 +307,6 @@ void mp::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc, if (mp::xml::check_element_mp(node, "start")) { const struct _xmlAttr *attr; - std::string id_value; for (attr = node->properties; attr; attr = attr->next) { std::string name = std::string((const char *) attr->name); @@ -280,7 +318,7 @@ void mp::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc, if (name == "route") m_start_route = value; else - throw mp::XMLError("Only attribute start allowed" + throw mp::XMLError("Only attribute route allowed" " in element 'start'. Got " + name); } node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE); @@ -306,7 +344,32 @@ void mp::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc, throw mp::XMLError("Unexpected element " + std::string((const char *)node->name)); } -} + + node = mp::xml::jump_to_children(root, XML_ELEMENT_NODE); + while (node) + { + if (mp::xml::is_element_mp(node, "filters")) + check_routes_in_filters( + mp::xml::jump_to_children(node, + XML_ELEMENT_NODE)); + else if (mp::xml::is_element_mp(node, "routes")) + { + const xmlNode* n = mp::xml::jump_to_children(node, + XML_ELEMENT_NODE); + while (n) + { + if (mp::xml::is_element_mp(n, "route")) + { + check_routes_in_filters( + mp::xml::jump_to_children(n, XML_ELEMENT_NODE)); + + } + n = mp::xml::jump_to_next(n, XML_ELEMENT_NODE); + } + } + node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE); + } +} mp::RouterFleXML::Rep::Rep() : m_xinclude(false) {