1 /* This file is part of Metaproxy.
2 Copyright (C) 2005-2012 Index Data
4 Metaproxy is free software; you can redistribute it and/or modify it under
5 the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2, or (at your option) any later
9 Metaproxy is distributed in the hope that it will be useful, but WITHOUT ANY
10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 #include "gduutil.hpp"
20 #include <metaproxy/util.hpp>
22 #include <yaz/wrbuf.h>
23 #include <yaz/oid_db.h>
24 #include <yaz/querytowrbuf.h>
28 namespace mp = metaproxy_1;
30 // Doxygen doesn't like mp::gdu, so we use this instead
31 namespace mp_util = metaproxy_1::util;
33 std::ostream& std::operator<<(std::ostream& os, Z_GDU& zgdu)
35 if (zgdu.which == Z_GDU_Z3950)
39 os << *(zgdu.u.z3950);
41 else if (zgdu.which == Z_GDU_HTTP_Request)
44 if (zgdu.u.HTTP_Request)
45 os << " " << *(zgdu.u.HTTP_Request);
47 else if (zgdu.which == Z_GDU_HTTP_Response)
49 os << "HTTP_Response";
50 if (zgdu.u.HTTP_Response)
51 os << " " << *(zgdu.u.HTTP_Response);
58 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Request& httpreq)
60 os << httpreq.method << " ";
65 std::ostream& std::operator<<(std::ostream& os, Z_HTTP_Response& httpres)
67 os << httpres.code << " ";
68 os << httpres.content_len;
72 std::ostream& std::operator<<(std::ostream& os, Z_Records & rs)
76 case Z_Records_DBOSD :
79 if (rs.u.nonSurrogateDiagnostic)
80 os << *(rs.u.nonSurrogateDiagnostic);
82 case Z_Records_multipleNSD:
83 os << "Z_Records_multipleNSD";
84 //os << *(rs.u.multipleNonSurDiagnostics);
93 std::ostream& std::operator<<(std::ostream& os, Z_DiagRec& dr)
97 case Z_DiagRec_defaultFormat:
98 if (dr.u.defaultFormat)
99 os << *(dr.u.defaultFormat);
101 case Z_DiagRec_externallyDefined :
102 os << "Z_DiagRec_externallyDefined";
111 std::ostream& std::operator<<(std::ostream& os, Z_DefaultDiagFormat& ddf)
114 os << *(ddf.condition) << " ";
118 case Z_DefaultDiagFormat_v2Addinfo:
119 os << ddf.u.v2Addinfo;
121 case Z_DefaultDiagFormat_v3Addinfo:
122 os << ddf.u.v3Addinfo;
125 os << "Z_DefaultDiagFormat" ;
131 static void dump_opt_string(std::ostream& os, const char *s)
140 static void dump_opt_int(std::ostream& os, const Odr_int *i)
149 std::ostream& std::operator<<(std::ostream& os, Z_APDU& zapdu)
151 switch(zapdu.which) {
153 case Z_APDU_initRequest:
154 os << " " << "initRequest";
158 = zapdu.u.initRequest;
160 Z_IdAuthentication *a = ir->idAuthentication;
161 if (a && a->which == Z_IdAuthentication_idPass)
162 dump_opt_string(os, a->u.idPass->userId);
163 else if (a && a->which == Z_IdAuthentication_open)
164 dump_opt_string(os, a->u.open);
166 dump_opt_string(os, 0);
169 std::list<std::string> vhosts;
170 mp::util::get_vhost_otherinfo(ir->otherInfo, vhosts);
172 copy(vhosts.begin(), vhosts.end(),
173 ostream_iterator<string>(os, " "));
178 dump_opt_string(os, ir->implementationId);
179 dump_opt_string(os, ir->implementationName);
180 dump_opt_string(os, ir->implementationVersion);
183 case Z_APDU_initResponse:
184 os << " " << "initResponse ";
187 = zapdu.u.initResponse;
188 if (ir->result && *(ir->result))
196 dump_opt_string(os, ir->implementationId);
197 dump_opt_string(os, ir->implementationName);
198 dump_opt_string(os, ir->implementationVersion);
201 case Z_APDU_searchRequest:
202 os << " " << "searchRequest" << " ";
205 = zapdu.u.searchRequest;
207 for (int i = 0; i < sr->num_databaseNames; i++)
209 os << sr->databaseNames[i];
210 if (i+1 != sr->num_databaseNames)
214 dump_opt_string(os, sr->resultSetName);
217 if (sr->preferredRecordSyntax)
219 char oid_name_str[OID_STR_MAX];
220 const char *oid_name = yaz_oid_to_string_buf(
221 sr->preferredRecordSyntax, 0, oid_name_str);
230 yaz_query_to_wrbuf(wr, sr->query);
231 os << wrbuf_cstr(wr);
234 case Z_APDU_searchResponse:
235 os << " " << "searchResponse ";
237 Z_SearchResponse *sr = zapdu.u.searchResponse;
238 if (!sr->searchStatus)
240 else if (*sr->searchStatus)
244 if (sr->records && sr->records->which != Z_Records_DBOSD)
246 os << " DIAG " << *sr->records;
250 dump_opt_int(os, sr->resultCount);
251 dump_opt_int(os, sr->numberOfRecordsReturned);
252 dump_opt_int(os, sr->nextResultSetPosition);
256 case Z_APDU_presentRequest:
257 os << " " << "presentRequest";
259 Z_PresentRequest *pr = zapdu.u.presentRequest;
260 dump_opt_string(os, pr->resultSetId);
261 dump_opt_int(os, pr->resultSetStartPoint);
262 dump_opt_int(os, pr->numberOfRecordsRequested);
263 if (pr->preferredRecordSyntax)
265 char oid_name_str[OID_STR_MAX];
266 const char *oid_name = yaz_oid_to_string_buf(
267 pr->preferredRecordSyntax, 0, oid_name_str);
269 os << " " << oid_name;
273 const char * msg = 0;
274 if (pr->recordComposition)
275 msg = mp_util::record_composition_to_esn(pr->recordComposition);
276 dump_opt_string(os, msg);
279 case Z_APDU_presentResponse:
280 os << " " << "presentResponse" << " ";
282 Z_PresentResponse *pr
283 = zapdu.u.presentResponse;
284 if (!pr->presentStatus)
288 switch (*pr->presentStatus)
290 case Z_PresentStatus_success:
292 case Z_PresentStatus_partial_1:
293 os << "Partial-1"; break;
294 case Z_PresentStatus_partial_2:
295 os << "Partial-2"; break;
296 case Z_PresentStatus_partial_3:
297 os << "Partial-3"; break;
298 case Z_PresentStatus_partial_4:
299 os << "Partial-4"; break;
300 case Z_PresentStatus_failure:
301 os << "Failure"; break;
303 os << "Unknown"; break;
306 if (pr->records && pr->records->which != Z_Records_DBOSD)
307 os << " DIAG " << *pr->records;
310 dump_opt_int(os, pr->numberOfRecordsReturned);
311 dump_opt_int(os, pr->nextResultSetPosition);
315 case Z_APDU_deleteResultSetRequest:
316 os << " " << "deleteResultSetRequest";
318 case Z_APDU_deleteResultSetResponse:
319 os << " " << "deleteResultSetResponse";
321 case Z_APDU_accessControlRequest:
322 os << " " << "accessControlRequest";
324 case Z_APDU_accessControlResponse:
325 os << " " << "accessControlResponse";
327 case Z_APDU_resourceControlRequest:
328 os << " " << "resourceControlRequest";
330 case Z_APDU_resourceControlResponse:
331 os << " " << "resourceControlResponse";
333 case Z_APDU_triggerResourceControlRequest:
334 os << " " << "triggerResourceControlRequest";
336 case Z_APDU_resourceReportRequest:
337 os << " " << "resourceReportRequest";
339 case Z_APDU_resourceReportResponse:
340 os << " " << "resourceReportResponse";
342 case Z_APDU_scanRequest:
343 os << " " << "scanRequest" << " ";
345 Z_ScanRequest *sr = zapdu.u.scanRequest;
349 for (int i = 0; i < sr->num_databaseNames; i++)
351 os << sr->databaseNames[i];
352 if (i+1 != sr->num_databaseNames)
355 dump_opt_int(os, sr->numberOfTermsRequested);
356 dump_opt_int(os, sr->preferredPositionInResponse);
357 dump_opt_int(os, sr->stepSize);
360 if (sr->termListAndStartPoint)
363 yaz_scan_to_wrbuf(wr, sr->termListAndStartPoint,
365 os << wrbuf_cstr(wr);
372 case Z_APDU_scanResponse:
373 os << " " << "scanResponse" << " ";
375 Z_ScanResponse *sr = zapdu.u.scanResponse;
382 switch (*sr->scanStatus)
387 case Z_Scan_partial_1:
390 case Z_Scan_partial_2:
393 case Z_Scan_partial_3:
396 case Z_Scan_partial_4:
399 case Z_Scan_partial_5:
409 dump_opt_int(os, sr->numberOfEntriesReturned);
410 dump_opt_int(os, sr->positionOfTerm);
411 dump_opt_int(os, sr->stepSize);
415 case Z_APDU_sortRequest:
416 os << " " << "sortRequest" << " ";
418 case Z_APDU_sortResponse:
419 os << " " << "sortResponse" << " ";
421 case Z_APDU_segmentRequest:
422 os << " " << "segmentRequest" << " ";
424 case Z_APDU_extendedServicesRequest:
425 os << " " << "extendedServicesRequest";
427 Z_ExtendedServicesRequest *er
428 = zapdu.u.extendedServicesRequest;
434 switch(*(er->function))
436 case Z_ExtendedServicesRequest_create:
439 case Z_ExtendedServicesRequest_delete:
442 case Z_ExtendedServicesRequest_modify:
454 os << " " << er->userId ;
459 os << " " << er->packageName;
464 os << " " << er->description;
470 case Z_APDU_extendedServicesResponse:
471 os << " " << "extendedServicesResponse";
473 Z_ExtendedServicesResponse *er
474 = zapdu.u.extendedServicesResponse;
477 if (er->operationStatus)
480 switch (*er->operationStatus)
482 case Z_ExtendedServicesResponse_done:
485 case Z_ExtendedServicesResponse_accepted:
488 case Z_ExtendedServicesResponse_failure:
489 if (er->num_diagnostics)
490 os << "DIAG " << **(er->diagnostics);
504 os << " " << "close" << " ";
506 Z_Close *c = zapdu.u.close;
511 os << *(c->closeReason) << " ";
513 switch (*c->closeReason)
515 case Z_Close_finished:
518 case Z_Close_shutdown:
521 case Z_Close_systemProblem:
522 os << "systemProblem";
524 case Z_Close_costLimit:
527 case Z_Close_resources:
530 case Z_Close_securityViolation:
531 os << "securityViolation";
533 case Z_Close_protocolError:
534 os << "protocolError";
536 case Z_Close_lackOfActivity:
537 os << "lackOfActivity";
539 case Z_Close_peerAbort:
542 case Z_Close_unspecified:
550 if (c->diagnosticInformation)
551 os << " " << c->diagnosticInformation;
555 case Z_APDU_duplicateDetectionRequest:
556 os << " " << "duplicateDetectionRequest";
558 case Z_APDU_duplicateDetectionResponse:
559 os << " " << "duplicateDetectionResponse";
562 os << " " << "Z_APDU " << "UNKNOWN";
574 * c-file-style: "Stroustrup"
575 * indent-tabs-mode: nil
577 * vim: shiftwidth=4 tabstop=8 expandtab