Dont assume error if fgets returns NULL
[yaz-moved-to-github.git] / client / client.c
1 /* This file is part of the YAZ toolkit.
2  * Copyright (C) 1995-2009 Index Data
3  * See the file LICENSE for details.
4  */
5 /** \file client.c
6  *  \brief yaz-client program
7  */
8
9 #include <stdio.h>
10 #include <stdlib.h>
11 #include <assert.h>
12 #include <time.h>
13 #include <ctype.h>
14 #ifndef WIN32
15 #include <signal.h>
16 #endif
17 #if HAVE_SYS_TYPES_H
18 #include <sys/types.h>
19 #endif
20 #if HAVE_LOCALE_H
21 #include <locale.h>
22 #endif
23 #if HAVE_LANGINFO_H
24 #include <langinfo.h>
25 #endif
26 #if HAVE_UNISTD_H
27 #include <unistd.h>
28 #endif
29 #if HAVE_SYS_STAT_H
30 #include <sys/stat.h>
31 #endif
32 #if HAVE_SYS_TIME_H
33 #include <sys/time.h>
34 #endif
35
36 #ifdef WIN32
37 #include <sys/stat.h>
38 #include <io.h>
39 #include <windows.h>
40 #define S_ISREG(x) (x & _S_IFREG)
41 #define S_ISDIR(x) (x & _S_IFDIR)
42 #endif
43
44 #include <yaz/yaz-util.h>
45
46 #include <yaz/comstack.h>
47
48 #include <yaz/oid_db.h>
49 #define NO_OID 1
50 #include <yaz/proto.h>
51 #include <yaz/marcdisp.h>
52 #include <yaz/diagbib1.h>
53 #include <yaz/otherinfo.h>
54 #include <yaz/charneg.h>
55 #include <yaz/query-charset.h>
56
57 #include <yaz/pquery.h>
58 #include <yaz/sortspec.h>
59
60 #include <yaz/ill.h>
61 #include <yaz/srw.h>
62 #include <yaz/yaz-ccl.h>
63 #include <yaz/cql.h>
64 #include <yaz/log.h>
65
66 #if HAVE_READLINE_READLINE_H
67 #include <readline/readline.h>
68 #endif
69 #if HAVE_READLINE_HISTORY_H
70 #include <readline/history.h>
71 #endif
72
73
74 #include "admin.h"
75 #include "tabcomplete.h"
76 #include "fhistory.h"
77
78 #define C_PROMPT "Z> "
79
80 static file_history_t file_history = 0;
81
82 static char sru_method[10] = "soap";
83 static char sru_version[10] = "1.2";
84 static char *codeset = 0;               /* character set for output */
85 static int hex_dump = 0;
86 static char *dump_file_prefix = 0;
87 static ODR out, in, print;              /* encoding and decoding streams */
88 #if YAZ_HAVE_XML2
89 static ODR srw_sr_odr_out = 0;
90 static Z_SRW_PDU *srw_sr = 0;
91 #endif
92 static FILE *apdu_file = 0;
93 static FILE *ber_file = 0;
94 static COMSTACK conn = 0;               /* our z-association */
95 static Z_IdAuthentication *auth = 0;    /* our current auth definition */
96 char *databaseNames[128];
97 int num_databaseNames = 0;
98 static Z_External *record_last = 0;
99 static int setnumber = -1;              /* current result set number */
100 static int smallSetUpperBound = 0;
101 static int largeSetLowerBound = 1;
102 static int mediumSetPresentNumber = 0;
103 static Z_ElementSetNames *elementSetNames = 0;
104 static int setno = 1;                   /* current set offset */
105 static enum oid_proto protocol = PROTO_Z3950;      /* current app protocol */
106 #define RECORDSYNTAX_MAX 20
107 static char *recordsyntax_list[RECORDSYNTAX_MAX];
108 static int recordsyntax_size = 0;
109
110 static char *record_schema = 0;
111 static int sent_close = 0;
112 static NMEM session_mem = NULL;         /* memory handle for init-response */
113 static Z_InitResponse *session_initResponse = 0;   /* session parameters */
114 static char last_scan_line[512] = "0";
115 static char last_scan_query[512] = "0";
116 static char ccl_fields[512] = "default.bib";
117 /* ### How can I set this path to use wherever YAZ is installed? */
118 static char cql_fields[512] = "/usr/local/share/yaz/etc/pqf.properties";
119 static char *esPackageName = 0;
120 static char *yazProxy = 0;
121 static int kilobytes = 1024;
122 static char *negotiationCharset = 0;
123 static int  negotiationCharsetRecords = 1;
124 static int  negotiationCharsetVersion = 3;
125 static char *outputCharset = 0;
126 static char *marcCharset = 0;
127 static char *queryCharset = 0;
128 static char* yazLang = 0;
129
130 static char last_cmd[32] = "?";
131 static FILE *marc_file = 0;
132 static char *refid = NULL;
133 static char *last_open_command = NULL;
134 static int auto_reconnect = 0;
135 static int auto_wait = 1;
136 static Odr_bitmask z3950_options;
137 static int z3950_version = 3;
138 static int scan_stepSize = 0;
139 static int scan_position = 1;
140 static int scan_size = 20;
141 static char cur_host[200];
142 static int last_hit_count = 0;
143
144 typedef enum {
145     QueryType_Prefix,
146     QueryType_CCL,
147     QueryType_CCL2RPN,
148     QueryType_CQL,
149     QueryType_CQL2RPN
150 } QueryType;
151
152 static QueryType queryType = QueryType_Prefix;
153
154 static CCL_bibset bibset;               /* CCL bibset handle */
155 static cql_transform_t cqltrans = 0; /* CQL context-set handle */
156
157 #if HAVE_READLINE_COMPLETION_OVER
158
159 #else
160 /* readline doesn't have this var. Define it ourselves. */
161 int rl_attempted_completion_over = 0;
162 #endif
163
164 #define maxOtherInfosSupported 10
165 struct eoi {
166     Odr_oid oid[OID_SIZE];
167     char* value;
168 } extraOtherInfos[maxOtherInfosSupported];
169
170 void process_cmd_line(char* line);
171 #if HAVE_READLINE_READLINE_H
172 char **readline_completer(char *text, int start, int end);
173 #endif
174 static char *command_generator(const char *text, int state);
175 int cmd_register_tab(const char* arg);
176 int cmd_querycharset(const char *arg);
177
178 static void close_session(void);
179
180 static void marc_file_write(const char *buf, size_t sz);
181
182 ODR getODROutputStream(void)
183 {
184     return out;
185 }
186
187 const char* query_type_as_string(QueryType q)
188 {
189     switch (q) {
190     case QueryType_Prefix: return "prefix (RPN sent to server)";
191     case QueryType_CCL: return "CCL (CCL sent to server) ";
192     case QueryType_CCL2RPN: return "CCL -> RPN (RPN sent to server)";
193     case QueryType_CQL: return "CQL (CQL sent to server)";
194     case QueryType_CQL2RPN: return "CQL -> RPN (RPN sent to server)";
195     default:
196         return "unknown Query type internal yaz-client error";
197     }
198 }
199
200 static void do_hex_dump(const char* buf, size_t len)
201 {
202     if (hex_dump)
203     {
204         size_t i;
205         int x;
206         for (i = 0; i < len ; i = i+16 )
207         {
208             printf(" %4.4ld ", (long) i);
209             for(x=0 ; i+x<len && x<16; ++x)
210             {
211                 printf("%2.2X ",(unsigned int)((unsigned char)buf[i+x]));
212             }
213             printf("\n");
214         }
215     }
216     if (dump_file_prefix)
217     {
218         static int no = 0;
219         if (++no < 1000 && strlen(dump_file_prefix) < 500)
220         {
221             char fname[1024];
222             FILE *of;
223             sprintf(fname, "%s.%03d.raw", dump_file_prefix, no);
224             of = fopen(fname, "wb");
225
226             if (fwrite(buf, 1, len, of) != len)
227             {
228                 printf("write failed for %s", fname);
229             }
230             if (fclose(of))
231             {
232                 printf("close failed for %s", fname);
233             }
234         }
235     }
236 }
237
238 void add_otherInfos(Z_APDU *a)
239 {
240     Z_OtherInformation **oi;
241     int i;
242
243     yaz_oi_APDU(a, &oi);
244     for(i=0; i<maxOtherInfosSupported; ++i)
245     {
246         if (oid_oidlen(extraOtherInfos[i].oid) > 0)
247             yaz_oi_set_string_oid(oi, out, extraOtherInfos[i].oid,
248                                      1, extraOtherInfos[i].value);
249     }
250 }
251
252 int send_apdu(Z_APDU *a)
253 {
254     char *buf;
255     int len;
256
257     add_otherInfos(a);
258
259     if (apdu_file)
260     {
261         z_APDU(print, &a, 0, 0);
262         odr_reset(print);
263     }
264     if (!z_APDU(out, &a, 0, 0))
265     {
266         odr_perror(out, "Encoding APDU");
267         close_session();
268         return 0;
269     }
270     buf = odr_getbuf(out, &len, 0);
271     if (ber_file)
272         odr_dumpBER(ber_file, buf, len);
273     /* printf ("sending APDU of size %d\n", len); */
274     do_hex_dump(buf, len);
275     if (cs_put(conn, buf, len) < 0)
276     {
277         fprintf(stderr, "cs_put: %s", cs_errmsg(cs_errno(conn)));
278         close_session();
279         return 0;
280     }
281     odr_reset(out); /* release the APDU structure  */
282     return 1;
283 }
284
285 static void print_stringn(const unsigned char *buf, size_t len)
286 {
287     size_t i;
288     for (i = 0; i<len; i++)
289         if ((buf[i] <= 126 && buf[i] >= 32) || strchr("\n\r\t\f", buf[i]))
290             printf("%c", buf[i]);
291         else
292             printf("\\X%02X", buf[i]);
293 }
294
295 static void print_refid(Z_ReferenceId *id)
296 {
297     if (id)
298     {
299         printf("Reference Id: ");
300         print_stringn(id->buf, id->len);
301         printf("\n");
302     }
303 }
304
305 static Z_ReferenceId *set_refid(ODR out)
306 {
307     Z_ReferenceId *id;
308     if (!refid)
309         return 0;
310     id = (Z_ReferenceId *) odr_malloc(out, sizeof(*id));
311     id->size = id->len = strlen(refid);
312     id->buf = (unsigned char *) odr_malloc(out, id->len);
313     memcpy(id->buf, refid, id->len);
314     return id;
315 }
316
317 /* INIT SERVICE ------------------------------- */
318
319 static void send_initRequest(const char* type_and_host)
320 {
321     Z_APDU *apdu = zget_APDU(out, Z_APDU_initRequest);
322     Z_InitRequest *req = apdu->u.initRequest;
323     int i;
324
325     req->options = &z3950_options;
326
327     ODR_MASK_ZERO(req->protocolVersion);
328     for (i = 0; i<z3950_version; i++)
329         ODR_MASK_SET(req->protocolVersion, i);
330
331     *req->maximumRecordSize = 1024*kilobytes;
332     *req->preferredMessageSize = 1024*kilobytes;
333
334     req->idAuthentication = auth;
335
336     req->referenceId = set_refid(out);
337
338     if (yazProxy && type_and_host)
339     {
340         yaz_oi_set_string_oid(&req->otherInfo, out, yaz_oid_userinfo_proxy,
341                               1, type_and_host);
342     }
343
344     if (negotiationCharset || yazLang) {
345         Z_OtherInformation **p;
346         Z_OtherInformationUnit *p0;
347
348         yaz_oi_APDU(apdu, &p);
349
350         if ((p0=yaz_oi_update(p, out, NULL, 0, 0)))
351         {
352             ODR_MASK_SET(req->options, Z_Options_negotiationModel);
353
354             p0->which = Z_OtherInfo_externallyDefinedInfo;
355             p0->information.externallyDefinedInfo =
356                 yaz_set_proposal_charneg_list(out, ",",
357                                               negotiationCharset,
358                                               yazLang,
359                                               negotiationCharsetRecords);
360         }
361     }
362     if (send_apdu(apdu))
363         printf("Sent initrequest.\n");
364 }
365
366
367 /* These two are used only from process_initResponse() */
368 static void render_initUserInfo(Z_OtherInformation *ui1);
369 static void render_diag(Z_DiagnosticFormat *diag);
370
371 static void pr_opt(const char *opt, void *clientData)
372 {
373     printf(" %s", opt);
374 }
375
376 static int process_initResponse(Z_InitResponse *res)
377 {
378     int ver = 0;
379     /* save session parameters for later use */
380     session_mem = odr_extract_mem(in);
381     session_initResponse = res;
382
383     for (ver = 0; ver < 8; ver++)
384         if (!ODR_MASK_GET(res->protocolVersion, ver))
385             break;
386
387     if (!*res->result)
388         printf("Connection rejected by v%d target.\n", ver);
389     else
390         printf("Connection accepted by v%d target.\n", ver);
391     if (res->implementationId)
392         printf("ID     : %s\n", res->implementationId);
393     if (res->implementationName)
394         printf("Name   : %s\n", res->implementationName);
395     if (res->implementationVersion)
396         printf("Version: %s\n", res->implementationVersion);
397     if (res->userInformationField)
398     {
399         Z_External *uif = res->userInformationField;
400         if (uif->which == Z_External_userInfo1) {
401             render_initUserInfo(uif->u.userInfo1);
402         } else {
403             printf("UserInformationfield:\n");
404             if (!z_External(print, (Z_External**)&uif, 0, 0))
405             {
406                 odr_perror(print, "Printing userinfo\n");
407                 odr_reset(print);
408             }
409             if (uif->which == Z_External_octet) {
410                 printf("Guessing visiblestring:\n");
411                 printf("'%.*s'\n", uif->u.octet_aligned->len,
412                        uif->u.octet_aligned->buf);
413             }
414             else if (uif->which == Z_External_single)
415             {
416                 Odr_any *sat = uif->u.single_ASN1_type;
417                 if (!oid_oidcmp(uif->direct_reference,
418                                 yaz_oid_userinfo_oclc_userinfo))
419                 {
420                     Z_OCLC_UserInformation *oclc_ui;
421                     ODR decode = odr_createmem(ODR_DECODE);
422                     odr_setbuf(decode, (char *) sat->buf, sat->len, 0);
423                     if (!z_OCLC_UserInformation(decode, &oclc_ui, 0, 0))
424                         printf("Bad OCLC UserInformation:\n");
425                     else
426                         printf("OCLC UserInformation:\n");
427                     if (!z_OCLC_UserInformation(print, &oclc_ui, 0, 0))
428                         printf("Bad OCLC UserInformation spec\n");
429                     odr_destroy(decode);
430                 }
431                 else
432                 {
433                     /* Peek at any private Init-diagnostic APDUs */
434                     printf("### NAUGHTY: External is '%.*s'\n",
435                            sat->len, sat->buf);
436                 }
437             }
438             odr_reset(print);
439         }
440     }
441     printf("Options:");
442     yaz_init_opt_decode(res->options, pr_opt, 0);
443     printf("\n");
444
445     if (ODR_MASK_GET(res->options, Z_Options_namedResultSets))
446         setnumber = 0;
447
448     if (ODR_MASK_GET(res->options, Z_Options_negotiationModel)) {
449
450         Z_CharSetandLanguageNegotiation *p =
451                 yaz_get_charneg_record(res->otherInfo);
452
453         if (p)
454         {
455             char *charset=NULL, *lang=NULL;
456             int selected;
457
458             yaz_get_response_charneg(session_mem, p, &charset, &lang,
459                                      &selected);
460
461             printf("Accepted character set : %s\n", charset ? charset:"none");
462             printf("Accepted code language : %s\n", lang ? lang:"none");
463             printf("Accepted records in ...: %d\n", selected );
464
465             if (outputCharset && charset)
466             {
467                 printf("Converting between %s and %s\n",
468                        outputCharset, charset);
469                 odr_set_charset(out, charset, outputCharset);
470                 odr_set_charset(in, outputCharset, charset);
471                 cmd_querycharset(charset);
472             }
473             else
474             {
475                 odr_set_charset(out, 0, 0);
476                 odr_set_charset(in, 0, 0);
477             }
478         }
479     }
480     fflush(stdout);
481     return 0;
482 }
483
484
485 static void render_initUserInfo(Z_OtherInformation *ui1) {
486     int i;
487     printf("Init response contains %d otherInfo unit%s:\n",
488            ui1->num_elements, ui1->num_elements == 1 ? "" : "s");
489
490     for (i = 0; i < ui1->num_elements; i++) {
491         Z_OtherInformationUnit *unit = ui1->list[i];
492         printf("  %d: otherInfo unit contains ", i+1);
493         if (unit->which == Z_OtherInfo_externallyDefinedInfo &&
494             unit->information.externallyDefinedInfo &&
495             unit->information.externallyDefinedInfo->which ==
496             Z_External_diag1) {
497             render_diag(unit->information.externallyDefinedInfo->u.diag1);
498         }
499         else if (unit->which != Z_OtherInfo_externallyDefinedInfo)
500         {
501             printf("unsupported otherInfo unit->which = %d\n", unit->which);
502         }
503         else
504         {
505             printf("unsupported otherInfo unit external %d\n",
506                    unit->information.externallyDefinedInfo ?
507                    unit->information.externallyDefinedInfo->which : -2);
508         }
509     }
510 }
511
512
513 /* ### should this share code with display_diagrecs()? */
514 static void render_diag(Z_DiagnosticFormat *diag) {
515     int i;
516
517     printf("%d diagnostic%s:\n", diag->num, diag->num == 1 ? "" : "s");
518     for (i = 0; i < diag->num; i++) {
519         Z_DiagnosticFormat_s *ds = diag->elements[i];
520         printf("    %d: ", i+1);
521         switch (ds->which) {
522         case Z_DiagnosticFormat_s_defaultDiagRec: {
523             Z_DefaultDiagFormat *dd = ds->u.defaultDiagRec;
524             /* ### should check `dd->diagnosticSetId' */
525             printf("code=%d (%s)", *dd->condition,
526                    diagbib1_str(*dd->condition));
527             /* Both types of addinfo are the same, so use type-pun */
528             if (dd->u.v2Addinfo != 0)
529                 printf(",\n\taddinfo='%s'", dd->u.v2Addinfo);
530             break;
531         }
532         case Z_DiagnosticFormat_s_explicitDiagnostic:
533             printf("Explicit diagnostic (not supported)");
534             break;
535         default:
536             printf("Unrecognised diagnostic type %d", ds->which);
537             break;
538         }
539
540         if (ds->message != 0)
541             printf(", message='%s'", ds->message);
542         printf("\n");
543     }
544 }
545
546
547 static int set_base(const char *arg)
548 {
549     int i;
550     const char *cp;
551
552     for (i = 0; i<num_databaseNames; i++)
553         xfree(databaseNames[i]);
554     num_databaseNames = 0;
555     while (1)
556     {
557         char *cp1;
558         if (!(cp = strchr(arg, ' ')))
559             cp = arg + strlen(arg);
560         if (cp - arg < 1)
561             break;
562         databaseNames[num_databaseNames] = (char *)xmalloc(1 + cp - arg);
563         memcpy(databaseNames[num_databaseNames], arg, cp - arg);
564         databaseNames[num_databaseNames][cp - arg] = '\0';
565
566         for (cp1 = databaseNames[num_databaseNames]; *cp1 ; cp1++)
567             if (*cp1 == '+')
568                 *cp1 = ' ';
569         num_databaseNames++;
570
571         if (!*cp)
572             break;
573         arg = cp+1;
574     }
575     if (num_databaseNames == 0)
576     {
577         num_databaseNames = 1;
578         databaseNames[0] = xstrdup("");
579     }
580     return 1;
581 }
582
583 static int parse_cmd_doc(const char **arg, ODR out, char **buf, int *len)
584 {
585     const char *sep;
586     while (**arg && strchr(" \t\n\r\f", **arg))
587         (*arg)++;
588     if (**arg == '\0')
589     {
590         return 0;
591     }
592     else if ((*arg)[0] == '<')
593     {
594         size_t fsize;
595         FILE *inf;
596         const char *fname;
597         const char *arg_start = ++(*arg);
598
599         while (**arg != '\0' && **arg != ' ')
600             (*arg)++;
601
602         fname = odr_strdupn(out, arg_start, *arg - arg_start);
603
604         inf = fopen(fname, "rb");
605         if (!inf)
606         {
607             printf("Couldn't open %s\n", fname);
608             return 0;
609         }
610         if (fseek(inf, 0L, SEEK_END) == -1)
611         {
612             printf("Couldn't seek in %s\n", fname);
613             fclose(inf);
614             return 0;
615         }
616         fsize = ftell(inf);
617         if (fseek(inf, 0L, SEEK_SET) == -1)
618         {
619             printf("Couldn't seek in %s\n", fname);
620             fclose(inf);
621             return 0;
622         }
623         *len = fsize;
624         *buf = (char *) odr_malloc(out, fsize+1);
625         (*buf)[fsize] = '\0';
626         if (fread(*buf, 1, fsize, inf) != fsize)
627         {
628             printf("Unable to read %s\n", fname);
629             fclose(inf);
630             return 0;
631         }
632         fclose(inf);
633     }
634     else if ((*arg)[0] == '\"' && (sep=strchr(*arg+1, '"')))
635     {
636         (*arg)++;
637         *len = sep - *arg;
638         *buf = odr_strdupn(out, *arg, *len);
639         (*arg) = sep+1;
640     }
641     else
642     {
643         const char *arg_start = *arg;
644
645         while (**arg != '\0' && **arg != ' ')
646             (*arg)++;
647
648         *len = *arg - arg_start;
649         *buf = odr_strdupn(out, arg_start, *len);
650     }
651     return 1;
652 }
653
654 static int cmd_base(const char *arg)
655 {
656     if (!*arg)
657     {
658         printf("Usage: base <database> <database> ...\n");
659         return 0;
660     }
661     return set_base(arg);
662 }
663
664 void cmd_open_remember_last_open_command(const char* arg, char* new_open_command)
665 {
666     if(last_open_command != arg)
667     {
668         if(last_open_command) xfree(last_open_command);
669         last_open_command = xstrdup(new_open_command);
670     }
671 }
672
673 int session_connect(const char *arg)
674 {
675     void *add;
676     char type_and_host[101];
677     const char *basep = 0;
678     if (conn)
679     {
680         cs_close(conn);
681         conn = 0;
682     }
683     if (session_mem)
684     {
685         nmem_destroy(session_mem);
686         session_mem = NULL;
687         session_initResponse = 0;
688     }
689     cs_get_host_args(arg, &basep);
690
691     strncpy(type_and_host, arg, sizeof(type_and_host)-1);
692     type_and_host[sizeof(type_and_host)-1] = '\0';
693
694     cmd_open_remember_last_open_command(arg, type_and_host);
695
696     if (yazProxy)
697         conn = cs_create_host(yazProxy, 1, &add);
698     else
699         conn = cs_create_host(arg, 1, &add);
700     if (!conn)
701     {
702         printf("Could not resolve address %s\n", arg);
703         return 0;
704     }
705 #if YAZ_HAVE_XML2
706 #else
707     if (conn->protocol == PROTO_HTTP)
708     {
709         printf("SRW/HTTP not enabled in this YAZ\n");
710         cs_close(conn);
711         conn = 0;
712         return 0;
713     }
714 #endif
715     protocol = conn->protocol;
716     if (conn->protocol == PROTO_HTTP)
717         set_base("");
718     else
719         set_base("Default");
720     printf("Connecting...");
721     fflush(stdout);
722     if (cs_connect(conn, add) < 0)
723     {
724         printf("error = %s\n", cs_strerror(conn));
725         cs_close(conn);
726         conn = 0;
727         return 0;
728     }
729     printf("OK.\n");
730     cs_print_session_info(conn);
731     if (basep && *basep)
732         set_base (basep);
733     if (protocol == PROTO_Z3950)
734     {
735         send_initRequest(type_and_host);
736         return 2;
737     }
738     return 0;
739 }
740
741 int cmd_open(const char *arg)
742 {
743     int r;
744     if (arg)
745     {
746         strncpy(cur_host, arg, sizeof(cur_host)-1);
747         cur_host[sizeof(cur_host)-1] = 0;
748     }
749     r = session_connect(cur_host);
750     if (conn && conn->protocol == PROTO_HTTP)
751         queryType = QueryType_CQL;
752     return r;
753 }
754
755 void try_reconnect(void)
756 {
757     char* open_command;
758
759     if(!( auto_reconnect && last_open_command) ) return ;
760
761     open_command = (char *) xmalloc(strlen(last_open_command)+6);
762     strcpy(open_command, "open ");
763
764     strcat(open_command, last_open_command);
765
766     process_cmd_line(open_command);
767
768     xfree(open_command);
769 }
770
771 int cmd_authentication(const char *arg)
772 {
773     static Z_IdAuthentication au;
774     static char user[40], group[40], pass[40];
775     static Z_IdPass idPass;
776     int r;
777
778     if (!*arg)
779     {
780         printf("Auth field set to null\n");
781         auth = 0;
782         return 1;
783     }
784     r = sscanf(arg, "%39s %39s %39s", user, group, pass);
785     if (r == 0)
786     {
787         printf("Authentication set to null\n");
788         auth = 0;
789     }
790     if (r == 1)
791     {
792         auth = &au;
793         if (!strcmp(user, "-")) {
794             au.which = Z_IdAuthentication_anonymous;
795             printf("Authentication set to Anonymous\n");
796         } else {
797             au.which = Z_IdAuthentication_open;
798             au.u.open = user;
799             printf("Authentication set to Open (%s)\n", user);
800         }
801     }
802     if (r == 2)
803     {
804         auth = &au;
805         au.which = Z_IdAuthentication_idPass;
806         au.u.idPass = &idPass;
807         idPass.groupId = NULL;
808         idPass.userId = !strcmp(user, "-") ? 0 : user;
809         idPass.password = !strcmp(group, "-") ? 0 : group;
810         printf("Authentication set to User (%s), Pass (%s)\n", user, group);
811     }
812     if (r == 3)
813     {
814         auth = &au;
815         au.which = Z_IdAuthentication_idPass;
816         au.u.idPass = &idPass;
817         idPass.groupId = group;
818         idPass.userId = user;
819         idPass.password = pass;
820         printf("Authentication set to User (%s), Group (%s), Pass (%s)\n",
821                user, group, pass);
822     }
823     return 1;
824 }
825
826 /* SEARCH SERVICE ------------------------------ */
827 static void display_record(Z_External *r);
828
829 static void print_record(const unsigned char *buf, size_t len)
830 {
831     size_t i = len;
832     print_stringn(buf, len);
833     /* add newline if not already added ... */
834     if (i <= 0 || buf[i-1] != '\n')
835         printf("\n");
836 }
837
838 static void display_record(Z_External *r)
839 {
840     const Odr_oid *oid = r->direct_reference;
841
842     record_last = r;
843     /*
844      * Tell the user what we got.
845      */
846     if (oid)
847     {
848         oid_class oclass;
849         char oid_name_buf[OID_STR_MAX];
850         const char *oid_name
851             =  yaz_oid_to_string_buf(oid, &oclass, oid_name_buf);
852         printf("Record type: ");
853         if (oid_name)
854             printf("%s\n", oid_name);
855     }
856     /* Check if this is a known, ASN.1 type tucked away in an octet string */
857     if (r->which == Z_External_octet)
858     {
859         Z_ext_typeent *type = z_ext_getentbyref(r->direct_reference);
860         char *rr;
861
862         if (type)
863         {
864             /*
865              * Call the given decoder to process the record.
866              */
867             odr_setbuf(in, (char*)r->u.octet_aligned->buf,
868                 r->u.octet_aligned->len, 0);
869             if (!(*type->fun)(in, &rr, 0, 0))
870             {
871                 odr_perror(in, "Decoding constructed record.");
872                 fprintf(stdout, "[Near %ld]\n", (long) odr_offset(in));
873                 fprintf(stdout, "Packet dump:\n---------\n");
874                 odr_dumpBER(stdout, (char*)r->u.octet_aligned->buf,
875                             r->u.octet_aligned->len);
876                 fprintf(stdout, "---------\n");
877
878                 /* note just ignores the error ant print the bytes form the octet_aligned later */
879             } else {
880                 /*
881                  * Note: we throw away the original, BER-encoded record here.
882                  * Do something else with it if you want to keep it.
883                  */
884                 r->u.sutrs = (Z_SUTRS *) rr; /* we don't actually check the type here. */
885                 r->which = type->what;
886             }
887         }
888     }
889     if (oid && !oid_oidcmp(oid, yaz_oid_recsyn_soif))
890     {
891         print_record((const unsigned char *) r->u.octet_aligned->buf,
892                      r->u.octet_aligned->len);
893         marc_file_write((const char *) r->u.octet_aligned->buf,
894                         r->u.octet_aligned->len);
895     }
896     else if (oid && r->which == Z_External_octet)
897     {
898         const char *octet_buf = (char*)r->u.octet_aligned->buf;
899         if (oid && (!oid_oidcmp(oid, yaz_oid_recsyn_xml)
900                     || !oid_oidcmp(oid, yaz_oid_recsyn_xml)
901                     || !oid_oidcmp(oid, yaz_oid_recsyn_html)))
902         {
903             print_record((const unsigned char *) octet_buf,
904                          r->u.octet_aligned->len);
905         }
906         else if (oid && !oid_oidcmp(oid, yaz_oid_recsyn_postscript))
907         {
908             int size = r->u.octet_aligned->len;
909             if (size > 100)
910                 size = 100;
911             print_record((const unsigned char *) octet_buf, size);
912         }
913         else
914         {
915             if (oid && yaz_oid_is_iso2709(oid))
916             {
917                 const char *result;
918                 size_t rlen;
919                 yaz_iconv_t cd = 0;
920                 yaz_marc_t mt = yaz_marc_create();
921                 const char *from = 0;
922
923                 if (marcCharset && !strcmp(marcCharset, "auto"))
924                 {
925                     if (!oid_oidcmp(oid, yaz_oid_recsyn_usmarc))
926                     {
927                         if (octet_buf[9] == 'a')
928                             from = "UTF-8";
929                         else
930                             from = "MARC-8";
931                     }
932                     else
933                         from = "ISO-8859-1";
934                 }
935                 else if (marcCharset)
936                     from = marcCharset;
937                 if (outputCharset && from)
938                 {
939                     cd = yaz_iconv_open(outputCharset, from);
940                     printf("convert from %s to %s", from,
941                             outputCharset);
942                     if (!cd)
943                         printf(" unsupported\n");
944                     else
945                     {
946                         yaz_marc_iconv(mt, cd);
947                         printf("\n");
948                     }
949                 }
950
951                 if (yaz_marc_decode_buf(mt, octet_buf, r->u.octet_aligned->len,
952                                         &result, &rlen)> 0)
953                 {
954                     if (fwrite(result, rlen, 1, stdout) != 1)
955                     {
956                         printf("write to stdout failed\n");
957                     }
958                 }
959                 else
960                 {
961                     printf("bad MARC. Dumping as it is:\n");
962                     print_record((const unsigned char*) octet_buf,
963                                   r->u.octet_aligned->len);
964                 }
965                 yaz_marc_destroy(mt);
966                 if (cd)
967                     yaz_iconv_close(cd);
968             }
969             else
970             {
971                 print_record((const unsigned char*) octet_buf,
972                              r->u.octet_aligned->len);
973             }
974         }
975         marc_file_write(octet_buf, r->u.octet_aligned->len);
976     }
977     else if (oid && !oid_oidcmp(oid, yaz_oid_recsyn_sutrs))
978     {
979         if (r->which != Z_External_sutrs)
980         {
981             printf("Expecting single SUTRS type for SUTRS.\n");
982             return;
983         }
984         print_record(r->u.sutrs->buf, r->u.sutrs->len);
985         marc_file_write((const char *) r->u.sutrs->buf, r->u.sutrs->len);
986     }
987     else if (oid && !oid_oidcmp(oid, yaz_oid_recsyn_grs_1))
988     {
989         WRBUF w;
990         if (r->which != Z_External_grs1)
991         {
992             printf("Expecting single GRS type for GRS.\n");
993             return;
994         }
995         w = wrbuf_alloc();
996         yaz_display_grs1(w, r->u.grs1, 0);
997         puts(wrbuf_cstr(w));
998         wrbuf_destroy(w);
999     }
1000     else if (oid && !oid_oidcmp(oid, yaz_oid_recsyn_opac))
1001     {
1002         int i;
1003         if (r->u.opac->bibliographicRecord)
1004             display_record(r->u.opac->bibliographicRecord);
1005         for (i = 0; i<r->u.opac->num_holdingsData; i++)
1006         {
1007             Z_HoldingsRecord *h = r->u.opac->holdingsData[i];
1008             if (h->which == Z_HoldingsRecord_marcHoldingsRecord)
1009             {
1010                 printf("MARC holdings %d\n", i);
1011                 display_record(h->u.marcHoldingsRecord);
1012             }
1013             else if (h->which == Z_HoldingsRecord_holdingsAndCirc)
1014             {
1015                 int j;
1016
1017                 Z_HoldingsAndCircData *data = h->u.holdingsAndCirc;
1018
1019                 printf("Data holdings %d\n", i);
1020                 if (data->typeOfRecord)
1021                     printf("typeOfRecord: %s\n", data->typeOfRecord);
1022                 if (data->encodingLevel)
1023                     printf("encodingLevel: %s\n", data->encodingLevel);
1024                 if (data->receiptAcqStatus)
1025                     printf("receiptAcqStatus: %s\n", data->receiptAcqStatus);
1026                 if (data->generalRetention)
1027                     printf("generalRetention: %s\n", data->generalRetention);
1028                 if (data->completeness)
1029                     printf("completeness: %s\n", data->completeness);
1030                 if (data->dateOfReport)
1031                     printf("dateOfReport: %s\n", data->dateOfReport);
1032                 if (data->nucCode)
1033                     printf("nucCode: %s\n", data->nucCode);
1034                 if (data->localLocation)
1035                     printf("localLocation: %s\n", data->localLocation);
1036                 if (data->shelvingLocation)
1037                     printf("shelvingLocation: %s\n", data->shelvingLocation);
1038                 if (data->callNumber)
1039                     printf("callNumber: %s\n", data->callNumber);
1040                 if (data->shelvingData)
1041                     printf("shelvingData: %s\n", data->shelvingData);
1042                 if (data->copyNumber)
1043                     printf("copyNumber: %s\n", data->copyNumber);
1044                 if (data->publicNote)
1045                     printf("publicNote: %s\n", data->publicNote);
1046                 if (data->reproductionNote)
1047                     printf("reproductionNote: %s\n", data->reproductionNote);
1048                 if (data->termsUseRepro)
1049                     printf("termsUseRepro: %s\n", data->termsUseRepro);
1050                 if (data->enumAndChron)
1051                     printf("enumAndChron: %s\n", data->enumAndChron);
1052                 for (j = 0; j<data->num_volumes; j++)
1053                 {
1054                     printf("volume %d\n", j);
1055                     if (data->volumes[j]->enumeration)
1056                         printf(" enumeration: %s\n",
1057                                 data->volumes[j]->enumeration);
1058                     if (data->volumes[j]->chronology)
1059                         printf(" chronology: %s\n",
1060                                 data->volumes[j]->chronology);
1061                     if (data->volumes[j]->enumAndChron)
1062                         printf(" enumAndChron: %s\n",
1063                                 data->volumes[j]->enumAndChron);
1064                 }
1065                 for (j = 0; j<data->num_circulationData; j++)
1066                 {
1067                     printf("circulation %d\n", j);
1068                     if (data->circulationData[j]->availableNow)
1069                         printf(" availableNow: %d\n",
1070                                 *data->circulationData[j]->availableNow);
1071                     if (data->circulationData[j]->availablityDate)
1072                         printf(" availabiltyDate: %s\n",
1073                                 data->circulationData[j]->availablityDate);
1074                     if (data->circulationData[j]->availableThru)
1075                         printf(" availableThru: %s\n",
1076                                 data->circulationData[j]->availableThru);
1077                     if (data->circulationData[j]->restrictions)
1078                         printf(" restrictions: %s\n",
1079                                 data->circulationData[j]->restrictions);
1080                     if (data->circulationData[j]->itemId)
1081                         printf(" itemId: %s\n",
1082                                 data->circulationData[j]->itemId);
1083                     if (data->circulationData[j]->renewable)
1084                         printf(" renewable: %d\n",
1085                                 *data->circulationData[j]->renewable);
1086                     if (data->circulationData[j]->onHold)
1087                         printf(" onHold: %d\n",
1088                                 *data->circulationData[j]->onHold);
1089                     if (data->circulationData[j]->enumAndChron)
1090                         printf(" enumAndChron: %s\n",
1091                                 data->circulationData[j]->enumAndChron);
1092                     if (data->circulationData[j]->midspine)
1093                         printf(" midspine: %s\n",
1094                                 data->circulationData[j]->midspine);
1095                     if (data->circulationData[j]->temporaryLocation)
1096                         printf(" temporaryLocation: %s\n",
1097                                 data->circulationData[j]->temporaryLocation);
1098                 }
1099             }
1100         }
1101     }
1102     else
1103     {
1104         printf("Unknown record representation.\n");
1105         if (!z_External(print, &r, 0, 0))
1106         {
1107             odr_perror(print, "Printing external");
1108             odr_reset(print);
1109         }
1110     }
1111 }
1112
1113 static void display_diagrecs(Z_DiagRec **pp, int num)
1114 {
1115     int i;
1116     Z_DefaultDiagFormat *r;
1117
1118     printf("Diagnostic message(s) from database:\n");
1119     for (i = 0; i<num; i++)
1120     {
1121         Z_DiagRec *p = pp[i];
1122         if (p->which != Z_DiagRec_defaultFormat)
1123         {
1124             printf("Diagnostic record not in default format.\n");
1125             return;
1126         }
1127         else
1128             r = p->u.defaultFormat;
1129
1130         if (!r->diagnosticSetId)
1131             printf("Missing diagset\n");
1132         else
1133         {
1134             oid_class oclass;
1135             char diag_name_buf[OID_STR_MAX];
1136             const char *diag_name = 0;
1137             diag_name = yaz_oid_to_string_buf
1138                 (r->diagnosticSetId, &oclass, diag_name_buf);
1139             if (oid_oidcmp(r->diagnosticSetId, yaz_oid_diagset_bib_1))
1140                 printf("Unknown diagset: %s\n", diag_name);
1141         }
1142         printf("    [%d] %s", *r->condition, diagbib1_str(*r->condition));
1143         switch (r->which)
1144         {
1145         case Z_DefaultDiagFormat_v2Addinfo:
1146             printf(" -- v2 addinfo '%s'\n", r->u.v2Addinfo);
1147             break;
1148         case Z_DefaultDiagFormat_v3Addinfo:
1149             printf(" -- v3 addinfo '%s'\n", r->u.v3Addinfo);
1150             break;
1151         }
1152     }
1153 }
1154
1155
1156 static void display_nameplusrecord(Z_NamePlusRecord *p)
1157 {
1158     if (p->databaseName)
1159         printf("[%s]", p->databaseName);
1160     if (p->which == Z_NamePlusRecord_surrogateDiagnostic)
1161         display_diagrecs(&p->u.surrogateDiagnostic, 1);
1162     else if (p->which == Z_NamePlusRecord_databaseRecord)
1163         display_record(p->u.databaseRecord);
1164 }
1165
1166 static void display_records(Z_Records *p)
1167 {
1168     int i;
1169
1170     if (p->which == Z_Records_NSD)
1171     {
1172         Z_DiagRec dr, *dr_p = &dr;
1173         dr.which = Z_DiagRec_defaultFormat;
1174         dr.u.defaultFormat = p->u.nonSurrogateDiagnostic;
1175         display_diagrecs(&dr_p, 1);
1176     }
1177     else if (p->which == Z_Records_multipleNSD)
1178         display_diagrecs(p->u.multipleNonSurDiagnostics->diagRecs,
1179                           p->u.multipleNonSurDiagnostics->num_diagRecs);
1180     else
1181     {
1182         printf("Records: %d\n", p->u.databaseOrSurDiagnostics->num_records);
1183         for (i = 0; i < p->u.databaseOrSurDiagnostics->num_records; i++)
1184             display_nameplusrecord(p->u.databaseOrSurDiagnostics->records[i]);
1185     }
1186 }
1187
1188 static int send_deleteResultSetRequest(const char *arg)
1189 {
1190     char names[8][32];
1191     int i;
1192
1193     Z_APDU *apdu = zget_APDU(out, Z_APDU_deleteResultSetRequest);
1194     Z_DeleteResultSetRequest *req = apdu->u.deleteResultSetRequest;
1195
1196     req->referenceId = set_refid(out);
1197
1198     req->num_resultSetList =
1199         sscanf(arg, "%30s %30s %30s %30s %30s %30s %30s %30s",
1200                names[0], names[1], names[2], names[3],
1201                names[4], names[5], names[6], names[7]);
1202
1203     req->deleteFunction = (int *)
1204         odr_malloc(out, sizeof(*req->deleteFunction));
1205     if (req->num_resultSetList > 0)
1206     {
1207         *req->deleteFunction = Z_DeleteResultSetRequest_list;
1208         req->resultSetList = (char **)
1209             odr_malloc(out, sizeof(*req->resultSetList)*
1210                         req->num_resultSetList);
1211         for (i = 0; i<req->num_resultSetList; i++)
1212             req->resultSetList[i] = names[i];
1213     }
1214     else
1215     {
1216         *req->deleteFunction = Z_DeleteResultSetRequest_all;
1217         req->resultSetList = 0;
1218     }
1219
1220     send_apdu(apdu);
1221     printf("Sent deleteResultSetRequest.\n");
1222     return 2;
1223 }
1224
1225 #if YAZ_HAVE_XML2
1226 static int send_srw(Z_SRW_PDU *sr)
1227 {
1228     const char *charset = negotiationCharset;
1229     const char *host_port = cur_host;
1230     Z_GDU *gdu;
1231     char *path = 0;
1232
1233     path = (char *) odr_malloc(out, 2+strlen(databaseNames[0]));
1234     *path = '/';
1235     strcpy(path+1, databaseNames[0]);
1236
1237     gdu = z_get_HTTP_Request_host_path(out, host_port, path);
1238
1239     if (!yaz_matchstr(sru_method, "get"))
1240     {
1241         yaz_sru_get_encode(gdu->u.HTTP_Request, sr, out, charset);
1242     }
1243     else if (!yaz_matchstr(sru_method, "post"))
1244     {
1245         yaz_sru_post_encode(gdu->u.HTTP_Request, sr, out, charset);
1246     }
1247     else if (!yaz_matchstr(sru_method, "soap"))
1248     {
1249         yaz_sru_soap_encode(gdu->u.HTTP_Request, sr, out, charset);
1250     }
1251
1252     if (z_GDU(out, &gdu, 0, 0))
1253     {
1254         /* encode OK */
1255         char *buf_out;
1256         int len_out;
1257         int r;
1258         if (apdu_file)
1259         {
1260             if (!z_GDU(print, &gdu, 0, 0))
1261                 printf("Failed to print outgoing SRU package\n");
1262             odr_reset(print);
1263         }
1264         buf_out = odr_getbuf(out, &len_out, 0);
1265
1266         /* we don't odr_reset(out), since we may need the buffer again */
1267
1268         do_hex_dump(buf_out, len_out);
1269
1270         r = cs_put(conn, buf_out, len_out);
1271
1272         if (r >= 0)
1273             return 2;
1274     }
1275     return 0;
1276 }
1277 #endif
1278
1279 #if YAZ_HAVE_XML2
1280 static char *encode_SRW_term(ODR o, const char *q)
1281 {
1282     const char *in_charset = "ISO-8859-1";
1283     WRBUF w = wrbuf_alloc();
1284     yaz_iconv_t cd;
1285     char *res;
1286     if (outputCharset)
1287         in_charset = outputCharset;
1288     cd = yaz_iconv_open("UTF-8", in_charset);
1289     if (!cd)
1290     {
1291         wrbuf_destroy(w);
1292         return odr_strdup(o, q);
1293     }
1294     wrbuf_iconv_write(w, cd, q, strlen(q));
1295     if (wrbuf_len(w))
1296         res = odr_strdup(o, wrbuf_cstr(w));
1297     else
1298         res = odr_strdup(o, q);
1299     yaz_iconv_close(cd);
1300     wrbuf_destroy(w);
1301     return res;
1302 }
1303
1304
1305 static int send_SRW_scanRequest(const char *arg, int pos, int num)
1306 {
1307     Z_SRW_PDU *sr = 0;
1308
1309     /* regular requestse .. */
1310     sr = yaz_srw_get_pdu(out, Z_SRW_scan_request, sru_version);
1311
1312     switch(queryType)
1313     {
1314     case QueryType_CQL:
1315         sr->u.scan_request->query_type = Z_SRW_query_type_cql;
1316         sr->u.scan_request->scanClause.cql = encode_SRW_term(out, arg);
1317         break;
1318     case QueryType_Prefix:
1319         sr->u.scan_request->query_type = Z_SRW_query_type_pqf;
1320         sr->u.scan_request->scanClause.pqf = encode_SRW_term(out, arg);
1321         break;
1322     default:
1323         printf("Only CQL and PQF supported in SRW\n");
1324         return 0;
1325     }
1326     sr->u.scan_request->responsePosition = odr_intdup(out, pos);
1327     sr->u.scan_request->maximumTerms = odr_intdup(out, num);
1328     return send_srw(sr);
1329 }
1330
1331 static int send_SRW_searchRequest(const char *arg)
1332 {
1333     Z_SRW_PDU *sr = 0;
1334
1335     if (!srw_sr)
1336     {
1337         assert(srw_sr_odr_out == 0);
1338         srw_sr_odr_out = odr_createmem(ODR_ENCODE);
1339     }
1340     odr_reset(srw_sr_odr_out);
1341
1342     setno = 1;
1343
1344     /* save this for later .. when fetching individual records */
1345     srw_sr =  yaz_srw_get_pdu(srw_sr_odr_out, Z_SRW_searchRetrieve_request,
1346                               sru_version);
1347
1348     /* regular request .. */
1349     sr = yaz_srw_get_pdu(out, Z_SRW_searchRetrieve_request, sru_version);
1350
1351     switch(queryType)
1352     {
1353     case QueryType_CQL:
1354         srw_sr->u.request->query_type = Z_SRW_query_type_cql;
1355         srw_sr->u.request->query.cql = encode_SRW_term(srw_sr_odr_out, arg);
1356
1357         sr->u.request->query_type = Z_SRW_query_type_cql;
1358         sr->u.request->query.cql = encode_SRW_term(srw_sr_odr_out, arg);
1359         break;
1360     case QueryType_Prefix:
1361         srw_sr->u.request->query_type = Z_SRW_query_type_pqf;
1362         srw_sr->u.request->query.pqf = encode_SRW_term(srw_sr_odr_out, arg);
1363
1364         sr->u.request->query_type = Z_SRW_query_type_pqf;
1365         sr->u.request->query.pqf = encode_SRW_term(srw_sr_odr_out, arg);
1366         break;
1367     default:
1368         printf("Only CQL and PQF supported in SRW\n");
1369         return 0;
1370     }
1371     sr->u.request->maximumRecords = odr_intdup(out, 0);
1372
1373     if (record_schema)
1374         sr->u.request->recordSchema = record_schema;
1375     if (recordsyntax_size == 1 && !yaz_matchstr(recordsyntax_list[0], "xml"))
1376         sr->u.request->recordPacking = "xml";
1377     return send_srw(sr);
1378 }
1379 #endif
1380
1381 static void query_charset_convert(Z_RPNQuery *q)
1382 {
1383     if (queryCharset && outputCharset)
1384     {
1385         yaz_iconv_t cd = yaz_iconv_open(queryCharset, outputCharset);
1386         if (!cd)
1387         {
1388             printf("Conversion from %s to %s unsupported\n",
1389                    outputCharset, queryCharset);
1390             return;
1391         }
1392         yaz_query_charset_convert_rpnquery(q, out, cd);
1393         yaz_iconv_close(cd);
1394     }
1395 }
1396
1397 static int send_searchRequest(const char *arg)
1398 {
1399     Z_APDU *apdu = zget_APDU(out, Z_APDU_searchRequest);
1400     Z_SearchRequest *req = apdu->u.searchRequest;
1401     Z_Query query;
1402     struct ccl_rpn_node *rpn = NULL;
1403     int error, pos;
1404     char setstring[100];
1405     Z_RPNQuery *RPNquery;
1406     Odr_oct ccl_query;
1407     YAZ_PQF_Parser pqf_parser;
1408     Z_External *ext;
1409     QueryType myQueryType = queryType;
1410     char pqfbuf[512];
1411
1412     if (myQueryType == QueryType_CCL2RPN)
1413     {
1414         rpn = ccl_find_str(bibset, arg, &error, &pos);
1415         if (error)
1416         {
1417             printf("CCL ERROR: %s\n", ccl_err_msg(error));
1418             return 0;
1419         }
1420     } else if (myQueryType == QueryType_CQL2RPN) {
1421         /* ### All this code should be wrapped in a utility function */
1422         CQL_parser parser;
1423         struct cql_node *node;
1424         const char *addinfo;
1425         if (cqltrans == 0) {
1426             printf("Can't use CQL: no translation file.  Try set_cqlfile\n");
1427             return 0;
1428         }
1429         parser = cql_parser_create();
1430         if ((error = cql_parser_string(parser, arg)) != 0) {
1431             printf("Can't parse CQL: must be a syntax error\n");
1432             return 0;
1433         }
1434         node = cql_parser_result(parser);
1435         if ((error = cql_transform_buf(cqltrans, node, pqfbuf,
1436                                        sizeof pqfbuf)) != 0) {
1437             error = cql_transform_error(cqltrans, &addinfo);
1438             printf("Can't convert CQL to PQF: %s (addinfo=%s)\n",
1439                     cql_strerror(error), addinfo);
1440             return 0;
1441         }
1442         arg = pqfbuf;
1443         myQueryType = QueryType_Prefix;
1444     }
1445
1446     req->referenceId = set_refid(out);
1447     if (!strcmp(arg, "@big")) /* strictly for troublemaking */
1448     {
1449         static unsigned char big[2100];
1450         static Odr_oct bigo;
1451
1452         /* send a very big referenceid to test transport stack etc. */
1453         memset(big, 'A', 2100);
1454         bigo.len = bigo.size = 2100;
1455         bigo.buf = big;
1456         req->referenceId = &bigo;
1457     }
1458
1459     if (setnumber >= 0)
1460     {
1461         sprintf(setstring, "%d", ++setnumber);
1462         req->resultSetName = setstring;
1463     }
1464     *req->smallSetUpperBound = smallSetUpperBound;
1465     *req->largeSetLowerBound = largeSetLowerBound;
1466     *req->mediumSetPresentNumber = mediumSetPresentNumber;
1467     if (smallSetUpperBound > 0 || (largeSetLowerBound > 1 &&
1468         mediumSetPresentNumber > 0))
1469     {
1470         if (recordsyntax_size)
1471             req->preferredRecordSyntax =
1472                 yaz_string_to_oid_odr(yaz_oid_std(),
1473                                       CLASS_RECSYN, recordsyntax_list[0], out);
1474
1475         req->smallSetElementSetNames =
1476             req->mediumSetElementSetNames = elementSetNames;
1477     }
1478     req->num_databaseNames = num_databaseNames;
1479     req->databaseNames = databaseNames;
1480
1481     req->query = &query;
1482
1483     switch (myQueryType)
1484     {
1485     case QueryType_Prefix:
1486         query.which = Z_Query_type_1;
1487         pqf_parser = yaz_pqf_create();
1488         RPNquery = yaz_pqf_parse(pqf_parser, out, arg);
1489         if (!RPNquery)
1490         {
1491             const char *pqf_msg;
1492             size_t off;
1493             int code = yaz_pqf_error(pqf_parser, &pqf_msg, &off);
1494             int ioff = off;
1495             printf("%*s^\n", ioff+4, "");
1496             printf("Prefix query error: %s (code %d)\n", pqf_msg, code);
1497
1498             yaz_pqf_destroy(pqf_parser);
1499             return 0;
1500         }
1501         yaz_pqf_destroy(pqf_parser);
1502         query_charset_convert(RPNquery);
1503         query.u.type_1 = RPNquery;
1504         break;
1505     case QueryType_CCL:
1506         query.which = Z_Query_type_2;
1507         query.u.type_2 = &ccl_query;
1508         ccl_query.buf = (unsigned char*) arg;
1509         ccl_query.len = strlen(arg);
1510         break;
1511     case QueryType_CCL2RPN:
1512         query.which = Z_Query_type_1;
1513         RPNquery = ccl_rpn_query(out, rpn);
1514         if (!RPNquery)
1515         {
1516             printf("Couldn't convert from CCL to RPN\n");
1517             return 0;
1518         }
1519         query_charset_convert(RPNquery);
1520         query.u.type_1 = RPNquery;
1521         ccl_rpn_delete(rpn);
1522         break;
1523     case QueryType_CQL:
1524         query.which = Z_Query_type_104;
1525         ext = (Z_External *) odr_malloc(out, sizeof(*ext));
1526         ext->direct_reference = odr_getoidbystr(out, "1.2.840.10003.16.2");
1527         ext->indirect_reference = 0;
1528         ext->descriptor = 0;
1529         ext->which = Z_External_CQL;
1530         ext->u.cql = odr_strdup(out, arg);
1531         query.u.type_104 =  ext;
1532         break;
1533     default:
1534         printf("Unsupported query type\n");
1535         return 0;
1536     }
1537     if (send_apdu(apdu))
1538         printf("Sent searchRequest.\n");
1539     setno = 1;
1540     return 2;
1541 }
1542
1543 /* display Query Expression as part of searchResult-1 */
1544 static void display_queryExpression(const char *lead, Z_QueryExpression *qe)
1545 {
1546     if (!qe)
1547         return;
1548     printf(" %s=", lead);
1549     if (qe->which == Z_QueryExpression_term)
1550     {
1551         if (qe->u.term->queryTerm)
1552         {
1553             Z_Term *term = qe->u.term->queryTerm;
1554             switch (term->which)
1555             {
1556             case Z_Term_general:
1557                 printf("%.*s", term->u.general->len, term->u.general->buf);
1558                 break;
1559             case Z_Term_characterString:
1560                 printf("%s", term->u.characterString);
1561                 break;
1562             case Z_Term_numeric:
1563                 printf("%d", *term->u.numeric);
1564                 break;
1565             case Z_Term_null:
1566                 printf("null");
1567                 break;
1568             }
1569         }
1570     }
1571 }
1572
1573 /* see if we can find USR:SearchResult-1 */
1574 static void display_searchResult(Z_OtherInformation *o)
1575 {
1576     int i;
1577     if (!o)
1578         return ;
1579     for (i = 0; i < o->num_elements; i++)
1580     {
1581         if (o->list[i]->which == Z_OtherInfo_externallyDefinedInfo)
1582         {
1583             Z_External *ext = o->list[i]->information.externallyDefinedInfo;
1584
1585             if (ext->which == Z_External_searchResult1)
1586             {
1587                 int j;
1588                 Z_SearchInfoReport *sr = ext->u.searchResult1;
1589                 printf("SearchResult-1:");
1590                 for (j = 0; j < sr->num; j++)
1591                 {
1592                     if (j)
1593                         printf(",");
1594                     if (!sr->elements[j]->subqueryExpression)
1595                         printf("%d", j);
1596                     display_queryExpression("term",
1597                         sr->elements[j]->subqueryExpression);
1598                     display_queryExpression("interpretation",
1599                         sr->elements[j]->subqueryInterpretation);
1600                     display_queryExpression("recommendation",
1601                         sr->elements[j]->subqueryRecommendation);
1602                     if (sr->elements[j]->subqueryCount)
1603                         printf(" cnt=%d", *sr->elements[j]->subqueryCount);
1604                     if (sr->elements[j]->subqueryId)
1605                         printf(" id=%s ", sr->elements[j]->subqueryId);
1606                 }
1607                 printf("\n");
1608             }
1609         }
1610     }
1611 }
1612
1613 static int process_searchResponse(Z_SearchResponse *res)
1614 {
1615     printf("Received SearchResponse.\n");
1616     print_refid(res->referenceId);
1617     if (*res->searchStatus)
1618         printf("Search was a success.\n");
1619     else
1620         printf("Search was a bloomin' failure.\n");
1621     printf("Number of hits: %d", *res->resultCount);
1622     last_hit_count = *res->resultCount;
1623     if (setnumber >= 0)
1624         printf(", setno %d", setnumber);
1625     putchar('\n');
1626     if (res->resultSetStatus)
1627     {
1628         printf("Result Set Status: ");
1629         switch(*res->resultSetStatus)
1630         {
1631         case Z_SearchResponse_subset:
1632             printf("subset"); break;
1633         case Z_SearchResponse_interim:
1634             printf("interim"); break;
1635         case Z_SearchResponse_none:
1636             printf("none"); break;
1637         case Z_SearchResponse_estimate:
1638             printf("estimate"); break;
1639         default:
1640             printf("%d", *res->resultSetStatus);
1641         }
1642         putchar('\n');
1643     }
1644     display_searchResult(res->additionalSearchInfo);
1645     printf("records returned: %d\n",
1646            *res->numberOfRecordsReturned);
1647     setno += *res->numberOfRecordsReturned;
1648     if (res->records)
1649         display_records(res->records);
1650     return 0;
1651 }
1652
1653 static void print_level(int iLevel)
1654 {
1655     int i;
1656     for (i = 0; i < iLevel * 4; i++)
1657         printf(" ");
1658 }
1659
1660 static void print_int(int iLevel, const char *pTag, int *pInt)
1661 {
1662     if (pInt != NULL)
1663     {
1664         print_level(iLevel);
1665         printf("%s: %d\n", pTag, *pInt);
1666     }
1667 }
1668
1669 static void print_string(int iLevel, const char *pTag, const char *pString)
1670 {
1671     if (pString != NULL)
1672     {
1673         print_level(iLevel);
1674         printf("%s: %s\n", pTag, pString);
1675     }
1676 }
1677
1678 static void print_oid(int iLevel, const char *pTag, Odr_oid *pOid)
1679 {
1680     if (pOid != NULL)
1681     {
1682         Odr_oid *pInt = pOid;
1683
1684         print_level(iLevel);
1685         printf("%s:", pTag);
1686         for (; *pInt != -1; pInt++)
1687             printf(" %d", *pInt);
1688         printf("\n");
1689     }
1690 }
1691
1692 static void print_referenceId(int iLevel, Z_ReferenceId *referenceId)
1693 {
1694     if (referenceId != NULL)
1695     {
1696         int i;
1697
1698         print_level(iLevel);
1699         printf("Ref Id (%d, %d): ", referenceId->len, referenceId->size);
1700         for (i = 0; i < referenceId->len; i++)
1701             printf("%c", referenceId->buf[i]);
1702         printf("\n");
1703     }
1704 }
1705
1706 static void print_string_or_numeric(int iLevel, const char *pTag, Z_StringOrNumeric *pStringNumeric)
1707 {
1708     if (pStringNumeric != NULL)
1709     {
1710         switch (pStringNumeric->which)
1711         {
1712         case Z_StringOrNumeric_string:
1713             print_string(iLevel, pTag, pStringNumeric->u.string);
1714             break;
1715
1716         case Z_StringOrNumeric_numeric:
1717             print_int(iLevel, pTag, pStringNumeric->u.numeric);
1718             break;
1719
1720         default:
1721             print_level(iLevel);
1722             printf("%s: valid type for Z_StringOrNumeric\n", pTag);
1723             break;
1724         }
1725     }
1726 }
1727
1728 static void print_universe_report_duplicate(
1729     int iLevel,
1730     Z_UniverseReportDuplicate *pUniverseReportDuplicate)
1731 {
1732     if (pUniverseReportDuplicate != NULL)
1733     {
1734         print_level(iLevel);
1735         printf("Universe Report Duplicate: \n");
1736         iLevel++;
1737         print_string_or_numeric(iLevel, "Hit No",
1738                                 pUniverseReportDuplicate->hitno);
1739     }
1740 }
1741
1742 static void print_universe_report_hits(
1743     int iLevel,
1744     Z_UniverseReportHits *pUniverseReportHits)
1745 {
1746     if (pUniverseReportHits != NULL)
1747     {
1748         print_level(iLevel);
1749         printf("Universe Report Hits: \n");
1750         iLevel++;
1751         print_string_or_numeric(iLevel, "Database",
1752                                 pUniverseReportHits->database);
1753         print_string_or_numeric(iLevel, "Hits", pUniverseReportHits->hits);
1754     }
1755 }
1756
1757 static void print_universe_report(int iLevel, Z_UniverseReport *pUniverseReport)
1758 {
1759     if (pUniverseReport != NULL)
1760     {
1761         print_level(iLevel);
1762         printf("Universe Report: \n");
1763         iLevel++;
1764         print_int(iLevel, "Total Hits", pUniverseReport->totalHits);
1765         switch (pUniverseReport->which)
1766         {
1767         case Z_UniverseReport_databaseHits:
1768             print_universe_report_hits(iLevel,
1769                                        pUniverseReport->u.databaseHits);
1770             break;
1771
1772         case Z_UniverseReport_duplicate:
1773             print_universe_report_duplicate(iLevel,
1774                                             pUniverseReport->u.duplicate);
1775             break;
1776
1777         default:
1778             print_level(iLevel);
1779             printf("Type: %d\n", pUniverseReport->which);
1780             break;
1781         }
1782     }
1783 }
1784
1785 static void print_external(int iLevel, Z_External *pExternal)
1786 {
1787     if (pExternal != NULL)
1788     {
1789         print_level(iLevel);
1790         printf("External: \n");
1791         iLevel++;
1792         print_oid(iLevel, "Direct Reference", pExternal->direct_reference);
1793         print_int(iLevel, "InDirect Reference", pExternal->indirect_reference);
1794         print_string(iLevel, "Descriptor", pExternal->descriptor);
1795         switch (pExternal->which)
1796         {
1797         case Z_External_universeReport:
1798             print_universe_report(iLevel, pExternal->u.universeReport);
1799             break;
1800
1801         default:
1802             print_level(iLevel);
1803             printf("Type: %d\n", pExternal->which);
1804             break;
1805         }
1806     }
1807 }
1808
1809 static int process_resourceControlRequest(Z_ResourceControlRequest *req)
1810 {
1811     printf("Received ResourceControlRequest.\n");
1812     print_referenceId(1, req->referenceId);
1813     print_int(1, "Suspended Flag", req->suspendedFlag);
1814     print_int(1, "Partial Results Available", req->partialResultsAvailable);
1815     print_int(1, "Response Required", req->responseRequired);
1816     print_int(1, "Triggered Request Flag", req->triggeredRequestFlag);
1817     print_external(1, req->resourceReport);
1818     return 0;
1819 }
1820
1821 void process_ESResponse(Z_ExtendedServicesResponse *res)
1822 {
1823     printf("Status: ");
1824     switch (*res->operationStatus)
1825     {
1826     case Z_ExtendedServicesResponse_done:
1827         printf("done\n");
1828         break;
1829     case Z_ExtendedServicesResponse_accepted:
1830         printf("accepted\n");
1831         break;
1832     case Z_ExtendedServicesResponse_failure:
1833         printf("failure\n");
1834         display_diagrecs(res->diagnostics, res->num_diagnostics);
1835         break;
1836     default:
1837         printf("unknown\n");
1838     }
1839     if ( (*res->operationStatus != Z_ExtendedServicesResponse_failure) &&
1840         (res->num_diagnostics != 0) ) {
1841         display_diagrecs(res->diagnostics, res->num_diagnostics);
1842     }
1843     print_refid (res->referenceId);
1844     if (res->taskPackage &&
1845         res->taskPackage->which == Z_External_extendedService)
1846     {
1847         Z_TaskPackage *taskPackage = res->taskPackage->u.extendedService;
1848         Odr_oct *id = taskPackage->targetReference;
1849         Z_External *ext = taskPackage->taskSpecificParameters;
1850
1851         if (id)
1852         {
1853             printf("Target Reference: ");
1854             print_stringn (id->buf, id->len);
1855             printf("\n");
1856         }
1857         if (ext->which == Z_External_update)
1858         {
1859             Z_IUUpdateTaskPackage *utp = ext->u.update->u.taskPackage;
1860             if (utp && utp->targetPart)
1861             {
1862                 Z_IUTargetPart *targetPart = utp->targetPart;
1863                 int i;
1864
1865                 for (i = 0; i<targetPart->num_taskPackageRecords;  i++)
1866                 {
1867
1868                     Z_IUTaskPackageRecordStructure *tpr =
1869                         targetPart->taskPackageRecords[i];
1870                     printf("task package record %d\n", i+1);
1871                     if (tpr->which == Z_IUTaskPackageRecordStructure_record)
1872                     {
1873                         display_record (tpr->u.record);
1874                     }
1875                     else
1876                     {
1877                         printf("other type\n");
1878                     }
1879                 }
1880             }
1881         }
1882         if (ext->which == Z_External_itemOrder)
1883         {
1884             Z_IOTaskPackage *otp = ext->u.itemOrder->u.taskPackage;
1885
1886             if (otp && otp->targetPart)
1887             {
1888                 if (otp->targetPart->itemRequest)
1889                 {
1890                     Z_External *ext = otp->targetPart->itemRequest;
1891                     if (ext->which == Z_External_octet)
1892                     {
1893                         Odr_oct *doc = ext->u.octet_aligned;
1894                         printf("Got itemRequest doc %.*s\n",
1895                                doc->len, doc->buf);
1896                     }
1897                 }
1898                 else if (otp->targetPart->statusOrErrorReport)
1899                 {
1900                     Z_External *ext = otp->targetPart->statusOrErrorReport;
1901                     if (ext->which == Z_External_octet)
1902                     {
1903                         Odr_oct *doc = ext->u.octet_aligned;
1904                         printf("Got Status or Error Report doc %.*s\n",
1905                                doc->len, doc->buf);
1906                     }
1907                 }
1908             }
1909         }
1910     }
1911     if (res->taskPackage && res->taskPackage->which == Z_External_octet)
1912     {
1913         Odr_oct *doc = res->taskPackage->u.octet_aligned;
1914         printf("%.*s\n", doc->len, doc->buf);
1915     }
1916 }
1917
1918 const char *get_ill_element(void *clientData, const char *element)
1919 {
1920     return 0;
1921 }
1922
1923 static Z_External *create_external_itemRequest(void)
1924 {
1925     struct ill_get_ctl ctl;
1926     ILL_ItemRequest *req;
1927     Z_External *r = 0;
1928     int item_request_size = 0;
1929     char *item_request_buf = 0;
1930
1931     ctl.odr = out;
1932     ctl.clientData = 0;
1933     ctl.f = get_ill_element;
1934
1935     req = ill_get_ItemRequest(&ctl, "ill", 0);
1936     if (!req)
1937         printf("ill_get_ItemRequest failed\n");
1938
1939     if (!ill_ItemRequest(out, &req, 0, 0))
1940     {
1941         if (apdu_file)
1942         {
1943             ill_ItemRequest(print, &req, 0, 0);
1944             odr_reset(print);
1945         }
1946         item_request_buf = odr_getbuf (out, &item_request_size, 0);
1947         if (item_request_buf)
1948             odr_setbuf (out, item_request_buf, item_request_size, 1);
1949         printf("Couldn't encode ItemRequest, size %d\n", item_request_size);
1950         return 0;
1951     }
1952     else
1953     {
1954         r = (Z_External *) odr_malloc(out, sizeof(*r));
1955         r->direct_reference = odr_oiddup(out, yaz_oid_general_isoill_1);
1956         r->indirect_reference = 0;
1957         r->descriptor = 0;
1958         r->which = Z_External_single;
1959
1960         r->u.single_ASN1_type = (Odr_oct *)
1961             odr_malloc(out, sizeof(*r->u.single_ASN1_type));
1962         r->u.single_ASN1_type->buf = (unsigned char *)
1963         odr_malloc(out, item_request_size);
1964         r->u.single_ASN1_type->len = item_request_size;
1965         r->u.single_ASN1_type->size = item_request_size;
1966         memcpy(r->u.single_ASN1_type->buf, item_request_buf,
1967                 item_request_size);
1968
1969         do_hex_dump(item_request_buf,item_request_size);
1970     }
1971     return r;
1972 }
1973
1974 static Z_External *create_external_ILL_APDU(int which)
1975 {
1976     struct ill_get_ctl ctl;
1977     ILL_APDU *ill_apdu;
1978     Z_External *r = 0;
1979     int ill_request_size = 0;
1980     char *ill_request_buf = 0;
1981
1982     ctl.odr = out;
1983     ctl.clientData = 0;
1984     ctl.f = get_ill_element;
1985
1986     ill_apdu = ill_get_APDU(&ctl, "ill", 0);
1987
1988     if (!ill_APDU (out, &ill_apdu, 0, 0))
1989     {
1990         if (apdu_file)
1991         {
1992             printf("-------------------\n");
1993             ill_APDU(print, &ill_apdu, 0, 0);
1994             odr_reset(print);
1995             printf("-------------------\n");
1996         }
1997         ill_request_buf = odr_getbuf (out, &ill_request_size, 0);
1998         if (ill_request_buf)
1999             odr_setbuf (out, ill_request_buf, ill_request_size, 1);
2000         printf("Couldn't encode ILL-Request, size %d\n", ill_request_size);
2001         return 0;
2002     }
2003     else
2004     {
2005         ill_request_buf = odr_getbuf (out, &ill_request_size, 0);
2006
2007         r = (Z_External *) odr_malloc(out, sizeof(*r));
2008         r->direct_reference = odr_oiddup(out, yaz_oid_general_isoill_1);
2009         r->indirect_reference = 0;
2010         r->descriptor = 0;
2011         r->which = Z_External_single;
2012
2013         r->u.single_ASN1_type = (Odr_oct *)
2014             odr_malloc(out, sizeof(*r->u.single_ASN1_type));
2015         r->u.single_ASN1_type->buf = (unsigned char *)
2016         odr_malloc(out, ill_request_size);
2017         r->u.single_ASN1_type->len = ill_request_size;
2018         r->u.single_ASN1_type->size = ill_request_size;
2019         memcpy(r->u.single_ASN1_type->buf, ill_request_buf, ill_request_size);
2020 /*         printf("len = %d\n", ill_request_size); */
2021 /*              do_hex_dump(ill_request_buf,ill_request_size); */
2022 /*              printf("--- end of extenal\n"); */
2023
2024     }
2025     return r;
2026 }
2027
2028
2029 static Z_External *create_ItemOrderExternal(const char *type, int itemno,
2030                                             const char *xml_buf,
2031                                             int xml_len)
2032 {
2033     Z_External *r = (Z_External *) odr_malloc(out, sizeof(Z_External));
2034     r->direct_reference = odr_oiddup(out, yaz_oid_extserv_item_order);
2035     r->indirect_reference = 0;
2036     r->descriptor = 0;
2037
2038     r->which = Z_External_itemOrder;
2039
2040     r->u.itemOrder = (Z_ItemOrder *) odr_malloc(out,sizeof(Z_ItemOrder));
2041     memset(r->u.itemOrder, 0, sizeof(Z_ItemOrder));
2042     r->u.itemOrder->which=Z_IOItemOrder_esRequest;
2043
2044     r->u.itemOrder->u.esRequest = (Z_IORequest *)
2045         odr_malloc(out,sizeof(Z_IORequest));
2046     memset(r->u.itemOrder->u.esRequest, 0, sizeof(Z_IORequest));
2047
2048     r->u.itemOrder->u.esRequest->toKeep = (Z_IOOriginPartToKeep *)
2049         odr_malloc(out,sizeof(Z_IOOriginPartToKeep));
2050     memset(r->u.itemOrder->u.esRequest->toKeep, 0, sizeof(Z_IOOriginPartToKeep));
2051     r->u.itemOrder->u.esRequest->notToKeep = (Z_IOOriginPartNotToKeep *)
2052         odr_malloc(out,sizeof(Z_IOOriginPartNotToKeep));
2053     memset(r->u.itemOrder->u.esRequest->notToKeep, 0, sizeof(Z_IOOriginPartNotToKeep));
2054
2055     r->u.itemOrder->u.esRequest->toKeep->supplDescription = NULL;
2056     r->u.itemOrder->u.esRequest->toKeep->contact = NULL;
2057     r->u.itemOrder->u.esRequest->toKeep->addlBilling = NULL;
2058
2059     r->u.itemOrder->u.esRequest->notToKeep->resultSetItem =
2060         (Z_IOResultSetItem *) odr_malloc(out, sizeof(Z_IOResultSetItem));
2061     memset(r->u.itemOrder->u.esRequest->notToKeep->resultSetItem, 0, sizeof(Z_IOResultSetItem));
2062     r->u.itemOrder->u.esRequest->notToKeep->resultSetItem->resultSetId = "1";
2063
2064     r->u.itemOrder->u.esRequest->notToKeep->resultSetItem->item =
2065         (int *) odr_malloc(out, sizeof(int));
2066     *r->u.itemOrder->u.esRequest->notToKeep->resultSetItem->item = itemno;
2067
2068     if (!strcmp (type, "item") || !strcmp(type, "2"))
2069     {
2070         printf("using item-request\n");
2071         r->u.itemOrder->u.esRequest->notToKeep->itemRequest =
2072             create_external_itemRequest();
2073     }
2074     else if (!strcmp(type, "ill") || !strcmp(type, "1"))
2075     {
2076         printf("using ILL-request\n");
2077         r->u.itemOrder->u.esRequest->notToKeep->itemRequest =
2078             create_external_ILL_APDU(ILL_APDU_ILL_Request);
2079     }
2080     else if (!strcmp(type, "xml") || !strcmp(type, "3"))
2081     {
2082         printf("using XML ILL-request\n");
2083
2084         if (!xml_buf)
2085         {
2086             printf("no docoument added\n");
2087             r->u.itemOrder->u.esRequest->notToKeep->itemRequest = 0;
2088         }
2089         else
2090         {
2091             r->u.itemOrder->u.esRequest->notToKeep->itemRequest =
2092                 z_ext_record_oid(out, yaz_oid_recsyn_xml, xml_buf, xml_len);
2093         }
2094     }
2095     else
2096         r->u.itemOrder->u.esRequest->notToKeep->itemRequest = 0;
2097
2098     return r;
2099 }
2100
2101 static int send_itemorder(const char *type, int itemno,
2102                           const char *xml_buf, int xml_len)
2103 {
2104     Z_APDU *apdu = zget_APDU(out, Z_APDU_extendedServicesRequest);
2105     Z_ExtendedServicesRequest *req = apdu->u.extendedServicesRequest;
2106
2107     req->referenceId = set_refid (out);
2108
2109     req->packageType = odr_oiddup(out, yaz_oid_extserv_item_order);
2110     req->packageName = esPackageName;
2111
2112     req->taskSpecificParameters = create_ItemOrderExternal(type, itemno,
2113                                                            xml_buf, xml_len);
2114     send_apdu(apdu);
2115     return 0;
2116 }
2117
2118 static int only_z3950(void)
2119 {
2120     if (!conn)
2121     {
2122         printf("Not connected yet\n");
2123         return 1;
2124     }
2125     if (protocol == PROTO_HTTP)
2126     {
2127         printf("Not supported by SRW\n");
2128         return 1;
2129     }
2130     return 0;
2131 }
2132
2133 static int cmd_update_common(const char *arg, int version);
2134
2135 static int cmd_update(const char *arg)
2136 {
2137     return cmd_update_common(arg, 1);
2138 }
2139
2140 static int cmd_update0(const char *arg)
2141 {
2142     return cmd_update_common(arg, 0);
2143 }
2144
2145 static int cmd_update_Z3950(int version, int action_no, const char *recid,
2146                             char *rec_buf, int rec_len);
2147
2148 #if YAZ_HAVE_XML2
2149 static int cmd_update_SRW(int action_no, const char *recid,
2150                           char *rec_buf, int rec_len);
2151 #endif
2152
2153 static int cmd_update_common(const char *arg, int version)
2154 {
2155     char *action_buf;
2156     int action_len;
2157     char *recid_buf;
2158     int recid_len;
2159     const char *recid = 0;
2160     char *rec_buf;
2161     int rec_len;
2162     int action_no;
2163     int noread = 0;
2164
2165     if (parse_cmd_doc(&arg, out, &action_buf, &action_len) == 0)
2166     {
2167         printf("Use: update action recid [fname]\n");
2168         printf(" where action is one of insert,replace,delete.update\n");
2169         printf(" recid is some record ID. Use none for no ID\n");
2170         printf(" fname is file of record to be updated\n");
2171         return 0;
2172     }
2173
2174     if (parse_cmd_doc(&arg, out, &recid_buf, &recid_len) == 0)
2175     {
2176         printf("Missing recid\n");
2177         return 0;
2178     }
2179
2180     if (!strcmp(action_buf, "insert"))
2181         action_no = Z_IUOriginPartToKeep_recordInsert;
2182     else if (!strcmp(action_buf, "replace"))
2183         action_no = Z_IUOriginPartToKeep_recordReplace;
2184     else if (!strcmp(action_buf, "delete"))
2185         action_no = Z_IUOriginPartToKeep_recordDelete;
2186     else if (!strcmp(action_buf, "update"))
2187         action_no = Z_IUOriginPartToKeep_specialUpdate;
2188     else
2189     {
2190         printf("Bad action: %s\n", action_buf);
2191         printf("Possible values: insert, replace, delete, update\n");
2192         return 0;
2193     }
2194
2195     if (strcmp(recid_buf, "none")) /* none means no record ID */
2196         recid = recid_buf;
2197
2198     arg += noread;
2199     if (parse_cmd_doc(&arg, out, &rec_buf, &rec_len) == 0)
2200         return 0;
2201
2202 #if YAZ_HAVE_XML2
2203     if (protocol == PROTO_HTTP)
2204         return cmd_update_SRW(action_no, recid_buf, rec_buf, rec_len);
2205 #endif
2206     return cmd_update_Z3950(version, action_no, recid_buf, rec_buf, rec_len);
2207 }
2208
2209 #if YAZ_HAVE_XML2
2210 static int cmd_update_SRW(int action_no, const char *recid,
2211                           char *rec_buf, int rec_len)
2212 {
2213     if (!conn)
2214         session_connect(cur_host);
2215     if (!conn)
2216         return 0;
2217     else
2218     {
2219         Z_SRW_PDU *srw = yaz_srw_get(out, Z_SRW_update_request);
2220         Z_SRW_updateRequest *sr = srw->u.update_request;
2221
2222         switch(action_no)
2223         {
2224         case Z_IUOriginPartToKeep_recordInsert:
2225             sr->operation = "info:srw/action/1/create";
2226             break;
2227         case Z_IUOriginPartToKeep_recordReplace:
2228             sr->operation = "info:srw/action/1/replace";
2229             break;
2230         case Z_IUOriginPartToKeep_recordDelete:
2231             sr->operation = "info:srw/action/1/delete";
2232             break;
2233         }
2234         if (rec_buf)
2235         {
2236             sr->record = yaz_srw_get_record(out);
2237             sr->record->recordData_buf = rec_buf;
2238             sr->record->recordData_len = rec_len;
2239             sr->record->recordSchema = record_schema;
2240         }
2241         if (recid)
2242             sr->recordId = odr_strdup(out, recid);
2243         return send_srw(srw);
2244     }
2245 }
2246 #endif
2247
2248 static int cmd_update_Z3950(int version, int action_no, const char *recid,
2249                             char *rec_buf, int rec_len)
2250 {
2251     Z_APDU *apdu = zget_APDU(out, Z_APDU_extendedServicesRequest );
2252     Z_ExtendedServicesRequest *req = apdu->u.extendedServicesRequest;
2253     Z_External *r;
2254     Z_External *record_this = 0;
2255     if (rec_buf)
2256         record_this = z_ext_record_oid(out, yaz_oid_recsyn_xml,
2257                                        rec_buf, rec_len);
2258     else
2259     {
2260         if (!record_last)
2261         {
2262             printf("No last record (update ignored)\n");
2263             return 0;
2264         }
2265         record_this = record_last;
2266     }
2267
2268     req->packageType = odr_oiddup(out, (version == 0 ?
2269        yaz_oid_extserv_database_update_first_version :
2270        yaz_oid_extserv_database_update));
2271
2272     req->packageName = esPackageName;
2273
2274     req->referenceId = set_refid (out);
2275
2276     r = req->taskSpecificParameters = (Z_External *)
2277         odr_malloc(out, sizeof(*r));
2278     r->direct_reference = req->packageType;
2279     r->indirect_reference = 0;
2280     r->descriptor = 0;
2281     if (version == 0)
2282     {
2283         Z_IU0OriginPartToKeep *toKeep;
2284         Z_IU0SuppliedRecords *notToKeep;
2285
2286         r->which = Z_External_update0;
2287         r->u.update0 = (Z_IU0Update *) odr_malloc(out, sizeof(*r->u.update0));
2288         r->u.update0->which = Z_IUUpdate_esRequest;
2289         r->u.update0->u.esRequest = (Z_IU0UpdateEsRequest *)
2290             odr_malloc(out, sizeof(*r->u.update0->u.esRequest));
2291         toKeep = r->u.update0->u.esRequest->toKeep = (Z_IU0OriginPartToKeep *)
2292             odr_malloc(out, sizeof(*r->u.update0->u.esRequest->toKeep));
2293
2294         toKeep->databaseName = databaseNames[0];
2295         toKeep->schema = 0;
2296         if (record_schema)
2297         {
2298             toKeep->schema = yaz_string_to_oid_odr(yaz_oid_std(),
2299                                                    CLASS_SCHEMA,
2300                                                    record_schema, out);
2301         }
2302         toKeep->elementSetName = 0;
2303
2304         toKeep->action = (int *) odr_malloc(out, sizeof(*toKeep->action));
2305         *toKeep->action = action_no;
2306
2307         notToKeep = r->u.update0->u.esRequest->notToKeep = (Z_IU0SuppliedRecords *)
2308             odr_malloc(out, sizeof(*r->u.update0->u.esRequest->notToKeep));
2309         notToKeep->num = 1;
2310         notToKeep->elements = (Z_IU0SuppliedRecords_elem **)
2311             odr_malloc(out, sizeof(*notToKeep->elements));
2312         notToKeep->elements[0] = (Z_IU0SuppliedRecords_elem *)
2313             odr_malloc(out, sizeof(**notToKeep->elements));
2314         notToKeep->elements[0]->which = Z_IUSuppliedRecords_elem_opaque;
2315         if (recid)
2316         {
2317             notToKeep->elements[0]->u.opaque = (Odr_oct *)
2318                 odr_malloc(out, sizeof(Odr_oct));
2319             notToKeep->elements[0]->u.opaque->buf = (unsigned char *) recid;
2320             notToKeep->elements[0]->u.opaque->size = strlen(recid);
2321             notToKeep->elements[0]->u.opaque->len = strlen(recid);
2322         }
2323         else
2324             notToKeep->elements[0]->u.opaque = 0;
2325         notToKeep->elements[0]->supplementalId = 0;
2326         notToKeep->elements[0]->correlationInfo = 0;
2327         notToKeep->elements[0]->record = record_this;
2328     }
2329     else
2330     {
2331         Z_IUOriginPartToKeep *toKeep;
2332         Z_IUSuppliedRecords *notToKeep;
2333
2334         r->which = Z_External_update;
2335         r->u.update = (Z_IUUpdate *) odr_malloc(out, sizeof(*r->u.update));
2336         r->u.update->which = Z_IUUpdate_esRequest;
2337         r->u.update->u.esRequest = (Z_IUUpdateEsRequest *)
2338             odr_malloc(out, sizeof(*r->u.update->u.esRequest));
2339         toKeep = r->u.update->u.esRequest->toKeep = (Z_IUOriginPartToKeep *)
2340             odr_malloc(out, sizeof(*r->u.update->u.esRequest->toKeep));
2341
2342         toKeep->databaseName = databaseNames[0];
2343         toKeep->schema = 0;
2344         if (record_schema)
2345         {
2346             toKeep->schema = yaz_string_to_oid_odr(yaz_oid_std(),
2347                                                    CLASS_SCHEMA,
2348                                                    record_schema, out);
2349         }
2350         toKeep->elementSetName = 0;
2351         toKeep->actionQualifier = 0;
2352         toKeep->action = (int *) odr_malloc(out, sizeof(*toKeep->action));
2353         *toKeep->action = action_no;
2354
2355         notToKeep = r->u.update->u.esRequest->notToKeep = (Z_IUSuppliedRecords *)
2356             odr_malloc(out, sizeof(*r->u.update->u.esRequest->notToKeep));
2357         notToKeep->num = 1;
2358         notToKeep->elements = (Z_IUSuppliedRecords_elem **)
2359             odr_malloc(out, sizeof(*notToKeep->elements));
2360         notToKeep->elements[0] = (Z_IUSuppliedRecords_elem *)
2361             odr_malloc(out, sizeof(**notToKeep->elements));
2362         notToKeep->elements[0]->which = Z_IUSuppliedRecords_elem_opaque;
2363         if (recid)
2364         {
2365             notToKeep->elements[0]->u.opaque = (Odr_oct *)
2366                 odr_malloc(out, sizeof(Odr_oct));
2367             notToKeep->elements[0]->u.opaque->buf = (unsigned char *) recid;
2368             notToKeep->elements[0]->u.opaque->size = strlen(recid);
2369             notToKeep->elements[0]->u.opaque->len = strlen(recid);
2370         }
2371         else
2372             notToKeep->elements[0]->u.opaque = 0;
2373         notToKeep->elements[0]->supplementalId = 0;
2374         notToKeep->elements[0]->correlationInfo = 0;
2375         notToKeep->elements[0]->record = record_this;
2376     }
2377
2378     send_apdu(apdu);
2379
2380     return 2;
2381 }
2382
2383 static int cmd_xmles(const char *arg)
2384 {
2385     if (only_z3950())
2386         return 1;
2387     else
2388     {
2389         char *asn_buf = 0;
2390         int noread = 0;
2391         Odr_oid *oid;
2392         char oid_str[51];
2393         Z_APDU *apdu = zget_APDU(out, Z_APDU_extendedServicesRequest);
2394         Z_ExtendedServicesRequest *req = apdu->u.extendedServicesRequest;
2395
2396
2397         Z_External *ext = (Z_External *) odr_malloc(out, sizeof(*ext));
2398
2399         req->referenceId = set_refid (out);
2400         req->taskSpecificParameters = ext;
2401         ext->indirect_reference = 0;
2402         ext->descriptor = 0;
2403         ext->which = Z_External_octet;
2404         ext->u.single_ASN1_type = (Odr_oct *) odr_malloc(out, sizeof(Odr_oct));
2405         sscanf(arg, "%50s%n", oid_str, &noread);
2406         if (noread == 0)
2407         {
2408             printf("Missing OID for xmles\n");
2409             return 0;
2410         }
2411         arg += noread;
2412         if (parse_cmd_doc(&arg, out, &asn_buf,
2413                           &ext->u.single_ASN1_type->len) == 0)
2414             return 0;
2415
2416         ext->u.single_ASN1_type->buf = (unsigned char *) asn_buf;
2417
2418         oid = yaz_string_to_oid_odr(yaz_oid_std(),
2419                                     CLASS_EXTSERV, oid_str, out);
2420         if (!oid)
2421         {
2422             printf("Bad OID: %s\n", oid_str);
2423             return 0;
2424         }
2425
2426         req->packageType = oid;
2427
2428         ext->direct_reference = oid;
2429
2430         send_apdu(apdu);
2431
2432         return 2;
2433     }
2434 }
2435
2436 static int cmd_itemorder(const char *arg)
2437 {
2438     char type[12];
2439     int itemno;
2440     char *xml_buf = 0;
2441     int xml_len = 0;
2442     int no_read = 0;
2443
2444     if (only_z3950())
2445         return 1;
2446     if (sscanf(arg, "%10s %d%n", type, &itemno, &no_read) < 2)
2447         return 0;
2448     arg += no_read;
2449     parse_cmd_doc(&arg, out, &xml_buf, &xml_len);
2450
2451     fflush(stdout);
2452     send_itemorder(type, itemno, xml_buf, xml_len);
2453     return 2;
2454 }
2455
2456 static void show_opt(const char *arg, void *clientData)
2457 {
2458     printf("%s ", arg);
2459 }
2460
2461 static int cmd_zversion(const char *arg)
2462 {
2463     if (*arg && arg)
2464         z3950_version = atoi(arg);
2465     else
2466         printf("version is %d\n", z3950_version);
2467     return 0;
2468 }
2469
2470 static int cmd_options(const char *arg)
2471 {
2472     if (*arg)
2473     {
2474         int r;
2475         int pos;
2476         r = yaz_init_opt_encode(&z3950_options, arg, &pos);
2477         if (r == -1)
2478             printf("Unknown option(s) near %s\n", arg+pos);
2479     }
2480     else
2481     {
2482         yaz_init_opt_decode(&z3950_options, show_opt, 0);
2483         printf("\n");
2484     }
2485     return 0;
2486 }
2487
2488 static int cmd_explain(const char *arg)
2489 {
2490     if (protocol != PROTO_HTTP)
2491         return 0;
2492 #if YAZ_HAVE_XML2
2493     if (!conn)
2494         session_connect(cur_host);
2495     if (conn)
2496     {
2497         Z_SRW_PDU *sr = 0;
2498
2499         setno = 1;
2500
2501         /* save this for later .. when fetching individual records */
2502         sr = yaz_srw_get(out, Z_SRW_explain_request);
2503         if (recordsyntax_size == 1
2504             && !yaz_matchstr(recordsyntax_list[0], "xml"))
2505             sr->u.explain_request->recordPacking = "xml";
2506         send_srw(sr);
2507         return 2;
2508     }
2509 #endif
2510     return 0;
2511 }
2512
2513 static int cmd_init(const char *arg)
2514 {
2515     if (*arg)
2516     {
2517         strncpy(cur_host, arg, sizeof(cur_host)-1);
2518         cur_host[sizeof(cur_host)-1] = 0;
2519     }
2520     if (only_z3950())
2521         return 1;
2522     send_initRequest(cur_host);
2523     return 2;
2524 }
2525
2526 static int cmd_sru(const char *arg)
2527 {
2528     if (!*arg)
2529     {
2530         printf("SRU method is: %s\n", sru_method);
2531         printf("SRU version is: %s\n", sru_version);
2532     }
2533     else
2534     {
2535         int r;
2536         r = sscanf(arg, "%9s %9s", sru_method, sru_version);
2537         if (r >= 1)
2538         {
2539             if (!yaz_matchstr(sru_method, "post"))
2540                 ;
2541             else if (!yaz_matchstr(sru_method, "get"))
2542                 ;
2543             else if (!yaz_matchstr(sru_method, "soap"))
2544                 ;
2545             else
2546             {
2547                 strcpy(sru_method, "soap");
2548                 printf("Unknown SRU method: %s\n", arg);
2549                 printf("Specify one of POST, GET, SOAP\n");
2550             }
2551         }
2552     }
2553     return 0;
2554 }
2555
2556 static int cmd_find(const char *arg)
2557 {
2558     if (!*arg)
2559     {
2560         printf("Find what?\n");
2561         return 0;
2562     }
2563     if (protocol == PROTO_HTTP)
2564     {
2565 #if YAZ_HAVE_XML2
2566         if (!conn)
2567             session_connect(cur_host);
2568         if (!conn)
2569             return 0;
2570         if (!send_SRW_searchRequest(arg))
2571             return 0;
2572 #else
2573         return 0;
2574 #endif
2575     }
2576     else
2577     {
2578         if (!conn)
2579         {
2580             try_reconnect();
2581
2582             if (!conn) {
2583                 printf("Not connected yet\n");
2584                 return 0;
2585             }
2586         }
2587         if (!send_searchRequest(arg))
2588             return 0;
2589     }
2590     return 2;
2591 }
2592
2593 static int cmd_delete(const char *arg)
2594 {
2595     if (only_z3950())
2596         return 0;
2597     if (!send_deleteResultSetRequest(arg))
2598         return 0;
2599     return 2;
2600 }
2601
2602 static int cmd_ssub(const char *arg)
2603 {
2604     if (!(smallSetUpperBound = atoi(arg)))
2605         return 0;
2606     return 1;
2607 }
2608
2609 static int cmd_lslb(const char *arg)
2610 {
2611     if (!(largeSetLowerBound = atoi(arg)))
2612         return 0;
2613     return 1;
2614 }
2615
2616 static int cmd_mspn(const char *arg)
2617 {
2618     if (!(mediumSetPresentNumber = atoi(arg)))
2619         return 0;
2620     return 1;
2621 }
2622
2623 static int cmd_status(const char *arg)
2624 {
2625     printf("smallSetUpperBound: %d\n", smallSetUpperBound);
2626     printf("largeSetLowerBound: %d\n", largeSetLowerBound);
2627     printf("mediumSetPresentNumber: %d\n", mediumSetPresentNumber);
2628     return 1;
2629 }
2630
2631 static int cmd_setnames(const char *arg)
2632 {
2633     if (*arg == '1')         /* enable ? */
2634         setnumber = 0;
2635     else if (*arg == '0')    /* disable ? */
2636         setnumber = -1;
2637     else if (setnumber < 0)  /* no args, toggle .. */
2638         setnumber = 0;
2639     else
2640         setnumber = -1;
2641
2642     if (setnumber >= 0)
2643         printf("Set numbering enabled.\n");
2644     else
2645         printf("Set numbering disabled.\n");
2646     return 1;
2647 }
2648
2649 /* PRESENT SERVICE ----------------------------- */
2650
2651 static void parse_show_args(const char *arg_c, char *setstring,
2652                             int *start, int *number)
2653 {
2654     char arg[40];
2655     char *p;
2656
2657     strncpy(arg, arg_c, sizeof(arg)-1);
2658     arg[sizeof(arg)-1] = '\0';
2659
2660     if ((p = strchr(arg, '+')))
2661     {
2662         *number = atoi(p + 1);
2663         *p = '\0';
2664     }
2665     if (*arg)
2666     {
2667         if (!strcmp(arg, "all"))
2668         {
2669             *number = last_hit_count;
2670             *start = 1;
2671         }
2672         else
2673             *start = atoi(arg);
2674     }
2675     if (p && (p=strchr(p+1, '+')))
2676         strcpy(setstring, p+1);
2677     else if (setnumber >= 0)
2678         sprintf(setstring, "%d", setnumber);
2679     else
2680         *setstring = '\0';
2681 }
2682
2683 static int send_presentRequest(const char *arg)
2684 {
2685     Z_APDU *apdu = zget_APDU(out, Z_APDU_presentRequest);
2686     Z_PresentRequest *req = apdu->u.presentRequest;
2687     Z_RecordComposition compo;
2688     int nos = 1;
2689     char setstring[100];
2690
2691     req->referenceId = set_refid(out);
2692
2693     parse_show_args(arg, setstring, &setno, &nos);
2694     if (*setstring)
2695         req->resultSetId = setstring;
2696
2697     req->resultSetStartPoint = &setno;
2698     req->numberOfRecordsRequested = &nos;
2699
2700     if (recordsyntax_size)
2701         req->preferredRecordSyntax =
2702             yaz_string_to_oid_odr(yaz_oid_std(),
2703                                   CLASS_RECSYN, recordsyntax_list[0], out);
2704
2705     if (record_schema || recordsyntax_size >= 2)
2706     {
2707         req->recordComposition = &compo;
2708         compo.which = Z_RecordComp_complex;
2709         compo.u.complex = (Z_CompSpec *)
2710             odr_malloc(out, sizeof(*compo.u.complex));
2711         compo.u.complex->selectAlternativeSyntax = (bool_t *)
2712             odr_malloc(out, sizeof(bool_t));
2713         *compo.u.complex->selectAlternativeSyntax = 0;
2714
2715         compo.u.complex->generic = (Z_Specification *)
2716             odr_malloc(out, sizeof(*compo.u.complex->generic));
2717
2718         compo.u.complex->generic->which = Z_Schema_oid;
2719         if (!record_schema)
2720             compo.u.complex->generic->schema.oid = 0;
2721         else
2722         {
2723             compo.u.complex->generic->schema.oid =
2724                 yaz_string_to_oid_odr(yaz_oid_std(),
2725                                       CLASS_SCHEMA, record_schema, out);
2726
2727             if (!compo.u.complex->generic->schema.oid)
2728             {
2729                 /* OID wasn't a schema! Try record syntax instead. */
2730                 compo.u.complex->generic->schema.oid = (Odr_oid *)
2731                     yaz_string_to_oid_odr(yaz_oid_std(),
2732                                           CLASS_RECSYN, record_schema, out);
2733             }
2734         }
2735         if (!elementSetNames)
2736             compo.u.complex->generic->elementSpec = 0;
2737         else
2738         {
2739             compo.u.complex->generic->elementSpec = (Z_ElementSpec *)
2740                 odr_malloc(out, sizeof(Z_ElementSpec));
2741             compo.u.complex->generic->elementSpec->which =
2742                 Z_ElementSpec_elementSetName;
2743             compo.u.complex->generic->elementSpec->u.elementSetName =
2744                 elementSetNames->u.generic;
2745         }
2746         compo.u.complex->num_dbSpecific = 0;
2747         compo.u.complex->dbSpecific = 0;
2748
2749         compo.u.complex->num_recordSyntax = 0;
2750         compo.u.complex->recordSyntax = 0;
2751         if (recordsyntax_size >= 2)
2752         {
2753             int i;
2754             compo.u.complex->num_recordSyntax = recordsyntax_size;
2755             compo.u.complex->recordSyntax = (Odr_oid **)
2756                 odr_malloc(out, recordsyntax_size * sizeof(Odr_oid*));
2757             for (i = 0; i < recordsyntax_size; i++)
2758             compo.u.complex->recordSyntax[i] =
2759                 yaz_string_to_oid_odr(yaz_oid_std(),
2760                                       CLASS_RECSYN, recordsyntax_list[i], out);
2761         }
2762     }
2763     else if (elementSetNames)
2764     {
2765         req->recordComposition = &compo;
2766         compo.which = Z_RecordComp_simple;
2767         compo.u.simple = elementSetNames;
2768     }
2769     send_apdu(apdu);
2770     printf("Sent presentRequest (%d+%d).\n", setno, nos);
2771     return 2;
2772 }
2773
2774 #if YAZ_HAVE_XML2
2775 static int send_SRW_presentRequest(const char *arg)
2776 {
2777     char setstring[100];
2778     int nos = 1;
2779     Z_SRW_PDU *sr = srw_sr;
2780
2781     if (!sr)
2782         return 0;
2783     parse_show_args(arg, setstring, &setno, &nos);
2784     sr->u.request->startRecord = odr_intdup(out, setno);
2785     sr->u.request->maximumRecords = odr_intdup(out, nos);
2786     if (record_schema)
2787         sr->u.request->recordSchema = record_schema;
2788     if (recordsyntax_size == 1 && !yaz_matchstr(recordsyntax_list[0], "xml"))
2789         sr->u.request->recordPacking = "xml";
2790     return send_srw(sr);
2791 }
2792 #endif
2793
2794 static void close_session(void)
2795 {
2796     if (conn)
2797         cs_close(conn);
2798     conn = 0;
2799     sent_close = 0;
2800     odr_reset(out);
2801     odr_reset(in);
2802     odr_reset(print);
2803     last_hit_count = 0;
2804 }
2805
2806 void process_close(Z_Close *req)
2807 {
2808     Z_APDU *apdu = zget_APDU(out, Z_APDU_close);
2809     Z_Close *res = apdu->u.close;
2810
2811     static char *reasons[] =
2812     {
2813         "finished",
2814         "shutdown",
2815         "system problem",
2816         "cost limit reached",
2817         "resources",
2818         "security violation",
2819         "protocolError",
2820         "lack of activity",
2821         "peer abort",
2822         "unspecified"
2823     };
2824
2825     printf("Reason: %s, message: %s\n", reasons[*req->closeReason],
2826         req->diagnosticInformation ? req->diagnosticInformation : "NULL");
2827     if (sent_close)
2828         close_session();
2829     else
2830     {
2831         *res->closeReason = Z_Close_finished;
2832         send_apdu(apdu);
2833         printf("Sent response.\n");
2834         sent_close = 1;
2835     }
2836 }
2837
2838 static int cmd_show(const char *arg)
2839 {
2840     if (protocol == PROTO_HTTP)
2841     {
2842 #if YAZ_HAVE_XML2
2843         if (!conn)
2844             session_connect(cur_host);
2845         if (!conn)
2846             return 0;
2847         if (!send_SRW_presentRequest(arg))
2848             return 0;
2849 #else
2850         return 0;
2851 #endif
2852     }
2853     else
2854     {
2855         if (!conn)
2856         {
2857             printf("Not connected yet\n");
2858             return 0;
2859         }
2860         if (!send_presentRequest(arg))
2861             return 0;
2862     }
2863     return 2;
2864 }
2865
2866 void exit_client(int code)
2867 {
2868     file_history_save(file_history);
2869     file_history_destroy(&file_history);
2870     exit(code);
2871 }
2872
2873 int cmd_quit(const char *arg)
2874 {
2875     printf("See you later, alligator.\n");
2876     xmalloc_trav("");
2877     exit_client(0);
2878     return 0;
2879 }
2880
2881 int cmd_cancel(const char *arg)
2882 {
2883     Z_APDU *apdu = zget_APDU(out, Z_APDU_triggerResourceControlRequest);
2884     Z_TriggerResourceControlRequest *req =
2885         apdu->u.triggerResourceControlRequest;
2886     bool_t rfalse = 0;
2887     char command[16];
2888
2889     *command = '\0';
2890     sscanf(arg, "%15s", command);
2891
2892     if (only_z3950())
2893         return 0;
2894     if (session_initResponse &&
2895         !ODR_MASK_GET(session_initResponse->options,
2896                       Z_Options_triggerResourceCtrl))
2897     {
2898         printf("Target doesn't support cancel (trigger resource ctrl)\n");
2899         return 0;
2900     }
2901     *req->requestedAction = Z_TriggerResourceControlRequest_cancel;
2902     req->resultSetWanted = &rfalse;
2903     req->referenceId = set_refid(out);
2904
2905     send_apdu(apdu);
2906     printf("Sent cancel request\n");
2907     if (!strcmp(command, "wait"))
2908          return 2;
2909     return 1;
2910 }
2911
2912
2913 int cmd_cancel_find(const char *arg) {
2914     int fres;
2915     fres=cmd_find(arg);
2916     if( fres > 0 ) {
2917         return cmd_cancel("");
2918     };
2919     return fres;
2920 }
2921
2922 int send_scanrequest(const char *set,  const char *query,
2923                      int pp, int num, const char *term)
2924 {
2925     Z_APDU *apdu = zget_APDU(out, Z_APDU_scanRequest);
2926     Z_ScanRequest *req = apdu->u.scanRequest;
2927
2928     if (only_z3950())
2929         return 0;
2930     if (queryType == QueryType_CCL2RPN)
2931     {
2932         int error, pos;
2933         struct ccl_rpn_node *rpn;
2934
2935         rpn = ccl_find_str(bibset,  query, &error, &pos);
2936         if (error)
2937         {
2938             printf("CCL ERROR: %s\n", ccl_err_msg(error));
2939             return -1;
2940         }
2941         req->attributeSet =
2942             yaz_string_to_oid_odr(yaz_oid_std(),
2943                                   CLASS_ATTSET, "Bib-1", out);
2944         if (!(req->termListAndStartPoint = ccl_scan_query(out, rpn)))
2945         {
2946             printf("Couldn't convert CCL to Scan term\n");
2947             return -1;
2948         }
2949         ccl_rpn_delete(rpn);
2950     }
2951     else
2952     {
2953         YAZ_PQF_Parser pqf_parser = yaz_pqf_create();
2954
2955         if (!(req->termListAndStartPoint =
2956               yaz_pqf_scan(pqf_parser, out, &req->attributeSet, query)))
2957         {
2958             const char *pqf_msg;
2959             size_t off;
2960             int code = yaz_pqf_error(pqf_parser, &pqf_msg, &off);
2961             int ioff = off;
2962             printf("%*s^\n", ioff+7, "");
2963             printf("Prefix query error: %s (code %d)\n", pqf_msg, code);
2964             yaz_pqf_destroy(pqf_parser);
2965             return -1;
2966         }
2967         yaz_pqf_destroy(pqf_parser);
2968     }
2969     if (queryCharset && outputCharset)
2970     {
2971         yaz_iconv_t cd = yaz_iconv_open(queryCharset, outputCharset);
2972         if (!cd)
2973         {
2974             printf("Conversion from %s to %s unsupported\n",
2975                    outputCharset, queryCharset);
2976             return -1;
2977         }
2978         yaz_query_charset_convert_apt(req->termListAndStartPoint, out, cd);
2979         yaz_iconv_close(cd);
2980     }
2981     if (term && *term)
2982     {
2983         if (req->termListAndStartPoint->term &&
2984             req->termListAndStartPoint->term->which == Z_Term_general &&
2985             req->termListAndStartPoint->term->u.general)
2986         {
2987             req->termListAndStartPoint->term->u.general->buf =
2988                 (unsigned char *) odr_strdup(out, term);
2989             req->termListAndStartPoint->term->u.general->len =
2990                 req->termListAndStartPoint->term->u.general->size =
2991                 strlen(term);
2992         }
2993     }
2994     req->referenceId = set_refid(out);
2995     req->num_databaseNames = num_databaseNames;
2996     req->databaseNames = databaseNames;
2997     req->numberOfTermsRequested = &num;
2998     req->preferredPositionInResponse = &pp;
2999     req->stepSize = odr_intdup(out, scan_stepSize);
3000
3001     if (set)
3002         yaz_oi_set_string_oid(&req->otherInfo, out,
3003                               yaz_oid_userinfo_scan_set, 1, set);
3004
3005     send_apdu(apdu);
3006     return 2;
3007 }
3008
3009 int send_sortrequest(const char *arg, int newset)
3010 {
3011     Z_APDU *apdu = zget_APDU(out, Z_APDU_sortRequest);
3012     Z_SortRequest *req = apdu->u.sortRequest;
3013     Z_SortKeySpecList *sksl = (Z_SortKeySpecList *)
3014         odr_malloc(out, sizeof(*sksl));
3015     char setstring[32];
3016
3017     if (only_z3950())
3018         return 0;
3019     if (setnumber >= 0)
3020         sprintf(setstring, "%d", setnumber);
3021     else
3022         sprintf(setstring, "default");
3023
3024     req->referenceId = set_refid(out);
3025
3026     req->num_inputResultSetNames = 1;
3027     req->inputResultSetNames = (Z_InternationalString **)
3028         odr_malloc(out, sizeof(*req->inputResultSetNames));
3029     req->inputResultSetNames[0] = odr_strdup(out, setstring);
3030
3031     if (newset && setnumber >= 0)
3032         sprintf(setstring, "%d", ++setnumber);
3033
3034     req->sortedResultSetName = odr_strdup(out, setstring);
3035
3036     req->sortSequence = yaz_sort_spec(out, arg);
3037     if (!req->sortSequence)
3038     {
3039         printf("Missing sort specifications\n");
3040         return -1;
3041     }
3042     send_apdu(apdu);
3043     return 2;
3044 }
3045
3046 void display_term(Z_TermInfo *t)
3047 {
3048     if (t->displayTerm)
3049         printf("%s", t->displayTerm);
3050     else if (t->term->which == Z_Term_general)
3051         printf("%.*s", t->term->u.general->len, t->term->u.general->buf);
3052     else
3053         printf("Term (not general)");
3054     if (t->term->which == Z_Term_general)
3055         sprintf(last_scan_line, "%.*s", t->term->u.general->len,
3056             t->term->u.general->buf);
3057
3058     if (t->globalOccurrences)
3059         printf(" (%d)\n", *t->globalOccurrences);
3060     else
3061         printf("\n");
3062 }
3063
3064 void process_scanResponse(Z_ScanResponse *res)
3065 {
3066     int i;
3067     Z_Entry **entries = NULL;
3068     int num_entries = 0;
3069
3070     printf("Received ScanResponse\n");
3071     print_refid(res->referenceId);
3072     printf("%d entries", *res->numberOfEntriesReturned);
3073     if (res->positionOfTerm)
3074         printf(", position=%d", *res->positionOfTerm);
3075     printf("\n");
3076     if (*res->scanStatus != Z_Scan_success)
3077         printf("Scan returned code %d\n", *res->scanStatus);
3078     if (!res->entries)
3079         return;
3080     if ((entries = res->entries->entries))
3081         num_entries = res->entries->num_entries;
3082     for (i = 0; i < num_entries; i++)
3083     {
3084         int pos_term = res->positionOfTerm ? *res->positionOfTerm : -1;
3085         if (entries[i]->which == Z_Entry_termInfo)
3086         {
3087             printf("%c ", i + 1 == pos_term ? '*' : ' ');
3088             display_term(entries[i]->u.termInfo);
3089         }
3090         else
3091             display_diagrecs(&entries[i]->u.surrogateDiagnostic, 1);
3092     }
3093     if (res->entries->nonsurrogateDiagnostics)
3094         display_diagrecs(res->entries->nonsurrogateDiagnostics,
3095                           res->entries->num_nonsurrogateDiagnostics);
3096 }
3097
3098 void process_sortResponse(Z_SortResponse *res)
3099 {
3100     printf("Received SortResponse: status=");
3101     switch (*res->sortStatus)
3102     {
3103     case Z_SortResponse_success:
3104         printf("success"); break;
3105     case Z_SortResponse_partial_1:
3106         printf("partial"); break;
3107     case Z_SortResponse_failure:
3108         printf("failure"); break;
3109     default:
3110         printf("unknown (%d)", *res->sortStatus);
3111     }
3112     printf("\n");
3113     print_refid (res->referenceId);
3114     if (res->diagnostics)
3115         display_diagrecs(res->diagnostics,
3116                          res->num_diagnostics);
3117 }
3118
3119 void process_deleteResultSetResponse(Z_DeleteResultSetResponse *res)
3120 {
3121     printf("Got deleteResultSetResponse status=%d\n",
3122            *res->deleteOperationStatus);
3123     if (res->deleteListStatuses)
3124     {
3125         int i;
3126         for (i = 0; i < res->deleteListStatuses->num; i++)
3127         {
3128             printf("%s status=%d\n", res->deleteListStatuses->elements[i]->id,
3129                     *res->deleteListStatuses->elements[i]->status);
3130         }
3131     }
3132 }
3133
3134 int cmd_sort_generic(const char *arg, int newset)
3135 {
3136     if (only_z3950())
3137         return 0;
3138     if (session_initResponse &&
3139         !ODR_MASK_GET(session_initResponse->options, Z_Options_sort))
3140     {
3141         printf("Target doesn't support sort\n");
3142         return 0;
3143     }
3144     if (*arg)
3145     {
3146         if (send_sortrequest(arg, newset) < 0)
3147             return 0;
3148         return 2;
3149     }
3150     return 0;
3151 }
3152
3153 int cmd_sort(const char *arg)
3154 {
3155     return cmd_sort_generic(arg, 0);
3156 }
3157
3158 int cmd_sort_newset(const char *arg)
3159 {
3160     return cmd_sort_generic(arg, 1);
3161 }
3162
3163 int cmd_scanstep(const char *arg)
3164 {
3165     scan_stepSize = atoi(arg);
3166     return 0;
3167 }
3168
3169 int cmd_scanpos(const char *arg)
3170 {
3171     int r = sscanf(arg, "%d", &scan_position);
3172     if (r == 0)
3173         scan_position = 1;
3174     return 0;
3175 }
3176
3177 int cmd_scansize(const char *arg)
3178 {
3179     int r = sscanf(arg, "%d", &scan_size);
3180     if (r == 0)
3181         scan_size = 20;
3182     return 0;
3183 }
3184
3185 static int cmd_scan_common(const char *set, const char *arg)
3186 {
3187     if (protocol == PROTO_HTTP)
3188     {
3189 #if YAZ_HAVE_XML2
3190         if (!conn)
3191             session_connect(cur_host);
3192         if (!conn)
3193             return 0;
3194         if (*arg)
3195         {
3196             if (send_SRW_scanRequest(arg, scan_position, scan_size) < 0)
3197                 return 0;
3198         }
3199         else
3200         {
3201             if (send_SRW_scanRequest(last_scan_line, 1, scan_size) < 0)
3202                 return 0;
3203         }
3204         return 2;
3205 #else
3206         return 0;
3207 #endif
3208     }
3209     else
3210     {
3211         if (!conn)
3212         {
3213             try_reconnect();
3214
3215             if (!conn) {
3216                 printf("Session not initialized yet\n");
3217                 return 0;
3218             }
3219         }
3220         if (session_initResponse &&
3221             !ODR_MASK_GET(session_initResponse->options, Z_Options_scan))
3222         {
3223             printf("Target doesn't support scan\n");
3224             return 0;
3225         }
3226         if (*arg)
3227         {
3228             strcpy(last_scan_query, arg);
3229             if (send_scanrequest(set, arg,
3230                                  scan_position, scan_size, 0) < 0)
3231                 return 0;
3232         }
3233         else
3234         {
3235             if (send_scanrequest(set, last_scan_query,
3236                                  1, scan_size, last_scan_line) < 0)
3237                 return 0;
3238         }
3239         return 2;
3240     }
3241 }
3242
3243 int cmd_scan(const char *arg)
3244 {
3245     return cmd_scan_common(0, arg);
3246 }
3247
3248 int cmd_setscan(const char *arg)
3249 {
3250     char setstring[100];
3251     int nor;
3252     if (sscanf(arg, "%99s%n", setstring, &nor) < 1)
3253     {
3254         printf("missing set for setscan\n");
3255         return 0;
3256     }
3257     return cmd_scan_common(setstring, arg + nor);
3258 }
3259
3260 int cmd_schema(const char *arg)
3261 {
3262     xfree(record_schema);
3263     record_schema = 0;
3264     if (arg && *arg)
3265         record_schema = xstrdup(arg);
3266     return 1;
3267 }
3268
3269 int cmd_format(const char *arg)
3270 {
3271     const char *cp = arg;
3272     int nor;
3273     int idx = 0;
3274     int i;
3275     char form_str[41];
3276     if (!arg || !*arg)
3277     {
3278         printf("Usage: format <recordsyntax>\n");
3279         return 0;
3280     }
3281     while (sscanf(cp, "%40s%n", form_str, &nor) >= 1 && nor > 0
3282            && idx < RECORDSYNTAX_MAX)
3283     {
3284         if (strcmp(form_str, "none") && 
3285             !yaz_string_to_oid_odr(yaz_oid_std(), CLASS_RECSYN, form_str, out))
3286         {
3287             printf("Bad format: %s\n", form_str);
3288             return 0;
3289         }
3290         cp += nor;
3291     }
3292     for (i = 0; i < recordsyntax_size; i++)
3293     {
3294         xfree(recordsyntax_list[i]);
3295         recordsyntax_list[i] = 0;
3296     }
3297     
3298     cp = arg;
3299     while (sscanf(cp, "%40s%n", form_str, &nor) >= 1 && nor > 0
3300            && idx < RECORDSYNTAX_MAX)
3301     {
3302         if (!strcmp(form_str, "none"))
3303             break;
3304         recordsyntax_list[idx] = xstrdup(form_str);
3305         cp += nor;
3306         idx++;
3307     }
3308     recordsyntax_size = idx;
3309     return 1;
3310 }
3311
3312 int cmd_elements(const char *arg)
3313 {
3314     static Z_ElementSetNames esn;
3315     static char what[100];
3316
3317     if (!arg || !*arg)
3318     {
3319         elementSetNames = 0;
3320         return 1;
3321     }
3322     strcpy(what, arg);
3323     esn.which = Z_ElementSetNames_generic;
3324     esn.u.generic = what;
3325     elementSetNames = &esn;
3326     return 1;
3327 }
3328
3329 int cmd_querytype(const char *arg)
3330 {
3331     if (!strcmp(arg, "ccl"))
3332         queryType = QueryType_CCL;
3333     else if (!strcmp(arg, "prefix") || !strcmp(arg, "rpn"))
3334         queryType = QueryType_Prefix;
3335     else if (!strcmp(arg, "ccl2rpn") || !strcmp(arg, "cclrpn"))
3336         queryType = QueryType_CCL2RPN;
3337     else if (!strcmp(arg, "cql"))
3338         queryType = QueryType_CQL;
3339     else if (!strcmp(arg, "cql2rpn") || !strcmp(arg, "cqlrpn"))
3340         queryType = QueryType_CQL2RPN;
3341     else
3342     {
3343         printf("Querytype must be one of:\n");
3344         printf(" prefix         - Prefix query\n");
3345         printf(" ccl            - CCL query\n");
3346         printf(" ccl2rpn        - CCL query converted to RPN\n");
3347         printf(" cql            - CQL\n");
3348         printf(" cql2rpn        - CQL query converted to RPN\n");
3349         return 0;
3350     }
3351     return 1;
3352 }
3353
3354 int cmd_refid(const char *arg)
3355 {
3356     xfree(refid);
3357     refid = NULL;
3358     if (*arg)
3359         refid = xstrdup(arg);
3360     return 1;
3361 }
3362
3363 int cmd_close(const char *arg)
3364 {
3365     Z_APDU *apdu;
3366     Z_Close *req;
3367     if (only_z3950())
3368         return 0;
3369     apdu = zget_APDU(out, Z_APDU_close);
3370     req = apdu->u.close;
3371     *req->closeReason = Z_Close_finished;
3372     send_apdu(apdu);
3373     printf("Sent close request.\n");
3374     sent_close = 1;
3375     return 2;
3376 }
3377
3378 int cmd_packagename(const char* arg)
3379 {
3380     xfree(esPackageName);
3381     esPackageName = NULL;
3382     if (*arg)
3383         esPackageName = xstrdup(arg);
3384     return 1;
3385 }
3386
3387 int cmd_proxy(const char* arg)
3388 {
3389     xfree(yazProxy);
3390     yazProxy = 0;
3391     if (*arg)
3392         yazProxy = xstrdup(arg);
3393     return 1;
3394 }
3395
3396 int cmd_marccharset(const char *arg)
3397 {
3398     char l1[30];
3399
3400     *l1 = 0;
3401     if (sscanf(arg, "%29s", l1) < 1)
3402     {
3403         printf("MARC character set is `%s'\n",
3404                marcCharset ? marcCharset: "none");
3405         return 1;
3406     }
3407     xfree(marcCharset);
3408     marcCharset = 0;
3409     if (strcmp(l1, "-") && strcmp(l1, "none"))
3410         marcCharset = xstrdup(l1);
3411     return 1;
3412 }
3413
3414 int cmd_querycharset(const char *arg)
3415 {
3416     char l1[30];
3417
3418     *l1 = 0;
3419     if (sscanf(arg, "%29s", l1) < 1)
3420     {
3421         printf("Query character set is `%s'\n",
3422                queryCharset ? queryCharset: "none");
3423         return 1;
3424     }
3425     xfree(queryCharset);
3426     queryCharset = 0;
3427     if (strcmp(l1, "-") && strcmp(l1, "none"))
3428         queryCharset = xstrdup(l1);
3429     return 1;
3430 }
3431
3432 int cmd_displaycharset(const char *arg)
3433 {
3434     char l1[30];
3435
3436     *l1 = 0;
3437     if (sscanf(arg, "%29s", l1) < 1)
3438     {
3439         printf("Display character set is `%s'\n",
3440                outputCharset ? outputCharset: "none");
3441     }
3442     else
3443     {
3444         xfree(outputCharset);
3445         outputCharset = 0;
3446         if (!strcmp(l1, "auto") && codeset)
3447         {
3448             if (codeset)
3449             {
3450                 printf("Display character set: %s\n", codeset);
3451                 outputCharset = xstrdup(codeset);
3452             }
3453             else
3454                 printf("No codeset found on this system\n");
3455         }
3456         else if (strcmp(l1, "-") && strcmp(l1, "none"))
3457             outputCharset = xstrdup(l1);
3458     }
3459     return 1;
3460 }
3461
3462 int cmd_negcharset(const char *arg)
3463 {
3464     char l1[30];
3465
3466     *l1 = 0;
3467     if (sscanf(arg, "%29s %d %d", l1, &negotiationCharsetRecords,
3468                &negotiationCharsetVersion) < 1)
3469     {
3470         printf("Negotiation character set `%s'\n",
3471                negotiationCharset ? negotiationCharset: "none");
3472         if (negotiationCharset)
3473         {
3474             printf("Records in charset %s\n", negotiationCharsetRecords ?
3475                    "yes" : "no");
3476             printf("Charneg version %d\n", negotiationCharsetVersion);
3477         }
3478     }
3479     else
3480     {
3481         xfree(negotiationCharset);
3482         negotiationCharset = NULL;
3483         if (*l1 && strcmp(l1, "-") && strcmp(l1, "none"))
3484         {
3485             negotiationCharset = xstrdup(l1);
3486             printf("Character set negotiation : %s\n", negotiationCharset);
3487         }
3488     }
3489     return 1;
3490 }
3491
3492 int cmd_charset(const char* arg)
3493 {
3494     char l1[30], l2[30], l3[30], l4[30];
3495
3496     *l1 = *l2 = *l3 = *l4 = '\0';
3497     if (sscanf(arg, "%29s %29s %29s %29s", l1, l2, l3, l4) < 1)
3498     {
3499         cmd_negcharset("");
3500         cmd_displaycharset("");
3501         cmd_marccharset("");
3502         cmd_querycharset("");
3503     }
3504     else
3505     {
3506         cmd_negcharset(l1);
3507         if (*l2)
3508             cmd_displaycharset(l2);
3509         if (*l3)
3510             cmd_marccharset(l3);
3511         if (*l4)
3512             cmd_querycharset(l4);
3513     }
3514     return 1;
3515 }
3516
3517 int cmd_lang(const char* arg)
3518 {
3519     if (*arg == '\0') {
3520         printf("Current language is `%s'\n", yazLang ? yazLang : "none");
3521         return 1;
3522     }
3523     xfree(yazLang);
3524     yazLang = NULL;
3525     if (*arg)
3526         yazLang = xstrdup(arg);
3527     return 1;
3528 }
3529
3530 int cmd_source(const char* arg, int echo )
3531 {
3532     /* first should open the file and read one line at a time.. */
3533     FILE* includeFile;
3534     char line[102400], *cp;
3535
3536     if (strlen(arg) < 1)
3537     {
3538         fprintf(stderr, "Error in source command use a filename\n");
3539         return -1;
3540     }
3541
3542     includeFile = fopen(arg, "r");
3543
3544     if (!includeFile)
3545     {
3546         fprintf(stderr, "Unable to open file %s for reading\n",arg);
3547         return -1;
3548     }
3549
3550     while (fgets(line, sizeof(line), includeFile)) 
3551     {
3552         if (strlen(line) < 2)
3553             continue;
3554         if (line[0] == '#')
3555             continue;
3556
3557         if ((cp = strrchr(line, '\n')))
3558             *cp = '\0';
3559
3560         if (echo)
3561             printf("processing line: %s\n", line);
3562         process_cmd_line(line);
3563     }
3564
3565     if (fclose(includeFile))
3566     {
3567         perror("unable to close include file");
3568         exit(1);
3569     }
3570     return 1;
3571 }
3572
3573 int cmd_source_echo(const char* arg)
3574 {
3575     cmd_source(arg, 1);
3576     return 1;
3577 }
3578
3579 int cmd_source_noecho(const char* arg)
3580 {
3581     cmd_source(arg, 0);
3582     return 1;
3583 }
3584
3585
3586 int cmd_subshell(const char* args)
3587 {
3588     int ret = system(strlen(args) ? args : getenv("SHELL"));
3589     printf("\n");
3590     if (ret)
3591     {
3592         printf("Exit %d\n", ret);
3593     }
3594     return 1;
3595 }
3596
3597 int cmd_set_berfile(const char *arg)
3598 {
3599     if (ber_file && ber_file != stdout && ber_file != stderr)
3600         fclose(ber_file);
3601     if (!strcmp(arg, ""))
3602         ber_file = 0;
3603     else if (!strcmp(arg, "-"))
3604         ber_file = stdout;
3605     else
3606         ber_file = fopen(arg, "a");
3607     return 1;
3608 }
3609
3610 int cmd_set_apdufile(const char *arg)
3611 {
3612     if(apdu_file && apdu_file != stderr && apdu_file != stderr)
3613         fclose(apdu_file);
3614     if (!strcmp(arg, ""))
3615         apdu_file = 0;
3616     else if (!strcmp(arg, "-"))
3617         apdu_file = stderr;
3618     else
3619     {
3620         apdu_file = fopen(arg, "a");
3621         if (!apdu_file)
3622             perror("unable to open apdu log file");
3623     }
3624     if (apdu_file)
3625         odr_setprint(print, apdu_file);
3626     return 1;
3627 }
3628
3629 int cmd_set_cclfile(const char* arg)
3630 {
3631     FILE *inf;
3632
3633     bibset = ccl_qual_mk();
3634     inf = fopen(arg, "r");
3635     if (!inf)
3636         perror("unable to open CCL file");
3637     else
3638     {
3639         ccl_qual_file(bibset, inf);
3640         fclose(inf);
3641     }
3642     strcpy(ccl_fields,arg);
3643     return 0;
3644 }
3645
3646 int cmd_set_cqlfile(const char* arg)
3647 {
3648     cql_transform_t newcqltrans;
3649
3650     if ((newcqltrans = cql_transform_open_fname(arg)) == 0) {
3651         perror("unable to open CQL file");
3652         return 0;
3653     }
3654     if (cqltrans != 0)
3655         cql_transform_close(cqltrans);
3656
3657     cqltrans = newcqltrans;
3658     strcpy(cql_fields, arg);
3659     return 0;
3660 }
3661
3662 int cmd_set_auto_reconnect(const char* arg)