src/srw.c

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