X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fyaz-proxy-config.cpp;h=88449f35a9dc02a1ea1710179a98971f2e2661d6;hb=d3d51bee2100324025f7530d4e3ff3502397fd83;hp=6132ed7172b037df6fce7398c5da17f829f28473;hpb=0b89dffba19f762e1d34455f3030d8b8deea2db4;p=yazpp-moved-to-github.git diff --git a/src/yaz-proxy-config.cpp b/src/yaz-proxy-config.cpp index 6132ed7..88449f3 100644 --- a/src/yaz-proxy-config.cpp +++ b/src/yaz-proxy-config.cpp @@ -1,17 +1,18 @@ /* - * Copyright (c) 1998-2003, Index Data. + * Copyright (c) 1998-2004, Index Data. * See the file LICENSE for details. * - * $Id: yaz-proxy-config.cpp,v 1.3 2003-10-04 06:44:16 adam Exp $ + * $Id: yaz-proxy-config.cpp,v 1.27 2004-01-30 00:38:28 adam Exp $ */ +#include #include #include Yaz_ProxyConfig::Yaz_ProxyConfig() { m_copy = 0; -#if HAVE_XML2 +#if HAVE_XSLT m_docPtr = 0; m_proxyPtr = 0; #endif @@ -19,24 +20,15 @@ Yaz_ProxyConfig::Yaz_ProxyConfig() Yaz_ProxyConfig::~Yaz_ProxyConfig() { -#if HAVE_XML2 +#if HAVE_XSLT if (!m_copy && m_docPtr) xmlFreeDoc(m_docPtr); #endif } -void Yaz_ProxyConfig::operator=(const Yaz_ProxyConfig &conf) -{ -#if HAVE_XML2 - m_docPtr = conf.m_docPtr; - m_proxyPtr = conf.m_proxyPtr; -#endif - m_copy = 1; -} - int Yaz_ProxyConfig::read_xml(const char *fname) { -#if HAVE_XML2 +#if HAVE_XSLT xmlDocPtr ndoc = xmlParseFile(fname); if (!ndoc) @@ -64,7 +56,7 @@ int Yaz_ProxyConfig::read_xml(const char *fname) #endif } -#if HAVE_XML2 +#if HAVE_XSLT const char *Yaz_ProxyConfig::get_text(xmlNodePtr ptr) { for(ptr = ptr->children; ptr; ptr = ptr->next) @@ -82,7 +74,7 @@ const char *Yaz_ProxyConfig::get_text(xmlNodePtr ptr) } #endif -#if HAVE_XML2 +#if HAVE_XSLT void Yaz_ProxyConfig::return_limit(xmlNodePtr ptr, int *limit_bw, int *limit_pdu, @@ -115,34 +107,48 @@ void Yaz_ProxyConfig::return_limit(xmlNodePtr ptr, } #endif -#if HAVE_XML2 +#if HAVE_XSLT void Yaz_ProxyConfig::return_target_info(xmlNodePtr ptr, const char **url, - int *keepalive, int *limit_bw, int *limit_pdu, int *limit_req, int *target_idletime, - int *client_idletime) + int *client_idletime, + int *keepalive_limit_bw, + int *keepalive_limit_pdu, + int *pre_init, + const char **cql2rpn) { + *pre_init = 0; + int no_url = 0; ptr = ptr->children; for (; ptr; ptr = ptr->next) { if (ptr->type == XML_ELEMENT_NODE + && !strcmp((const char *) ptr->name, "preinit")) + { + const char *v = get_text(ptr); + *pre_init = v ? atoi(v) : 1; + } + if (ptr->type == XML_ELEMENT_NODE && !strcmp((const char *) ptr->name, "url")) { const char *t = get_text(ptr); - if (t) - *url = t; + if (t && no_url < MAX_ZURL_PLEX) + { + url[no_url++] = t; + url[no_url] = 0; + } } if (ptr->type == XML_ELEMENT_NODE && !strcmp((const char *) ptr->name, "keepalive")) { - const char *t = get_text(ptr); - if (!t || *t == '1') - *keepalive = 1; - else - *keepalive = 0; + int dummy; + *keepalive_limit_bw = 500000; + *keepalive_limit_pdu = 1000; + return_limit(ptr, keepalive_limit_bw, keepalive_limit_pdu, + &dummy); } if (ptr->type == XML_ELEMENT_NODE && !strcmp((const char *) ptr->name, "limit")) @@ -169,73 +175,116 @@ void Yaz_ProxyConfig::return_target_info(xmlNodePtr ptr, *client_idletime = 0; } } + if (ptr->type == XML_ELEMENT_NODE + && !strcmp((const char *) ptr->name, "cql2rpn")) + { + const char *t = get_text(ptr); + if (t) + *cql2rpn = t; + } } } #endif -#if HAVE_XML2 -int Yaz_ProxyConfig::check_type_1_attributes(ODR odr, xmlNodePtr ptr, +int Yaz_ProxyConfig::atoi_l(const char **cp) +{ + int v = 0; + while (**cp && isdigit(**cp)) + { + v = v*10 + (**cp - '0'); + (*cp)++; + } + return v; +} + +int Yaz_ProxyConfig::match_list(int v, const char *m) +{ + while(m && *m) + { + while(*m && isspace(*m)) + m++; + if (*m == '*') + return 1; + int l = atoi_l(&m); + int h = l; + if (*m == '-') + { + ++m; + h = atoi_l(&m); + } + if (v >= l && v <= h) + return 1; + if (*m == ',') + m++; + } + return 0; +} + +#if HAVE_XSLT +int Yaz_ProxyConfig::check_type_1_attributes(ODR odr, xmlNodePtr ptrl, Z_AttributeList *attrs, char **addinfo) { - for(ptr = ptr->children; ptr; ptr = ptr->next) + int i; + for (i = 0; inum_attributes; i++) { - if (ptr->type == XML_ELEMENT_NODE && - !strcmp((const char *) ptr->name, "query")) + Z_AttributeElement *el = attrs->attributes[i]; + + if (!el->attributeType) + continue; + int type = *el->attributeType; + int *value = 0; + + if (el->which == Z_AttributeValue_numeric && el->value.numeric) + value = el->value.numeric; + + xmlNodePtr ptr; + for(ptr = ptrl->children; ptr; ptr = ptr->next) { - const char *match_type = 0; - const char *match_value = 0; - const char *match_error = 0; - struct _xmlAttr *attr; - for (attr = ptr->properties; attr; attr = attr->next) + if (ptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr->name, "attribute")) { - if (!strcmp((const char *) attr->name, "type") && - attr->children && attr->children->type == XML_TEXT_NODE) - match_type = (const char *) attr->children->content; - if (!strcmp((const char *) attr->name, "value") && - attr->children && attr->children->type == XML_TEXT_NODE) - match_value = (const char *) attr->children->content; - if (!strcmp((const char *) attr->name, "error") && - attr->children && attr->children->type == XML_TEXT_NODE) - match_error = (const char *) attr->children->content; - } - int i; - - if (match_type && match_value) - { - for (i = 0; inum_attributes; i++) + const char *match_type = 0; + const char *match_value = 0; + const char *match_error = 0; + struct _xmlAttr *attr; + for (attr = ptr->properties; attr; attr = attr->next) { - Z_AttributeElement *el = attrs->attributes[i]; - char value_str[20]; - - value_str[0] = '\0'; - if (!el->attributeType) + if (!strcmp((const char *) attr->name, "type") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_type = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "value") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_value = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "error") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_error = (const char *) attr->children->content; + } + if (match_type && match_value) + { + char addinfo_str[20]; + if (!match_list(type, match_type)) continue; - int type = *el->attributeType; - - if (strcmp(match_type, "*")) { - if (type != atoi(match_type)) - continue; // no match on type - } - if (el->which == Z_AttributeValue_numeric && - el->value.numeric) + + *addinfo_str = '\0'; + if (!strcmp(match_type, "*")) + sprintf (addinfo_str, "%d", type); + else if (value) { - int value = *el->value.numeric; - if (strcmp(match_value, "*")) { - if (value != atoi(match_value)) - continue; // no match on value - } - sprintf(value_str, "%d", value); + if (!match_list(*value, match_value)) + continue; + sprintf (addinfo_str, "%d", *value); } else continue; + if (match_error) { - if (*value_str) - *addinfo = odr_strdup(odr, value_str); + if (*addinfo_str) + *addinfo = odr_strdup(odr, addinfo_str); return atoi(match_error); } - return 0; + break; } } } @@ -244,12 +293,11 @@ int Yaz_ProxyConfig::check_type_1_attributes(ODR odr, xmlNodePtr ptr, } #endif -#if HAVE_XML2 +#if HAVE_XSLT int Yaz_ProxyConfig::check_type_1_structure(ODR odr, xmlNodePtr ptr, Z_RPNStructure *q, char **addinfo) { - int c; if (q->which == Z_RPNStructure_complex) { int e = check_type_1_structure(odr, ptr, q->u.complex->s1, addinfo); @@ -271,7 +319,7 @@ int Yaz_ProxyConfig::check_type_1_structure(ODR odr, xmlNodePtr ptr, } #endif -#if HAVE_XML2 +#if HAVE_XSLT int Yaz_ProxyConfig::check_type_1(ODR odr, xmlNodePtr ptr, Z_RPNQuery *query, char **addinfo) { @@ -283,10 +331,10 @@ int Yaz_ProxyConfig::check_type_1(ODR odr, xmlNodePtr ptr, Z_RPNQuery *query, int Yaz_ProxyConfig::check_query(ODR odr, const char *name, Z_Query *query, char **addinfo) { -#if HAVE_XML2 +#if HAVE_XSLT xmlNodePtr ptr; - ptr = find_target_node(name); + ptr = find_target_node(name, 0); if (ptr) { if (query->which == Z_Query_type_1 || query->which == Z_Query_type_101) @@ -296,10 +344,193 @@ int Yaz_ProxyConfig::check_query(ODR odr, const char *name, Z_Query *query, return 0; } -#if HAVE_XML2 -xmlNodePtr Yaz_ProxyConfig::find_target_node(const char *name) +#if HAVE_XSLT +int Yaz_ProxyConfig::check_schema(xmlNodePtr ptr, Z_RecordComposition *comp, + const char *schema_identifier) +{ + char *esn = 0; + int default_match = 1; + if (comp && comp->which == Z_RecordComp_simple && + comp->u.simple && comp->u.simple->which == Z_ElementSetNames_generic) + { + esn = comp->u.simple->u.generic; + } + // if no ESN/schema was given accept.. + if (!esn) + return 1; + // check if schema identifier match + if (schema_identifier && !strcmp(esn, schema_identifier)) + return 1; + // Check each name element + for (; ptr; ptr = ptr->next) + { + if (ptr->type == XML_ELEMENT_NODE + && !strcmp((const char *) ptr->name, "name")) + { + xmlNodePtr tptr = ptr->children; + default_match = 0; + for (; tptr; tptr = tptr->next) + if (tptr->type == XML_TEXT_NODE && tptr->content) + { + xmlChar *t = tptr->content; + while (*t && isspace(*t)) + t++; + int i = 0; + while (esn[i] && esn[i] == t[i]) + i++; + if (!esn[i] && (!t[i] || isspace(t[i]))) + return 1; + } + } + } + return default_match; +} +#endif + +int Yaz_ProxyConfig::check_syntax(ODR odr, const char *name, + Odr_oid *syntax, Z_RecordComposition *comp, + char **addinfo, + char **stylesheet, char **schema) { + if (stylesheet) + { + xfree (*stylesheet); + *stylesheet = 0; + } + if (schema) + { + xfree (*schema); + *schema = 0; + } +#if HAVE_XSLT + int syntax_has_matched = 0; xmlNodePtr ptr; + + ptr = find_target_node(name, 0); + if (!ptr) + return 0; + for(ptr = ptr->children; ptr; ptr = ptr->next) + { + if (ptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr->name, "syntax")) + { + int match = 0; // if we match record syntax + const char *match_type = 0; + const char *match_error = 0; + const char *match_marcxml = 0; + const char *match_stylesheet = 0; + const char *match_identifier = 0; + struct _xmlAttr *attr; + for (attr = ptr->properties; attr; attr = attr->next) + { + if (!strcmp((const char *) attr->name, "type") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_type = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "error") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_error = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "marcxml") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_marcxml = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "stylesheet") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_stylesheet = (const char *) attr->children->content; + if (!strcmp((const char *) attr->name, "identifier") && + attr->children && attr->children->type == XML_TEXT_NODE) + match_identifier = (const char *) attr->children->content; + } + if (match_type) + { + if (!strcmp(match_type, "*")) + match = 1; + else if (!strcmp(match_type, "none")) + { + if (syntax == 0) + match = 1; + } + else if (syntax) + { + int match_oid[OID_SIZE]; + oid_name_to_oid(CLASS_RECSYN, match_type, match_oid); + if (oid_oidcmp(match_oid, syntax) == 0) + match = 1; + } + } + if (match) + { + if (!match_error) + syntax_has_matched = 1; + match = check_schema(ptr->children, comp, match_identifier); + } + if (match) + { + if (stylesheet && match_stylesheet) + { + xfree(*stylesheet); + *stylesheet = xstrdup(match_stylesheet); + } + if (schema && match_identifier) + { + xfree(*schema); + *schema = xstrdup(match_identifier); + } + if (match_marcxml) + { + return -1; + } + if (match_error) + { + if (syntax_has_matched) // if syntax OK, bad schema/ESN + return 25; + if (syntax) + { + char dotoid_str[100]; + oid_to_dotstring(syntax, dotoid_str); + *addinfo = odr_strdup(odr, dotoid_str); + } + return atoi(match_error); + } + return 0; + } + } + } +#endif + return 0; +} + +#if HAVE_XSLT +xmlNodePtr Yaz_ProxyConfig::find_target_db(xmlNodePtr ptr, const char *db) +{ + xmlNodePtr dptr; + if (!db) + return ptr; + if (!ptr) + return 0; + for (dptr = ptr->children; dptr; dptr = dptr->next) + if (dptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) dptr->name, "database")) + { + struct _xmlAttr *attr; + for (attr = dptr->properties; attr; attr = attr->next) + if (!strcmp((const char *) attr->name, "name")) + { + if (attr->children + && attr->children->type==XML_TEXT_NODE + && attr->children->content + && (!strcmp((const char *) attr->children->content, db) + || !strcmp((const char *) attr->children->content, + "*"))) + return dptr; + } + } + return ptr; +} + +xmlNodePtr Yaz_ProxyConfig::find_target_node(const char *name, const char *db) +{ + xmlNodePtr ptr; + if (!m_proxyPtr) + return 0; for (ptr = m_proxyPtr->children; ptr; ptr = ptr->next) { if (ptr->type == XML_ELEMENT_NODE && @@ -316,7 +547,9 @@ xmlNodePtr Yaz_ProxyConfig::find_target_node(const char *name) { xmlChar *t = attr->children->content; if (!t || *t == '1') - return ptr; + { + return find_target_db(ptr, db); + } } } else @@ -334,7 +567,7 @@ xmlNodePtr Yaz_ProxyConfig::find_target_node(const char *name) || !strcmp((const char *) attr->children->content, "*"))) { - return ptr; + return find_target_db(ptr, db); } } } @@ -344,23 +577,189 @@ xmlNodePtr Yaz_ProxyConfig::find_target_node(const char *name) } #endif +int Yaz_ProxyConfig::get_target_no(int no, + const char **name, + const char **url, + int *limit_bw, + int *limit_pdu, + int *limit_req, + int *target_idletime, + int *client_idletime, + int *max_clients, + int *keepalive_limit_bw, + int *keepalive_limit_pdu, + int *pre_init, + const char **cql2rpn) +{ +#if HAVE_XSLT + xmlNodePtr ptr; + if (!m_proxyPtr) + return 0; + int i = 0; + for (ptr = m_proxyPtr->children; ptr; ptr = ptr->next) + if (ptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr->name, "target")) + { + if (i == no) + { + struct _xmlAttr *attr; + for (attr = ptr->properties; attr; attr = attr->next) + if (!strcmp((const char *) attr->name, "name")) + { + if (attr->children + && attr->children->type==XML_TEXT_NODE + && attr->children->content) + *name = (const char *) attr->children->content; + } + return_target_info(ptr, url, limit_bw, limit_pdu, limit_req, + target_idletime, client_idletime, + keepalive_limit_bw, keepalive_limit_pdu, + pre_init, cql2rpn); + return 1; + } + i++; + } +#endif + return 0; +} + +int Yaz_ProxyConfig::mycmp(const char *hay, const char *item, size_t len) +{ + if (len == strlen(item) && memcmp(hay, item, len) == 0) + return 1; + return 0; +} + +void Yaz_ProxyConfig::get_generic_info(int *log_mask, + int *max_clients) +{ +#if HAVE_XSLT + xmlNodePtr ptr; + if (!m_proxyPtr) + return; + for (ptr = m_proxyPtr->children; ptr; ptr = ptr->next) + { + if (ptr->type == XML_ELEMENT_NODE + && !strcmp((const char *) ptr->name, "log")) + { + const char *v = get_text(ptr); + *log_mask = 0; + while (v && *v) + { + const char *cp = v; + while (*cp && *cp != ',' && !isspace(*cp)) + cp++; + size_t len = cp - v; + if (mycmp(v, "client-apdu", len)) + *log_mask |= PROXY_LOG_APDU_CLIENT; + if (mycmp(v, "server-apdu", len)) + *log_mask |= PROXY_LOG_APDU_SERVER; + if (mycmp(v, "client-requests", len)) + *log_mask |= PROXY_LOG_REQ_CLIENT; + if (mycmp(v, "server-requests", len)) + *log_mask |= PROXY_LOG_REQ_SERVER; + if (isdigit(*v)) + *log_mask |= atoi(v); + if (*cp == ',') + cp++; + while (*cp && isspace(*cp)) + cp++; + v = cp; + } + } + if (ptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr->name, "max-clients")) + { + const char *t = get_text(ptr); + if (t) + { + *max_clients = atoi(t); + if (*max_clients < 1) + *max_clients = 1; + } + } + } +#endif +} + +char *Yaz_ProxyConfig::get_explain(ODR odr, const char *name, const char *db, + int *len) +{ +#if HAVE_XSLT + xmlNodePtr ptr = find_target_node(name, db); + if (ptr) + { + ptr = ptr->children; + for (; ptr; ptr = ptr->next) + if (ptr->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr->name, "explain")) + { + xmlNodePtr ptr1 = ptr->children; + if (db) + { + for (; ptr1; ptr1 = ptr1->next) + if (ptr1->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr1->name, "serverInfo")) + break; + if (!ptr1) + continue; + for (ptr1 = ptr1->children; ptr1; ptr1 = ptr1->next) + if (ptr1->type == XML_ELEMENT_NODE && + !strcmp((const char *) ptr1->name, "database")) + break; + + if (!ptr1) + continue; + for (ptr1 = ptr1->children; ptr1; ptr1 = ptr1->next) + if (ptr1->type == XML_TEXT_NODE && + ptr1->content && + !strcmp((const char *) ptr1->content, db)) + break; + if (!ptr1) + continue; + } + xmlNodePtr ptr2 = xmlCopyNode(ptr, 1); + + xmlDocPtr doc = xmlNewDoc((const xmlChar *) "1.0"); + + xmlDocSetRootElement(doc, ptr2); + + xmlChar *buf_out; + xmlDocDumpMemory(doc, &buf_out, len); + char *content = (char*) odr_malloc(odr, *len); + memcpy(content, buf_out, *len); + + xmlFree(buf_out); + xmlFreeDoc(doc); + return content; + } + } +#endif + return 0; +} + void Yaz_ProxyConfig::get_target_info(const char *name, const char **url, - int *keepalive, int *limit_bw, int *limit_pdu, int *limit_req, int *target_idletime, int *client_idletime, - int *max_clients) + int *max_clients, + int *keepalive_limit_bw, + int *keepalive_limit_pdu, + int *pre_init, + const char **cql2rpn) { -#if HAVE_XML2 +#if HAVE_XSLT xmlNodePtr ptr; if (!m_proxyPtr) { - *url = name; + url[0] = name; + url[1] = 0; return; } + url[0] = 0; for (ptr = m_proxyPtr->children; ptr; ptr = ptr->next) { if (ptr->type == XML_ELEMENT_NODE && @@ -375,13 +774,18 @@ void Yaz_ProxyConfig::get_target_info(const char *name, } } } - ptr = find_target_node(name); + ptr = find_target_node(name, 0); if (ptr) { if (name) - *url = name; - return_target_info(ptr, url, keepalive, limit_bw, limit_pdu, limit_req, - target_idletime, client_idletime); + { + url[0] = name; + url[1] = 0; + } + return_target_info(ptr, url, limit_bw, limit_pdu, limit_req, + target_idletime, client_idletime, + keepalive_limit_bw, keepalive_limit_pdu, + pre_init, cql2rpn); } #else *url = name;