getaddrinfo/host sub system gone
[pazpar2-moved-to-github.git] / src / pazpar2_config.c
1 /* This file is part of Pazpar2.
2    Copyright (C) Index Data
3
4 Pazpar2 is free software; you can redistribute it and/or modify it under
5 the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2, or (at your option) any later
7 version.
8
9 Pazpar2 is distributed in the hope that it will be useful, but WITHOUT ANY
10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
12 for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17
18 */
19
20 #if HAVE_CONFIG_H
21 #include <config.h>
22 #endif
23
24 #include <string.h>
25 #include <assert.h>
26
27 #include <libxml/parser.h>
28 #include <libxml/tree.h>
29 #include <libxml/xinclude.h>
30
31 #include <yaz/yaz-util.h>
32 #include <yaz/nmem.h>
33 #include <yaz/snprintf.h>
34 #include <yaz/tpath.h>
35 #include <yaz/xml_include.h>
36
37 #include <sys/types.h>
38 #include <sys/stat.h>
39 #if HAVE_UNISTD_H
40 #include <unistd.h>
41 #endif
42 #include "ppmutex.h"
43 #include "incref.h"
44 #include "pazpar2_config.h"
45 #include "service_xslt.h"
46 #include "settings.h"
47 #include "eventl.h"
48 #include "http.h"
49
50 struct conf_config
51 {
52     NMEM nmem; /* for conf_config and servers memory */
53     struct conf_server *servers;
54
55     int no_threads;
56     WRBUF confdir;
57     iochan_man_t iochan_man;
58 };
59
60 struct service_xslt
61 {
62     char *id;
63     xsltStylesheetPtr xsp;
64     struct service_xslt *next;
65 };
66
67 static char *xml_context(const xmlNode *ptr, char *res, size_t len)
68 {
69     xmlAttr *attr = ptr->properties;
70     size_t off = len - 1;
71
72     res[off] = '\0';
73     for (; attr; attr = attr->next)
74     {
75         size_t l = strlen((const char *) attr->name);
76         if (off <= l + 1)
77             break;
78         off = off - l;
79         memcpy(res + off, attr->name, l);
80         res[--off] = '@';
81     }
82     while (ptr && ptr->type == XML_ELEMENT_NODE)
83     {
84         size_t l = strlen((const char *) ptr->name);
85         if (off <= l + 1)
86             break;
87
88         off = off - l;
89         memcpy(res + off, ptr->name, l);
90         res[--off] = '/';
91
92         ptr = ptr->parent;
93     }
94     return res + off;
95 }
96
97 struct conf_service *service_init(struct conf_server *server,
98                                          int num_metadata, int num_sortkeys,
99                                          const char *service_id)
100 {
101     struct conf_service * service = 0;
102     NMEM nmem = nmem_create();
103
104
105     service = nmem_malloc(nmem, sizeof(struct conf_service));
106     service->mutex = 0;
107     service->ref_count = 1;
108     service->nmem = nmem;
109     service->next = 0;
110     service->databases = 0;
111     service->xslt_list = 0;
112     service->ccl_bibset = 0;
113     service->server = server;
114     service->session_timeout = 60; /* default session timeout */
115     service->z3950_session_timeout = 180;
116     service->z3950_operation_timeout = 30;
117     service->rank_cluster = 1;
118     service->rank_debug = 0;
119     service->rank_follow = 0.0;
120     service->rank_lead = 0.0;
121     service->rank_length = 2;
122
123     service->charsets = 0;
124
125     service->id = service_id ? nmem_strdup(nmem, service_id) : 0;
126
127     // Setup a dictionary from server.
128     service->dictionary = 0;
129
130     service->settings = nmem_malloc(nmem, sizeof(*service->settings));
131     service->settings->num_settings = PZ_MAX_EOF;
132     service->settings->settings = nmem_malloc(nmem, sizeof(struct setting*) * service->settings->num_settings);
133     memset(service->settings->settings, 0, sizeof(struct setting*) * service->settings->num_settings);
134     //  inherit_server_settings_values(service);
135
136     service->next = 0;
137
138     service->num_metadata = num_metadata;
139
140     service->metadata = 0;
141     if (service->num_metadata)
142         service->metadata
143             = nmem_malloc(nmem,
144                           sizeof(struct conf_metadata) * service->num_metadata);
145     service->num_sortkeys = num_sortkeys;
146
147     service->default_sort = nmem_strdup(nmem, "relevance");
148     service->sortkeys = 0;
149     if (service->num_sortkeys)
150         service->sortkeys
151             = nmem_malloc(nmem,
152                           sizeof(struct conf_sortkey) * service->num_sortkeys);
153     service->xml_node = 0;
154     return service;
155 }
156
157 static struct conf_metadata* conf_service_add_metadata(
158     struct conf_service *service,
159     int field_id,
160     const char *name,
161     enum conf_metadata_type type,
162     enum conf_metadata_merge merge,
163     enum conf_setting_type setting,
164     int brief,
165     int termlist,
166     const char *rank,
167     int sortkey_offset,
168     enum conf_metadata_mergekey mt,
169     const char *facetrule,
170     const char *limitmap,
171     const char *limitcluster
172     )
173 {
174     struct conf_metadata * md = 0;
175     NMEM nmem = service->nmem;
176
177     if (!service->metadata || !service->num_metadata
178         || field_id < 0  || !(field_id < service->num_metadata))
179         return 0;
180
181     md = service->metadata + field_id;
182     assert(nmem && md && name);
183
184     md->name = nmem_strdup(nmem, name);
185
186     md->type = type;
187
188     // enforcing that type_year is always range_merge
189     if (md->type == Metadata_type_year)
190         md->merge = Metadata_merge_range;
191     else
192         md->merge = merge;
193
194     md->setting = setting;
195     md->brief = brief;
196     md->termlist = termlist;
197     md->rank = nmem_strdup_null(nmem, rank);
198     md->sortkey_offset = sortkey_offset;
199     md->mergekey = mt;
200     md->facetrule = nmem_strdup_null(nmem, facetrule);
201     md->limitmap = nmem_strdup_null(nmem, limitmap);
202     md->limitcluster = nmem_strdup_null(nmem, limitcluster);
203     return md;
204 }
205
206 static struct conf_sortkey *conf_service_add_sortkey(
207     struct conf_service *service,
208     int field_id,
209     const char *name,
210     enum conf_metadata_type type)
211 {
212     struct conf_sortkey *sk = 0;
213     NMEM nmem = service->nmem;
214
215     if (!service->sortkeys || !service->num_sortkeys
216         || field_id < 0 || !(field_id < service->num_sortkeys))
217         return 0;
218
219     sk = service->sortkeys + field_id;
220
221     assert(nmem && sk && name);
222
223     sk->name = nmem_strdup(nmem, name);
224     sk->type = type;
225     return sk;
226 }
227
228 int conf_service_metadata_field_id(struct conf_service *service,
229                                    const char * name)
230 {
231     int i = 0;
232
233     if (!service || !service->metadata || !service->num_metadata)
234         return -1;
235
236     for (i = 0; i < service->num_metadata; i++)
237         if (!strcmp(name, (service->metadata[i]).name))
238             return i;
239     return -1;
240 }
241
242 int conf_service_sortkey_field_id(struct conf_service *service,
243                                   const char * name)
244 {
245     int i = 0;
246
247     if (!service || !service->sortkeys || !service->num_sortkeys)
248         return -1;
249
250     for (i = 0; i < service->num_sortkeys; i++)
251         if (!strcmp(name, (service->sortkeys[i]).name))
252             return i;
253     return -1;
254 }
255
256 static void conf_dir_path(struct conf_config *config, WRBUF w, const char *src)
257 {
258     if (config->confdir && wrbuf_len(config->confdir) > 0 &&
259         !yaz_is_abspath(src))
260     {
261         wrbuf_printf(w, "%s/%s", wrbuf_cstr(config->confdir), src);
262     }
263     else
264         wrbuf_puts(w, src);
265 }
266
267 void service_destroy(struct conf_service *service)
268 {
269     if (service)
270     {
271         if (!pazpar2_decref(&service->ref_count, service->mutex))
272         {
273             service_xslt_destroy(service);
274             pp2_charset_fact_destroy(service->charsets);
275             ccl_qual_rm(&service->ccl_bibset);
276             yaz_mutex_destroy(&service->mutex);
277             nmem_destroy(service->nmem);
278         }
279     }
280 }
281
282 void service_incref(struct conf_service *service)
283 {
284     pazpar2_incref(&service->ref_count, service->mutex);
285 }
286
287 static int parse_metadata(struct conf_service *service, xmlNode *n,
288                           int *md_node, int *sk_node)
289 {
290     enum conf_metadata_type type = Metadata_type_generic;
291     enum conf_metadata_merge merge = Metadata_merge_no;
292     enum conf_setting_type setting = Metadata_setting_no;
293     enum conf_metadata_mergekey mergekey_type = Metadata_mergekey_no;
294     int brief = 0;
295     int termlist = 0;
296     int sortkey_offset = 0;
297     xmlChar *xml_name = 0;
298     xmlChar *xml_brief = 0;
299     xmlChar *xml_sortkey = 0;
300     xmlChar *xml_merge = 0;
301     xmlChar *xml_type = 0;
302     xmlChar *xml_termlist = 0;
303     xmlChar *xml_rank = 0;
304     xmlChar *xml_setting = 0;
305     xmlChar *xml_mergekey = 0;
306     xmlChar *xml_limitmap = 0;
307     xmlChar *xml_limitcluster = 0;
308     xmlChar *xml_icu_chain = 0;
309
310     struct _xmlAttr *attr;
311
312     assert(service);
313
314     for (attr = n->properties; attr; attr = attr->next)
315     {
316         if (!xmlStrcmp(attr->name, BAD_CAST "name") &&
317             attr->children && attr->children->type == XML_TEXT_NODE)
318             xml_name = attr->children->content;
319         else if (!xmlStrcmp(attr->name, BAD_CAST "brief") &&
320                  attr->children && attr->children->type == XML_TEXT_NODE)
321             xml_brief = attr->children->content;
322         else if (!xmlStrcmp(attr->name, BAD_CAST "sortkey") &&
323                  attr->children && attr->children->type == XML_TEXT_NODE)
324             xml_sortkey = attr->children->content;
325         else if (!xmlStrcmp(attr->name, BAD_CAST "merge") &&
326                  attr->children && attr->children->type == XML_TEXT_NODE)
327             xml_merge = attr->children->content;
328         else if (!xmlStrcmp(attr->name, BAD_CAST "type") &&
329                  attr->children && attr->children->type == XML_TEXT_NODE)
330             xml_type = attr->children->content;
331         else if (!xmlStrcmp(attr->name, BAD_CAST "termlist") &&
332                  attr->children && attr->children->type == XML_TEXT_NODE)
333             xml_termlist = attr->children->content;
334         else if (!xmlStrcmp(attr->name, BAD_CAST "rank") &&
335                  attr->children && attr->children->type == XML_TEXT_NODE)
336             xml_rank = attr->children->content;
337         else if (!xmlStrcmp(attr->name, BAD_CAST "setting") &&
338                  attr->children && attr->children->type == XML_TEXT_NODE)
339             xml_setting = attr->children->content;
340         else if (!xmlStrcmp(attr->name, BAD_CAST "mergekey") &&
341                  attr->children && attr->children->type == XML_TEXT_NODE)
342             xml_mergekey = attr->children->content;
343         else if (!xmlStrcmp(attr->name, BAD_CAST "facetrule") &&
344                  attr->children && attr->children->type == XML_TEXT_NODE)
345             xml_icu_chain = attr->children->content;
346         else if (!xmlStrcmp(attr->name, BAD_CAST "limitmap") &&
347                  attr->children && attr->children->type == XML_TEXT_NODE)
348             xml_limitmap = attr->children->content;
349         else if (!xmlStrcmp(attr->name, BAD_CAST "limitcluster") &&
350                  attr->children && attr->children->type == XML_TEXT_NODE)
351             xml_limitcluster = attr->children->content;
352         else
353         {
354             yaz_log(YLOG_FATAL, "Unknown metadata attribute '%s'", attr->name);
355             return -1;
356         }
357     }
358
359     // now do the parsing logic
360     if (!xml_name)
361     {
362         yaz_log(YLOG_FATAL, "Must specify name in metadata element");
363         return -1;
364     }
365     if (xml_brief)
366     {
367         if (!strcmp((const char *) xml_brief, "yes"))
368             brief = 1;
369         else if (strcmp((const char *) xml_brief, "no"))
370         {
371             yaz_log(YLOG_FATAL, "metadata/brief must be yes or no");
372             return -1;
373         }
374     }
375
376     if (xml_termlist)
377     {
378         if (!strcmp((const char *) xml_termlist, "yes"))
379             termlist = 1;
380         else if (strcmp((const char *) xml_termlist, "no"))
381         {
382             yaz_log(YLOG_FATAL, "metadata/termlist must be yes or no");
383             return -1;
384         }
385     }
386
387     if (xml_type)
388     {
389         if (!strcmp((const char *) xml_type, "generic"))
390             type = Metadata_type_generic;
391         else if (!strcmp((const char *) xml_type, "year"))
392             type = Metadata_type_year;
393         else if (!strcmp((const char *) xml_type, "date"))
394             type = Metadata_type_date;
395         else if (!strcmp((const char *) xml_type, "float"))
396             type = Metadata_type_float;
397         else
398         {
399             yaz_log(YLOG_FATAL,
400                     "Unknown value for metadata/type: %s", xml_type);
401             return -1;
402         }
403     }
404
405     if (xml_merge)
406     {
407         if (!strcmp((const char *) xml_merge, "no"))
408             merge = Metadata_merge_no;
409         else if (!strcmp((const char *) xml_merge, "unique"))
410             merge = Metadata_merge_unique;
411         else if (!strcmp((const char *) xml_merge, "longest"))
412             merge = Metadata_merge_longest;
413         else if (!strcmp((const char *) xml_merge, "range"))
414             merge = Metadata_merge_range;
415         else if (!strcmp((const char *) xml_merge, "all"))
416             merge = Metadata_merge_all;
417         else if (!strcmp((const char *) xml_merge, "first"))
418             merge = Metadata_merge_first;
419         else
420         {
421             yaz_log(YLOG_FATAL,
422                     "Unknown value for metadata/merge: %s", xml_merge);
423             return -1;
424         }
425     }
426
427     if (xml_setting)
428     {
429         if (!strcmp((const char *) xml_setting, "no"))
430             setting = Metadata_setting_no;
431         else if (!strcmp((const char *) xml_setting, "postproc"))
432             setting = Metadata_setting_postproc;
433         else if (!strcmp((const char *) xml_setting, "parameter"))
434             setting = Metadata_setting_parameter;
435         else
436         {
437             yaz_log(YLOG_FATAL,
438                     "Unknown value for metadata/setting: %s", xml_setting);
439             return -1;
440         }
441     }
442
443     // add a sortkey if so specified
444     if (xml_sortkey && strcmp((const char *) xml_sortkey, "no"))
445     {
446         enum conf_metadata_type sk_type = type;
447         if (merge == Metadata_merge_no)
448         {
449             yaz_log(YLOG_FATAL,
450                     "Can't specify sortkey on a non-merged field");
451             return -1;
452         }
453         if (!strcmp((const char *) xml_sortkey, "yes"))
454             ;
455         if (!strcmp((const char *) xml_sortkey, "numeric"))
456             ;
457         else if (!strcmp((const char *) xml_sortkey, "skiparticle"))
458         {
459             if (sk_type == Metadata_type_generic)
460                 sk_type = Metadata_type_skiparticle;
461             else
462             {
463                 yaz_log(YLOG_FATAL,
464                         "skiparticle only supported for type=generic: %s",
465                     xml_type);
466                 return -1;
467             }
468         }
469         else
470         {
471             yaz_log(YLOG_FATAL,
472                     "Unknown sortkey in metadata element: %s",
473                     xml_sortkey);
474             return -1;
475         }
476         sortkey_offset = *sk_node;
477
478         conf_service_add_sortkey(service, *sk_node,
479                                  (const char *) xml_name, sk_type);
480         (*sk_node)++;
481     }
482     else
483         sortkey_offset = -1;
484
485     if (xml_mergekey)
486     {
487         if (!strcmp((const char *) xml_mergekey, "required"))
488             mergekey_type = Metadata_mergekey_required;
489         else if (!strcmp((const char *) xml_mergekey, "optional"))
490             mergekey_type = Metadata_mergekey_optional;
491         else if (!strcmp((const char *) xml_mergekey, "no"))
492             mergekey_type = Metadata_mergekey_no;
493         else
494         {
495             yaz_log(YLOG_FATAL, "Unknown value for mergekey: %s", xml_mergekey);
496             return -1;
497         }
498     }
499
500     // metadata known, assign values
501     conf_service_add_metadata(service, *md_node,
502                               (const char *) xml_name,
503                               type, merge, setting,
504                               brief, termlist,
505                               (const char *) xml_rank, sortkey_offset,
506                               mergekey_type,
507                               (const char *) xml_icu_chain,
508                               (const char *) xml_limitmap,
509                               (const char *) xml_limitcluster);
510     (*md_node)++;
511     return 0;
512 }
513
514
515 static void count_metadata(xmlNode *n, int *num_metadata, int *num_sortkeys)
516 {
517     xmlChar *sortkey = xmlGetProp(n, (xmlChar *) "sortkey");
518     (*num_metadata)++;
519
520     if (sortkey && strcmp((const char *) sortkey, "no"))
521         (*num_sortkeys)++;
522     xmlFree(sortkey);
523 }
524
525
526 static struct conf_service *service_create_static(struct conf_server *server,
527                                                   xmlNode *node,
528                                                   const char *service_id)
529 {
530     xmlNode *n;
531     int md_node = 0;
532     int sk_node = 0;
533
534     struct conf_service *service = 0;
535     int num_metadata = 0;
536     int num_sortkeys = 0;
537     int got_settings = 0;
538
539     // count num_metadata and num_sortkeys
540     for (n = node->children; n; n = n->next)
541         if (n->type == XML_ELEMENT_NODE && !strcmp((const char *)
542                                                    n->name, "metadata"))
543         {
544             if (n->children) // This is a <metadata> container, look at its contents.
545             {
546                 xmlNode *m;
547                 for (m = n->children; m; m = m->next)
548                 {
549                     if (m->type == XML_ELEMENT_NODE &&
550                             !strcmp((const char *) m->name, "metadata"))
551                         count_metadata(m, &num_metadata, &num_sortkeys);
552                 }
553             }
554             else // This is a metadata-element proper, count it right away.
555                 count_metadata(n, &num_metadata, &num_sortkeys);
556         }
557
558     service = service_init(server, num_metadata, num_sortkeys, service_id);
559
560     for (n = node->children; n; n = n->next)
561     {
562         if (n->type != XML_ELEMENT_NODE)
563             continue;
564         if (!strcmp((const char *) n->name, "timeout"))
565         {
566             xmlChar *src = xmlGetProp(n, (xmlChar *) "session");
567             if (src)
568             {
569                 service->session_timeout = atoi((const char *) src);
570                 xmlFree(src);
571                 if (service->session_timeout < 9)
572                 {
573                     yaz_log(YLOG_FATAL, "session timeout out of range");
574                     return 0;
575                 }
576             }
577             src = xmlGetProp(n, (xmlChar *) "z3950_operation");
578             if (src)
579             {
580                 service->z3950_operation_timeout = atoi((const char *) src);
581                 xmlFree(src);
582                 if (service->z3950_session_timeout < 9)
583                 {
584                     yaz_log(YLOG_FATAL, "Z39.50 operation timeout out of range");
585                     return 0;
586                 }
587             }
588             src = xmlGetProp(n, (xmlChar *) "z3950_session");
589             if (src)
590             {
591                 service->z3950_session_timeout = atoi((const char *) src);
592                 xmlFree(src);
593                 if (service->z3950_session_timeout < 9)
594                 {
595                     yaz_log(YLOG_FATAL, "Z39.50 session timeout out of range");
596                     return 0;
597                 }
598             }
599         }
600         else if (!strcmp((const char *) n->name, "ccldirective"))
601         {
602             char *name;
603             char *value;
604             if (!service->ccl_bibset)
605                 service->ccl_bibset = ccl_qual_mk();
606             name = (char *) xmlGetProp(n, (xmlChar *) "name");
607             if (!name)
608             {
609                 yaz_log(YLOG_FATAL, "ccldirective: missing @name");
610                 return 0;
611             }
612             value = (char *) xmlGetProp(n, (xmlChar *) "value");
613             if (!value)
614             {
615                 xmlFree(name);
616                 yaz_log(YLOG_FATAL, "ccldirective: missing @value");
617                 return 0;
618             }
619             ccl_qual_add_special(service->ccl_bibset, name, value);
620             xmlFree(value);
621             xmlFree(name);
622         }
623         else if (!strcmp((const char *) n->name, "settings"))
624             got_settings++;
625         else if (!strcmp((const char *) n->name, "icu_chain"))
626         {
627             if (!service->charsets)
628                 service->charsets = pp2_charset_fact_create();
629             if (pp2_charset_fact_define(service->charsets, n, 0))
630             {
631                 yaz_log(YLOG_FATAL, "ICU chain definition error");
632                 return 0;
633             }
634         }
635         else if (!strcmp((const char *) n->name, "relevance")
636                  || !strcmp((const char *) n->name, "sort")
637                  || !strcmp((const char *) n->name, "mergekey")
638                  || !strcmp((const char *) n->name, "facet"))
639
640         {
641             yaz_log(YLOG_FATAL, "No longer supported: <%s>", n->name);
642             yaz_log(YLOG_LOG, "Use <icu_chain id=\"%s\">.. instead", n->name);
643             return 0;
644         }
645         else if (!strcmp((const char *) n->name, (const char *) "metadata"))
646         {
647             if (n->children) // This is a <metadata> container, look at its content.
648             {
649                 xmlNode *m;
650                 for (m = n->children; m; m = m->next)
651                     if ((!strcmp((const char *) m->name, (const char *) "metadata")))
652                         if (parse_metadata(service, m, &md_node, &sk_node))
653                             return 0;
654             }
655             else // This is a metadata-element proper, count it right away.
656                 if (parse_metadata(service, n, &md_node, &sk_node))
657                     return 0;
658         }
659         else if (!strcmp((const char *) n->name, (const char *) "xslt"))
660         {
661             if (service_xslt_config(service, n))
662                 return 0;
663         }
664         else if (!strcmp((const char *) n->name, "rank"))
665         {
666             char *rank_cluster = (char *) xmlGetProp(n, (xmlChar *) "cluster");
667             char *rank_debug = (char *) xmlGetProp(n, (xmlChar *) "debug");
668             char *rank_follow = (char *) xmlGetProp(n, (xmlChar *) "follow");
669             char *rank_lead = (char *) xmlGetProp(n, (xmlChar *) "lead");
670             char *rank_length= (char *) xmlGetProp(n, (xmlChar *) "length");
671             if (rank_cluster)
672             {
673                 if (!strcmp(rank_cluster, "yes"))
674                     service->rank_cluster = 1;
675                 else if (!strcmp(rank_cluster, "no"))
676                     service->rank_cluster = 0;
677                 else
678                 {
679                     yaz_log(YLOG_FATAL, "service: rank@cluster boolean");
680                     return 0;
681                 }
682             }
683             if (rank_debug)
684             {
685                 if (!strcmp(rank_debug, "yes"))
686                     service->rank_debug = 1;
687                 else if (!strcmp(rank_debug, "no"))
688                     service->rank_debug = 0;
689                 else
690                 {
691                     yaz_log(YLOG_FATAL, "service: rank@debug boolean");
692                     return 0;
693                 }
694             }
695             if (rank_follow)
696             {
697                 service->rank_follow = atof(rank_follow);
698             }
699             if (rank_lead)
700             {
701                 service->rank_lead = atof(rank_lead);
702             }
703             if (rank_length)
704             {
705                 if (!strcmp(rank_length, "linear"))
706                     service->rank_length = 2;
707                 else if (!strcmp(rank_length, "log"))
708                     service->rank_length = 1;
709                 else if (!strcmp(rank_length, "none"))
710                     service->rank_length = 0;
711                 else
712                 {
713                     yaz_log(YLOG_FATAL, "service: rank@length linear|log|none");
714                     return 0;
715                 }
716             }
717             xmlFree(rank_cluster);
718             xmlFree(rank_debug);
719             xmlFree(rank_follow);
720             xmlFree(rank_lead);
721             xmlFree(rank_length);
722         }
723         else if (!strcmp((const char *) n->name, "sort-default"))
724         {
725             char *default_sort = (char *) xmlGetProp(n, (xmlChar *) "field");
726
727             if (default_sort && strcmp(default_sort, "")) {
728                 service->default_sort = nmem_strdup(service->nmem, default_sort);
729                 yaz_log(YLOG_LOG, "service %s: default sort order configured to: %s",
730                         service_id ? service_id : "unnamed", default_sort);
731             }
732             else
733             {
734                 yaz_log(YLOG_FATAL, "default sort order is invalid: %s", default_sort);
735                 return 0;
736             }
737             xmlFree(default_sort);
738         }
739         else
740         {
741             char tmp[80];
742             yaz_log(YLOG_FATAL, "Bad element: %s . Context: %s", n->name,
743                     xml_context(n, tmp, sizeof tmp));
744             return 0;
745         }
746     }
747     if (got_settings)
748     {
749         int pass;
750         /* metadata has been read.. Consider now settings */
751         init_settings(service);
752         for (pass = 1; pass <= 2; pass++)
753         {
754             for (n = node->children; n; n = n->next)
755             {
756                 if (n->type != XML_ELEMENT_NODE)
757                     continue;
758                 if (!strcmp((const char *) n->name, "settings"))
759                 {
760                     int ret;
761                     xmlChar *src = xmlGetProp(n, (xmlChar *) "src");
762                     if (src)
763                     {
764                         WRBUF w = wrbuf_alloc();
765                         conf_dir_path(server->config, w, (const char *) src);
766                         ret = settings_read_file(service, wrbuf_cstr(w), pass);
767                         wrbuf_destroy(w);
768                         xmlFree(src);
769                     }
770                     else
771                     {
772                         ret = settings_read_node(service, n, pass);
773                     }
774                     if (ret)
775                         return 0;
776                 }
777             }
778         }
779     }
780
781     {
782         xmlBufferPtr buf = xmlBufferCreate();
783         xmlNodeDump(buf, node->doc, node, 0, 0);
784         service->xml_node =
785             nmem_strdupn(service->nmem, (const char *) buf->content, buf->use);
786         xmlBufferFree(buf);
787     }
788     return service;
789 }
790
791 static int inherit_server_settings(struct conf_service *s)
792 {
793     int ret = 0;
794     struct conf_server *server = s->server;
795     if (!s->dictionary) /* service has no config settings ? */
796     {
797         if (server->settings_fname)
798         {
799             /* inherit settings from server */
800             init_settings(s);
801             if (settings_read_file(s, server->settings_fname, 1))
802                 ret = -1;
803             if (settings_read_file(s, server->settings_fname, 2))
804                 ret = -1;
805         }
806         else
807         {
808             yaz_log(YLOG_WARN, "server '%s' has no settings", s->id ? s->id : "unnamed");
809             init_settings(s);
810         }
811     }
812
813     /* use relevance/sort/mergekey/facet from server if not defined
814        for this service.. */
815     if (!s->charsets)
816     {
817         if (server->charsets)
818         {
819             s->charsets = server->charsets;
820             pp2_charset_fact_incref(s->charsets);
821         }
822         else
823         {
824             s->charsets = pp2_charset_fact_create();
825         }
826     }
827     return ret;
828 }
829
830 struct conf_service *service_create(struct conf_server *server,
831                                     xmlNode *node)
832 {
833     struct conf_service *service = service_create_static(server, node, 0);
834     if (service)
835     {
836         inherit_server_settings(service);
837         assert(service->mutex == 0);
838         pazpar2_mutex_create(&service->mutex, "conf");
839     }
840     return service;
841 }
842
843 static struct conf_server *server_create(struct conf_config *config,
844                                          NMEM nmem, xmlNode *node)
845 {
846     xmlNode *n;
847     struct conf_server *server = nmem_malloc(nmem, sizeof(struct conf_server));
848     xmlChar *server_id = xmlGetProp(node, (xmlChar *) "id");
849
850     server->host = "@";
851     server->port = 0;
852     server->proxy_host = 0;
853     server->proxy_port = 0;
854     server->myurl = 0;
855     server->service = 0;
856     server->config = config;
857     server->next = 0;
858     server->charsets = 0;
859     server->http_server = 0;
860     server->iochan_man = 0;
861     server->settings_fname = 0;
862
863     if (server_id)
864     {
865         server->server_id = nmem_strdup(nmem, (const char *)server_id);
866         xmlFree(server_id);
867     }
868     else
869         server->server_id = 0;
870     for (n = node->children; n; n = n->next)
871     {
872         if (n->type != XML_ELEMENT_NODE)
873             continue;
874         if (!strcmp((const char *) n->name, "listen"))
875         {
876             xmlChar *port = xmlGetProp(n, (xmlChar *) "port");
877             xmlChar *host = xmlGetProp(n, (xmlChar *) "host");
878
879             if (port)
880                 server->port = nmem_strdup(nmem, (const char *) port);
881             if (host)
882                 server->host = nmem_strdup(nmem, (const char *) host);
883
884             xmlFree(port);
885             xmlFree(host);
886         }
887         else if (!strcmp((const char *) n->name, "proxy"))
888         {
889             xmlChar *port = xmlGetProp(n, (xmlChar *) "port");
890             xmlChar *host = xmlGetProp(n, (xmlChar *) "host");
891             xmlChar *myurl = xmlGetProp(n, (xmlChar *) "myurl");
892             if (port)
893                 server->proxy_port = atoi((const char *) port);
894             if (host)
895                 server->proxy_host = nmem_strdup(nmem, (const char *) host);
896             if (myurl)
897                 server->myurl = nmem_strdup(nmem, (const char *) myurl);
898             xmlFree(port);
899             xmlFree(host);
900             xmlFree(myurl);
901         }
902         else if (!strcmp((const char *) n->name, "settings"))
903         {
904             xmlChar *src = xmlGetProp(n, (xmlChar *) "src");
905             WRBUF w;
906             if (!src)
907             {
908                 yaz_log(YLOG_FATAL, "Missing src attribute for settings");
909                 return 0;
910             }
911             if (server->settings_fname)
912             {
913                 xmlFree(src);
914                 yaz_log(YLOG_FATAL, "Can't repeat 'settings'");
915                 return 0;
916             }
917             w = wrbuf_alloc();
918             conf_dir_path(config, w, (const char *) src);
919             server->settings_fname = nmem_strdup(nmem, wrbuf_cstr(w));
920             wrbuf_destroy(w);
921             xmlFree(src);
922         }
923         else if (!strcmp((const char *) n->name, "icu_chain"))
924         {
925             if (!server->charsets)
926                 server->charsets = pp2_charset_fact_create();
927             if (pp2_charset_fact_define(server->charsets, n, 0))
928             {
929                 yaz_log(YLOG_FATAL, "ICU chain definition error");
930                 return 0;
931             }
932         }
933         else if (!strcmp((const char *) n->name, "relevance")
934                  || !strcmp((const char *) n->name, "sort")
935                  || !strcmp((const char *) n->name, "mergekey")
936                  || !strcmp((const char *) n->name, "facet"))
937         {
938             yaz_log(YLOG_FATAL, "No longer supported: <%s>", n->name);
939             yaz_log(YLOG_LOG, "Use <icu_chain id=\"%s\">.. instead", n->name);
940             return 0;
941         }
942         else if (!strcmp((const char *) n->name, "service"))
943         {
944             char *service_id = (char *)
945                 xmlGetProp(n, (xmlChar *) "id");
946
947             struct conf_service **sp = &server->service;
948             for (; *sp; sp = &(*sp)->next)
949                 if ((*sp)->id && service_id &&
950                     0 == strcmp((*sp)->id, service_id))
951                 {
952                     yaz_log(YLOG_FATAL, "Duplicate service: %s", service_id);
953                     break;
954                 }
955                 else if (!(*sp)->id && !service_id)
956                 {
957                     yaz_log(YLOG_FATAL, "Duplicate unnamed service");
958                     break;
959                 }
960
961             if (*sp)  /* service already exist */
962             {
963                 xmlFree(service_id);
964                 return 0;
965             }
966             else
967             {
968                 struct conf_service *s = service_create_static(server, n,
969                                                                service_id);
970                 xmlFree(service_id);
971                 if (!s)
972                     return 0;
973                 *sp = s;
974             }
975         }
976         else
977         {
978             yaz_log(YLOG_FATAL, "Bad element: %s", n->name);
979             return 0;
980         }
981     }
982     if (!server->port)
983     {
984         yaz_log(YLOG_FATAL, "No listening port given");
985         return 0;
986     }
987     if (server->service)
988     {
989         struct conf_service *s;
990         for (s = server->service; s; s = s->next)
991             inherit_server_settings(s);
992     }
993     return server;
994 }
995
996 WRBUF conf_get_fname(struct conf_config *config, const char *fname)
997 {
998     WRBUF w = wrbuf_alloc();
999
1000     conf_dir_path(config, w, fname);
1001     return w;
1002 }
1003
1004 struct conf_service *locate_service(struct conf_server *server,
1005                                     const char *service_id)
1006 {
1007     struct conf_service *s = server->service;
1008     for (; s; s = s->next)
1009         if (s->id && service_id && 0 == strcmp(s->id, service_id))
1010             break;
1011         else if (!s->id && !service_id)
1012             break;
1013     if (s)
1014         service_incref(s);
1015     return s;
1016 }
1017
1018 static void info_service_metadata(struct conf_service *service, WRBUF w)
1019 {
1020     int i;
1021     struct conf_metadata *md;
1022
1023     if (service->num_metadata)
1024     {
1025         for (i = 0; i < service->num_metadata; i++)
1026         {
1027             md = &(service->metadata[i]);
1028             wrbuf_puts(w, "   <metadata");
1029             if (md->name) {
1030                 wrbuf_puts(w, " name=\"");
1031                 wrbuf_xmlputs(w, md->name);
1032                 wrbuf_puts(w, "\"");
1033             }
1034             if (md->brief) {
1035                 wrbuf_puts(w, " brief=\"yes\"");
1036             }
1037             if (md->termlist) {
1038                 wrbuf_puts(w, " termlist=\"yes\"");
1039             }
1040             if (md->rank) {
1041                 wrbuf_puts(w, " rank=\"");
1042                 wrbuf_xmlputs(w, md->rank);
1043                 wrbuf_puts(w, "\"");
1044             }
1045             if (md->sortkey_offset > 0) {
1046                 wrbuf_puts(w, " sortkey=\"");
1047                 switch (service->sortkeys[md->sortkey_offset].type)
1048                 {
1049                 case Metadata_type_relevance:
1050                     wrbuf_puts(w, "relevance");
1051                     break;
1052                 case Metadata_type_skiparticle:
1053                     wrbuf_puts(w, "skiparticle");
1054                     break;
1055                 case Metadata_type_position:
1056                     wrbuf_puts(w, "position");
1057                     break;
1058                 default:
1059                     wrbuf_puts(w, "yes");
1060                     break;
1061                 }
1062                 wrbuf_puts(w, "\"");
1063             }
1064             switch (md->type)
1065             {
1066             case Metadata_type_generic:
1067             case Metadata_type_skiparticle:
1068                 break;
1069             case Metadata_type_year:
1070                 wrbuf_puts(w, " type=\"year\"");
1071                 break;
1072             case Metadata_type_date:
1073                 wrbuf_puts(w, " type=\"date\"");
1074                 break;
1075             case Metadata_type_float:
1076                 wrbuf_puts(w, " type=\"float\"");
1077                 break;
1078             case Metadata_type_relevance:
1079             case Metadata_type_position:
1080                 break;
1081             }
1082             switch (md->merge)
1083             {
1084             case Metadata_merge_no:
1085                 break;
1086             case Metadata_merge_unique:
1087                 wrbuf_puts(w, " merge=\"unique\"");
1088                 break;
1089             case Metadata_merge_longest:
1090                 wrbuf_puts(w, " merge=\"longest\"");
1091                 break;
1092             case Metadata_merge_range:
1093                 wrbuf_puts(w, " merge=\"range\"");
1094                 break;
1095             case Metadata_merge_all:
1096                 wrbuf_puts(w, " merge=\"all\"");
1097                 break;
1098             case Metadata_merge_first:
1099                 wrbuf_puts(w, " merge=\"first\"");
1100                 break;
1101             }
1102             switch (md->mergekey)
1103             {
1104             case Metadata_mergekey_no:
1105                 break;
1106             case Metadata_mergekey_optional:
1107                 wrbuf_puts(w, " mergekey=\"optional\"");
1108                 break;
1109             case Metadata_mergekey_required:
1110                 wrbuf_puts(w, " mergekey=\"required\"");
1111                 break;
1112             }
1113             wrbuf_puts(w, " />\n");
1114         }
1115     }
1116 }
1117
1118 static void info_service_databases(struct conf_service *service, WRBUF w)
1119 {
1120     struct database *db;
1121     struct setting *s;
1122     int i;
1123
1124     if (service->databases)
1125     {
1126         wrbuf_puts(w, "   <databases>\n");
1127         for(db = service->databases; db; db = db->next)
1128         {
1129             wrbuf_puts(w, "    <database");
1130             if (db->id)
1131             {
1132                 wrbuf_puts(w, " id=\"");
1133                 wrbuf_printf(w, "%s", db->id);
1134                 wrbuf_puts(w, "\"");
1135             }
1136             wrbuf_puts(w, ">\n");
1137             for (i = 0; i < db->num_settings; i++)
1138             {
1139                 s = db->settings[i];
1140                 while (s != NULL)
1141                 {
1142                     wrbuf_puts(w, "     <setting");
1143                     wrbuf_puts(w, " name=\"");
1144                     wrbuf_xmlputs(w, s->name);
1145                     wrbuf_puts(w, "\"");
1146                     wrbuf_puts(w, " value=\"");
1147                     wrbuf_xmlputs(w, s->value);
1148                     wrbuf_puts(w, "\"");
1149                     wrbuf_puts(w, " />\n");
1150                     s = s->next;
1151                 }
1152             }
1153             wrbuf_puts(w, "    </database>\n");
1154         }
1155         wrbuf_puts(w, "   </databases>\n");
1156     }
1157 }
1158
1159 void info_services(struct conf_server *server, WRBUF w)
1160 {
1161     struct conf_service *s = server->service;
1162     int i;
1163     struct setting *S;
1164
1165     wrbuf_puts(w, " <services>\n");
1166     for (; s; s = s->next)
1167     {
1168         wrbuf_puts(w, "  <service");
1169         if (s->id)
1170         {
1171             wrbuf_puts(w, " id=\"");
1172             wrbuf_xmlputs(w, s->id);
1173             wrbuf_puts(w, "\"");
1174         }
1175         wrbuf_puts(w, ">\n");
1176         if (s->settings)
1177         {
1178             for (i=0; i<s->settings->num_settings; i++)
1179             {
1180                 S = s->settings->settings[i];
1181                 while (S != NULL) {
1182                     wrbuf_puts(w, "   <setting");
1183                     wrbuf_puts(w, " name=\"");
1184                     wrbuf_xmlputs(w,  S->name);
1185                     wrbuf_puts(w, "\"");
1186                     wrbuf_puts(w, " value=\"");
1187                     wrbuf_xmlputs(w, S->value);
1188                     wrbuf_puts(w, "\"");
1189                     if (S->target) {
1190                         wrbuf_puts(w, " target=\"");
1191                         wrbuf_xmlputs(w, S->target);
1192                         wrbuf_puts(w, "\"");
1193                     }
1194
1195                     wrbuf_puts(w, " />\n");
1196
1197                     S = S->next;
1198                 }
1199             }
1200         }
1201         info_service_metadata(s, w);
1202         info_service_databases(s, w);
1203         wrbuf_puts(w, "  </service>");
1204
1205         wrbuf_puts(w, "\n");
1206     }
1207     wrbuf_puts(w, " </services>\n");
1208 }
1209
1210 static int parse_config(struct conf_config *config, xmlNode *root)
1211 {
1212     xmlNode *n;
1213
1214     for (n = root->children; n; n = n->next)
1215     {
1216         if (n->type != XML_ELEMENT_NODE)
1217             continue;
1218         if (!strcmp((const char *) n->name, "server"))
1219         {
1220             struct conf_server *tmp = server_create(config, config->nmem, n);
1221             if (!tmp)
1222                 return -1;
1223             tmp->next = config->servers;
1224             config->servers = tmp;
1225         }
1226         else if (!strcmp((const char *) n->name, "threads"))
1227         {
1228             xmlChar *number = xmlGetProp(n, (xmlChar *) "number");
1229             if (number)
1230             {
1231                 config->no_threads = atoi((const char *) number);
1232                 xmlFree(number);
1233             }
1234         }
1235         else if (!strcmp((const char *) n->name, "targetprofiles"))
1236         {
1237             yaz_log(YLOG_FATAL, "targetprofiles unsupported here. Must be part of service");
1238             return -1;
1239
1240         }
1241         else
1242         {
1243             yaz_log(YLOG_FATAL, "Bad element: %s", n->name);
1244             return -1;
1245         }
1246     }
1247     return 0;
1248 }
1249
1250 struct conf_config *config_create(const char *fname, int verbose)
1251 {
1252     xmlDoc *doc = xmlReadFile(fname,
1253                               NULL,
1254                               XML_PARSE_XINCLUDE
1255                               + XML_PARSE_NSCLEAN + XML_PARSE_NONET);
1256     xmlNode *n;
1257     const char *p;
1258     int r;
1259     NMEM nmem = nmem_create();
1260     struct conf_config *config = nmem_malloc(nmem, sizeof(struct conf_config));
1261
1262     xmlSubstituteEntitiesDefault(1);
1263     xmlLoadExtDtdDefaultValue = 1;
1264     if (!doc)
1265     {
1266         yaz_log(YLOG_FATAL, "Failed to read %s", fname);
1267         nmem_destroy(nmem);
1268         return 0;
1269     }
1270
1271     // Perform XInclude.
1272     r = xmlXIncludeProcess(doc);
1273     if (r == -1)
1274     {
1275         yaz_log(YLOG_FATAL, "XInclude processing failed");
1276         return 0;
1277     }
1278
1279     config->nmem = nmem;
1280     config->servers = 0;
1281     config->no_threads = 0;
1282     config->iochan_man = 0;
1283
1284     config->confdir = wrbuf_alloc();
1285     if ((p = strrchr(fname,
1286 #ifdef WIN32
1287                      '\\'
1288 #else
1289                      '/'
1290 #endif
1291              )))
1292     {
1293         int len = p - fname;
1294         wrbuf_write(config->confdir, fname, len);
1295     }
1296     wrbuf_puts(config->confdir, "");
1297
1298     n = xmlDocGetRootElement(doc);
1299     r = yaz_xml_include_simple(n, wrbuf_cstr(config->confdir));
1300     if (r == 0) /* OK */
1301     {
1302         if (verbose)
1303         {
1304             yaz_log(YLOG_LOG, "Configuration %s after include processing",
1305                     fname);
1306 #if LIBXML_VERSION >= 20600
1307             xmlDocFormatDump(yaz_log_file(), doc, 0);
1308 #else
1309             xmlDocDump(yaz_log_file(), doc);
1310 #endif
1311         }
1312         r = parse_config(config, n);
1313     }
1314     xmlFreeDoc(doc);
1315
1316     if (r)
1317     {
1318         config_destroy(config);
1319         return 0;
1320     }
1321     return config;
1322 }
1323
1324 void server_destroy(struct conf_server *server)
1325 {
1326     struct conf_service *s = server->service;
1327     while (s)
1328     {
1329         struct conf_service *s_next = s->next;
1330         service_destroy(s);
1331         s = s_next;
1332     }
1333     pp2_charset_fact_destroy(server->charsets);
1334     http_server_destroy(server->http_server);
1335 }
1336
1337 void config_destroy(struct conf_config *config)
1338 {
1339     if (config)
1340     {
1341         struct conf_server *server = config->servers;
1342         iochan_man_destroy(&config->iochan_man);
1343         while (server)
1344         {
1345             struct conf_server *s_next = server->next;
1346             server_destroy(server);
1347             server = s_next;
1348         }
1349         wrbuf_destroy(config->confdir);
1350         nmem_destroy(config->nmem);
1351     }
1352 }
1353
1354 void config_stop_listeners(struct conf_config *conf)
1355 {
1356     struct conf_server *ser;
1357     for (ser = conf->servers; ser; ser = ser->next)
1358         http_close_server(ser);
1359 }
1360
1361 void config_process_events(struct conf_config *conf)
1362 {
1363     struct conf_server *ser;
1364
1365     for (ser = conf->servers; ser; ser = ser->next)
1366     {
1367         struct conf_service *s = ser->service;
1368
1369         for (;s ; s = s->next)
1370         {
1371             assert(s->mutex == 0);
1372             pazpar2_mutex_create(&s->mutex, "service");
1373         }
1374         http_mutex_init(ser);
1375     }
1376     iochan_man_events(conf->iochan_man);
1377 }
1378
1379 int config_start_listeners(struct conf_config *conf,
1380                            const char *listener_override,
1381                            const char *record_fname)
1382 {
1383     struct conf_server *ser;
1384
1385     conf->iochan_man = iochan_man_create(conf->no_threads);
1386     for (ser = conf->servers; ser; ser = ser->next)
1387     {
1388         WRBUF w;
1389         int r;
1390
1391         ser->iochan_man = conf->iochan_man;
1392         if (listener_override)
1393         {
1394             const char *cp = strrchr(listener_override, ':');
1395             if (cp)
1396             {
1397                 ser->host = nmem_strdupn(conf->nmem, listener_override,
1398                                          cp - listener_override);
1399                 ser->port = nmem_strdup(conf->nmem, cp + 1);
1400             }
1401             else
1402             {
1403                 ser->host = "@";
1404                 ser->port = nmem_strdup(conf->nmem, listener_override);
1405             }
1406             listener_override = 0; /* only first server is overriden */
1407         }
1408         r = http_init(ser, record_fname);
1409         if (r)
1410             return -1;
1411
1412         w = wrbuf_alloc();
1413         if (ser->proxy_host || ser->proxy_port)
1414         {
1415             if (ser->proxy_host)
1416                 wrbuf_puts(w, ser->proxy_host);
1417             if (ser->proxy_port)
1418             {
1419                 if (wrbuf_len(w))
1420                     wrbuf_puts(w, ":");
1421                 wrbuf_printf(w, "%d", ser->proxy_port);
1422             }
1423         }
1424         if (wrbuf_len(w))
1425             http_set_proxyaddr(wrbuf_cstr(w), ser);
1426         wrbuf_destroy(w);
1427     }
1428     return 0;
1429 }
1430
1431 /*
1432  * Local variables:
1433  * c-basic-offset: 4
1434  * c-file-style: "Stroustrup"
1435  * indent-tabs-mode: nil
1436  * End:
1437  * vim: shiftwidth=4 tabstop=8 expandtab
1438  */
1439