src/srw.c

   1 /* This file is part of the YAZ toolkit.
   2  * Copyright (C) 1995-2013 Index Data
   3  * See the file LICENSE for details.
   4  */
   5 /**
   6  * \file srw.c
   7  * \brief Implements SRW/SRU package encoding and decoding
   8  */
   9 #if HAVE_CONFIG_H
  10 #include <config.h>
  11 #endif
  12
  13 #include <stdlib.h>
  14
  15 #include <yaz/srw.h>
  16 #include <yaz/wrbuf.h>
  17 #if YAZ_HAVE_XML2
  18 #include <libxml/parser.h>
  19 #include <libxml/tree.h>
  20 #include <assert.h>
  21
  22 #include "sru-p.h"
  23
  24 static void add_XML_n(xmlNodePtr ptr, const char *elem, char *val, int len,
  25                       xmlNsPtr ns_ptr)
  26 {
  27     if (val)
  28     {
  29         xmlDocPtr doc = xmlParseMemory(val,len);
  30         if (doc)
  31         {
  32             xmlNodePtr c = xmlNewChild(ptr, ns_ptr, BAD_CAST elem, 0);
  33             xmlNodePtr t = xmlDocGetRootElement(doc);
  34             xmlAddChild(c, xmlCopyNode(t,1));
  35             xmlFreeDoc(doc);
  36         }
  37     }
  38 }
  39
  40 xmlNodePtr add_xsd_string_n(xmlNodePtr ptr, const char *elem, const char *val,
  41                             int len)
  42 {
  43     if (val)
  44     {
  45         xmlNodePtr c = xmlNewChild(ptr, 0, BAD_CAST elem, 0);
  46         xmlNodePtr t = xmlNewTextLen(BAD_CAST val, len);
  47         xmlAddChild(c, t);
  48         return t;
  49     }
  50     return 0;
  51 }
  52
  53 xmlNodePtr add_xsd_string_ns(xmlNodePtr ptr, const char *elem, const char *val,
  54                              xmlNsPtr ns_ptr)
  55 {
  56     if (val)
  57     {
  58         xmlNodePtr c = xmlNewChild(ptr, ns_ptr, BAD_CAST elem, 0);
  59         xmlNodePtr t = xmlNewText(BAD_CAST val);
  60         xmlAddChild(c, t);
  61         return t;
  62     }
  63     return 0;
  64 }
  65
  66 xmlNodePtr add_xsd_string(xmlNodePtr ptr, const char *elem, const char *val)
  67 {
  68     return add_xsd_string_ns(ptr, elem, val, 0);
  69 }
  70
  71 static void add_xsd_integer(xmlNodePtr ptr, const char *elem,
  72                             const Odr_int *val)
  73 {
  74     if (val)
  75     {
  76         char str[40];
  77         sprintf(str, ODR_INT_PRINTF, *val);
  78         xmlNewTextChild(ptr, 0, BAD_CAST elem, BAD_CAST str);
  79     }
  80 }
  81
  82 static int match_element(xmlNodePtr ptr, const char *elem)
  83 {
  84     if (ptr->type == XML_ELEMENT_NODE && !xmlStrcmp(ptr->name, BAD_CAST elem))
  85     {
  86         return 1;
  87     }
  88     return 0;
  89 }
  90
  91 #define CHECK_TYPE 0
  92
  93 static int match_xsd_string_n(xmlNodePtr ptr, const char *elem, ODR o,
  94                               char **val, int *len)
  95 {
  96 #if CHECK_TYPE
  97     struct _xmlAttr *attr;
  98 #endif
  99     if (!match_element(ptr, elem))
 100         return 0;
 101 #if CHECK_TYPE
 102     for (attr = ptr->properties; attr; attr = attr->next)
 103         if (!strcmp(attr->name, "type") &&
 104             attr->children && attr->children->type == XML_TEXT_NODE)
 105         {
 106             const char *t = strchr(attr->children->content, ':');
 107             if (t)
 108                 t = t + 1;
 109             else
 110                 t = attr->children->content;
 111             if (!strcmp(t, "string"))
 112                 break;
 113         }
 114     if (!attr)
 115         return 0;
 116 #endif
 117     ptr = ptr->children;
 118     if (!ptr || ptr->type != XML_TEXT_NODE)
 119     {
 120         *val = "";
 121         return 1;
 122     }
 123     *val = odr_strdup(o, (const char *) ptr->content);
 124     if (len)
 125         *len = xmlStrlen(ptr->content);
 126     return 1;
 127 }
 128
 129
 130 static int match_xsd_string(xmlNodePtr ptr, const char *elem, ODR o,
 131                             char **val)
 132 {
 133     return match_xsd_string_n(ptr, elem, o, val, 0);
 134 }
 135
 136 static int match_xsd_XML_n2(xmlNodePtr ptr, const char *elem, ODR o,
 137                             char **val, int *len, int fixup_root)
 138 {
 139     xmlBufferPtr buf;
 140     int no_root_nodes = 0;
 141
 142     if (!match_element(ptr, elem))
 143         return 0;
 144
 145     buf = xmlBufferCreate();
 146
 147     /* Copy each element nodes at top.
 148        In most cases there is only one root node.. At least one server
 149        http://www.theeuropeanlibrary.org/sru/sru.pl
 150        has multiple root nodes in recordData.
 151     */
 152     for (ptr = ptr->children; ptr; ptr = ptr->next)
 153     {
 154         if (ptr->type == XML_ELEMENT_NODE)
 155         {
 156             /* copy node to get NS right (bug #740). */
 157             xmlNode *tmp = xmlCopyNode(ptr, 1);
 158
 159             xmlNodeDump(buf, tmp->doc, tmp, 0, 0);
 160
 161             xmlFreeNode(tmp);
 162             no_root_nodes++;
 163         }
 164     }
 165     if (no_root_nodes != 1 && fixup_root)
 166     {
 167         /* does not appear to be an XML document. Make it so */
 168         xmlBufferAddHead(buf, (const xmlChar *) "<yaz_record>", -1);
 169         xmlBufferAdd(buf, (const xmlChar *) "</yaz_record>", -1);
 170     }
 171     *val = (char *) odr_malloc(o, buf->use + 1);
 172     memcpy(*val, buf->content, buf->use);
 173     (*val)[buf->use] = '\0';
 174
 175     if (len)
 176         *len = buf->use;
 177
 178     xmlBufferFree(buf);
 179
 180     return 1;
 181 }
 182
 183 static int match_xsd_XML_n(xmlNodePtr ptr, const char *elem, ODR o,
 184                            char **val, int *len)
 185 {
 186     return match_xsd_XML_n2(ptr, elem, o, val, len, 0);
 187 }
 188
 189 static int match_xsd_integer(xmlNodePtr ptr, const char *elem, ODR o,
 190                              Odr_int **val)
 191 {
 192 #if CHECK_TYPE
 193     struct _xmlAttr *attr;
 194 #endif
 195     if (!match_element(ptr, elem))
 196         return 0;
 197 #if CHECK_TYPE
 198     for (attr = ptr->properties; attr; attr = attr->next)
 199         if (!strcmp(attr->name, "type") &&
 200             attr->children && attr->children->type == XML_TEXT_NODE)
 201         {
 202             const char *t = strchr(attr->children->content, ':');
 203             if (t)
 204                 t = t + 1;
 205             else
 206                 t = attr->children->content;
 207             if (!strcmp(t, "integer"))
 208                 break;
 209         }
 210     if (!attr)
 211         return 0;
 212 #endif
 213     ptr = ptr->children;
 214     if (!ptr || ptr->type != XML_TEXT_NODE)
 215         return 0;
 216     *val = odr_intdup(o, odr_atoi((const char *) ptr->content));
 217     return 1;
 218 }
 219
 220 char *yaz_negotiate_sru_version(char *input_ver)
 221 {
 222     if (!input_ver)
 223         return "2.0";
 224     if (!strcmp(input_ver, "1.1"))
 225         return "1.1";
 226     if (!strncmp(input_ver, "1.", 2))
 227         return "1.2";
 228     if (!strncmp(input_ver, "2.", 2))
 229         return "2.0";
 230     return 0;
 231 }
 232
 233 static int yaz_srw_record(ODR o, xmlNodePtr pptr, Z_SRW_record *rec,
 234                           Z_SRW_extra_record **extra,
 235                           void *client_data, int version2)
 236 {
 237     if (o->direction == ODR_DECODE)
 238     {
 239         Z_SRW_extra_record ex;
 240
 241         char *spack = 0;
 242         xmlNodePtr ptr;
 243 #ifdef Z_SRW_packed
 244         rec->packing = 0;
 245 #endif
 246         rec->recordSchema = 0;
 247         rec->recordData_buf = 0;
 248         rec->recordData_len = 0;
 249         rec->recordPosition = 0;
 250         *extra = 0;
 251
 252         ex.extraRecordData_buf = 0;
 253         ex.extraRecordData_len = 0;
 254         ex.recordIdentifier = 0;
 255
 256         for (ptr = pptr->children; ptr; ptr = ptr->next)
 257         {
 258
 259             if (match_xsd_string(ptr, "recordSchema", o,
 260                                  &rec->recordSchema))
 261                 ;
 262             else if (match_xsd_string(ptr, "recordPacking", o, &spack))
 263                 ;  /* can't rely on it: in SRU 2.0 it's different semantics */
 264             else if (match_xsd_integer(ptr, "recordPosition", o,
 265                                        &rec->recordPosition))
 266                 ;
 267             else if (match_element(ptr, "recordData"))
 268             {
 269                 /* we assume XML packing, if any element nodes exist below
 270                    recordData. Unfortunately, in SRU 2.0 recordPacking
 271                    means something different */
 272                 xmlNode *p = ptr->children;
 273                 for (; p; p = p->next)
 274                     if (p->type == XML_ELEMENT_NODE)
 275                         break;
 276                 if (p)
 277                 {
 278                     match_xsd_XML_n2(
 279                         ptr, "recordData", o,
 280                         &rec->recordData_buf, &rec->recordData_len, 1);
 281                     rec->recordPacking = Z_SRW_recordPacking_XML;
 282                 }
 283                 else
 284                 {
 285                     match_xsd_string_n(
 286                         ptr, "recordData", o,
 287                         &rec->recordData_buf, &rec->recordData_len);
 288                     rec->recordPacking = Z_SRW_recordPacking_string;
 289                 }
 290             }
 291             else if (match_xsd_XML_n(ptr, "extraRecordData", o,
 292                                      &ex.extraRecordData_buf,
 293                                      &ex.extraRecordData_len) )
 294                 ;
 295             else
 296                 match_xsd_string(ptr, "recordIdentifier", o,
 297                                  &ex.recordIdentifier);
 298         }
 299         if (ex.extraRecordData_buf || ex.recordIdentifier)
 300         {
 301             *extra = (Z_SRW_extra_record *)
 302                 odr_malloc(o, sizeof(Z_SRW_extra_record));
 303             memcpy(*extra, &ex, sizeof(Z_SRW_extra_record));
 304         }
 305     }
 306     else if (o->direction == ODR_ENCODE)
 307     {
 308         xmlNodePtr ptr = pptr;
 309         int pack = rec->recordPacking;
 310         const char *spack = yaz_srw_pack_to_str(pack);
 311
 312         add_xsd_string(ptr, "recordSchema", rec->recordSchema);
 313         if (spack)
 314         {
 315             if (version2)
 316                 add_xsd_string(ptr, "recordXMLEscaping", spack);
 317             else
 318                 add_xsd_string(ptr, "recordPacking", spack);
 319         }
 320         switch (pack)
 321         {
 322         case Z_SRW_recordPacking_string:
 323             add_xsd_string_n(ptr, "recordData", rec->recordData_buf,
 324                              rec->recordData_len);
 325             break;
 326         case Z_SRW_recordPacking_XML:
 327             add_XML_n(ptr, "recordData", rec->recordData_buf,
 328                       rec->recordData_len, 0);
 329             break;
 330         case Z_SRW_recordPacking_URL:
 331             add_xsd_string_n(ptr, "recordData", rec->recordData_buf,
 332                              rec->recordData_len);
 333             break;
 334         }
 335         if (rec->recordPosition)
 336             add_xsd_integer(ptr, "recordPosition", rec->recordPosition );
 337         if (extra && *extra)
 338         {
 339             if ((*extra)->recordIdentifier)
 340                 add_xsd_string(ptr, "recordIdentifier",
 341                                (*extra)->recordIdentifier);
 342             if ((*extra)->extraRecordData_buf)
 343                 add_XML_n(ptr, "extraRecordData",
 344                           (*extra)->extraRecordData_buf,
 345                           (*extra)->extraRecordData_len, 0);
 346         }
 347     }
 348     return 0;
 349 }
 350
 351 static int yaz_srw_records(ODR o, xmlNodePtr pptr, Z_SRW_record **recs,
 352                            Z_SRW_extra_record ***extra,
 353                            int *num, void *client_data, int version2)
 354 {
 355     if (o->direction == ODR_DECODE)
 356     {
 357         int i;
 358         xmlNodePtr ptr;
 359         *num = 0;
 360         for (ptr = pptr->children; ptr; ptr = ptr->next)
 361         {
 362             if (ptr->type == XML_ELEMENT_NODE &&
 363                 !xmlStrcmp(ptr->name, BAD_CAST "record"))
 364                 (*num)++;
 365         }
 366         if (!*num)
 367             return 1;
 368         *recs = (Z_SRW_record *) odr_malloc(o, *num * sizeof(**recs));
 369         *extra = (Z_SRW_extra_record **) odr_malloc(o, *num * sizeof(**extra));
 370         for (i = 0, ptr = pptr->children; ptr; ptr = ptr->next)
 371         {
 372             if (ptr->type == XML_ELEMENT_NODE &&
 373                 !xmlStrcmp(ptr->name, BAD_CAST "record"))
 374             {
 375                 yaz_srw_record(o, ptr, *recs + i, *extra + i, client_data, 0);
 376                 i++;
 377             }
 378         }
 379     }
 380     else if (o->direction == ODR_ENCODE)
 381     {
 382         int i;
 383         for (i = 0; i < *num; i++)
 384         {
 385             xmlNodePtr rptr = xmlNewChild(pptr, 0, BAD_CAST "record",
 386                                           0);
 387             yaz_srw_record(o, rptr, (*recs)+i, (*extra ? *extra + i : 0),
 388                            client_data, version2);
 389         }
 390     }
 391     return 0;
 392 }
 393
 394 static int yaz_srw_version(ODR o, xmlNodePtr pptr, Z_SRW_recordVersion *rec,
 395                            void *client_data, const char *ns)
 396 {
 397     if (o->direction == ODR_DECODE)
 398     {
 399         xmlNodePtr ptr;
 400         rec->versionType = 0;
 401         rec->versionValue = 0;
 402         for (ptr = pptr->children; ptr; ptr = ptr->next)
 403         {
 404
 405             if (match_xsd_string(ptr, "versionType", o,
 406                                  &rec->versionType))
 407                 ;
 408             else
 409                 match_xsd_string(ptr, "versionValue", o, &rec->versionValue);
 410         }
 411     }
 412     else if (o->direction == ODR_ENCODE)
 413     {
 414         xmlNodePtr ptr = pptr;
 415         add_xsd_string(ptr, "versionType", rec->versionType);
 416         add_xsd_string(ptr, "versionValue", rec->versionValue);
 417     }
 418     return 0;
 419 }
 420
 421 static int yaz_srw_versions(ODR o, xmlNodePtr pptr,
 422                             Z_SRW_recordVersion **vers,
 423                             int *num, void *client_data, const char *ns)
 424 {
 425     if (o->direction == ODR_DECODE)
 426     {
 427         int i;
 428         xmlNodePtr ptr;
 429         *num = 0;
 430         for (ptr = pptr->children; ptr; ptr = ptr->next)
 431         {
 432             if (ptr->type == XML_ELEMENT_NODE &&
 433                 !xmlStrcmp(ptr->name, BAD_CAST "recordVersion"))
 434                 (*num)++;
 435         }
 436         if (!*num)
 437             return 1;
 438         *vers = (Z_SRW_recordVersion *) odr_malloc(o, *num * sizeof(**vers));
 439         for (i = 0, ptr = pptr->children; ptr; ptr = ptr->next)
 440         {
 441             if (ptr->type == XML_ELEMENT_NODE &&
 442                 !xmlStrcmp(ptr->name, BAD_CAST "recordVersion"))
 443             {
 444                 yaz_srw_version(o, ptr, *vers + i, client_data, ns);
 445                 i++;
 446             }
 447         }
 448     }
 449     else if (o->direction == ODR_ENCODE)
 450     {
 451         int i;
 452         for (i = 0; i < *num; i++)
 453         {
 454             xmlNodePtr rptr = xmlNewChild(pptr, 0, BAD_CAST "version",
 455                                           0);
 456             yaz_srw_version(o, rptr, (*vers)+i, client_data, ns);
 457         }
 458     }
 459     return 0;
 460 }
 461
 462 Z_FacetTerm *yaz_sru_proxy_get_facet_term_count(ODR odr, xmlNodePtr node)
 463 {
 464     Odr_int freq;
 465     xmlNodePtr child;
 466     WRBUF wrbuf = wrbuf_alloc();
 467     Z_FacetTerm *facet_term;
 468     const char *freq_string = yaz_element_attribute_value_get(
 469         node, "facetvalue", "est_representation");
 470     if (freq_string)
 471         freq = odr_atoi(freq_string);
 472     else
 473         freq = -1;
 474
 475     for (child = node->children; child ; child = child->next)
 476     {
 477         if (child->type == XML_TEXT_NODE)
 478             wrbuf_puts(wrbuf, (const char *) child->content);
 479     }
 480     facet_term = facet_term_create_cstr(odr, wrbuf_cstr(wrbuf), freq);
 481     wrbuf_destroy(wrbuf);
 482     return facet_term;
 483 }
 484
 485 static Z_FacetField *yaz_sru_proxy_decode_facet_field(ODR odr, xmlNodePtr ptr)
 486 {
 487     Z_AttributeList *list;
 488     Z_FacetField *facet_field;
 489     int num_terms = 0;
 490     int index = 0;
 491     xmlNodePtr node;
 492     /* USE attribute */
 493     const char* name = yaz_element_attribute_value_get(ptr, "facet", "code");
 494     yaz_log(YLOG_DEBUG, "sru-proxy facet type: %s", name);
 495
 496     list = yaz_use_attribute_create(odr, name);
 497     for (node = ptr->children; node; node = node->next) {
 498         if (match_element(node, "facetvalue"))
 499             num_terms++;
 500     }
 501     facet_field = facet_field_create(odr, list, num_terms);
 502     index = 0;
 503     for (node = ptr->children; node; node = node->next)
 504     {
 505         if (match_element(node, "facetvalue"))
 506         {
 507             facet_field_term_set(odr, facet_field,
 508                                  yaz_sru_proxy_get_facet_term_count(odr, node),
 509                                  index);
 510             index++;
 511         }
 512     }
 513     return facet_field;
 514 }
 515
 516 static int yaz_sru_proxy_decode_facets(ODR o, xmlNodePtr root,
 517                                        Z_FacetList **facetList)
 518 {
 519     xmlNodePtr ptr;
 520
 521     for (ptr = root->children; ptr; ptr = ptr->next)
 522     {
 523         if (match_element(ptr, "facets"))
 524         {
 525             xmlNodePtr node;
 526             Z_FacetList *facet_list;
 527             int num_facets = 0;
 528             for (node = ptr->children; node; node= node->next)
 529             {
 530                 if (node->type == XML_ELEMENT_NODE)
 531                     num_facets++;
 532             }
 533             facet_list = facet_list_create(o, num_facets);
 534             num_facets = 0;
 535             for (node = ptr->children; node; node= node->next)
 536             {
 537                 if (match_element(node, "facet"))
 538                 {
 539                     facet_list_field_set(
 540                         o, facet_list,
 541                         yaz_sru_proxy_decode_facet_field(o, node), num_facets);
 542                     num_facets++;
 543                 }
 544             }
 545             *facetList = facet_list;
 546             break;
 547         }
 548     }
 549     return 0;
 550 }
 551
 552
 553
 554 static int yaz_srw_decode_diagnostics(ODR o, xmlNodePtr pptr,
 555                                       Z_SRW_diagnostic **recs, int *num,
 556                                       void *client_data, const char *ns)
 557 {
 558     int i;
 559     xmlNodePtr ptr;
 560     *num = 0;
 561     for (ptr = pptr; ptr; ptr = ptr->next)
 562     {
 563         if (ptr->type == XML_ELEMENT_NODE &&
 564             !xmlStrcmp(ptr->name, BAD_CAST "diagnostic"))
 565             (*num)++;
 566     }
 567     if (!*num)
 568         return 1;
 569     *recs = (Z_SRW_diagnostic *) odr_malloc(o, *num * sizeof(**recs));
 570     for (i = 0; i < *num; i++)
 571     {
 572         (*recs)[i].uri = 0;
 573         (*recs)[i].details = 0;
 574         (*recs)[i].message = 0;
 575     }
 576     for (i = 0, ptr = pptr; ptr; ptr = ptr->next)
 577     {
 578         if (ptr->type == XML_ELEMENT_NODE &&
 579             !xmlStrcmp(ptr->name, BAD_CAST "diagnostic"))
 580         {
 581             xmlNodePtr rptr;
 582             (*recs)[i].uri = 0;
 583             (*recs)[i].details = 0;
 584             (*recs)[i].message = 0;
 585             for (rptr = ptr->children; rptr; rptr = rptr->next)
 586             {
 587                 if (match_xsd_string(rptr, "uri", o,
 588                                      &(*recs)[i].uri))
 589                     ;
 590                 else if (match_xsd_string(rptr, "details", o,
 591                                           &(*recs)[i].details))
 592                     ;
 593                 else
 594                     match_xsd_string(rptr, "message", o, &(*recs)[i].message);
 595             }
 596             i++;
 597         }
 598     }
 599     return 0;
 600 }
 601
 602 int sru_decode_surrogate_diagnostics(const char *buf, size_t len,
 603                                      Z_SRW_diagnostic **diag,
 604                                      int *num, ODR odr)
 605 {
 606     int ret = 0;
 607     xmlDocPtr doc = xmlParseMemory(buf, len);
 608     if (doc)
 609     {
 610         xmlNodePtr ptr = xmlDocGetRootElement(doc);
 611         while (ptr && ptr->type != XML_ELEMENT_NODE)
 612             ptr = ptr->next;
 613         if (ptr && ptr->ns
 614             && !xmlStrcmp(ptr->ns->href,
 615                           BAD_CAST "http://www.loc.gov/zing/srw/diagnostic/"))
 616         {
 617             ret = yaz_srw_decode_diagnostics(odr, ptr, diag, num, 0, 0);
 618         }
 619         xmlFreeDoc(doc);
 620     }
 621     return ret;
 622 }
 623
 624 static int yaz_srw_diagnostics(ODR o, xmlNodePtr pptr, Z_SRW_diagnostic **recs,
 625                                int *num, void *client_data, const char *ns)
 626 {
 627     if (o->direction == ODR_DECODE)
 628     {
 629         return yaz_srw_decode_diagnostics(o, pptr->children, recs, num, client_data, ns);
 630     }
 631     else if (o->direction == ODR_ENCODE)
 632     {
 633         int i;
 634         xmlNsPtr ns_diag =
 635             xmlNewNs(pptr, BAD_CAST YAZ_XMLNS_DIAG_v1_1, BAD_CAST "diag" );
 636         for (i = 0; i < *num; i++)
 637         {
 638             const char *std_diag = "info:srw/diagnostic/1/";
 639             const char *ucp_diag = "info:srw/diagnostic/12/";
 640             xmlNodePtr rptr = xmlNewChild(pptr, ns_diag,
 641                                           BAD_CAST "diagnostic", 0);
 642             add_xsd_string(rptr, "uri", (*recs)[i].uri);
 643             if ((*recs)[i].message)
 644                 add_xsd_string(rptr, "message", (*recs)[i].message);
 645             else if ((*recs)[i].uri )
 646             {
 647                 if (!strncmp((*recs)[i].uri, std_diag, strlen(std_diag)))
 648                 {
 649                     int no = atoi((*recs)[i].uri + strlen(std_diag));
 650                     const char *message = yaz_diag_srw_str(no);
 651                     if (message)
 652                         add_xsd_string(rptr, "message", message);
 653                 }
 654                 else if (!strncmp((*recs)[i].uri, ucp_diag, strlen(ucp_diag)))
 655                 {
 656                     int no = atoi((*recs)[i].uri + strlen(ucp_diag));
 657                     const char *message = yaz_diag_sru_update_str(no);
 658                     if (message)
 659                         add_xsd_string(rptr, "message", message);
 660                 }
 661             }
 662             add_xsd_string(rptr, "details", (*recs)[i].details);
 663         }
 664     }
 665     return 0;
 666 }
 667
 668 static int yaz_srw_term(ODR o, xmlNodePtr pptr, Z_SRW_scanTerm *term,
 669                         void *client_data, const char *ns)
 670 {
 671     if (o->direction == ODR_DECODE)
 672     {
 673         xmlNodePtr ptr;
 674         term->value = 0;
 675         term->numberOfRecords = 0;
 676         term->displayTerm = 0;
 677         term->whereInList = 0;
 678         for (ptr = pptr->children; ptr; ptr = ptr->next)
 679         {
 680             if (match_xsd_string(ptr, "value", o,  &term->value))
 681                 ;
 682             else if (match_xsd_integer(ptr, "numberOfRecords", o,
 683                                        &term->numberOfRecords))
 684                 ;
 685             else if (match_xsd_string(ptr, "displayTerm", o,
 686                                       &term->displayTerm))
 687                 ;
 688             else
 689                 match_xsd_string(ptr, "whereInList", o, &term->whereInList);
 690         }
 691     }
 692     else if (o->direction == ODR_ENCODE)
 693     {
 694         xmlNodePtr ptr = pptr;
 695         add_xsd_string(ptr, "value", term->value);
 696         add_xsd_integer(ptr, "numberOfRecords", term->numberOfRecords);
 697         add_xsd_string(ptr, "displayTerm", term->displayTerm);
 698         add_xsd_string(ptr, "whereInList", term->whereInList);
 699     }
 700     return 0;
 701 }
 702
 703 static int yaz_srw_terms(ODR o, xmlNodePtr pptr, Z_SRW_scanTerm **terms,
 704                          int *num, void *client_data, const char *ns)
 705 {
 706     if (o->direction == ODR_DECODE)
 707     {
 708         int i;
 709         xmlNodePtr ptr;
 710         *num = 0;
 711         for (ptr = pptr->children; ptr; ptr = ptr->next)
 712         {
 713             if (ptr->type == XML_ELEMENT_NODE &&
 714                 !xmlStrcmp(ptr->name, BAD_CAST "term"))
 715                 (*num)++;
 716         }
 717         if (!*num)
 718             return 1;
 719         *terms = (Z_SRW_scanTerm *) odr_malloc(o, *num * sizeof(**terms));
 720         for (i = 0, ptr = pptr->children; ptr; ptr = ptr->next, i++)
 721         {
 722             if (ptr->type == XML_ELEMENT_NODE &&
 723                 !xmlStrcmp(ptr->name, BAD_CAST "term"))
 724                 yaz_srw_term(o, ptr, (*terms)+i, client_data, ns);
 725         }
 726     }
 727     else if (o->direction == ODR_ENCODE)
 728     {
 729         int i;
 730         for (i = 0; i < *num; i++)
 731         {
 732             xmlNodePtr rptr = xmlNewChild(pptr, 0, BAD_CAST "term", 0);
 733             yaz_srw_term(o, rptr, (*terms)+i, client_data, ns);
 734         }
 735     }
 736     return 0;
 737 }
 738
 739 int yaz_srw_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data,
 740                   void *client_data, const char *ns)
 741 {
 742     xmlNodePtr pptr = (xmlNodePtr) vptr;
 743     if (o->direction == ODR_DECODE)
 744     {
 745         Z_SRW_PDU **p = handler_data;
 746         xmlNodePtr method = pptr->children;
 747         char *neg_version;
 748
 749         while (method && method->type == XML_TEXT_NODE)
 750             method = method->next;
 751
 752         if (!method)
 753             return -1;
 754         if (method->type != XML_ELEMENT_NODE)
 755             return -1;
 756
 757         *p = yaz_srw_get_core_v_2_0(o);
 758
 759         if (!xmlStrcmp(method->name, BAD_CAST "searchRetrieveRequest"))
 760         {
 761             xmlNodePtr ptr = method->children;
 762             Z_SRW_searchRetrieveRequest *req;
 763             char *recordPacking = 0;
 764             char *recordXMLEscaping = 0;
 765
 766             (*p)->which = Z_SRW_searchRetrieve_request;
 767             req = (*p)->u.request = (Z_SRW_searchRetrieveRequest *)
 768                 odr_malloc(o, sizeof(*req));
 769             req->queryType = "cql";
 770             req->query = 0;
 771             req->sort_type = Z_SRW_sort_type_none;
 772             req->sort.none = 0;
 773             req->startRecord = 0;
 774             req->maximumRecords = 0;
 775             req->recordSchema = 0;
 776             req->recordPacking = 0;
 777             req->packing = 0;
 778             req->recordXPath = 0;
 779             req->resultSetTTL = 0;
 780             req->stylesheet = 0;
 781             req->database = 0;
 782
 783             for (; ptr; ptr = ptr->next)
 784             {
 785                 if (match_xsd_string(ptr, "version", o,
 786                                      &(*p)->srw_version))
 787                     ;
 788                 else if (match_xsd_string(ptr, "queryType", o,
 789                                           &req->queryType))
 790                     ;
 791                 else if (match_xsd_string(ptr, "query", o,
 792                                           &req->query))
 793                     ;
 794                 else if (match_xsd_string(ptr, "pQuery", o,
 795                                           &req->query))
 796                     req->queryType = "pqf";
 797                 else if (match_xsd_string(ptr, "xQuery", o,
 798                                           &req->query))
 799                     req->queryType = "xcql";
 800                 else if (match_xsd_integer(ptr, "startRecord", o,
 801                                            &req->startRecord))
 802                     ;
 803                 else if (match_xsd_integer(ptr, "maximumRecords", o,
 804                                            &req->maximumRecords))
 805                     ;
 806                 else if (match_xsd_string(ptr, "recordPacking", o,
 807                                           &recordPacking))
 808                     ;
 809                 else if (match_xsd_string(ptr, "recordXMLEscaping", o,
 810                                           &recordXMLEscaping))
 811                     ;
 812                 else if (match_xsd_string(ptr, "recordSchema", o,
 813                                           &req->recordSchema))
 814                     ;
 815                 else if (match_xsd_string(ptr, "recordXPath", o,
 816                                           &req->recordXPath))
 817                     ;
 818                 else if (match_xsd_integer(ptr, "resultSetTTL", o,
 819                                            &req->resultSetTTL))
 820                     ;
 821                 else if (match_xsd_string(ptr, "sortKeys", o,
 822                                           &req->sort.sortKeys))
 823                     req->sort_type = Z_SRW_sort_type_sort;
 824                 else if (match_xsd_string(ptr, "stylesheet", o,
 825                                           &req->stylesheet))
 826                     ;
 827                 else
 828                     match_xsd_string(ptr, "database", o, &req->database);
 829             }
 830             if (!req->query)
 831             {
 832                 /* should put proper diagnostic here */
 833                 return -1;
 834             }
 835             if (!strcmp((*p)->srw_version, "2.0"))
 836             {
 837                 req->recordPacking = recordXMLEscaping;
 838                 req->packing = recordPacking;
 839             }
 840             else
 841             {
 842                 req->recordPacking = recordPacking;
 843             }
 844         }
 845         else if (!xmlStrcmp(method->name, BAD_CAST "searchRetrieveResponse"))
 846         {
 847             xmlNodePtr ptr = method->children;
 848             Z_SRW_searchRetrieveResponse *res;
 849
 850             (*p)->which = Z_SRW_searchRetrieve_response;
 851             res = (*p)->u.response = (Z_SRW_searchRetrieveResponse *)
 852                 odr_malloc(o, sizeof(*res));
 853
 854             res->numberOfRecords = 0;
 855             res->resultSetId = 0;
 856             res->resultSetIdleTime = 0;
 857             res->records = 0;
 858             res->num_records = 0;
 859             res->diagnostics = 0;
 860             res->num_diagnostics = 0;
 861             res->nextRecordPosition = 0;
 862             res->facetList = 0;
 863             res->suggestions = 0;
 864
 865             for (; ptr; ptr = ptr->next)
 866             {
 867                 if (match_xsd_string(ptr, "version", o,
 868                                      &(*p)->srw_version))
 869                     ;
 870                 else if (match_xsd_XML_n(ptr, "extraResponseData", o,
 871                                          &(*p)->extraResponseData_buf,
 872                                          &(*p)->extraResponseData_len))
 873                     ;
 874                 else if (match_xsd_integer(ptr, "numberOfRecords", o,
 875                                            &res->numberOfRecords))
 876                     ;
 877                 else if (match_xsd_string(ptr, "resultSetId", o,
 878                                           &res->resultSetId))
 879                     ;
 880                 else if (match_xsd_integer(ptr, "resultSetIdleTime", o,
 881                                            &res->resultSetIdleTime))
 882                     ;
 883                 else if (match_xsd_integer(ptr, "resultSetTTL", o,
 884                                            &res->resultSetIdleTime))
 885                     ;
 886                 else if (match_element(ptr, "records"))
 887                     yaz_srw_records(o, ptr, &res->records,
 888                                     &res->extra_records,
 889                                     &res->num_records, client_data, 0);
 890                 else if (match_xsd_integer(ptr, "nextRecordPosition", o,
 891                                            &res->nextRecordPosition))
 892                     ;
 893                 else if (match_element(ptr, "diagnostics"))
 894                     yaz_srw_diagnostics(o, ptr, &res->diagnostics,
 895                                         &res->num_diagnostics,
 896                                         client_data, ns);
 897                 else if (match_element(ptr, "facet_analysis"))
 898                     yaz_sru_proxy_decode_facets(o, ptr, &res->facetList);
 899             }
 900         }
 901         else if (!xmlStrcmp(method->name, BAD_CAST "explainRequest"))
 902         {
 903             Z_SRW_explainRequest *req;
 904             xmlNodePtr ptr = method->children;
 905
 906             (*p)->which = Z_SRW_explain_request;
 907             req = (*p)->u.explain_request = (Z_SRW_explainRequest *)
 908                 odr_malloc(o, sizeof(*req));
 909             req->recordPacking = 0;
 910             req->packing = 0;
 911             req->database = 0;
 912             req->stylesheet = 0;
 913             for (; ptr; ptr = ptr->next)
 914             {
 915                 if (match_xsd_string(ptr, "version", o,
 916                                      &(*p)->srw_version))
 917                     ;
 918                 else if (match_xsd_XML_n(ptr, "extraResponseData", o,
 919                                          &(*p)->extraResponseData_buf,
 920                                          &(*p)->extraResponseData_len))
 921                     ;
 922                 else if (match_xsd_string(ptr, "stylesheet", o,
 923                                           &req->stylesheet))
 924                     ;
 925                 else if (match_xsd_string(ptr, "recordPacking", o,
 926                                           &req->recordPacking))
 927                     ;
 928                 else
 929                     match_xsd_string(ptr, "database", o, &req->database);
 930             }
 931         }
 932         else if (!xmlStrcmp(method->name, BAD_CAST "explainResponse"))
 933         {
 934             Z_SRW_explainResponse *res;
 935             xmlNodePtr ptr = method->children;
 936
 937             (*p)->which = Z_SRW_explain_response;
 938             res = (*p)->u.explain_response = (Z_SRW_explainResponse*)
 939                 odr_malloc(o, sizeof(*res));
 940             res->diagnostics = 0;
 941             res->num_diagnostics = 0;
 942             res->record.recordSchema = 0;
 943             res->record.recordData_buf = 0;
 944             res->record.recordData_len = 0;
 945             res->record.recordPosition = 0;
 946
 947             for (; ptr; ptr = ptr->next)
 948             {
 949                 if (match_xsd_string(ptr, "version", o,
 950                                      &(*p)->srw_version))
 951                     ;
 952                 else if (match_xsd_XML_n(ptr, "extraResponseData", o,
 953                                          &(*p)->extraResponseData_buf,
 954                                          &(*p)->extraResponseData_len))
 955                     ;
 956                 else if (match_element(ptr, "record"))
 957                     yaz_srw_record(o, ptr, &res->record, &res->extra_record,
 958                                    client_data, 0);
 959                 else if (match_element(ptr, "diagnostics"))
 960                     yaz_srw_diagnostics(o, ptr, &res->diagnostics,
 961                                         &res->num_diagnostics,
 962                                         client_data, ns);
 963                 ;
 964             }
 965         }
 966         else if (!xmlStrcmp(method->name, BAD_CAST "scanRequest"))
 967         {
 968             Z_SRW_scanRequest *req;
 969             xmlNodePtr ptr = method->children;
 970
 971             (*p)->which = Z_SRW_scan_request;
 972             req = (*p)->u.scan_request = (Z_SRW_scanRequest *)
 973                 odr_malloc(o, sizeof(*req));
 974             req->queryType = "cql";
 975             req->scanClause = 0;
 976             req->responsePosition = 0;
 977             req->maximumTerms = 0;
 978             req->stylesheet = 0;
 979             req->database = 0;
 980
 981             for (; ptr; ptr = ptr->next)
 982             {
 983                 if (match_xsd_string(ptr, "version", o,
 984                                      &(*p)->srw_version))
 985                     ;
 986                 else if (match_xsd_XML_n(ptr, "extraResponseData", o,
 987                                          &(*p)->extraResponseData_buf,
 988                                          &(*p)->extraResponseData_len))
 989                     ;
 990                 else if (match_xsd_string(ptr, "scanClause", o,
 991                                           &req->scanClause))
 992                     ;
 993                 else if (match_xsd_string(ptr, "pScanClause", o,
 994                                           &req->scanClause))
 995                 {
 996                     req->queryType = "pqf";
 997                 }
 998                 else if (match_xsd_integer(ptr, "responsePosition", o,
 999                                            &req->responsePosition))
1000                     ;
1001                 else if (match_xsd_integer(ptr, "maximumTerms", o,
1002                                            &req->maximumTerms))
1003                     ;
1004                 else if (match_xsd_string(ptr, "stylesheet", o,
1005                                           &req->stylesheet))
1006                     ;
1007                 else
1008                     match_xsd_string(ptr, "database", o, &req->database);
1009             }
1010         }
1011         else if (!xmlStrcmp(method->name, BAD_CAST "scanResponse"))
1012         {
1013             Z_SRW_scanResponse *res;
1014             xmlNodePtr ptr = method->children;
1015
1016             (*p)->which = Z_SRW_scan_response;
1017             res = (*p)->u.scan_response = (Z_SRW_scanResponse *)
1018                 odr_malloc(o, sizeof(*res));
1019             res->terms = 0;
1020             res->num_terms = 0;
1021             res->diagnostics = 0;
1022             res->num_diagnostics = 0;
1023
1024             for (; ptr; ptr = ptr->next)
1025             {
1026                 if (match_xsd_string(ptr, "version", o,
1027                                      &(*p)->srw_version))
1028                     ;
1029                 else if (match_xsd_XML_n(ptr, "extraResponseData", o,
1030                                          &(*p)->extraResponseData_buf,
1031                                          &(*p)->extraResponseData_len))
1032                     ;
1033                 else if (match_element(ptr, "terms"))
1034                     yaz_srw_terms(o, ptr, &res->terms,
1035                                   &res->num_terms, client_data,
1036                                   ns);
1037                 else if (match_element(ptr, "diagnostics"))
1038                     yaz_srw_diagnostics(o, ptr, &res->diagnostics,
1039                                         &res->num_diagnostics,
1040                                         client_data, ns);
1041             }
1042         }
1043         else
1044         {
1045             *p = 0;
1046             return -1;
1047         }
1048         neg_version = yaz_negotiate_sru_version((*p)->srw_version);
1049         if (neg_version)
1050             (*p)->srw_version = neg_version;
1051     }
1052     else if (o->direction == ODR_ENCODE)
1053     {
1054         Z_SRW_PDU **p = handler_data;
1055         xmlNsPtr ns_srw;
1056         xmlNodePtr ptr = 0;
1057         int version2 = !(*p)->srw_version ||
1058             strcmp((*p)->srw_version, "2.") > 0;
1059         if ((*p)->which == Z_SRW_searchRetrieve_request)
1060         {
1061             Z_SRW_searchRetrieveRequest *req = (*p)->u.request;
1062             const char *queryType = req->queryType;
1063             if (version2)
1064                 ns = "http://docs.oasis-open.org/ns/search-ws/sruRequest";
1065             ptr = xmlNewChild(pptr, 0, BAD_CAST "searchRetrieveRequest", 0);
1066             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1067             xmlSetNs(ptr, ns_srw);
1068
1069             if (!version2)
1070                 add_xsd_string(ptr, "version", (*p)->srw_version);
1071
1072             if (version2)
1073             {
1074                 if (queryType)
1075                     add_xsd_string(ptr, "queryType", queryType);
1076                 add_xsd_string(ptr, "query", req->query);
1077             }
1078             else
1079             {
1080                 if (!queryType || !strcmp(queryType, "cql"))
1081                     add_xsd_string(ptr, "query", req->query);
1082                 else if (!strcmp(queryType, "xcql"))
1083                     add_xsd_string(ptr, "xQuery", req->query);
1084                 else if (!strcmp(queryType, "pqf"))
1085                     add_xsd_string(ptr, "pQuery", req->query);
1086             }
1087             add_xsd_integer(ptr, "startRecord", req->startRecord);
1088             add_xsd_integer(ptr, "maximumRecords", req->maximumRecords);
1089             if (version2)
1090             {
1091                 add_xsd_string(ptr, "recordXMLEscaping", req->recordPacking);
1092                 add_xsd_string(ptr, "recordPacking", req->packing);
1093             }
1094             else
1095                 add_xsd_string(ptr, "recordPacking", req->recordPacking);
1096             add_xsd_string(ptr, "recordSchema", req->recordSchema);
1097             add_xsd_string(ptr, "recordXPath", req->recordXPath);
1098             add_xsd_integer(ptr, "resultSetTTL", req->resultSetTTL);
1099             switch (req->sort_type)
1100             {
1101             case Z_SRW_sort_type_none:
1102                 break;
1103             case Z_SRW_sort_type_sort:
1104                 add_xsd_string(ptr, "sortKeys", req->sort.sortKeys);
1105                 break;
1106             case Z_SRW_sort_type_xSort:
1107                 add_xsd_string(ptr, "xSortKeys", req->sort.xSortKeys);
1108                 break;
1109             }
1110             add_xsd_string(ptr, "stylesheet", req->stylesheet);
1111             add_xsd_string(ptr, "database", req->database);
1112         }
1113         else if ((*p)->which == Z_SRW_searchRetrieve_response)
1114         {
1115             Z_SRW_searchRetrieveResponse *res = (*p)->u.response;
1116             if (version2)
1117                 ns = "http://docs.oasis-open.org/ns/search-ws/sruResponse";
1118             ptr = xmlNewChild(pptr, 0, BAD_CAST "searchRetrieveResponse", 0);
1119             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1120             xmlSetNs(ptr, ns_srw);
1121
1122             if (!version2)
1123                 add_xsd_string(ptr, "version", (*p)->srw_version);
1124             add_xsd_integer(ptr, "numberOfRecords", res->numberOfRecords);
1125             add_xsd_string(ptr, "resultSetId", res->resultSetId);
1126             add_xsd_integer(ptr,
1127                             version2 ? "resultSetTTL" : "resultSetIdleTime" ,
1128                             res->resultSetIdleTime);
1129             if (res->num_records)
1130             {
1131                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "records", 0);
1132                 yaz_srw_records(o, rptr, &res->records, &res->extra_records,
1133                                 &res->num_records,
1134                                 client_data, version2);
1135             }
1136             add_xsd_integer(ptr, "nextRecordPosition",
1137                             res->nextRecordPosition);
1138             if (res->num_diagnostics)
1139             {
1140                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "diagnostics",
1141                                               0);
1142                 yaz_srw_diagnostics(o, rptr, &res->diagnostics,
1143                                     &res->num_diagnostics, client_data, ns);
1144             }
1145         }
1146         else if ((*p)->which == Z_SRW_explain_request)
1147         {
1148             Z_SRW_explainRequest *req = (*p)->u.explain_request;
1149             ptr = xmlNewChild(pptr, 0, BAD_CAST "explainRequest", 0);
1150             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1151             xmlSetNs(ptr, ns_srw);
1152
1153             if (!version2)
1154                 add_xsd_string(ptr, "version", (*p)->srw_version);
1155             if (version2)
1156             {
1157                 add_xsd_string(ptr, "recordXMLEscaping", req->recordPacking);
1158                 add_xsd_string(ptr, "recordPacking", req->packing);
1159             }
1160             else
1161                 add_xsd_string(ptr, "recordPacking", req->recordPacking);
1162             add_xsd_string(ptr, "stylesheet", req->stylesheet);
1163             add_xsd_string(ptr, "database", req->database);
1164         }
1165         else if ((*p)->which == Z_SRW_explain_response)
1166         {
1167             Z_SRW_explainResponse *res = (*p)->u.explain_response;
1168             ptr = xmlNewChild(pptr, 0, BAD_CAST "explainResponse", 0);
1169             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1170             xmlSetNs(ptr, ns_srw);
1171
1172             add_xsd_string(ptr, "version", (*p)->srw_version);
1173             if (1)
1174             {
1175                 xmlNodePtr ptr1 = xmlNewChild(ptr, 0, BAD_CAST "record", 0);
1176                 yaz_srw_record(o, ptr1, &res->record, &res->extra_record,
1177                                client_data, version2);
1178             }
1179             if (res->num_diagnostics)
1180             {
1181                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "diagnostics",
1182                                               0);
1183                 yaz_srw_diagnostics(o, rptr, &res->diagnostics,
1184                                     &res->num_diagnostics, client_data, ns);
1185             }
1186         }
1187         else if ((*p)->which == Z_SRW_scan_request)
1188         {
1189             Z_SRW_scanRequest *req = (*p)->u.scan_request;
1190             const char *queryType = req->queryType;
1191             if (version2)
1192                 ns = "http://docs.oasis-open.org/ns/search-ws/scan";
1193             ptr = xmlNewChild(pptr, 0, BAD_CAST "scanRequest", 0);
1194             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1195             xmlSetNs(ptr, ns_srw);
1196
1197             if (!version2)
1198                 add_xsd_string(ptr, "version", (*p)->srw_version);
1199
1200             if (version2)
1201             {
1202                 if (queryType && strcmp(queryType, "cql"))
1203                     add_xsd_string(ptr, "queryType", queryType);
1204                 add_xsd_string(ptr, "scanClause", req->scanClause);
1205             }
1206             else
1207             {
1208                 if (!queryType || !strcmp(queryType, "cql"))
1209                     add_xsd_string(ptr, "scanClause", req->scanClause);
1210                 else if (!strcmp(queryType, "pqf"))
1211                     add_xsd_string(ptr, "pScanClause", req->scanClause);
1212             }
1213             add_xsd_integer(ptr, "responsePosition", req->responsePosition);
1214             add_xsd_integer(ptr, "maximumTerms", req->maximumTerms);
1215             add_xsd_string(ptr, "stylesheet", req->stylesheet);
1216             add_xsd_string(ptr, "database", req->database);
1217         }
1218         else if ((*p)->which == Z_SRW_scan_response)
1219         {
1220             Z_SRW_scanResponse *res = (*p)->u.scan_response;
1221             if (version2)
1222                 ns = "http://docs.oasis-open.org/ns/search-ws/scan";
1223             ptr = xmlNewChild(pptr, 0, BAD_CAST "scanResponse", 0);
1224             ns_srw = xmlNewNs(ptr, BAD_CAST ns, BAD_CAST "zs");
1225             xmlSetNs(ptr, ns_srw);
1226
1227             if (!version2)
1228                 add_xsd_string(ptr, "version", (*p)->srw_version);
1229
1230             if (res->num_terms)
1231             {
1232                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "terms", 0);
1233                 yaz_srw_terms(o, rptr, &res->terms, &res->num_terms,
1234                               client_data, ns);
1235             }
1236             if (res->num_diagnostics)
1237             {
1238                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "diagnostics",
1239                                               0);
1240                 yaz_srw_diagnostics(o, rptr, &res->diagnostics,
1241                                     &res->num_diagnostics, client_data, ns);
1242             }
1243         }
1244         else
1245             return -1;
1246         if (ptr && (*p)->extraResponseData_len)
1247             add_XML_n(ptr, "extraResponseData",
1248                       (*p)->extraResponseData_buf,
1249                       (*p)->extraResponseData_len, ns_srw);
1250
1251
1252     }
1253     return 0;
1254 }
1255
1256 int yaz_ucp_codec(ODR o, void * vptr, Z_SRW_PDU **handler_data,
1257                   void *client_data, const char *ns_ucp_str)
1258 {
1259     xmlNodePtr pptr = (xmlNodePtr) vptr;
1260     const char *ns_srw_str = YAZ_XMLNS_SRU_v1_1;
1261     if (o->direction == ODR_DECODE)
1262     {
1263         Z_SRW_PDU **p = handler_data;
1264         xmlNodePtr method = pptr->children;
1265
1266         while (method && method->type == XML_TEXT_NODE)
1267             method = method->next;
1268
1269         if (!method)
1270             return -1;
1271         if (method->type != XML_ELEMENT_NODE)
1272             return -1;
1273
1274         *p = yaz_srw_get_core_v_2_0(o);
1275
1276         if (!xmlStrcmp(method->name, BAD_CAST "updateRequest"))
1277         {
1278             xmlNodePtr ptr = method->children;
1279             Z_SRW_updateRequest *req;
1280             char *oper = 0;
1281
1282             (*p)->which = Z_SRW_update_request;
1283             req = (*p)->u.update_request = (Z_SRW_updateRequest *)
1284                 odr_malloc(o, sizeof(*req));
1285             req->database = 0;
1286             req->operation = 0;
1287             req->recordId = 0;
1288             req->recordVersions = 0;
1289             req->num_recordVersions = 0;
1290             req->record = 0;
1291             req->extra_record = 0;
1292             req->extraRequestData_buf = 0;
1293             req->extraRequestData_len = 0;
1294             req->stylesheet = 0;
1295
1296             for (; ptr; ptr = ptr->next)
1297             {
1298                 if (match_xsd_string(ptr, "version", o,
1299                                      &(*p)->srw_version))
1300                     ;
1301                 else if (match_xsd_string(ptr, "action", o,
1302                                           &oper)){
1303                     if (oper)
1304                     {
1305                         if (!strcmp(oper, "info:srw/action/1/delete"))
1306                             req->operation = "delete";
1307                         else if (!strcmp(oper,"info:srw/action/1/replace" ))
1308                             req->operation = "replace";
1309                         else if (!strcmp(oper, "info:srw/action/1/create"))
1310                             req->operation = "insert";
1311                     }
1312                 }
1313                 else if (match_xsd_string(ptr, "recordIdentifier", o,
1314                                           &req->recordId))
1315                     ;
1316                 else if (match_element(ptr, "recordVersions" ) )
1317                     yaz_srw_versions( o, ptr, &req->recordVersions,
1318                                       &req->num_recordVersions, client_data,
1319                                       ns_ucp_str);
1320                 else if (match_element(ptr, "record"))
1321                 {
1322                     req->record = yaz_srw_get_record(o);
1323                     yaz_srw_record(o, ptr, req->record, &req->extra_record,
1324                                    client_data, 0);
1325                 }
1326                 else if (match_xsd_string(ptr, "stylesheet", o,
1327                                           &req->stylesheet))
1328                     ;
1329                 else
1330                     match_xsd_string(ptr, "database", o, &req->database);
1331             }
1332         }
1333         else if (!xmlStrcmp(method->name, BAD_CAST "updateResponse"))
1334         {
1335             xmlNodePtr ptr = method->children;
1336             Z_SRW_updateResponse *res;
1337
1338             (*p)->which = Z_SRW_update_response;
1339             res = (*p)->u.update_response = (Z_SRW_updateResponse *)
1340                 odr_malloc(o, sizeof(*res));
1341
1342             res->operationStatus = 0;
1343             res->recordId = 0;
1344             res->recordVersions = 0;
1345             res->num_recordVersions = 0;
1346             res->diagnostics = 0;
1347             res->num_diagnostics = 0;
1348             res->record = 0;
1349             res->extra_record = 0;
1350             res->extraResponseData_buf = 0;
1351             res->extraResponseData_len = 0;
1352
1353             for (; ptr; ptr = ptr->next)
1354             {
1355                 if (match_xsd_string(ptr, "version", o,
1356                                      &(*p)->srw_version))
1357                     ;
1358                 else if (match_xsd_string(ptr, "operationStatus", o,
1359                                           &res->operationStatus ))
1360                     ;
1361                 else if (match_xsd_string(ptr, "recordIdentifier", o,
1362                                           &res->recordId))
1363                     ;
1364                 else if (match_element(ptr, "recordVersions" ))
1365                     yaz_srw_versions(o, ptr, &res->recordVersions,
1366                                      &res->num_recordVersions,
1367                                      client_data, ns_ucp_str);
1368                 else if (match_element(ptr, "record"))
1369                 {
1370                     res->record = yaz_srw_get_record(o);
1371                     yaz_srw_record(o, ptr, res->record, &res->extra_record,
1372                                    client_data, 0);
1373                 }
1374                 else if (match_element(ptr, "diagnostics"))
1375                     yaz_srw_diagnostics(o, ptr, &res->diagnostics,
1376                                         &res->num_diagnostics,
1377                                         client_data, ns_ucp_str);
1378             }
1379         }
1380         else if (!xmlStrcmp(method->name, BAD_CAST "explainUpdateRequest"))
1381         {
1382         }
1383         else if (!xmlStrcmp(method->name, BAD_CAST "explainUpdateResponse"))
1384         {
1385         }
1386         else
1387         {
1388             *p = 0;
1389             return -1;
1390         }
1391     }
1392     else if (o->direction == ODR_ENCODE)
1393     {
1394         Z_SRW_PDU **p = handler_data;
1395         xmlNsPtr ns_ucp, ns_srw;
1396
1397         if ((*p)->which == Z_SRW_update_request)
1398         {
1399             Z_SRW_updateRequest *req = (*p)->u.update_request;
1400             xmlNodePtr ptr = xmlNewChild(pptr, 0, BAD_CAST "updateRequest", 0);
1401             ns_ucp = xmlNewNs(ptr, BAD_CAST ns_ucp_str, BAD_CAST "zu");
1402             xmlSetNs(ptr, ns_ucp);
1403             ns_srw = xmlNewNs(ptr, BAD_CAST ns_srw_str, BAD_CAST "zs");
1404
1405             add_xsd_string_ns(ptr, "version", (*p)->srw_version, ns_srw);
1406             add_xsd_string(ptr, "action", req->operation);
1407             add_xsd_string(ptr, "recordIdentifier", req->recordId );
1408             if (req->recordVersions)
1409                 yaz_srw_versions( o, ptr, &req->recordVersions,
1410                                   &req->num_recordVersions,
1411                                   client_data, ns_ucp_str);
1412             if (req->record && req->record->recordData_len)
1413             {
1414                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "record", 0);
1415                 xmlSetNs(rptr, ns_srw);
1416                 yaz_srw_record(o, rptr, req->record, &req->extra_record,
1417                                client_data, 0);
1418             }
1419             if (req->extraRequestData_len)
1420             {
1421                 add_XML_n(ptr, "extraRequestData",
1422                           req->extraRequestData_buf,
1423                           req->extraRequestData_len, ns_srw);
1424             }
1425             add_xsd_string(ptr, "stylesheet", req->stylesheet);
1426             add_xsd_string(ptr, "database", req->database);
1427         }
1428         else if ((*p)->which == Z_SRW_update_response)
1429         {
1430             Z_SRW_updateResponse *res = (*p)->u.update_response;
1431             xmlNodePtr ptr = xmlNewChild(pptr, 0, (xmlChar *)
1432                                          "updateResponse", 0);
1433             ns_ucp = xmlNewNs(ptr, BAD_CAST ns_ucp_str, BAD_CAST "zu");
1434             xmlSetNs(ptr, ns_ucp);
1435             ns_srw = xmlNewNs(ptr, BAD_CAST ns_srw_str, BAD_CAST "zs");
1436
1437             add_xsd_string_ns(ptr, "version", (*p)->srw_version, ns_srw);
1438             add_xsd_string(ptr, "operationStatus", res->operationStatus );
1439             add_xsd_string(ptr, "recordIdentifier", res->recordId );
1440             if (res->recordVersions)
1441                 yaz_srw_versions(o, ptr, &res->recordVersions,
1442                                  &res->num_recordVersions,
1443                                  client_data, ns_ucp_str);
1444             if (res->record && res->record->recordData_len)
1445             {
1446                 xmlNodePtr rptr = xmlNewChild(ptr, 0, BAD_CAST "record", 0);
1447                 xmlSetNs(rptr, ns_srw);
1448                 yaz_srw_record(o, rptr, res->record, &res->extra_record,
1449                                client_data, 0);
1450             }
1451             if (res->num_diagnostics)
1452             {
1453                 xmlNsPtr ns_diag =
1454                     xmlNewNs(pptr, BAD_CAST YAZ_XMLNS_DIAG_v1_1,
1455                              BAD_CAST "diag" );
1456
1457                 xmlNodePtr rptr = xmlNewChild(ptr, ns_diag, BAD_CAST "diagnostics", 0);
1458                 yaz_srw_diagnostics(o, rptr, &res->diagnostics,
1459                                     &res->num_diagnostics, client_data,
1460                                     ns_ucp_str);
1461             }
1462             if (res->extraResponseData_len)
1463                 add_XML_n(ptr, "extraResponseData",
1464                           res->extraResponseData_buf,
1465                           res->extraResponseData_len, ns_srw);
1466         }
1467         else
1468             return -1;
1469     }
1470     return 0;
1471 }
1472
1473 #endif
1474
1475
1476 /*
1477  * Local variables:
1478  * c-basic-offset: 4
1479  * c-file-style: "Stroustrup"
1480  * indent-tabs-mode: nil
1481  * End:
1482  * vim: shiftwidth=4 tabstop=8 expandtab
1483  */
1484