5 * Revision 1.6 1995/02/17 14:41:22 quinn
8 * Revision 1.5 1995/02/17 13:58:01 quinn
9 * First kick at present handling
11 * Revision 1.4 1995/02/16 15:33:45 quinn
12 * Fixed bug in KWAQS generator
14 * Revision 1.3 1995/02/16 15:20:45 quinn
15 * Added initialization of response from search
17 * Revision 1.2 1995/02/16 15:14:53 quinn
18 * Fixed KWAQS-generator
20 * Revision 1.1 1995/02/16 14:47:55 quinn
26 * Interface to the Z39.50 toolkit.
41 struct zass /* Z-assoc */
43 NETBOXPROFILE *ass; /* ZDIST association handle */
44 int fd; /* low-level socket (for select only) */
46 int preferredmessagesize;
47 char *buf; /* intermediary buffer */
50 int rpn2kwaqs(struct ccl_rpn_node *q, char **p)
52 struct ccl_rpn_attr *i;
53 static char *ops[] = {"and", "or", "not"};
59 strcpy(*p, q->u.t.term);
60 (*p) += strlen(q->u.t.term);
65 for (i = q->u.t.attr_list; i; i = i->next)
67 sprintf(*p, "%d,%d%s", i->type, i->value, i->next ?
76 gw_log(GW_LOG_FATAL, ZASS_TYPE, "KWAQS Doesn't support set refs");
78 case CCL_RPN_AND: case CCL_RPN_OR: case CCL_RPN_NOT:
79 strcpy(*p, ops[q->kind]);
80 *p += strlen(ops[q->kind]);
83 if (rpn2kwaqs(q->u.p[0], p) < 0)
87 if (rpn2kwaqs(q->u.p[1], p) < 0)
93 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Unknown RPN node");
98 ZASS zass_open(char *host, int port)
105 if (!(p = malloc(sizeof(*p))))
107 gw_log(GW_LOG_FATAL, ZASS_TYPE, "memory alloc failed");
110 p->maxrecordsize = ZASS_MAXRECORDSIZE;
111 p->preferredmessagesize = ZASS_PREFERREDMESSAGESIZE;
112 if (!(p->buf = malloc(ZASS_MAXRECORDSIZE + 100)))
114 gw_log(GW_LOG_FATAL, ZASS_TYPE, "alloc zass-buffer");
117 if (!(p->ass = NEWSTRUCT(NETBOXPROFILE)))
119 gw_log(GW_LOG_FATAL, ZASS_TYPE, "memory alloc failed");
122 p->ass->TimeOutSec = 120;
123 p->ass->TimeOutUSec = 0;
124 strcpy(p->ass->HostName, host);
127 if (netbox_Open(p->ass) != 1)
129 gw_log(GW_LOG_WARN, ZASS_TYPE, "netbox_Open failed");
132 gw_log(ZASS_DEBUG, ZASS_TYPE, "Opened connection to %s:%d", p->ass->HostName,
134 ireq = InitRequest_CreateInitAllASCII(0, "yy", "yy", p->maxrecordsize,
135 p->preferredmessagesize, ZASS_ID, ZASS_NAME, ZASS_VERSION, 0);
138 gw_log(GW_LOG_FATAL, "ZASS_TYPE", "failed to create initrequest");
141 zutil_GetBEREncodedBuffer(ireq, (unsigned char*)p->buf, &len,
145 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to encode initrequest");
148 InitRequest_Destroy(ireq);
149 if (netbox_SendBuffer(p->ass, p->buf, len) != len)
151 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to send initrequest");
154 gw_log(ZASS_DEBUG, ZASS_TYPE, "Sent initrequest.");
155 if ((len = zutil_GetBERFromNet(p->ass, (unsigned char*)p->buf,
156 p->maxrecordsize)) <= 0)
158 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to receive initresponse");
161 ires = (PINITRESPONSE) zutil_CreateFromData((unsigned char*)p->buf, len);
162 if (InitResponse_GetTag(ires) != INITRESPONSE_TAG)
164 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Expected initresponse from target");
167 gw_log(ZASS_DEBUG, ZASS_TYPE, "Got initresponse");
168 if (!InitResponse_GetResult(ires))
170 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Access to target denied.");
173 gw_log(ZASS_DEBUG, ZASS_TYPE, "Connected OK");
174 p->preferredmessagesize = InitResponse_GetPreferredMessageSize(ires);
175 p->maxrecordsize = InitResponse_GetExceptionalRecordSize(ires);
176 InitResponse_Destroy(ires);
180 const struct zass_searchent *zass_search(ZASS a, struct ccl_rpn_node *query,
181 char *resname, char *databases)
183 static struct zass_searchent r;
185 DATA_DIR *pdu, *record;
189 if (rpn2kwaqs(query, &p) < 0)
191 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to encode query");
194 gw_log(ZASS_DEBUG, ZASS_TYPE, "Query: KWAQS: '%s'", kwaqs);
195 pdu = SearchRequest_CreateInitAllASCII(0, 0, 2, 0, 1, resname, databases,
196 0, 0, 0, kwaqs, BIB1_OID);
199 gw_log(GW_LOG_FATAL, "ZASS_TYPE", "failed to create searchrequest");
202 zutil_GetBEREncodedBuffer(pdu, (unsigned char*)a->buf, &len,
206 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to encode initrequest");
209 SearchRequest_Destroy(pdu);
210 if (netbox_SendBuffer(a->ass, a->buf, len) != len)
212 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to send initrequest");
215 gw_log(ZASS_DEBUG, ZASS_TYPE, "Sent searchrequest.");
216 if ((len = zutil_GetBERFromNet(a->ass, (unsigned char*)a->buf,
217 a->maxrecordsize)) <= 0)
219 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to receive searchresponse");
222 pdu = zutil_CreateFromData((unsigned char*)a->buf, len);
223 if (zutil_GetTag(pdu) != SEARCHRESPONSE_TAG)
225 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Expected serchresponse from target");
228 gw_log(ZASS_DEBUG, ZASS_TYPE, "Got searchresponse");
229 r.status = SearchResponse_GetSearchStatus(pdu);
230 r.num = SearchResponse_GetResultCount(pdu);
231 r.status = SearchResponse_GetResultSetStatus(pdu);
234 if ((record = SearchResponse_GetRecords(pdu)))
236 if (zutil_GetTag(record) == NONSURROGATEDIAGNOSTIC_TAG)
240 r.errcode = zutil_GetTaggedInt(record, ASN1_INTEGER);
241 if ((ad = zutil_GetTaggedObject(record, ASN1_VISIBLESTRING)))
245 if ((s = OctetString_GetASCIIString(ad)))
247 strcpy(r.errstring, s);
253 gw_log(GW_LOG_WARN, ZASS_TYPE, "Got real record in SRCHRESP");
255 SearchResponse_Destroy(pdu);
261 * Triple indirection - that's kinda heavy. We'll fix it later.
262 * There are worse things around, though. Like ZDist.
264 void get_diagrec(zass_record ***p, DATA_DIR *rec)
268 **p = malloc(sizeof(***p));
270 (**p)->errcode = zutil_GetTaggedInt(rec, ASN1_INTEGER);
271 if ((ad = zutil_GetTaggedObject(rec, ASN1_VISIBLESTRING)))
275 if ((s = OctetString_GetASCIIString(ad)))
277 strcpy((**p)->errstring, s);
281 (**p)->which = ZASS_REC_DIAG;
285 void get_responserecords(zass_record ***p, DATA_DIR *rec)
287 int num, recsyntaxlen, i;
288 DATA_DIR *record, *retrec, *align;
290 POBJECTIDENTIFIER oid;
293 num = ResponseRecords_GetCount(rec);
294 for (i = 1; i <= num; i++)
296 record = ResponseRecords_GetRecord(rec, i);
299 gw_log(GW_LOG_WARN, ZASS_TYPE, "Failed to get record.");
302 retrec = NamePlusRecord_GetRetrievalRecord(record);
305 /* check if it's a diagrec */
306 if (record->ptr.child->fldid == 2)
307 get_diagrec(p, record->ptr.child);
310 gw_log(GW_LOG_WARN, ZASS_TYPE, "Illegal record.");
314 ext = RetrievalRecord_GetExternal(retrec);
317 gw_log(GW_LOG_WARN, ZASS_TYPE, "No external in record");
320 oid = External_GetDirectReference(ext);
323 gw_log(GW_LOG_WARN, ZASS_TYPE, "Unknown record type.");
326 recsyntaxlen = DirectReference_GetLength(oid);
327 memcpy(recsyntax, DirectReference_GetData(oid), recsyntaxlen);
328 recsyntax[recsyntaxlen] = '\0';
329 **p = malloc(sizeof(***p));
331 if (!strcmp(recsyntax, USMARC_OID))
332 (**p)->which = ZASS_REC_USMARC;
335 gw_log(GW_LOG_WARN, ZASS_TYPE, "ZLAYER only knows USMARC at this point.");
338 align = External_GetEncodingAligned(ext);
341 gw_log(GW_LOG_WARN, ZASS_TYPE, "AAAARRRGH!! Enough of these log-messages!!!");
344 if (!((**p)->record = malloc(align->count + 1)))
346 gw_log(GW_LOG_FATAL, ZASS_TYPE, "malloc");
349 memcpy((**p)->record, align->ptr.data, align->count);
350 (**p)->record[align->count] = '\0';
351 gw_log(ZASS_DEBUG, ZASS_TYPE, "Got a record of %d bytes",
358 static void zass_records_free(zass_record *p)
363 * Note that 1== first record.
365 const struct zass_presentent *zass_present(ZASS a, char *resname, int start,
368 static struct zass_presentent r = {0, 0, 0, 0};
369 zass_record **rec = &r.records;
376 zass_records_free(r.records);
381 gw_log(ZASS_DEBUG, ZASS_TYPE, "Fetching %d records from # %d", num,
383 pdu = PresentRequest_CreateInitAllASCII(0, resname, start, num, "F",
387 gw_log(GW_LOG_FATAL, "ZASS_TYPE", "failed to create presentrequest");
390 zutil_GetBEREncodedBuffer(pdu, (unsigned char*)a->buf, &len,
394 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to encode presentrequest");
397 PresentRequest_Destroy(pdu);
398 if (netbox_SendBuffer(a->ass, a->buf, len) != len)
400 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to send presentrequest");
403 gw_log(ZASS_DEBUG, ZASS_TYPE, "Sent presentrequest.");
404 if ((len = zutil_GetBERFromNet(a->ass, (unsigned char*)a->buf,
405 a->maxrecordsize)) <= 0)
407 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Failed to receive presentresponse");
410 pdu = zutil_CreateFromData((unsigned char*)a->buf, len);
411 if (zutil_GetTag(pdu) != PRESENTRESPONSE_TAG)
413 gw_log(GW_LOG_FATAL, ZASS_TYPE, "Expected presentresponse from target");
416 gw_log(ZASS_DEBUG, ZASS_TYPE, "Got presentresponse");
417 r.num = PresentResponse_GetNumberOfRecordsReturned(pdu);
420 gw_log(GW_LOG_WARN, ZASS_TYPE, "Got 0 records from target.");
423 r.nextpos = PresentResponse_GetNextResultSetPosition(pdu);
426 switch(PresentResponse_GetRecordType(pdu))
428 case RESPONSERECORDS_TAG:
429 get_responserecords(&rec, PresentResponse_GetResponseRecords(pdu));
431 case NONSURROGATEDIAGNOSTIC_TAG:
432 get_diagrec(&rec, PresentResponse_GetNonSurrogateDiagnostic(pdu));
435 gw_log(GW_LOG_WARN, ZASS_TYPE, "Bad tag in response rec.");
440 PresentResponse_Destroy(pdu);