2 * Copyright (c) 1998-1999, Index Data.
3 * See the file LICENSE for details.
4 * Sebastian Hammer, Adam Dickmeiss
6 * $Log: yaz-ir-assoc.cpp,v $
7 * Revision 1.9 1999-04-28 13:29:14 adam
8 * Yet another fix regarding database settings.
10 * Revision 1.8 1999/04/28 13:04:03 adam
11 * Fixed setting of proxy otherInfo so that database(s) are removed.
13 * Revision 1.7 1999/04/21 12:09:01 adam
14 * Many improvements. Modified to proxy server to work with "sessions"
17 * Revision 1.6 1999/04/20 10:30:05 adam
18 * Implemented various stuff for client and proxy. Updated calls
19 * to ODR to reflect new name parameter.
21 * Revision 1.5 1999/04/09 11:46:57 adam
22 * Added object Yaz_Z_Assoc. Much more functional client.
28 #include <yaz-ir-assoc.h>
30 Yaz_IR_Assoc::Yaz_IR_Assoc(IYaz_PDU_Observable *the_PDU_Observable)
31 : Yaz_Z_Assoc(the_PDU_Observable)
33 m_num_databaseNames = 0;
35 m_preferredRecordSyntax = VAL_NONE;
36 m_elementSetNames = 0;
41 const char *db = "Default";
42 set_databaseNames(1, &db);
45 Yaz_IR_Assoc::~Yaz_IR_Assoc()
47 if (m_elementSetNames)
48 delete [] m_elementSetNames->u.generic;
49 delete [] m_elementSetNames;
55 void Yaz_IR_Assoc::get_databaseNames (int *num, char ***list)
57 *num = m_num_databaseNames;
58 *list = m_databaseNames;
61 void Yaz_IR_Assoc::set_databaseNames (int num, const char **list)
64 logf (LOG_LOG, "Yaz_IR_Assoc::set_databaseNames num=%d", num);
65 for (i = 0; i<m_num_databaseNames; i++)
66 delete [] m_databaseNames[i];
67 delete [] m_databaseNames;
68 m_num_databaseNames = num;
69 m_databaseNames = new (char*) [num];
70 for (i = 0; i<m_num_databaseNames; i++)
72 m_databaseNames[i] = new char[strlen(list[i])+1];
73 strcpy(m_databaseNames[i], list[i]);
77 void Yaz_IR_Assoc::set_databaseNames(const char *dblist, const char *sep)
79 const char **list = new (const char*) [strlen(dblist)];
80 char *dbtmp = new char[strlen(dblist)+1];
81 strcpy(dbtmp, dblist);
84 for (char *cp = dbtmp; ; cp++)
85 if (*cp && !strchr(sep, *cp))
99 set_databaseNames (num, list);
104 void Yaz_IR_Assoc::set_preferredRecordSyntax (int value)
106 m_preferredRecordSyntax = value;
109 void Yaz_IR_Assoc::set_preferredRecordSyntax (const char *syntax)
111 m_preferredRecordSyntax = VAL_NONE;
112 if (syntax && *syntax)
113 m_preferredRecordSyntax = oid_getvalbyname (syntax);
116 void Yaz_IR_Assoc::get_preferredRecordSyntax (int *value)
118 *value = m_preferredRecordSyntax;
121 void Yaz_IR_Assoc::get_preferredRecordSyntax (const char **dst)
124 ent.proto = PROTO_Z3950;
125 ent.oclass = CLASS_RECSYN;
126 ent.value = (enum oid_value) m_preferredRecordSyntax;
129 oid_ent_to_oid (&ent, oid);
130 struct oident *entp = oid_getentbyoid (oid);
132 *dst = entp ? entp->desc : "";
135 void Yaz_IR_Assoc::set_elementSetName (const char *elementSetName)
137 if (m_elementSetNames)
138 delete [] m_elementSetNames->u.generic;
139 delete m_elementSetNames;
140 m_elementSetNames = 0;
141 if (elementSetName && *elementSetName)
143 m_elementSetNames = new Z_ElementSetNames;
144 m_elementSetNames->which = Z_ElementSetNames_generic;
145 m_elementSetNames->u.generic = new char[strlen(elementSetName)+1];
146 strcpy (m_elementSetNames->u.generic, elementSetName);
150 void Yaz_IR_Assoc::get_elementSetName (Z_ElementSetNames **elementSetNames)
152 *elementSetNames = m_elementSetNames;
155 void Yaz_IR_Assoc::get_elementSetName (const char **elementSetName)
157 if (!m_elementSetNames ||
158 m_elementSetNames->which != Z_ElementSetNames_generic)
163 *elementSetName = m_elementSetNames->u.generic;
166 void Yaz_IR_Assoc::recv_Z_PDU(Z_APDU *apdu)
168 logf (LOG_LOG, "recv_Z_PDU");
169 m_lastReceived = apdu->which;
172 case Z_APDU_initResponse:
173 logf (LOG_LOG, "recv InitResponse");
174 recv_initResponse(apdu->u.initResponse);
176 case Z_APDU_initRequest:
177 logf (LOG_LOG, "recv InitRequest");
178 recv_initRequest(apdu->u.initRequest);
180 case Z_APDU_searchRequest:
181 logf (LOG_LOG, "recv searchRequest");
182 recv_searchRequest(apdu->u.searchRequest);
184 case Z_APDU_searchResponse:
185 logf (LOG_LOG, "recv searchResponse");
186 recv_searchResponse(apdu->u.searchResponse);
188 case Z_APDU_presentRequest:
189 logf (LOG_LOG, "recv presentRequest");
190 recv_presentRequest(apdu->u.presentRequest);
192 case Z_APDU_presentResponse:
193 logf (LOG_LOG, "recv presentResponse");
194 recv_presentResponse(apdu->u.presentResponse);
199 int Yaz_IR_Assoc::send_searchRequest(Yaz_Z_Query *query)
201 Z_APDU *apdu = create_Z_PDU(Z_APDU_searchRequest);
202 Z_SearchRequest *req = apdu->u.searchRequest;
205 req->query = query->get_Z_Query();
208 get_databaseNames (&req->num_databaseNames, &req->databaseNames);
209 int oid_syntax[OID_SIZE];
211 get_preferredRecordSyntax(&recordSyntax);
212 if (recordSyntax != VAL_NONE)
214 prefsyn.proto = PROTO_Z3950;
215 prefsyn.oclass = CLASS_RECSYN;
216 prefsyn.value = (enum oid_value) recordSyntax;
217 oid_ent_to_oid(&prefsyn, oid_syntax);
218 req->preferredRecordSyntax = oid_syntax;
220 logf (LOG_LOG, "send_searchRequest");
221 assert (req->otherInfo == 0);
224 set_otherInformationString(&req->otherInfo, VAL_COOKIE, 1, m_cookie);
225 assert (req->otherInfo);
227 return send_Z_PDU(apdu);
230 int Yaz_IR_Assoc::send_presentRequest(int start, int number)
232 Z_APDU *apdu = create_Z_PDU(Z_APDU_presentRequest);
233 Z_PresentRequest *req = apdu->u.presentRequest;
235 req->resultSetStartPoint = &start;
236 req->numberOfRecordsRequested = &number;
238 int oid_syntax[OID_SIZE];
241 get_preferredRecordSyntax (&recordSyntax);
242 if (recordSyntax != VAL_NONE)
244 prefsyn.proto = PROTO_Z3950;
245 prefsyn.oclass = CLASS_RECSYN;
246 prefsyn.value = (enum oid_value) recordSyntax;
247 oid_ent_to_oid(&prefsyn, oid_syntax);
248 req->preferredRecordSyntax = oid_syntax;
250 Z_RecordComposition compo;
251 Z_ElementSetNames *elementSetNames;
252 get_elementSetName (&elementSetNames);
255 req->recordComposition = &compo;
256 compo.which = Z_RecordComp_simple;
257 compo.u.simple = elementSetNames;
260 set_otherInformationString(&req->otherInfo, VAL_COOKIE, 1, m_cookie);
261 return send_Z_PDU(apdu);
264 void Yaz_IR_Assoc::set_proxy(const char *str)
270 m_proxy = new char[strlen(str)+1];
271 strcpy (m_proxy, str);
275 void Yaz_IR_Assoc::set_cookie(const char *str)
281 m_cookie = new char[strlen(str)+1];
282 strcpy(m_cookie, str);
286 const char *Yaz_IR_Assoc::get_cookie()
291 void Yaz_IR_Assoc::client(const char *addr)
294 m_host = new char[strlen(addr)+1];
295 strcpy(m_host, addr);
296 const char *zurl_p = (m_proxy ? m_proxy : m_host);
297 char *zurl = new char[strlen(zurl_p)+1];
298 strcpy(zurl, zurl_p);
299 char *dbpart = strchr(zurl, '/');
302 set_databaseNames (dbpart+1, "+ ");
305 Yaz_Z_Assoc::client(zurl);
309 const char *Yaz_IR_Assoc::get_proxy()
314 const char *Yaz_IR_Assoc::get_host()
319 void Yaz_IR_Assoc::recv_searchRequest(Z_SearchRequest *searchRequest)
321 Z_APDU *apdu = create_Z_PDU(Z_APDU_searchResponse);
325 void Yaz_IR_Assoc::recv_presentRequest(Z_PresentRequest *presentRequest)
327 Z_APDU *apdu = create_Z_PDU(Z_APDU_presentResponse);
331 void Yaz_IR_Assoc::recv_initRequest(Z_InitRequest *initRequest)
333 Z_APDU *apdu = create_Z_PDU(Z_APDU_initResponse);
337 void Yaz_IR_Assoc::recv_searchResponse (Z_SearchResponse *searchResponse)
341 void Yaz_IR_Assoc::recv_presentResponse (Z_PresentResponse *presentResponse)
345 void Yaz_IR_Assoc::recv_initResponse(Z_InitResponse *initResponse)
349 int Yaz_IR_Assoc::get_lastReceived()
351 return m_lastReceived;
354 void Yaz_IR_Assoc::set_lastReceived(int lastReceived)
356 m_lastReceived = lastReceived;
359 int Yaz_IR_Assoc::send_initRequest()
361 Z_APDU *apdu = create_Z_PDU(Z_APDU_initRequest);
362 Z_InitRequest *req = apdu->u.initRequest;
364 ODR_MASK_SET(req->options, Z_Options_search);
365 ODR_MASK_SET(req->options, Z_Options_present);
366 ODR_MASK_SET(req->options, Z_Options_namedResultSets);
367 ODR_MASK_SET(req->options, Z_Options_triggerResourceCtrl);
368 ODR_MASK_SET(req->options, Z_Options_scan);
369 ODR_MASK_SET(req->options, Z_Options_sort);
370 ODR_MASK_SET(req->options, Z_Options_extendedServices);
371 ODR_MASK_SET(req->options, Z_Options_delSet);
373 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_1);
374 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_2);
375 ODR_MASK_SET(req->protocolVersion, Z_ProtocolVersion_3);
377 if (m_proxy && m_host)
379 char *rawhost = new char[strlen(m_host)+1];
380 strcpy(rawhost, m_host);
381 char *dbpart = strchr(rawhost, '/');
384 set_databaseNames (dbpart+1, "+ ");
387 set_otherInformationString(&req->otherInfo, VAL_PROXY, 1, rawhost);
391 set_otherInformationString(&req->otherInfo, VAL_COOKIE, 1, m_cookie);
392 return send_Z_PDU(apdu);