X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fsrw.c;h=d4970b2fdef27bee89ca815a81bbbfb486184034;hb=037037e14faa1f992ed3574817086eabc469c9c4;hp=d2157143fab1261434a2b0eadc2e8ea3bfb4ceca;hpb=c6e47cbbff56f39f6d81b079ebaeac41d793d4d9;p=yaz-moved-to-github.git diff --git a/src/srw.c b/src/srw.c index d215714..d4970b2 100644 --- a/src/srw.c +++ b/src/srw.c @@ -2,7 +2,7 @@ * Copyright (c) 2002-2003, Index Data. * See the file LICENSE for details. * - * $Id: srw.c,v 1.1 2003-10-27 12:21:35 adam Exp $ + * $Id: srw.c,v 1.7 2003-12-29 14:54:33 adam Exp $ */ #include @@ -26,21 +26,24 @@ static void add_XML_n(xmlNodePtr ptr, const char *elem, char *val, int len) } } -static void add_xsd_string_n(xmlNodePtr ptr, const char *elem, char *val, - int len) +xmlNodePtr add_xsd_string_n(xmlNodePtr ptr, const char *elem, char *val, + int len) { if (val) { xmlNodePtr c = xmlNewChild(ptr, 0, elem, 0); xmlNodePtr t = xmlNewTextLen(val, len); xmlAddChild(c, t); + return t; } + return 0; } -static void add_xsd_string(xmlNodePtr ptr, const char *elem, char *val) +xmlNodePtr add_xsd_string(xmlNodePtr ptr, const char *elem, char *val) { if (val) - xmlNewChild(ptr, 0, elem, val); + return xmlNewChild(ptr, 0, elem, val); + return 0; } static void add_xsd_integer(xmlNodePtr ptr, const char *elem, int *val) @@ -159,6 +162,69 @@ static int match_xsd_integer(xmlNodePtr ptr, const char *elem, ODR o, int **val) return 1; } +static int yaz_srw_record(ODR o, xmlNodePtr pptr, Z_SRW_record *rec, + void *client_data, const char *ns) +{ + if (o->direction == ODR_DECODE) + { + int pack = Z_SRW_recordPacking_string; + xmlNodePtr ptr; + rec->recordSchema = 0; + rec->recordData_buf = 0; + rec->recordData_len = 0; + rec->recordPosition = 0; + for (ptr = pptr->children; ptr; ptr = ptr->next) + { + char *spack = 0; + + if (match_xsd_string(ptr, "recordSchema", o, + &rec->recordSchema)) + ; + else if (match_xsd_string(ptr, "recordPacking", o, &spack)) + { + if (pack && !strcmp(spack, "xml")) + pack = Z_SRW_recordPacking_XML; + if (pack && !strcmp(spack, "string")) + pack = Z_SRW_recordPacking_string; + } + else if (match_xsd_integer(ptr, "recordPosition", o, + &rec->recordPosition)) + ; + else + { + if (pack == Z_SRW_recordPacking_XML) + match_xsd_XML_n(ptr, "recordData", o, + &rec->recordData_buf, + &rec->recordData_len); + if (pack == Z_SRW_recordPacking_string) + match_xsd_string_n(ptr, "recordData", o, + &rec->recordData_buf, + &rec->recordData_len); + } + } + rec->recordPacking = pack; + } + else if (o->direction == ODR_ENCODE) + { + xmlNodePtr ptr = pptr; + add_xsd_string(ptr, "recordSchema", rec->recordSchema); + switch(rec->recordPacking) + { + case Z_SRW_recordPacking_string: + add_xsd_string(ptr, "recordPacking", "string"); + add_xsd_string_n(ptr, "recordData", rec->recordData_buf, + rec->recordData_len); + break; + case Z_SRW_recordPacking_XML: + add_xsd_string(ptr, "recordPacking", "xml"); + add_XML_n(ptr, "recordData", rec->recordData_buf, + rec->recordData_len); + break; + } + add_xsd_integer(ptr, "recordPosition", rec->recordPosition); + } +} + static int yaz_srw_records(ODR o, xmlNodePtr pptr, Z_SRW_record **recs, int *num, void *client_data, const char *ns) { @@ -180,31 +246,7 @@ static int yaz_srw_records(ODR o, xmlNodePtr pptr, Z_SRW_record **recs, { if (ptr->type == XML_ELEMENT_NODE && !strcmp(ptr->name, "record")) - { - xmlNodePtr rptr; - (*recs)[i].recordSchema = 0; - (*recs)[i].recordPacking = Z_SRW_recordPacking_string; - (*recs)[i].recordData_buf = 0; - (*recs)[i].recordData_len = 0; - (*recs)[i].recordPosition = 0; - for (rptr = ptr->children; rptr; rptr = rptr->next) - { - if (match_xsd_string(rptr, "recordSchema", o, - &(*recs)[i].recordSchema)) - ; - else if (match_xsd_string_n(rptr, "recordData", o, - &(*recs)[i].recordData_buf, - &(*recs)[i].recordData_len)) - ; - else if (match_xsd_XML_n(rptr, "recordXML", o, - &(*recs)[i].recordData_buf, - &(*recs)[i].recordData_len)) - (*recs)[i].recordPacking = Z_SRW_recordPacking_XML; - else if (match_xsd_integer(rptr, "recordPosition", o, - &(*recs)[i].recordPosition)) - ; - } - } + yaz_srw_record(o, ptr, (*recs)+i, client_data, ns); } } else if (o->direction == ODR_ENCODE) @@ -213,19 +255,7 @@ static int yaz_srw_records(ODR o, xmlNodePtr pptr, Z_SRW_record **recs, for (i = 0; i < *num; i++) { xmlNodePtr rptr = xmlNewChild(pptr, 0, "record", 0); - add_xsd_string(rptr, "recordSchema", (*recs)[i].recordSchema); - switch((*recs)[i].recordPacking) - { - case Z_SRW_recordPacking_string: - add_xsd_string_n(rptr, "recordData", (*recs)[i].recordData_buf, - (*recs)[i].recordData_len); - break; - case Z_SRW_recordPacking_XML: - add_XML_n(rptr, "recordXML", (*recs)[i].recordData_buf, - (*recs)[i].recordData_len); - break; - } - add_xsd_integer(rptr, "recordPosition", (*recs)[i].recordPosition); + yaz_srw_record(o, rptr, (*recs)+i, client_data, ns); } } return 0; @@ -272,9 +302,11 @@ static int yaz_srw_diagnostics(ODR o, xmlNodePtr pptr, Z_SRW_diagnostic **recs, else if (o->direction == ODR_ENCODE) { int i; + xmlNsPtr ns_diag = + xmlNewNs(pptr, "http://www.loc.gov/zing/srw/diagnostics/", "diag"); for (i = 0; i < *num; i++) { - xmlNodePtr rptr = xmlNewChild(pptr, 0, "diagnostic", 0); + xmlNodePtr rptr = xmlNewChild(pptr, ns_diag, "diagnostic", 0); add_xsd_integer(rptr, "code", (*recs)[i].code); add_xsd_string(rptr, "details", (*recs)[i].details); } @@ -282,6 +314,73 @@ static int yaz_srw_diagnostics(ODR o, xmlNodePtr pptr, Z_SRW_diagnostic **recs, return 0; } +static int yaz_srw_term(ODR o, xmlNodePtr pptr, Z_SRW_scanTerm *term, + void *client_data, const char *ns) +{ + if (o->direction == ODR_DECODE) + { + xmlNodePtr ptr; + term->value = 0; + term->numberOfRecords = 0; + term->displayTerm = 0; + for (ptr = pptr->children; ptr; ptr = ptr->next) + { + char *spack = 0; + + if (match_xsd_string(ptr, "value", o, &term->value)) + ; + else if (match_xsd_integer(ptr, "numberOfRecords", o, + &term->numberOfRecords)) + ; + else if (match_xsd_string(ptr, "displayTerm", o, + &term->displayTerm)) + ; + } + } + else if (o->direction == ODR_ENCODE) + { + xmlNodePtr ptr = pptr; + add_xsd_string(ptr, "value", term->value); + add_xsd_integer(ptr, "value", term->numberOfRecords); + add_xsd_string(ptr, "displayTerm", term->displayTerm); + } +} + +static int yaz_srw_terms(ODR o, xmlNodePtr pptr, Z_SRW_scanTerm **terms, + int *num, void *client_data, const char *ns) +{ + if (o->direction == ODR_DECODE) + { + int i; + xmlNodePtr ptr; + *num = 0; + for (ptr = pptr->children; ptr; ptr = ptr->next) + { + if (ptr->type == XML_ELEMENT_NODE && + !strcmp(ptr->name, "term")) + (*num)++; + } + if (!*num) + return 1; + *terms = odr_malloc(o, *num * sizeof(**terms)); + for (i = 0, ptr = pptr->children; ptr; ptr = ptr->next, i++) + { + if (ptr->type == XML_ELEMENT_NODE && + !strcmp(ptr->name, "term")) + yaz_srw_term(o, ptr, (*terms)+i, client_data, ns); + } + } + else if (o->direction == ODR_ENCODE) + { + int i; + for (i = 0; i < *num; i++) + { + xmlNodePtr rptr = xmlNewChild(pptr, 0, "term", 0); + yaz_srw_term(o, rptr, (*terms)+i, client_data, ns); + } + } + return 0; +} int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, void *client_data, const char *ns) @@ -289,20 +388,25 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, xmlNodePtr pptr = vptr; if (o->direction == ODR_DECODE) { + Z_SRW_PDU **p = handler_data; xmlNodePtr method = pptr->children; while (method && method->type == XML_TEXT_NODE) method = method->next; - if (!method || method->type != XML_ELEMENT_NODE) + if (!method) + return -1; + if (method->type != XML_ELEMENT_NODE) return -1; + + *p = odr_malloc(o, sizeof(**p)); + (*p)->srw_version = odr_strdup(o, "1.1"); + if (!strcmp(method->name, "searchRetrieveRequest")) { - Z_SRW_PDU **p = handler_data; xmlNodePtr ptr = method->children; Z_SRW_searchRetrieveRequest *req; - *p = odr_malloc(o, sizeof(**p)); (*p)->which = Z_SRW_searchRetrieve_request; req = (*p)->u.request = odr_malloc(o, sizeof(*req)); req->query_type = Z_SRW_query_type_cql; @@ -313,6 +417,9 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, req->maximumRecords = 0; req->recordSchema = 0; req->recordPacking = 0; + req->recordXPath = 0; + req->resultSetTTL = 0; + req->stylesheet = 0; req->database = 0; for (; ptr; ptr = ptr->next) @@ -335,25 +442,35 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, else if (match_xsd_string(ptr, "recordPacking", o, &req->recordPacking)) ; + else if (match_xsd_string(ptr, "recordXPath", o, + &req->recordXPath)) + ; else if (match_xsd_integer(ptr, "startRecord", o, &req->startRecord)) ; else if (match_xsd_integer(ptr, "maximumRecords", o, &req->maximumRecords)) ; + else if (match_xsd_string(ptr, "stylesheet", o, + &req->stylesheet)) + ; else if (match_xsd_string(ptr, "database", o, &req->database)) ; + else if (match_xsd_string(ptr, "resultSetTTL", o, + &req->database)) + ; + else if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; /* missing is xQuery, xSortKeys .. */ } } else if (!strcmp(method->name, "searchRetrieveResponse")) { - Z_SRW_PDU **p = handler_data; xmlNodePtr ptr = method->children; Z_SRW_searchRetrieveResponse *res; - *p = odr_malloc(o, sizeof(**p)); (*p)->which = Z_SRW_searchRetrieve_response; res = (*p)->u.response = odr_malloc(o, sizeof(*res)); @@ -388,53 +505,140 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, else if (match_xsd_integer(ptr, "nextRecordPosition", o, &res->nextRecordPosition)) ; + else if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; } } else if (!strcmp(method->name, "explainRequest")) { - Z_SRW_PDU **p = handler_data; Z_SRW_explainRequest *req; + xmlNodePtr ptr = method->children; - *p = odr_malloc(o, sizeof(**p)); (*p)->which = Z_SRW_explain_request; req = (*p)->u.explain_request = odr_malloc(o, sizeof(*req)); - req->dummy = 0; + req->recordPacking = 0; + req->database = 0; + for (; ptr; ptr = ptr->next) + { + if (match_xsd_string(ptr, "database", o, + &req->database)) + ; + else if (match_xsd_string(ptr, "recordPacking", o, + &req->recordPacking)) + ; + else if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; + } } else if (!strcmp(method->name, "explainResponse")) { - Z_SRW_PDU **p = handler_data; Z_SRW_explainResponse *res; xmlNodePtr ptr = method->children; - *p = odr_malloc(o, sizeof(**p)); (*p)->which = Z_SRW_explain_response; res = (*p)->u.explain_response = odr_malloc(o, sizeof(*res)); - res->explainData_buf = 0; - res->explainData_len = 0; - res->explainPacking = Z_SRW_recordPacking_string; - for (; ptr; ptr = ptr->next) - { - match_xsd_string_n(ptr, "Explain", o, - &res->explainData_buf, - &res->explainData_len); - } + res->diagnostics = 0; + res->num_diagnostics = 0; + + for (; ptr; ptr = ptr->next) + { + if (match_element(ptr, "record")) + yaz_srw_record(o, ptr, &res->record, client_data, ns); + else if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; + else if (match_element(ptr, "diagnostics")) + yaz_srw_diagnostics(o, ptr, &res->diagnostics, + &res->num_diagnostics, + client_data, ns); + ; + } + } + else if (!strcmp(method->name, "scanRequest")) + { + Z_SRW_scanRequest *req; + xmlNodePtr ptr = method->children; + + (*p)->which = Z_SRW_scan_request; + req = (*p)->u.scan_request = odr_malloc(o, sizeof(*req)); + req->database = 0; + req->scanClause = 0; + req->stylesheet = 0; + req->responsePosition = 0; + req->maximumTerms = 0; + + for (; ptr; ptr = ptr->next) + { + if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; + else if (match_xsd_string(ptr, "scanClause", o, + &req->scanClause)) + ; + else if (match_xsd_string(ptr, "database", o, + &req->database)) + ; + else if (match_xsd_string(ptr, "stylesheet", o, + &req->stylesheet)) + ; + else if (match_xsd_integer(ptr, "responsePosition", o, + &req->responsePosition)) + ; + else if (match_xsd_integer(ptr, "maximumTerms", o, + &req->maximumTerms)) + ; + } + } + else if (!strcmp(method->name, "scanResponse")) + { + Z_SRW_scanResponse *res; + xmlNodePtr ptr = method->children; + + (*p)->which = Z_SRW_scan_response; + res = (*p)->u.scan_response = odr_malloc(o, sizeof(*res)); + res->terms = 0; + res->num_terms = 0; + res->diagnostics = 0; + res->num_diagnostics = 0; + + for (; ptr; ptr = ptr->next) + { + if (match_element(ptr, "terms")) + yaz_srw_terms(o, ptr, &res->terms, + &res->num_terms, client_data, + ns); + else if (match_element(ptr, "diagnostics")) + yaz_srw_diagnostics(o, ptr, &res->diagnostics, + &res->num_diagnostics, + client_data, ns); + else if (match_xsd_string(ptr, "version", o, + &(*p)->srw_version)) + ; + } } else + { + *p = 0; return -1; - + } } else if (o->direction == ODR_ENCODE) { Z_SRW_PDU **p = handler_data; + xmlNsPtr ns_srw; + if ((*p)->which == Z_SRW_searchRetrieve_request) { Z_SRW_searchRetrieveRequest *req = (*p)->u.request; xmlNodePtr ptr = xmlNewChild(pptr, 0, "searchRetrieveRequest", 0); - xmlNsPtr ns_srw = xmlNewNs(ptr, ns, "zs"); - - xmlSetNs(ptr, ns_srw); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); + if ((*p)->srw_version) + add_xsd_string(ptr, "version", (*p)->srw_version); switch(req->query_type) { case Z_SRW_query_type_cql: @@ -462,16 +666,21 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, add_xsd_integer(ptr, "maximumRecords", req->maximumRecords); add_xsd_string(ptr, "recordSchema", req->recordSchema); add_xsd_string(ptr, "recordPacking", req->recordPacking); + add_xsd_string(ptr, "recordXPath", req->recordXPath); add_xsd_string(ptr, "database", req->database); + add_xsd_integer(ptr, "resultSetTTL", req->resultSetTTL); + add_xsd_string(ptr, "stylesheet", req->stylesheet); } else if ((*p)->which == Z_SRW_searchRetrieve_response) { Z_SRW_searchRetrieveResponse *res = (*p)->u.response; xmlNodePtr ptr = xmlNewChild(pptr, 0, "searchRetrieveResponse", 0); - xmlNsPtr ns_srw = xmlNewNs(ptr, ns, "zs"); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); - xmlSetNs(ptr, ns_srw); + if ((*p)->srw_version) + add_xsd_string(ptr, "version", (*p)->srw_version); add_xsd_integer(ptr, "numberOfRecords", res->numberOfRecords); add_xsd_string(ptr, "resultSetId", res->resultSetId); add_xsd_integer(ptr, "resultSetIdleTime", res->resultSetIdleTime); @@ -492,20 +701,65 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, else if ((*p)->which == Z_SRW_explain_request) { xmlNodePtr ptr = xmlNewChild(pptr, 0, "explainRequest", 0); - xmlNsPtr ns_srw = xmlNewNs(ptr, ns, "zs"); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); - xmlSetNs(ptr, ns_srw); + add_xsd_string(ptr, "version", (*p)->srw_version); } else if ((*p)->which == Z_SRW_explain_response) { Z_SRW_explainResponse *res = (*p)->u.explain_response; xmlNodePtr ptr = xmlNewChild(pptr, 0, "explainResponse", 0); - xmlNsPtr ns_srw = xmlNewNs(ptr, ns, "zs"); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); + + add_xsd_string(ptr, "version", (*p)->srw_version); + if (1) + { + xmlNodePtr ptr1 = xmlNewChild(ptr, 0, "record", 0); + yaz_srw_record(o, ptr1, &res->record, client_data, ns); + } + if (res->num_diagnostics) + { + xmlNodePtr rptr = xmlNewChild(ptr, 0, "diagnostics", 0); + yaz_srw_diagnostics(o, rptr, &res->diagnostics, + &res->num_diagnostics, client_data, ns); + } + } + else if ((*p)->which == Z_SRW_scan_request) + { + Z_SRW_scanRequest *req = (*p)->u.scan_request; + xmlNodePtr ptr = xmlNewChild(pptr, 0, "scanRequest", 0); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); + + add_xsd_string(ptr, "version", (*p)->srw_version); + add_xsd_string(ptr, "scanClause", req->scanClause); + add_xsd_integer(ptr, "responsePosition", req->responsePosition); + add_xsd_integer(ptr, "maximumTerms", req->maximumTerms); + add_xsd_string(ptr, "stylesheet", req->stylesheet); + } + else if ((*p)->which == Z_SRW_scan_response) + { + Z_SRW_scanResponse *res = (*p)->u.scan_response; + xmlNodePtr ptr = xmlNewChild(pptr, 0, "scanResponse", 0); + ns_srw = xmlNewNs(ptr, ns, "zs"); + xmlSetNs(ptr, ns_srw); - xmlSetNs(ptr, ns_srw); + add_xsd_string(ptr, "version", (*p)->srw_version); - add_xsd_string_n(ptr, "Explain", res->explainData_buf, - res->explainData_len); + if (res->num_terms) + { + xmlNodePtr rptr = xmlNewChild(ptr, 0, "terms", 0); + yaz_srw_terms(o, rptr, &res->terms, &res->num_terms, + client_data, ns); + } + if (res->num_diagnostics) + { + xmlNodePtr rptr = xmlNewChild(ptr, 0, "diagnostics", 0); + yaz_srw_diagnostics(o, rptr, &res->diagnostics, + &res->num_diagnostics, client_data, ns); + } } else return -1; @@ -517,6 +771,8 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, Z_SRW_PDU *yaz_srw_get(ODR o, int which) { Z_SRW_PDU *sr = odr_malloc(o, sizeof(*o)); + + sr->srw_version = odr_strdup(o, "1.1"); sr->which = which; switch(which) { @@ -531,7 +787,9 @@ Z_SRW_PDU *yaz_srw_get(ODR o, int which) sr->u.request->maximumRecords = 0; sr->u.request->recordSchema = 0; sr->u.request->recordPacking = 0; - sr->u.request->database = 0; + sr->u.request->database = 0; + sr->u.request->resultSetTTL = 0; + sr->u.request->stylesheet = 0; break; case Z_SRW_searchRetrieve_response: sr->u.response = (Z_SRW_searchRetrieveResponse *) @@ -548,14 +806,20 @@ Z_SRW_PDU *yaz_srw_get(ODR o, int which) case Z_SRW_explain_request: sr->u.explain_request = (Z_SRW_explainRequest *) odr_malloc(o, sizeof(*sr->u.explain_request)); - sr->u.explain_request->dummy = 0; + sr->u.explain_request->recordPacking = 0; + sr->u.explain_request->database = 0; break; case Z_SRW_explain_response: sr->u.explain_response = (Z_SRW_explainResponse *) odr_malloc(o, sizeof(*sr->u.explain_response)); - sr->u.explain_response->explainPacking = 0; - sr->u.explain_response->explainData_buf = 0; - sr->u.explain_response->explainData_len = 0; + sr->u.explain_response->record.recordData_buf = 0; + sr->u.explain_response->record.recordData_len = 0; + sr->u.explain_response->record.recordSchema = 0; + sr->u.explain_response->record.recordPosition = 0; + sr->u.explain_response->record.recordPacking = + Z_SRW_recordPacking_string; + sr->u.explain_response->diagnostics = 0; + sr->u.explain_response->num_diagnostics = 0; } return sr; } @@ -576,9 +840,9 @@ static struct { {12, "Too many characters in query"}, {13, "Unbalanced or illegal use of parentheses"}, {14, "Unbalanced or illegal use of quotes"}, -{15, "Illegal or unsupported index set"}, +{15, "Illegal or unsupported context set"}, {16, "Illegal or unsupported index"}, -{17, "Illegal or unsupported combination of index and index set"}, +{17, "Illegal or unsupported combination of index and context set"}, {18, "Illegal or unsupported combination of indexes"}, {19, "Illegal or unsupported relation"}, {20, "Illegal or unsupported relation modifier"}, @@ -606,7 +870,7 @@ static struct { {42, "Illegal or unsupported proximity unit"}, {43, "Illegal or unsupported proximity ordering"}, {44, "Illegal or unsupported combination of proximity modifiers"}, -{45, "Index set name (prefix) assigned to multiple identifiers"}, +{45, "context set name (prefix) assigned to multiple identifiers"}, /* Diagnostics Relating to Result Sets */ {50, "Result sets not supported"}, {51, "Result set does not exist"}, @@ -853,3 +1117,4 @@ int yaz_diag_srw_to_bib1(int code) } return 1; } +