Rename from yp2 to metaproxy. The namespace for all definitions
[metaproxy-moved-to-github.git] / src / router_flexml.cpp
1 /* $Id: router_flexml.cpp,v 1.17 2006-03-16 10:40:59 adam Exp $
2    Copyright (c) 2005-2006, Index Data.
3
4 %LICENSE%
5  */
6
7 #include "config.hpp"
8 #include "xmlutil.hpp"
9 #include "router_flexml.hpp"
10 #include "factory_filter.hpp"
11 #include "factory_static.hpp"
12
13 #include <iostream>
14 #include <map>
15 #include <list>
16
17 #include <boost/shared_ptr.hpp>
18
19 #include <libxml/xmlversion.h>
20 #include <libxml/parser.h>
21 #include <libxml/tree.h>
22
23 namespace mp = metaproxy_1;
24
25 namespace metaproxy_1 {
26     class RouterFleXML::Route {
27         friend class RouterFleXML::Rep;
28         friend class RouterFleXML::Pos;
29         friend class RouterFleXML;
30         std::list<boost::shared_ptr<const mp::filter::Base> > m_list;
31     };
32     class RouterFleXML::Rep {
33         friend class RouterFleXML;
34         friend class RouterFleXML::Pos;
35         Rep();
36
37         void base(xmlDocPtr doc, mp::FactoryFilter &factory);
38
39         typedef std::map<std::string,
40                          boost::shared_ptr<const mp::filter::Base > >
41                          IdFilterMap ;
42
43         IdFilterMap m_id_filter_map;
44
45         std::map<std::string,RouterFleXML::Route> m_routes;
46
47         std::string m_start_route;
48
49         std::string m_dl_path;
50
51         void parse_xml_config_dom(xmlDocPtr doc);
52
53         void parse_xml_filters(xmlDocPtr doc, const xmlNode *node);
54         void parse_xml_routes(xmlDocPtr doc, const xmlNode *node);
55
56         bool m_xinclude;
57     private:
58         FactoryFilter *m_factory; // TODO shared_ptr
59     };
60
61     class RouterFleXML::Pos : public RoutePos {
62     public:
63         virtual const filter::Base *move(const char *route);
64         virtual RoutePos *clone();
65         virtual ~Pos();
66         mp::RouterFleXML::Rep *m_p;
67
68         std::map<std::string, 
69                  RouterFleXML::Route>::iterator m_route_it;
70         std::list<boost::shared_ptr <const mp::filter::Base> >::iterator m_filter_it;
71     };
72 }
73
74 void mp::RouterFleXML::Rep::parse_xml_filters(xmlDocPtr doc,
75                                                const xmlNode *node)
76 {
77     unsigned int filter_nr = 0;
78     while(node && mp::xml::check_element_yp2(node, "filter"))
79     {
80         filter_nr++;
81
82         const struct _xmlAttr *attr;
83         std::string id_value;
84         std::string type_value;
85         for (attr = node->properties; attr; attr = attr->next)
86         {
87             std::string name = std::string((const char *) attr->name);
88             std::string value;
89
90             if (attr->children && attr->children->type == XML_TEXT_NODE)
91                 value = std::string((const char *)attr->children->content);
92
93             if (name == "id")
94                 id_value = value;
95             else if (name == "type")
96                 type_value = value;
97             else
98                 throw mp::XMLError("Only attribute id or type allowed"
99                                     " in filter element. Got " + name);
100         }
101
102         if (!m_factory->exist(type_value))
103         {
104             std::cout << "about to load " << type_value << ", path=" << 
105                 m_dl_path << "\n";
106             m_factory->add_creator_dl(type_value, m_dl_path);
107         }
108         mp::filter::Base* filter_base = m_factory->create(type_value);
109
110         filter_base->configure(node);
111
112         if (m_id_filter_map.find(id_value) != m_id_filter_map.end())
113             throw mp::XMLError("Filter " + id_value + " already defined");
114
115         m_id_filter_map[id_value] =
116             boost::shared_ptr<mp::filter::Base>(filter_base);
117
118         node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
119     }
120 }
121
122 void mp::RouterFleXML::Rep::parse_xml_routes(xmlDocPtr doc,
123                                               const xmlNode *node)
124 {
125     mp::xml::check_element_yp2(node, "route");
126
127     unsigned int route_nr = 0;
128     while(mp::xml::is_element_yp2(node, "route"))
129     {
130         route_nr++;
131
132         const struct _xmlAttr *attr;
133         std::string id_value;
134         for (attr = node->properties; attr; attr = attr->next)
135         {
136             std::string name = std::string((const char *) attr->name);
137             std::string value;
138             
139             if (attr->children && attr->children->type == XML_TEXT_NODE)
140                 value = std::string((const char *)attr->children->content);
141             
142             if (name == "id")
143                 id_value = value;
144             else
145                 throw mp::XMLError("Only attribute 'id' allowed for"
146                                     " element 'route'."
147                                     " Got " + name);
148         }
149
150         Route route;
151
152         // process <filter> nodes in third level
153         const xmlNode* node3 = mp::xml::jump_to_children(node, XML_ELEMENT_NODE);
154
155         unsigned int filter3_nr = 0;
156         while(node3 && mp::xml::check_element_yp2(node3, "filter"))
157         {
158             filter3_nr++;
159             
160             const struct _xmlAttr *attr;
161             std::string refid_value;
162             std::string type_value;
163             for (attr = node3->properties; attr; attr = attr->next)
164             {
165                 std::string name = std::string((const char *) attr->name);
166                 std::string value;
167                 
168                 if (attr->children && attr->children->type == XML_TEXT_NODE)
169                     value = std::string((const char *)attr->children->content);
170                 
171                 if (name == "refid")
172                     refid_value = value;
173                 else if (name == "type")
174                     type_value = value;
175                 else
176                     throw mp::XMLError("Only attribute 'refid' or 'type'"
177                                         " allowed for element 'filter'."
178                                         " Got " + name);
179             }
180             if (refid_value.length())
181             {
182                 std::map<std::string,
183                     boost::shared_ptr<const mp::filter::Base > >::iterator it;
184                 it = m_id_filter_map.find(refid_value);
185                 if (it == m_id_filter_map.end())
186                     throw mp::XMLError("Unknown filter refid "
187                                         + refid_value);
188                 else
189                     route.m_list.push_back(it->second);
190             }
191             else if (type_value.length())
192             {
193                 if (!m_factory->exist(type_value))
194                 {
195                     std::cout << "about to load " << type_value << ", path=" << 
196                         m_dl_path << "\n";
197                     m_factory->add_creator_dl(type_value, m_dl_path);
198                 }
199                 mp::filter::Base* filter_base = m_factory->create(type_value);
200
201                 filter_base->configure(node3);
202                 
203                 route.m_list.push_back(
204                     boost::shared_ptr<mp::filter::Base>(filter_base));
205             }
206             node3 = mp::xml::jump_to_next(node3, XML_ELEMENT_NODE);
207             
208         }
209         std::map<std::string,RouterFleXML::Route>::iterator it;
210         it = m_routes.find(id_value);
211         if (it != m_routes.end())
212             throw mp::XMLError("Route id='" + id_value
213                                 + "' already exist");
214         else
215             m_routes[id_value] = route;
216         node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
217     }
218 }
219
220 void mp::RouterFleXML::Rep::parse_xml_config_dom(xmlDocPtr doc)
221 {
222     if (!doc)
223         throw mp::XMLError("Empty XML Document");
224     
225     const xmlNode* root = xmlDocGetRootElement(doc);
226     
227     mp::xml::check_element_yp2(root,  "yp2");
228
229     const xmlNode* node = mp::xml::jump_to_children(root, XML_ELEMENT_NODE);
230
231     if (mp::xml::is_element_yp2(node, "dlpath"))
232     {
233         m_dl_path = mp::xml::get_text(node);
234         node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
235     }
236     // process <start> node which is expected first element node
237     if (mp::xml::check_element_yp2(node, "start"))
238     {
239         const struct _xmlAttr *attr;
240         std::string id_value;
241         for (attr = node->properties; attr; attr = attr->next)
242         {
243             std::string name = std::string((const char *) attr->name);
244             std::string value;
245
246             if (attr->children && attr->children->type == XML_TEXT_NODE)
247                 value = std::string((const char *)attr->children->content);
248
249             if (name == "route")
250                 m_start_route = value;
251             else
252                 throw mp::XMLError("Only attribute start allowed"
253                                     " in element 'start'. Got " + name);
254         }
255         node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
256     }
257     // process <filters> node if given
258     if (mp::xml::is_element_yp2(node, "filters"))
259     {
260         parse_xml_filters(doc, mp::xml::jump_to_children(node,
261                                                           XML_ELEMENT_NODE));
262                       
263         node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
264     }
265     // process <routes> node which is expected third element node
266     mp::xml::check_element_yp2(node, "routes");
267     
268     parse_xml_routes(doc, mp::xml::jump_to_children(node, XML_ELEMENT_NODE));
269
270     node = mp::xml::jump_to_next(node, XML_ELEMENT_NODE);
271     if (node)
272     {
273         throw mp::XMLError("Unexpected element " 
274                             + std::string((const char *)node->name));
275     }
276 }        
277
278 mp::RouterFleXML::Rep::Rep() : m_xinclude(false)
279 {
280 }
281
282 void mp::RouterFleXML::Rep::base(xmlDocPtr doc, mp::FactoryFilter &factory)
283 {
284     m_factory = &factory;
285     parse_xml_config_dom(doc);
286     m_start_route = "start";
287 }
288
289 mp::RouterFleXML::RouterFleXML(xmlDocPtr doc, mp::FactoryFilter &factory)
290     : m_p(new Rep)
291 {
292     m_p->base(doc, factory);
293 }
294
295 mp::RouterFleXML::RouterFleXML(std::string xmlconf, mp::FactoryFilter &factory) 
296     : m_p(new Rep)
297 {            
298     LIBXML_TEST_VERSION;
299     
300     xmlDocPtr doc = xmlParseMemory(xmlconf.c_str(),
301                                    xmlconf.size());
302     if (!doc)
303         throw mp::XMLError("xmlParseMemory failed");
304     else
305     {
306         m_p->base(doc, factory);
307         xmlFreeDoc(doc);
308     }
309 }
310
311 mp::RouterFleXML::~RouterFleXML()
312 {
313 }
314
315 const mp::filter::Base *mp::RouterFleXML::Pos::move(const char *route)
316 {
317     if (route && *route)
318     {
319         std::cout << "move to " << route << "\n";
320         m_route_it = m_p->m_routes.find(route);
321         if (m_route_it == m_p->m_routes.end())
322         {
323             std::cout << "no such route " << route << "\n";
324             throw mp::XMLError("bad route " + std::string(route));
325         }
326         m_filter_it = m_route_it->second.m_list.begin();
327     }
328     if (m_filter_it == m_route_it->second.m_list.end())
329         return 0;
330     const mp::filter::Base *f = (*m_filter_it).get();
331     m_filter_it++;
332     return f;
333 }
334
335 mp::RoutePos *mp::RouterFleXML::createpos() const
336 {
337     mp::RouterFleXML::Pos *p = new mp::RouterFleXML::Pos;
338
339     p->m_route_it = m_p->m_routes.find(m_p->m_start_route);
340     if (p->m_route_it == m_p->m_routes.end())
341     {
342         delete p;
343         return 0;
344     }
345     p->m_filter_it = p->m_route_it->second.m_list.begin();
346     p->m_p = m_p.get();
347     return p;
348 }
349
350 mp::RoutePos *mp::RouterFleXML::Pos::clone()
351 {
352     mp::RouterFleXML::Pos *p = new mp::RouterFleXML::Pos;
353     p->m_filter_it = m_filter_it;
354     p->m_route_it = m_route_it;
355     p->m_p = m_p;
356     return p;
357 }
358
359 mp::RouterFleXML::Pos::~Pos()
360 {
361 }
362
363
364 /*
365  * Local variables:
366  * c-basic-offset: 4
367  * indent-tabs-mode: nil
368  * c-file-style: "stroustrup"
369  * End:
370  * vim: shiftwidth=4 tabstop=8 expandtab
371  */