X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=zutil%2Fsrw.c;h=5b6657e1a2da73cb1c00bd6731ef1ae4d662c96f;hb=c39a893dfdae5f792139177132e7e7a70e010aa7;hp=e8337b1d98de1fcb7955e0f7c82723ccd41adf2c;hpb=d21f71aa7f9d30fdf457c58e7403723415506c1e;p=yaz-moved-to-github.git diff --git a/zutil/srw.c b/zutil/srw.c index e8337b1..5b6657e 100644 --- a/zutil/srw.c +++ b/zutil/srw.c @@ -2,7 +2,7 @@ * Copyright (c) 2002-2003, Index Data. * See the file LICENSE for details. * - * $Id: srw.c,v 1.10 2003-03-20 21:15:00 adam Exp $ + * $Id: srw.c,v 1.15 2003-05-12 22:36:10 adam Exp $ */ #include @@ -101,6 +101,33 @@ static int match_xsd_string(xmlNodePtr ptr, const char *elem, ODR o, { return match_xsd_string_n(ptr, elem, o, val, 0); } + +static int match_xsd_XML_n(xmlNodePtr ptr, const char *elem, ODR o, + char **val, int *len) +{ + xmlBufferPtr buf; + + if (!match_element(ptr, elem)) + return 0; + ptr = ptr->children; + if (!ptr) + return 0; + buf = xmlBufferCreate(); + + xmlNodeDump(buf, ptr->doc, ptr, 0, 0); + + *val = odr_malloc(o, buf->use+1); + memcpy (*val, buf->content, buf->use); + (*val)[buf->use] = '\0'; + + if (len) + *len = buf->use; + + xmlBufferFree(buf); + + return 1; +} + static int match_xsd_integer(xmlNodePtr ptr, const char *elem, ODR o, int **val) { @@ -169,6 +196,10 @@ static int yaz_srw_records(ODR o, xmlNodePtr pptr, Z_SRW_record **recs, &(*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)) ; @@ -263,9 +294,9 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, while (method && method->type == XML_TEXT_NODE) method = method->next; - if (method->type != XML_ELEMENT_NODE) + if (!method || method->type != XML_ELEMENT_NODE) return -1; - if (method && !strcmp(method->name, "searchRetrieveRequest")) + if (!strcmp(method->name, "searchRetrieveRequest")) { Z_SRW_PDU **p = handler_data; xmlNodePtr ptr = method->children; @@ -316,7 +347,7 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, /* missing is xQuery, xSortKeys .. */ } } - else if (method && !strcmp(method->name, "searchRetrieveResponse")) + else if (!strcmp(method->name, "searchRetrieveResponse")) { Z_SRW_PDU **p = handler_data; xmlNodePtr ptr = method->children; @@ -359,6 +390,35 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, ; } } + else if (!strcmp(method->name, "explainRequest")) + { + Z_SRW_PDU **p = handler_data; + Z_SRW_explainRequest *req; + + *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; + } + 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); + } + } else return -1; @@ -429,6 +489,24 @@ int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data, } add_xsd_integer(ptr, "nextRecordPosition", res->nextRecordPosition); } + else if ((*p)->which == Z_SRW_explain_request) + { + xmlNodePtr ptr = xmlNewChild(pptr, 0, "explainRequest", 0); + xmlNsPtr ns_srw = xmlNewNs(ptr, ns, "zs"); + + xmlSetNs(ptr, ns_srw); + } + 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"); + + xmlSetNs(ptr, ns_srw); + + add_xsd_string_n(ptr, "Explain", res->explainData_buf, + res->explainData_len); + } else return -1; @@ -443,7 +521,8 @@ Z_SRW_PDU *yaz_srw_get(ODR o, int which) switch(which) { case Z_SRW_searchRetrieve_request: - sr->u.request = odr_malloc(o, sizeof(*sr->u.request)); + sr->u.request = (Z_SRW_searchRetrieveRequest *) + odr_malloc(o, sizeof(*sr->u.request)); sr->u.request->query_type = Z_SRW_query_type_cql; sr->u.request->query.cql = 0; sr->u.request->sort_type = Z_SRW_sort_type_none; @@ -455,7 +534,8 @@ Z_SRW_PDU *yaz_srw_get(ODR o, int which) sr->u.request->database = 0; break; case Z_SRW_searchRetrieve_response: - sr->u.response = odr_malloc(o, sizeof(*sr->u.response)); + sr->u.response = (Z_SRW_searchRetrieveResponse *) + odr_malloc(o, sizeof(*sr->u.response)); sr->u.response->numberOfRecords = 0; sr->u.response->resultSetId = 0; sr->u.response->resultSetIdleTime = 0; @@ -464,6 +544,18 @@ Z_SRW_PDU *yaz_srw_get(ODR o, int which) sr->u.response->diagnostics = 0; sr->u.response->num_diagnostics = 0; sr->u.response->nextRecordPosition = 0; + break; + 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; + 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; } return sr; }