X-Git-Url: http://lists.indexdata.com/cgi-bin?a=blobdiff_plain;f=src%2Frouter_flexml.cpp;h=47501df0ae101e2af7bcfa8ff08c2d35bc81cf6e;hb=111438f9a883ac784b4ce743a7e83fb8a5b3ff4d;hp=914868e7b15a58465360704d8aa93ac325fe01b4;hpb=c859210e9c315c0f15c93fc6f65477a6c3e65d14;p=metaproxy-moved-to-github.git diff --git a/src/router_flexml.cpp b/src/router_flexml.cpp index 914868e..47501df 100644 --- a/src/router_flexml.cpp +++ b/src/router_flexml.cpp @@ -1,13 +1,222 @@ -/* $Id: router_flexml.cpp,v 1.1 2005-10-26 14:12:00 marc Exp $ +/* $Id: router_flexml.cpp,v 1.6 2005-12-08 22:32:57 adam Exp $ Copyright (c) 2005, Index Data. %LICENSE% */ - +#include "config.hpp" #include "router_flexml.hpp" +#include +#include +#include + +#include + +#include +#include +#include + + +namespace yp2 { + class RouterFleXML::Rep { + friend class RouterFleXML; + Rep(); + + typedef std::map > + IdFilterMap ; + typedef std::list FilterIdList; + typedef std::map IdRouteMap ; + + bool m_xinclude; + IdFilterMap m_id_filter_map; + FilterIdList m_filter_id_list; + IdRouteMap m_id_route_map; + + void create_filter(std::string type, + const xmlDoc * xmldoc, + std::string id = ""); + + void parse_xml_config_dom(xmlDocPtr doc); + + bool is_element(const xmlNode *ptr, + const std::string &ns, + const std::string &name); + + bool is_element_yp2(const xmlNode *ptr, + const std::string &name); + + bool check_element_yp2(const xmlNode *ptr, + const std::string &name); + + const xmlNode* jump_to(const xmlNode* node, int xml_node_type); + + const xmlNode* jump_to_next(const xmlNode* node, int xml_node_type); + + const xmlNode* jump_to_children(const xmlNode* node, int xml_node_type); + }; +} + +const xmlNode* yp2::RouterFleXML::Rep::jump_to_children(const xmlNode* node, int xml_node_type) +{ + node = node->children; + for (; node && node->type != xml_node_type; node = node->next) + ; + return node; +} + +const xmlNode* yp2::RouterFleXML::Rep::jump_to_next(const xmlNode* node, int xml_node_type) +{ + node = node->next; + for (; node && node->type != xml_node_type; node = node->next) + ; + return node; +} + +const xmlNode* yp2::RouterFleXML::Rep::jump_to(const xmlNode* node, int xml_node_type) +{ + for (; node && node->type != xml_node_type; node = node->next) + ; + return node; +} + +bool yp2::RouterFleXML::Rep::is_element(const xmlNode *ptr, + const std::string &ns, + const std::string &name) +{ + if (ptr && ptr->type == XML_ELEMENT_NODE && ptr->ns && ptr->ns->href + && !xmlStrcmp(BAD_CAST ns.c_str(), ptr->ns->href) + && !xmlStrcmp(BAD_CAST name.c_str(), ptr->name)) + return true; + return false; +} + +bool yp2::RouterFleXML::Rep::is_element_yp2(const xmlNode *ptr, + const std::string &name) +{ + return is_element(ptr, "http://indexdata.dk/yp2/config/1", name); +} + +bool yp2::RouterFleXML::Rep::check_element_yp2(const xmlNode *ptr, + const std::string &name) +{ + if (!is_element_yp2(ptr, name)) + throw XMLError("Error. Expected element name " + name); + return true; +} + +void yp2::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc) +{ + if (!doc) + throw XMLError("Empty XML Document"); + + const xmlNode* root = xmlDocGetRootElement(doc); + + check_element_yp2(root, "yp2"); + + std::cout << "processing /yp2" << std::endl; + + // process node which is expected first element node + const xmlNode* node = jump_to_children(root, XML_ELEMENT_NODE); + //for (; node && node->type != XML_ELEMENT_NODE; node = node->next) + // ; + + check_element_yp2(node, "start"); + + std::cout << "processing /yp2/start" << std::endl; + + // process node which is expected second element node + node = jump_to_next(node, XML_ELEMENT_NODE); + check_element_yp2(node, "filters"); + std::cout << "processing /yp2/filters" << std::endl; + + // process nodes in next level + const xmlNode* node2 = jump_to_children(node, XML_ELEMENT_NODE); + + unsigned int filter_nr = 0; + while(node2 && check_element_yp2(node2, "filter")) + { + filter_nr++; + std::cout << "processing /yp2/filters/filter[" + << filter_nr << "]" << std::endl; + node2 = jump_to_next(node2, XML_ELEMENT_NODE); + } + + // process node which is expected third element node + node = jump_to_next(node, XML_ELEMENT_NODE); + check_element_yp2(node, "routes"); + std::cout << "processing /yp2/routes" << std::endl; + + // process nodes in next level + node2 = jump_to_children(node, XML_ELEMENT_NODE); + check_element_yp2(node2, "route"); + + unsigned int route_nr = 0; + while(is_element_yp2(node2, "router")) + { + route_nr++; + std::cout << "processing /yp2/routes/route[" + << route_nr << "]" << std::endl; + + // process nodes in third level + const xmlNode* node3 = jump_to_children(node2, XML_ELEMENT_NODE); + + unsigned int filter3_nr = 0; + while(node3 && check_element_yp2(node3, "filter")) + { + filter3_nr++; + + std::cout << "processing /yp2/routes/route[" + << route_nr << "]/filter[" + << filter3_nr << "]" << std::endl; + + node3 = jump_to_next(node3, XML_ELEMENT_NODE); + + } + node2 = jump_to_next(node2, XML_ELEMENT_NODE); + } +} + +void yp2::RouterFleXML::Rep::create_filter(std::string type, + const xmlDoc * xmldoc, + std::string id) +{ + std::cout << "Created Filter type='" << type + << "' id='" << id << "'" << std::endl; +} + +yp2::RouterFleXML::Rep::Rep() : + m_xinclude(false) +{ +} + +yp2::RouterFleXML::RouterFleXML(std::string xmlconf) + : m_p(new Rep) +{ + LIBXML_TEST_VERSION; + + xmlDocPtr doc = xmlParseMemory(xmlconf.c_str(), + xmlconf.size()); + if (!doc) + throw XMLError("xmlParseMemory failed"); + else + { + m_p->parse_xml_config_dom(doc); + xmlFreeDoc(doc); + } +} + +yp2::RouterFleXML::~RouterFleXML() +{ +} +const yp2::filter::Base * +yp2::RouterFleXML::move(const yp2::filter::Base *filter, + const yp2::Package *package) const +{ + return 0; +} + /* * Local variables: