+/* ------------------------------------------------------- */
+/*
+ * do_search: Do search request
+ */
+static int do_search (void *o, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ Z_SearchRequest req;
+ Z_Query query;
+ Z_APDU apdu, *apdup;
+ static Odr_oid bib1[] = {1, 2, 840, 10003, 3, 1, -1};
+ Odr_oct ccl_query;
+ IRSetObj *obj = o;
+ IRObj *p = obj->parent;
+ char *sbuf;
+ int slen;
+
+ p->child = o;
+ if (argc != 3)
+ {
+ interp->result = "wrong # args";
+ return TCL_ERROR;
+ }
+ if (!p->num_databaseNames)
+ {
+ interp->result = "no databaseNames";
+ return TCL_ERROR;
+ }
+ apdu.which = Z_APDU_searchRequest;
+ apdu.u.searchRequest = &req;
+ apdup = &apdu;
+
+ req.referenceId = 0;
+ req.smallSetUpperBound = &p->smallSetUpperBound;
+ req.largeSetLowerBound = &p->largeSetLowerBound;
+ req.mediumSetPresentNumber = &p->mediumSetPresentNumber;
+ req.replaceIndicator = &p->replaceIndicator;
+ req.resultSetName = "Default";
+ req.num_databaseNames = p->num_databaseNames;
+ req.databaseNames = p->databaseNames;
+ req.smallSetElementSetNames = 0;
+ req.mediumSetElementSetNames = 0;
+ req.preferredRecordSyntax = 0;
+ req.query = &query;
+
+ if (!strcmp (p->query_method, "rpn"))
+ {
+ int error;
+ int pos;
+ struct ccl_rpn_node *rpn;
+ Z_RPNQuery *RPNquery;
+
+ rpn = ccl_find_str(p->bibset, argv[2], &error, &pos);
+ if (error)
+ {
+ Tcl_AppendResult (interp, "CCL error: ", ccl_err_msg(error),NULL);
+ return TCL_ERROR;
+ }
+ query.which = Z_Query_type_1;
+ assert((RPNquery = ccl_rpn_query(rpn)));
+ RPNquery->attributeSetId = bib1;
+ query.u.type_1 = RPNquery;
+ }
+ else if (!strcmp (p->query_method, "ccl"))
+ {
+ query.which = Z_Query_type_2;
+ query.u.type_2 = &ccl_query;
+ ccl_query.buf = argv[2];
+ ccl_query.len = strlen (argv[2]);
+ }
+ else
+ {
+ interp->result = "unknown query method";
+ return TCL_ERROR;
+ }
+ if (!z_APDU (p->odr_out, &apdup, 0))
+ {
+ interp->result = odr_errlist [odr_geterror (p->odr_out)];
+ odr_reset (p->odr_out);
+ return TCL_ERROR;
+ }
+ sbuf = odr_getbuf (p->odr_out, &slen);
+ if (cs_put (p->cs_link, sbuf, slen) < 0)
+ {
+ interp->result = "cs_put failed in init";
+ return TCL_ERROR;
+ }
+ printf ("Search request\n");
+ return TCL_OK;
+}
+
+/*
+ * do_resultCount: Get number of hits
+ */
+static int do_resultCount (void *o, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ IRSetObj *obj = o;
+
+ sprintf (interp->result, "%d", obj->resultCount);
+ return TCL_OK;
+}
+
+/*
+ * do_numberOfRecordsReturned: Get number of records returned
+ */
+static int do_numberOfRecordsReturned (void *o, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ IRSetObj *obj = o;
+
+ sprintf (interp->result, "%d", obj->numberOfRecordsReturned);
+ return TCL_OK;
+}
+
+static int marc_cmp (const char *field, const char *pattern)
+{
+ if (*pattern == '*')
+ return 0;
+ for (; *field && *pattern; field++, pattern++)
+ {
+ if (*pattern == '?')
+ continue;
+ if (*pattern != *field)
+ break;
+ }
+ return *field - *pattern;
+}
+
+static int get_marc_fields(Tcl_Interp *interp, Iso2709Rec rec,
+ int argc, char **argv)
+{
+ struct iso2709_dir *dir;
+ struct iso2709_field *field;
+
+ for (dir = rec->directory; dir; dir = dir->next)
+ {
+ if (argc > 4 && marc_cmp (dir->tag, argv[4]))
+ continue;
+ if (argc > 5 && marc_cmp (dir->indicator, argv[5]))
+ continue;
+ for (field = dir->fields; field; field = field->next)
+ {
+ if (argc > 6 && marc_cmp (field->identifier, argv[6]))
+ continue;
+ Tcl_AppendElement (interp, field->data);
+ }
+ }
+ return TCL_OK;
+}
+
+static int get_marc_lines (Tcl_Interp *interp, Iso2709Rec rec,
+ int argc, char **argv)
+{
+ struct iso2709_dir *dir;
+ struct iso2709_field *field;
+
+ for (dir = rec->directory; dir; dir = dir->next)
+ {
+ if (argc > 4 && marc_cmp (dir->tag, argv[4]))
+ continue;
+ if (!dir->indicator)
+ Tcl_AppendResult (interp, "{", dir->tag, " {} {", NULL);
+ else
+ {
+ if (argc > 5 && marc_cmp (dir->indicator, argv[5]))
+ continue;
+ Tcl_AppendResult (interp, "{", dir->tag, " {", dir->indicator,
+ "} {", NULL);
+ }
+ for (field = dir->fields; field; field = field->next)
+ {
+ if (!field->identifier)
+ Tcl_AppendResult (interp, "{{} ", NULL);
+ else
+ {
+ if (argc > 6 && marc_cmp (field->identifier, argv[6]))
+ continue;
+ Tcl_AppendResult (interp, "{", field->identifier, " ", NULL);
+ }
+ Tcl_AppendResult (interp, "{", field->data, "}", NULL);
+ Tcl_AppendResult (interp, "} ", NULL);
+ }
+ Tcl_AppendResult (interp, "}} ", NULL);
+ }
+ return TCL_OK;
+}
+
+/*
+ * do_recordType: Return record type (if any) at position.
+ */
+static int do_recordType (void *o, Tcl_Interp *interp, int argc, char **argv)
+{
+ IRSetObj *obj = o;
+ int offset;
+ IRRecordList *rl;
+
+ if (argc < 3)
+ {
+ sprintf (interp->result, "wrong # args");
+ return TCL_ERROR;
+ }
+ if (Tcl_GetInt (interp, argv[2], &offset)==TCL_ERROR)
+ return TCL_ERROR;
+ for (rl = obj->record_list; rl; rl = rl->next)
+ {
+ if (rl->no == offset)
+ break;
+ }
+ if (!rl)
+ return TCL_OK;
+ switch (rl->which)
+ {
+ case Z_NamePlusRecord_databaseRecord:
+ interp->result = "databaseRecord";
+ break;
+ case Z_NamePlusRecord_surrogateDiagnostic:
+ interp->result = "surrogateDiagnostic";
+ break;
+ default:
+ interp->result = "unknown";
+ break;
+ }
+ return TCL_OK;
+}
+
+/*
+ * do_recordDiag: Return diagnostic record info
+ */
+static int do_recordDiag (void *o, Tcl_Interp *interp, int argc, char **argv)
+{
+ IRSetObj *obj = o;
+ int offset;
+ IRRecordList *rl;
+ char buf[20];
+
+ if (argc < 3)
+ {
+ sprintf (interp->result, "wrong # args");
+ return TCL_ERROR;
+ }
+ if (Tcl_GetInt (interp, argv[2], &offset)==TCL_ERROR)
+ return TCL_ERROR;
+ for (rl = obj->record_list; rl; rl = rl->next)
+ {
+ if (rl->no == offset)
+ break;
+ }
+ if (!rl)
+ {
+ Tcl_AppendResult (interp, "No record at #", argv[2], NULL);
+ return TCL_ERROR;
+ }
+ if (rl->which != Z_NamePlusRecord_surrogateDiagnostic)
+ {
+ Tcl_AppendResult (interp, "No Diagnostic record at #", argv[2], NULL);
+ return TCL_ERROR;
+ }
+ sprintf (buf, "%d ", rl->u.diag.code);
+ Tcl_AppendResult (interp, buf, NULL);
+ if (rl->u.diag.add_info)
+ Tcl_AppendElement (interp, rl->u.diag.add_info);
+ else
+ Tcl_AppendElement (interp, "");
+ return TCL_OK;
+}
+
+/*
+ * do_recordMarc: Get ISO2709 Record lines/fields
+ */
+static int do_recordMarc (void *o, Tcl_Interp *interp, int argc, char **argv)
+{
+ IRSetObj *obj = o;
+ int offset;
+ IRRecordList *rl;
+
+ if (argc < 4)
+ {
+ sprintf (interp->result, "wrong # args");
+ return TCL_ERROR;
+ }
+ if (Tcl_GetInt (interp, argv[2], &offset)==TCL_ERROR)
+ return TCL_ERROR;
+ for (rl = obj->record_list; rl; rl = rl->next)
+ if (rl->no == offset)
+ break;
+ if (!rl)
+ {
+ Tcl_AppendResult (interp, "No record at #", argv[2], NULL);
+ return TCL_ERROR;
+ }
+ if (rl->which != Z_NamePlusRecord_databaseRecord)
+ {
+ Tcl_AppendResult (interp, "No MARC record at #", argv[2], NULL);
+ return TCL_ERROR;
+ }
+ if (!strcmp (argv[3], "field"))
+ return get_marc_fields (interp, rl->u.marc.rec, argc, argv);
+ else if (!strcmp (argv[3], "line"))
+ return get_marc_lines (interp, rl->u.marc.rec, argc, argv);
+ else
+ {
+ Tcl_AppendResult (interp, "field/line expected", NULL);
+ return TCL_ERROR;
+ }
+}
+
+/*
+ * do_present: Perform Present Request
+ */
+
+static int do_present (void *o, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ IRSetObj *obj = o;
+ IRObj *p = obj->parent;
+ Z_APDU apdu, *apdup;
+ Z_PresentRequest req;
+ int start;
+ int number;
+ char *sbuf;
+ int slen;
+
+ if (argc >= 3)
+ {
+ if (Tcl_GetInt (interp, argv[2], &start) == TCL_ERROR)
+ return TCL_ERROR;
+ }
+ else
+ start = 1;
+ if (argc >= 4)
+ {
+ if (Tcl_GetInt (interp, argv[3], &number) == TCL_ERROR)
+ return TCL_ERROR;
+ }
+ else
+ number = 10;
+ obj->start = start;
+ obj->number = number;
+
+ apdup = &apdu;
+ apdu.which = Z_APDU_presentRequest;
+ apdu.u.presentRequest = &req;
+ req.referenceId = 0;
+ /* sprintf(setstring, "%d", setnumber); */
+ req.resultSetId = "Default";
+ req.resultSetStartPoint = &start;
+ req.numberOfRecordsRequested = &number;
+ req.elementSetNames = 0;
+ req.preferredRecordSyntax = 0;
+
+ if (!z_APDU (p->odr_out, &apdup, 0))
+ {
+ interp->result = odr_errlist [odr_geterror (p->odr_out)];
+ odr_reset (p->odr_out);
+ return TCL_ERROR;
+ }
+ sbuf = odr_getbuf (p->odr_out, &slen);
+ if (cs_put (p->cs_link, sbuf, slen) < 0)
+ {
+ interp->result = "cs_put failed in init";
+ return TCL_ERROR;
+ }
+ printf ("Present request, start=%d, num=%d\n", start, number);
+ return TCL_OK;
+}
+
+/*
+ * do_loadFile: Load result set from file
+ */
+
+static int do_loadFile (void *o, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ IRSetObj *setobj = o;
+ FILE *inf;
+ int no = 1;
+ const char *buf;
+
+ if (argc < 3)
+ {
+ interp->result = "wrong # args";
+ return TCL_ERROR;
+ }
+ inf = fopen (argv[2], "r");
+ if (!inf)
+ {
+ Tcl_AppendResult (interp, "Cannot open ", argv[2], NULL);
+ return TCL_ERROR;
+ }
+ while ((buf = iso2709_read (inf)))
+ {
+ IRRecordList *rl;
+ Iso2709Rec rec;
+
+ rec = iso2709_cvt (buf);
+ if (!rec)
+ break;
+ for (rl = setobj->record_list; rl; rl = rl->next)
+ {
+ if (no == rl->no)
+ {
+ if (rl->which == Z_NamePlusRecord_databaseRecord)
+ iso2709_rm (rl->u.marc.rec);
+ break;
+ }
+ }
+ if (!rl)
+ {
+ rl = malloc (sizeof(*rl));
+ assert (rl);
+ rl->next = setobj->record_list;
+ rl->no = no;
+ setobj->record_list = rl;
+ }
+ rl->which = Z_NamePlusRecord_databaseRecord;
+ rl->u.marc.rec = rec;
+ no++;
+ }
+ setobj->numberOfRecordsReturned = no-1;
+ fclose (inf);
+ return TCL_OK;
+}
+
+
+/*
+ * ir_set_obj_method: IR Set Object methods
+ */
+static int ir_set_obj_method (ClientData clientData, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ static IRMethod tab[] = {
+ { 0, "search", do_search },
+ { 0, "resultCount", do_resultCount },
+ { 0, "numberOfRecordsReturned", do_numberOfRecordsReturned },
+ { 0, "present", do_present },
+ { 0, "recordType", do_recordType },
+ { 0, "recordMarc", do_recordMarc },
+ { 0, "recordDiag", do_recordDiag },
+ { 0, "loadFile", do_loadFile },
+ { 0, NULL, NULL}
+ };
+
+ if (argc < 2)
+ {
+ interp->result = "wrong # args";
+ return TCL_ERROR;
+ }
+ return ir_method (clientData, interp, argc, argv, tab);
+}
+
+/*
+ * ir_set_obj_delete: IR Set Object disposal
+ */
+static void ir_set_obj_delete (ClientData clientData)
+{
+ free ( (void*) clientData);
+}
+
+/*
+ * ir_set_obj_mk: IR Set Object creation
+ */
+static int ir_set_obj_mk (ClientData clientData, Tcl_Interp *interp,
+ int argc, char **argv)
+{
+ Tcl_CmdInfo parent_info;
+ IRSetObj *obj;
+
+ if (argc != 2)
+ {
+ interp->result = "wrong # args";
+ return TCL_ERROR;
+ }
+ if (get_parent_info (interp, argv[1], &parent_info) == TCL_ERROR)
+ return TCL_ERROR;
+ if (!(obj = ir_malloc (interp, sizeof(*obj))))
+ return TCL_ERROR;
+ obj->z_records = NULL;
+ obj->record_list = NULL;
+ obj->parent = (IRObj *) parent_info.clientData;
+ Tcl_CreateCommand (interp, argv[1], ir_set_obj_method,
+ (ClientData) obj, ir_set_obj_delete);
+ return TCL_OK;
+}
+
+/* ------------------------------------------------------- */
+
+static void ir_searchResponse (void *o, Z_SearchResponse *searchrs)
+{
+ IRObj *p = o;
+ IRSetObj *obj = p->child;
+
+ if (obj)
+ obj->resultCount = *searchrs->resultCount;
+ if (searchrs->searchStatus)
+ printf("Search was a success.\n");
+ else
+ printf("Search was a bloomin' failure.\n");
+ printf("Number of hits: %d\n", *searchrs->resultCount);
+}
+
+static void ir_initResponse (void *obj, Z_InitResponse *initrs)
+{
+ if (!*initrs->result)
+ printf("Connection rejected by target.\n");
+ else
+ printf("Connection accepted by target.\n");
+ if (initrs->implementationId)
+ printf("ID : %s\n", initrs->implementationId);
+ if (initrs->implementationName)
+ printf("Name : %s\n", initrs->implementationName);
+ if (initrs->implementationVersion)
+ printf("Version: %s\n", initrs->implementationVersion);
+#if 0
+ if (initrs->userInformationField)
+ {
+ printf("UserInformationfield:\n");
+ odr_external(&print, (Odr_external**)&initrs->
+ userInformationField, 0);
+ }
+#endif
+}
+
+static void ir_presentResponse (void *o, Z_PresentResponse *presrs)
+{
+ IRObj *p = o;
+ IRSetObj *setobj = p->child;
+ Z_Records *zrs = presrs->records;
+ setobj->z_records = presrs->records;
+
+ printf ("Received presentResponse\n");
+ if (zrs)
+ {
+ if (zrs->which == Z_Records_NSD)
+ {
+ setobj->numberOfRecordsReturned = 0;
+ printf ("They are diagnostic!!!\n");
+ /*
+ char buf[16];
+ sprintf (buf, "%d", *zrs->u.nonSurrogateDiagnostic->condition);
+ Tcl_AppendResult (interp, "Diagnostic message: ", buf,
+ " : ",
+ zrs->u.nonSurrogateDiagnostic->addinfo, NULL);
+ return TCL_ERROR;
+ */
+ return;
+ }
+ else
+ {
+ int offset;
+ IRRecordList *rl;
+
+ setobj->numberOfRecordsReturned =
+ zrs->u.databaseOrSurDiagnostics->num_records;
+ printf ("Got %d records\n", setobj->numberOfRecordsReturned);
+ for (offset = 0; offset<setobj->numberOfRecordsReturned; offset++)
+ {
+ int no = setobj->start + offset;
+
+ for (rl = setobj->record_list; rl; rl = rl->next)
+ {
+ if (no == rl->no)
+ {
+ if (rl->which == Z_NamePlusRecord_databaseRecord)
+ iso2709_rm (rl->u.marc.rec);
+ break;
+ }
+ }
+ if (!rl)
+ {
+ rl = malloc (sizeof(*rl));
+ assert (rl);
+ rl->next = setobj->record_list;
+ rl->no = no;
+ setobj->record_list = rl;
+ }
+ rl->which = zrs->u.databaseOrSurDiagnostics->
+ records[offset]->which;
+ if (rl->which == Z_NamePlusRecord_surrogateDiagnostic)
+ {
+ rl->u.diag.code = 0;
+ rl->u.diag.add_info = NULL;
+ }
+ else
+ {
+ Z_DatabaseRecord *zr;
+ Odr_external *oe;
+
+ zr = zrs->u.databaseOrSurDiagnostics->records[offset]
+ ->u.databaseRecord;
+ oe = (Odr_external*) zr;
+ if (oe->which == ODR_EXTERNAL_octet
+ && zr->u.octet_aligned->len)
+ {
+ const char *buf = (char*) zr->u.octet_aligned->buf;
+ rl->u.marc.rec = iso2709_cvt (buf);
+ }
+ else
+ rl->u.marc.rec = NULL;
+ }
+ }
+ }
+ }
+ else
+ {
+ printf ("No records!\n");
+ }
+}
+
+void ir_select_proc (ClientData clientData)
+{
+ IRObj *p = clientData;
+ Z_APDU *apdu;
+ int r;
+
+ do
+ {
+ if ((r=cs_get (p->cs_link, &p->buf_in, &p->len_in)) <= 0)
+ {
+ printf ("cs_get failed\n");
+ ir_select_remove (cs_fileno (p->cs_link), p);
+ return;
+ }
+ odr_setbuf (p->odr_in, p->buf_in, r);
+ printf ("cs_get ok, got %d\n", r);
+ if (!z_APDU (p->odr_in, &apdu, 0))
+ {
+ printf ("%s\n", odr_errlist [odr_geterror (p->odr_in)]);
+ return;
+ }
+ switch(apdu->which)
+ {
+ case Z_APDU_initResponse:
+ ir_initResponse (p, apdu->u.initResponse);
+ break;
+ case Z_APDU_searchResponse:
+ ir_searchResponse (p, apdu->u.searchResponse);
+ break;
+ case Z_APDU_presentResponse:
+ ir_presentResponse (p, apdu->u.presentResponse);
+ break;
+ default:
+ printf("Received unknown APDU type (%d).\n",
+ apdu->which);
+ }
+ if (p->callback)
+ Tcl_Eval (p->interp, p->callback);
+ } while (cs_more (p->cs_link));
+}
+
+/* ------------------------------------------------------- */
+