* Sebastian Hammer, Adam Dickmeiss
*
* $Log: client.c,v $
- * Revision 1.10 1995-06-06 14:56:58 quinn
+ * Revision 1.20 1995-08-29 14:24:13 quinn
+ * Added second half of close-handshake
+ *
+ * Revision 1.19 1995/08/29 11:17:28 quinn
+ * Added code to receive close
+ *
+ * Revision 1.18 1995/08/28 12:21:27 quinn
+ * Client can now ask for simple element set names.
+ *
+ * Revision 1.17 1995/08/17 12:45:02 quinn
+ * Fixed minor problems with GRS-1. Added support in c&s.
+ *
+ * Revision 1.16 1995/08/15 12:00:04 quinn
+ * Updated External
+ *
+ * Revision 1.15 1995/06/22 09:28:03 quinn
+ * Fixed bug in SUTRS processing.
+ *
+ * Revision 1.14 1995/06/19 12:37:41 quinn
+ * Added BER dumper.
+ *
+ * Revision 1.13 1995/06/16 10:29:11 quinn
+ * *** empty log message ***
+ *
+ * Revision 1.12 1995/06/15 07:44:57 quinn
+ * Moving to v3.
+ *
+ * Revision 1.11 1995/06/14 15:26:40 quinn
+ * *** empty log message ***
+ *
+ * Revision 1.10 1995/06/06 14:56:58 quinn
* Better diagnostics.
*
* Revision 1.9 1995/06/06 08:15:19 quinn
#endif
#include <proto.h>
-
#include <marcdisp.h>
+#include <diagbib1.h>
#ifdef RPN_QUERY
#ifdef PREFIX_QUERY
#endif
#endif
-#include "../version.h"
-
#define C_PROMPT "Z> "
static ODR out, in, print; /* encoding and decoding streams */
static int smallSetUpperBound = 0;
static int largeSetLowerBound = 1;
static int mediumSetPresentNumber = 0;
+static Z_ElementSetNames *elementSetNames = 0;
static int setno = 1; /* current set offset */
static int protocol = PROTO_Z3950; /* current app protocol */
+static int recordsyntax = VAL_USMARC;
+static int sent_close = 0;
static ODR_MEM session_mem; /* memory handle for init-response */
static Z_InitResponse *session = 0; /* session parameters */
static char last_scan[512] = "0";
ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_1);
ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_2);
+ ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_3);
req->idAuthentication = auth;
if (res->userInformationField)
{
printf("UserInformationfield:\n");
- if (!odr_external(print, (Odr_external**)&res-> userInformationField,
+ if (!z_External(print, (Z_External**)&res-> userInformationField,
0))
{
odr_perror(print, "Printing userinfo\n");
odr_reset(print);
}
- if (res->userInformationField->which == ODR_EXTERNAL_octet)
+ if (res->userInformationField->which == Z_External_octet)
{
printf("Guessing visiblestring:\n");
printf("'%s'\n", res->userInformationField->u. octet_aligned->buf);
/* SEARCH SERVICE ------------------------------ */
+void display_grs1(Z_GenericRecord *r, int level)
+{
+ int i;
+
+ if (!r)
+ return;
+ for (i = 0; i < r->num_elements; i++)
+ {
+ Z_TaggedElement *t;
+
+ printf("%*s", level * 4, "");
+ t = r->elements[i];
+ printf("(");
+ if (t->tagType)
+ printf("%d,", *t->tagType);
+ else
+ printf("?,");
+ if (t->tagValue->which == Z_StringOrNumeric_numeric)
+ printf("%d) ", *t->tagValue->u.numeric);
+ else
+ printf("%s) ", t->tagValue->u.string);
+ if (t->content->which == Z_ElementData_subtree)
+ {
+ printf("\n");
+ display_grs1(t->content->u.subtree, level+1);
+ }
+ else if (t->content->which == Z_ElementData_string)
+ printf("%s\n", t->content->u.string);
+ else
+ printf("??????\n");
+ }
+}
+
void display_record(Z_DatabaseRecord *p)
{
- Odr_external *r = (Odr_external*) p;
+ Z_External *r = (Z_External*) p;
+ oident *ent = oid_getentbyoid(r->direct_reference);
if (r->direct_reference)
{
- oident *ent = oid_getentbyoid(r->direct_reference);
-
printf("Record type: ");
if (ent)
printf("%s\n", ent->desc);
odr_reset(print);
}
}
-#if 1
- if (r->which == ODR_EXTERNAL_octet && p->u.octet_aligned->len)
- {
-#if 1
+ if (r->which == Z_External_octet && p->u.octet_aligned->len)
marc_display ((char*)p->u.octet_aligned->buf, stdout);
-#else
- FILE *ofi = fopen("dump", "a");
- assert(ofi);
- fwrite(p->u.octet_aligned->buf, 1, p->u.octet_aligned->len, ofi);
- fclose(ofi);
- printf("dumped record\n");
-#endif
+ else if (ent->value == VAL_SUTRS)
+ {
+ if (r->which != Z_External_sutrs)
+ {
+ printf("Expecting single SUTRS type for SUTRS.\n");
+ return;
+ }
+ printf("%.*s", r->u.sutrs->len, r->u.sutrs->buf);
}
- else
+ else if (ent->value == VAL_GRS1)
+ {
+ if (r->which != Z_External_grs1)
+ {
+ printf("Expecting single GRS type for GRS.\n");
+ return;
+ }
+ display_grs1(r->u.grs1, 0);
+ }
+ else
{
printf("Unknown record representation.\n");
- if (!odr_external(print, &r, 0))
+ if (!z_External(print, &r, 0))
{
odr_perror(print, "Printing external");
odr_reset(print);
}
}
-#endif
}
static void display_diagrec(Z_DiagRec *p)
{
oident *ent;
+#ifdef Z_95
+ Z_DefaultDiagFormat *r;
+#else
+ Z_DiagRec *r = p;
+#endif
- printf("Diagnostic message from database.\n");
- if (!(ent = oid_getentbyoid(p->diagnosticSetId)) ||
+ printf("Diagnostic message from database:\n");
+#ifdef Z_95
+ if (p->which != Z_DiagRec_defaultFormat)
+ {
+ printf("Diagnostic record not in default format.\n");
+ return;
+ }
+ else
+ r = p->u.defaultFormat;
+#endif
+ if (!(ent = oid_getentbyoid(r->diagnosticSetId)) ||
ent->class != CLASS_DIAGSET || ent->value != VAL_BIB1)
printf("Missing or unknown diagset\n");
- printf("Error condition: %d", *p->condition);
- printf(" -- %s\n", p->addinfo ? p->addinfo : "");
+ printf(" [%d] %s", *r->condition, diagbib1_str(*r->condition));
+ if (r->addinfo && *r->addinfo)
+ printf(" -- %s\n", r->addinfo);
+ else
+ printf("\n");
}
static void display_nameplusrecord(Z_NamePlusRecord *p)
*req->smallSetUpperBound = smallSetUpperBound;
*req->largeSetLowerBound = largeSetLowerBound;
*req->mediumSetPresentNumber = mediumSetPresentNumber;
+ if (smallSetUpperBound > 0 || (largeSetLowerBound > 1 &&
+ mediumSetPresentNumber > 0))
+ {
+ oident prefsyn;
+
+ prefsyn.proto = protocol;
+ prefsyn.class = CLASS_RECSYN;
+ prefsyn.value = recordsyntax;
+ req->preferredRecordSyntax = odr_oiddup(out, oid_getoidbyent(&prefsyn));
+ req->smallSetElementSetNames =
+ req->mediumSetElementSetNames = elementSetNames;
+ }
req->num_databaseNames = 1;
req->databaseNames = &databaseNames;
{
Z_APDU *apdu = zget_APDU(out, Z_APDU_presentRequest);
Z_PresentRequest *req = apdu->u.presentRequest;
+ Z_RecordComposition compo;
+ oident prefsyn;
int nos = 1;
char *p;
char setstring[100];
}
req->resultSetStartPoint = &setno;
req->numberOfRecordsRequested = &nos;
+ prefsyn.proto = protocol;
+ prefsyn.class = CLASS_RECSYN;
+ prefsyn.value = recordsyntax;
+ req->preferredRecordSyntax = oid_getoidbyent(&prefsyn);
+ if (elementSetNames)
+ {
+ req->recordComposition = &compo;
+ compo.which = Z_RecordComp_simple;
+ compo.u.simple = elementSetNames;
+ }
send_apdu(apdu);
printf("Sent presentRequest (%d+%d).\n", setno, nos);
return 2;
}
+void process_close(Z_Close *req)
+{
+ Z_APDU *apdu = zget_APDU(out, Z_APDU_close);
+ Z_Close *res = apdu->u.close;
+
+ static char *reasons[] =
+ {
+ "finished",
+ "shutdown",
+ "systemProblem",
+ "costLimit",
+ "resources",
+ "securityViolation",
+ "protocolError",
+ "lackOfActivity",
+ "peerAbort",
+ "unspecified"
+ };
+
+ printf("Reason: %s, message: %s\n", reasons[*req->closeReason],
+ req->diagnosticInformation ? req->diagnosticInformation : "NULL");
+ if (sent_close)
+ {
+ printf("Goodbye.\n");
+ exit(0);
+ }
+ *res->closeReason = Z_Close_finished;
+ send_apdu(apdu);
+ printf("Sent response.\n");
+ sent_close = 1;
+}
+
static int cmd_show(char *arg)
{
if (!send_presentRequest(arg))
}
if (*arg)
{
- if (send_scanrequest(arg, 5, 19) < 0)
+ if (send_scanrequest(arg, 5, 20) < 0)
return 0;
}
else
- if (send_scanrequest(last_scan, 1, 19) < 0)
+ if (send_scanrequest(last_scan, 1, 20) < 0)
return 0;
return 2;
}
+int cmd_format(char *arg)
+{
+ if (!arg || !*arg)
+ {
+ printf("Usage: format <recordsyntax>\n");
+ return 0;
+ }
+ if (!strcmp(arg, "sutrs"))
+ {
+ printf("Preferred format is SUTRS.\n");
+ recordsyntax = VAL_SUTRS;
+ return 1;
+ }
+ else if (!strcmp(arg, "usmarc"))
+ {
+ printf("Preferred format is USMARC\n");
+ recordsyntax = VAL_USMARC;
+ return 1;
+ }
+ else if (!strcmp(arg, "danmarc"))
+ {
+ printf("Preferred format is DANMARC\n");
+ recordsyntax = VAL_DANMARC;
+ return 1;
+ }
+ else if (!strcmp(arg, "grs1"))
+ {
+ printf("Preferred format is GRS1\n");
+ recordsyntax = VAL_GRS1;
+ return 1;
+ }
+ else
+ {
+ printf("Specify one of {sutrs,usmarc,danmarc,grs1}.\n");
+ return 0;
+ }
+}
+
+int cmd_elements(char *arg)
+{
+ static Z_ElementSetNames esn;
+ static char what[100];
+
+ if (!arg || !*arg)
+ {
+ printf("Usage: elements <esn>\n");
+ return 0;
+ }
+ strcpy(what, arg);
+ esn.which = Z_ElementSetNames_generic;
+ esn.u.generic = what;
+ elementSetNames = &esn;
+ return 1;
+}
+
+int cmd_close(char *arg)
+{
+ Z_APDU *apdu = zget_APDU(out, Z_APDU_close);
+ Z_Close *req = apdu->u.close;
+
+ *req->closeReason = Z_Close_finished;
+ send_apdu(apdu);
+ printf("Sent close request.\n");
+ sent_close = 1;
+ return 2;
+}
+
static void initialize(void)
{
#ifdef RPN_QUERY
{"status", cmd_status, ""},
{"setnames", cmd_setnames, ""},
{"cancel", cmd_cancel, ""},
+ {"format", cmd_format, "<recordsyntax>"},
+ {"elements", cmd_elements, "<elementSetName>"},
+ {"close", cmd_close, ""},
{0,0}
};
char *netbuffer= 0;
if (!z_APDU(in, &apdu, 0))
{
odr_perror(in, "Decoding incoming APDU");
+ fprintf(stderr, "Packet dump:\n---------\n");
+ odr_dumpBER(stderr, netbuffer, res);
+ fprintf(stderr, "---------\n");
exit(1);
}
#if 0
else
printf("No records.\n");
break;
+ case Z_APDU_close:
+ printf("Target has closed the association.\n");
+ process_close(apdu->u.close);
+ break;
default:
printf("Received unknown APDU type (%d).\n",
apdu->which);
projects / yaz-moved-to-github.git / blobdiff