Same Ubuntu list as YAZ
[yazproxy-moved-to-github.git] / src / proxyp.h
1 /* This file is part of YAZ proxy
2    Copyright (C) 1998-2011 Index Data
3
4 YAZ proxy 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
7 version.
8
9 YAZ proxy 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
12 for more details.
13
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
17 */
18
19 #if YAZ_HAVE_XSLT
20 #include <libxml/parser.h>
21 #include <libxml/tree.h>
22 #include <libxml/xinclude.h>
23 #include <libxslt/xsltutils.h>
24 #include <libxslt/transform.h>
25 #endif
26
27 #if HAVE_USEMARCON
28 #include <usemarconlib.h>
29 #include <defines.h>
30 #endif
31
32 #include <yazpp/record-cache.h>
33 #include <yazproxy/proxy.h>
34 #include <yazproxy/module.h>
35
36 struct Yaz_RecordCache_Entry;
37
38 class Yaz_usemarcon {
39  public:
40     Yaz_usemarcon();
41     ~Yaz_usemarcon();
42
43     int convert(const char *stage1, const char *stage2,
44                 const char *input, int input_len,
45                 char **output, int *output_len);
46 #if HAVE_USEMARCON
47     Usemarcon *m_stage1;
48     Usemarcon *m_stage2;
49 #else
50     int dummy;
51 #endif
52 };
53
54 class Yaz_CharsetConverter {
55 public:
56     Yaz_CharsetConverter();
57     ~Yaz_CharsetConverter();
58     void set_target_query_charset(const char *s);
59     void set_client_query_charset(const char *org);
60     const char *get_client_query_charset(void);
61     const char *get_target_query_charset(void);
62     void convert_type_1(Z_RPNQuery *q, ODR o);
63     void convert_term(Z_Term *q, ODR o);
64     void set_client_charset_selected(int sel);
65     int get_client_charset_selected();
66 private:
67     void convert_type_1(char *buf_in, int len_in,
68                         char **buf_out, int *len_out,
69                         ODR o);
70     void convert_type_1(Z_Term *q, ODR o);
71     void convert_type_1(Z_RPNStructure *q, ODR o);
72     void convert_type_1(Z_Operand *q, ODR o);
73     char *m_target_query_charset;
74     char *m_client_query_charset;
75     int m_client_charset_selected;
76     yaz_iconv_t m_ct;
77     WRBUF m_wrbuf;
78 };
79
80 class Yaz_ProxyConfig {
81 public:
82     Yaz_ProxyConfig();
83     ~Yaz_ProxyConfig();
84     int read_xml(const char *fname);
85
86     int get_target_no(int no,
87                       const char **name,
88                       const char **url,
89                       int *limit_bw,
90                       int *limit_pdu,
91                       int *limit_req,
92                       int *limit_search,
93                       int *target_idletime,
94                       int *client_idletime,
95                       int *max_sockets,
96                       int *max_clients,
97                       int *keepalive_limit_bw,
98                       int *keepalive_limit_pdu,
99                       int *pre_init,
100                       const char **cql2rpn,
101                       const char **authentication,
102                       const char **negotiation_charset,
103                       const char **negotiation_lang,
104                       const char **query_charset,
105                       const char **default_client_query_charset);
106
107     void get_generic_info(int *log_mask, int *max_clients,
108                           int *max_connect, int *limit_connect,
109                           int *period_connect,
110                           int *msg_threads);
111
112     int get_file_access_info(const char *path);
113
114     void get_target_info(const char *name, const char **url,
115                          int *limit_bw, int *limit_pdu, int *limit_req,
116                          int *limit_search,
117                          int *target_idletime, int *client_idletime,
118                          int *max_sockets,
119                          int *max_clients,
120                          int *keepalive_limit_bw, int *keepalive_limit_pdu,
121                          int *pre_init,
122                          const char **cql2rpn,
123                          const char **negotiation_charset,
124                          const char **negotiation_lang,
125                          const char **query_charset,
126                          const char **default_client_query_charset);
127
128     const char *check_mime_type(const char *path);
129     int check_query(ODR odr, const char *name, Z_Query *query, char **addinfo);
130     int check_syntax(ODR odr, const char *name,
131                      Odr_oid *syntax, Z_RecordComposition *comp,
132                      char **addinfo, char **stylesheet, char **schema,
133                      char **backend_type, char **backend_charset,
134                      char **usemarcon_ini_stage1, char **usemarcon_ini_stage2,
135                      char **backend_elementset);
136
137     void target_authentication(const char *name,
138                                ODR odr,
139                                Z_InitRequest *req);
140
141     int client_authentication(const char *name,
142                               const char *user, const char *group,
143                               const char *password,
144                               const char *peer_IP);
145     int global_client_authentication(const char *user, const char *group,
146                                      const char *password,
147                                      const char *peer_IP);
148     char *get_explain_doc(ODR odr, const char *name, const char *db,
149                           int *len, int *http_status);
150     const char *get_explain_name(const char *db, const char **backend_db);
151  private:
152     void operator=(const Yaz_ProxyConfig &conf);
153     class Yaz_ProxyConfigP *m_cp;
154 };
155
156 class Yaz_ProxyClient : public yazpp_1::Z_Assoc {
157     friend class Yaz_Proxy;
158     Yaz_ProxyClient(yazpp_1::IPDU_Observable *the_PDU_Observable,
159                     Yaz_Proxy *parent);
160     ~Yaz_ProxyClient();
161     void recv_GDU(Z_GDU *apdu, int len);
162     void recv_Z_PDU(Z_APDU *apdu, int len);
163     void recv_HTTP_response(Z_HTTP_Response *apdu, int len);
164     IPDU_Observer* sessionNotify
165         (yazpp_1::IPDU_Observable *the_PDU_Observable, int fd);
166     void shutdown();
167     Yaz_Proxy *m_server;
168     void failNotify();
169     void timeoutNotify();
170     void connectNotify();
171     int send_to_target(Z_APDU *apdu);
172     const char *get_session_str();
173     char *m_cookie;
174     Yaz_ProxyClient *m_next;
175     Yaz_ProxyClient **m_prev;
176     int m_init_flag;
177     yazpp_1::Yaz_Z_Query *m_last_query;
178     yazpp_1::Yaz_Z_Databases m_last_databases;
179     char *m_last_resultSetId;
180     int m_last_ok;
181     Odr_int m_last_resultCount;
182     int m_sr_transform;
183     int m_seqno;
184     int m_waiting;
185     int m_resultSetStartPoint;
186     int m_bytes_sent;
187     int m_bytes_recv;
188     int m_pdu_recv;
189     ODR m_init_odr;
190     Z_APDU *m_initResponse;
191     Z_Options *m_initResponse_options;
192     Z_ProtocolVersion *m_initResponse_version;
193     int m_initResponse_preferredMessageSize;
194     int m_initResponse_maximumRecordSize;
195     yazpp_1::RecordCache m_cache;
196     void pre_init_client();
197     int m_target_idletime;
198     Yaz_Proxy *m_root;
199     char *m_idAuthentication_ber_buf;
200     int m_idAuthentication_ber_size;
201     ODR m_idAuthentication_odr;
202     void set_idAuthentication(Z_APDU *apdu);
203     bool compare_idAuthentication(Z_APDU *apdu);
204     bool compare_charset(Z_APDU *apdu);
205 };
206
207 /*
208  * Local variables:
209  * c-basic-offset: 4
210  * c-file-style: "Stroustrup"
211  * indent-tabs-mode: nil
212  * End:
213  * vim: shiftwidth=4 tabstop=8 expandtab
214  */
215