19784
|
1 /**
|
|
2 * @file soap.c
|
|
3 * SOAP connection related process
|
|
4 * Author
|
|
5 * MaYuan<mayuan2006@gmail.com>
|
|
6 * gaim
|
|
7 *
|
|
8 * Gaim is the legal property of its developers, whose names are too numerous
|
|
9 * to list here. Please refer to the COPYRIGHT file distributed with this
|
|
10 * source distribution.
|
|
11 *
|
|
12 * This program is free software; you can redistribute it and/or modify
|
|
13 * it under the terms of the GNU General Public License as published by
|
|
14 * the Free Software Foundation; either version 2 of the License, or
|
|
15 * (at your option) any later version.
|
|
16 *
|
|
17 * This program is distributed in the hope that it will be useful,
|
|
18 * but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
19 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
20 * GNU General Public License for more details.
|
|
21 *
|
|
22 * You should have received a copy of the GNU General Public License
|
|
23 * along with this program; if not, write to the Free Software
|
|
24 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
25 */
|
|
26 #include "msn.h"
|
|
27 #include "soap.h"
|
|
28
|
19785
|
29 //msn_soap_new(MsnSession *session,gpointer data,int sslconn)
|
19784
|
30 /*new a soap connection*/
|
|
31 MsnSoapConn *
|
19785
|
32 msn_soap_new(MsnSession *session,gpointer data,int sslconn)
|
19784
|
33 {
|
|
34 MsnSoapConn *soapconn;
|
|
35
|
|
36 soapconn = g_new0(MsnSoapConn, 1);
|
|
37 soapconn->session = session;
|
19785
|
38 soapconn->parent = data;
|
|
39 soapconn->ssl_conn = sslconn;
|
|
40
|
|
41 soapconn->gsc = NULL;
|
19784
|
42 soapconn->input_handler = -1;
|
|
43 soapconn->output_handler = -1;
|
|
44 return soapconn;
|
|
45 }
|
|
46
|
|
47 /*ssl soap connect callback*/
|
|
48 void
|
|
49 msn_soap_connect_cb(gpointer data, GaimSslConnection *gsc,
|
|
50 GaimInputCondition cond)
|
|
51 {
|
|
52 MsnSoapConn * soapconn;
|
|
53 MsnSession *session;
|
|
54
|
|
55 gaim_debug_info("MaYuan","Soap connection connected!\n");
|
|
56 soapconn = data;
|
|
57 g_return_if_fail(soapconn != NULL);
|
|
58
|
|
59 session = soapconn->session;
|
|
60 g_return_if_fail(session != NULL);
|
|
61
|
|
62 soapconn->gsc = gsc;
|
|
63
|
|
64 /*connection callback*/
|
|
65 if(soapconn->connect_cb != NULL){
|
|
66 soapconn->connect_cb(data,gsc,cond);
|
|
67 }
|
|
68 }
|
|
69
|
|
70 /*ssl soap error callback*/
|
|
71 static void
|
|
72 msn_soap_error_cb(GaimSslConnection *gsc, GaimSslErrorType error, void *data)
|
|
73 {
|
|
74 MsnSoapConn * soapconn = data;
|
|
75 g_return_if_fail(data != NULL);
|
|
76 gaim_debug_info("MaYuan","Soap connection error!\n");
|
|
77 /*error callback*/
|
|
78 if(soapconn->error_cb != NULL){
|
|
79 soapconn->error_cb(gsc,error,data);
|
|
80 }
|
|
81 }
|
|
82
|
|
83 /*init the soap connection*/
|
|
84 void
|
|
85 msn_soap_init(MsnSoapConn *soapconn,char * host,int ssl,
|
|
86 GaimSslInputFunction connect_cb,
|
|
87 GaimSslErrorFunction error_cb)
|
|
88 {
|
|
89 soapconn->login_host = g_strdup(host);
|
|
90 soapconn->ssl_conn = ssl;
|
|
91 soapconn->connect_cb = connect_cb;
|
|
92 soapconn->error_cb = error_cb;
|
|
93 if(soapconn->ssl_conn){
|
|
94 gaim_ssl_connect(soapconn->session->account, soapconn->login_host,
|
|
95 GAIM_SSL_DEFAULT_PORT, msn_soap_connect_cb, msn_soap_error_cb,
|
|
96 soapconn);
|
|
97 }else{
|
|
98 }
|
|
99 }
|
|
100
|
|
101 /*destroy the soap connection*/
|
|
102 void
|
|
103 msn_soap_destroy(MsnSoapConn *soapconn)
|
|
104 {
|
|
105 g_free(soapconn->login_host);
|
|
106 g_free(soapconn->login_path);
|
|
107
|
|
108 /*remove the write handler*/
|
|
109 if (soapconn->output_handler > 0){
|
|
110 gaim_input_remove(soapconn->output_handler);
|
|
111 }
|
|
112 /*remove the read handler*/
|
|
113 if (soapconn->input_handler > 0){
|
|
114 gaim_input_remove(soapconn->input_handler);
|
|
115 }
|
|
116 msn_soap_free_read_buf(soapconn);
|
|
117 msn_soap_free_write_buf(soapconn);
|
|
118
|
|
119 /*close ssl connection*/
|
19788
|
120 if(soapconn->gsc != NULL){
|
|
121 gaim_ssl_close(soapconn->gsc);
|
|
122 }
|
19784
|
123 soapconn->gsc = NULL;
|
|
124
|
|
125 g_free(soapconn);
|
|
126 }
|
|
127
|
19785
|
128 /*check the soap is connected?
|
|
129 * if connected return 0
|
|
130 */
|
|
131 int
|
|
132 msn_soap_connected(MsnSoapConn *soapconn)
|
|
133 {
|
|
134 if(soapconn->ssl_conn){
|
|
135 return (soapconn->gsc == NULL? -1 : 0);
|
|
136 }
|
|
137 return(soapconn->fd>0? 0 : -1);
|
|
138 }
|
|
139
|
19784
|
140 /*read and append the content to the buffer*/
|
|
141 static gssize
|
|
142 msn_soap_read(MsnSoapConn *soapconn)
|
|
143 {
|
|
144 gssize len;
|
|
145 gssize total_len = 0;
|
|
146 char temp_buf[10240];
|
|
147
|
|
148 if(soapconn->ssl_conn){
|
|
149 len = gaim_ssl_read(soapconn->gsc, temp_buf,sizeof(temp_buf));
|
|
150 }else{
|
|
151 len = read(soapconn->fd, temp_buf,sizeof(temp_buf));
|
|
152 }
|
|
153 if(len >0){
|
|
154 total_len += len;
|
|
155 soapconn->read_buf = g_realloc(soapconn->read_buf,
|
|
156 soapconn->read_len + len + 1);
|
|
157 // strncpy(soapconn->read_buf + soapconn->read_len, temp_buf, len);
|
|
158 memcpy(soapconn->read_buf + soapconn->read_len, temp_buf, len);
|
|
159 soapconn->read_len += len;
|
|
160 soapconn->read_buf[soapconn->read_len] = '\0';
|
|
161 }
|
|
162 // gaim_debug_info("MaYuan","nexus ssl read:{%s}\n",soapconn->read_buf);
|
|
163 return total_len;
|
|
164 }
|
|
165
|
|
166 /*read the whole SOAP server response*/
|
|
167 void
|
|
168 msn_soap_read_cb(gpointer data, gint source, GaimInputCondition cond)
|
|
169 {
|
|
170 MsnSoapConn *soapconn = data;
|
|
171 MsnSession *session;
|
|
172 int len;
|
|
173 char * body_start,*body_len;
|
|
174 char *length_start,*length_end;
|
|
175
|
19785
|
176 // gaim_debug_misc("MaYuan", "soap read cb\n");
|
19784
|
177 session = soapconn->session;
|
|
178 g_return_if_fail(session != NULL);
|
|
179
|
|
180 if (soapconn->input_handler == -1){
|
|
181 soapconn->input_handler = gaim_input_add(soapconn->gsc->fd,
|
|
182 GAIM_INPUT_READ, msn_soap_read_cb, soapconn);
|
|
183 }
|
|
184
|
|
185 /*read the request header*/
|
|
186 len = msn_soap_read(soapconn);
|
|
187 if (len < 0 && errno == EAGAIN){
|
|
188 return;
|
|
189 }else if (len < 0) {
|
|
190 gaim_debug_error("msn", "read Error!len:%d\n",len);
|
|
191 gaim_input_remove(soapconn->input_handler);
|
|
192 soapconn->input_handler = -1;
|
|
193 g_free(soapconn->read_buf);
|
|
194 soapconn->read_buf = NULL;
|
|
195 soapconn->read_len = 0;
|
|
196 /* TODO: error handling */
|
|
197 return;
|
|
198 }
|
|
199
|
|
200 if(soapconn->read_buf == NULL){
|
|
201 return;
|
|
202 }
|
|
203
|
19788
|
204 if (strstr(soapconn->read_buf, "HTTP/1.1 302") != NULL)
|
|
205 {
|
|
206 /* Redirect. */
|
|
207 char *location, *c;
|
|
208
|
|
209 location = strstr(soapconn->read_buf, "Location: ");
|
|
210 if (location == NULL)
|
|
211 {
|
|
212 msn_soap_free_read_buf(soapconn);
|
|
213
|
|
214 return;
|
|
215 }
|
|
216 location = strchr(location, ' ') + 1;
|
|
217
|
|
218 if ((c = strchr(location, '\r')) != NULL)
|
|
219 *c = '\0';
|
|
220
|
|
221 /* Skip the http:// */
|
|
222 if ((c = strchr(location, '/')) != NULL)
|
|
223 location = c + 2;
|
|
224
|
|
225 if ((c = strchr(location, '/')) != NULL)
|
|
226 {
|
|
227 g_free(soapconn->login_path);
|
|
228 soapconn->login_path = g_strdup(c);
|
|
229
|
|
230 *c = '\0';
|
|
231 }
|
|
232
|
|
233 g_free(soapconn->login_host);
|
|
234 soapconn->login_host = g_strdup(location);
|
|
235
|
|
236 gaim_ssl_connect(session->account, soapconn->login_host,
|
|
237 GAIM_SSL_DEFAULT_PORT, msn_soap_connect_cb,
|
|
238 msn_soap_error_cb, soapconn);
|
19784
|
239 }
|
19788
|
240 else if (strstr(soapconn->read_buf, "HTTP/1.1 401 Unauthorized") != NULL)
|
|
241 {
|
|
242 const char *error;
|
19784
|
243
|
19788
|
244 if ((error = strstr(soapconn->read_buf, "WWW-Authenticate")) != NULL)
|
|
245 {
|
|
246 if ((error = strstr(error, "cbtxt=")) != NULL)
|
|
247 {
|
|
248 const char *c;
|
|
249 char *temp;
|
|
250
|
|
251 error += strlen("cbtxt=");
|
|
252
|
|
253 if ((c = strchr(error, '\n')) == NULL)
|
|
254 c = error + strlen(error);
|
|
255
|
|
256 temp = g_strndup(error, c - error);
|
|
257 error = gaim_url_decode(temp);
|
|
258 g_free(temp);
|
|
259 }
|
|
260 }
|
19784
|
261
|
19788
|
262 msn_session_set_error(session, MSN_ERROR_SERV_UNAVAILABLE, error);
|
|
263 }
|
|
264 else if (strstr(soapconn->read_buf, "HTTP/1.1 200 OK"))
|
|
265 {
|
|
266 /*OK! process the SOAP body*/
|
|
267 body_start = (char *)g_strstr_len(soapconn->read_buf, soapconn->read_len,"\r\n\r\n");
|
|
268 if(!body_start){
|
|
269 return;
|
|
270 }
|
|
271 body_start += 4;
|
|
272
|
|
273 // gaim_debug_misc("msn", "Soap Read: {%s}\n", soapconn->read_buf);
|
19784
|
274
|
19788
|
275 /* we read the content-length*/
|
|
276 length_start = strstr(soapconn->read_buf, "Content-Length: ");
|
|
277 length_start += strlen("Content-Length: ");
|
|
278 length_end = strstr(length_start, "\r\n");
|
|
279 body_len = g_strndup(length_start,length_end - length_start);
|
19784
|
280
|
19788
|
281 /*setup the conn body */
|
|
282 soapconn->body = body_start;
|
|
283 soapconn->body_len = atoi(body_len);
|
|
284 // gaim_debug_misc("MaYuan","content length :%d",soapconn->body_len);
|
|
285
|
|
286 if(soapconn->read_len < body_start - soapconn->read_buf + atoi(body_len)){
|
|
287 return;
|
|
288 }
|
|
289
|
|
290 g_free(body_len);
|
19784
|
291
|
19785
|
292 #if 1
|
19788
|
293 /*remove the read handler*/
|
|
294 gaim_input_remove(soapconn->input_handler);
|
|
295 soapconn->input_handler = -1;
|
19785
|
296 #endif
|
|
297
|
19788
|
298 /*call the read callback*/
|
|
299 if(soapconn->read_cb != NULL){
|
|
300 soapconn->read_cb(soapconn,source,0);
|
|
301 }
|
19784
|
302 #if 0
|
|
303 /*clear the read buffer*/
|
|
304 msn_soap_free_read_buf(soapconn);
|
|
305
|
|
306 /*remove the read handler*/
|
|
307 gaim_input_remove(soapconn->input_handler);
|
|
308 soapconn->input_handler = -1;
|
19788
|
309 // gaim_ssl_close(soapconn->gsc);
|
|
310 // soapconn->gsc = NULL;
|
19784
|
311 #endif
|
19788
|
312 }
|
19784
|
313 }
|
|
314
|
|
315 void
|
|
316 msn_soap_free_read_buf(MsnSoapConn *soapconn)
|
|
317 {
|
|
318 if(soapconn->read_buf){
|
|
319 g_free(soapconn->read_buf);
|
|
320 }
|
|
321 soapconn->read_buf = NULL;
|
|
322 soapconn->read_len = 0;
|
|
323 }
|
|
324
|
|
325 void
|
|
326 msn_soap_free_write_buf(MsnSoapConn *soapconn)
|
|
327 {
|
|
328 if(soapconn->write_buf){
|
|
329 g_free(soapconn->write_buf);
|
|
330 }
|
|
331 soapconn->write_buf = NULL;
|
|
332 soapconn->written_len = 0;
|
|
333 }
|
|
334
|
|
335 /*Soap write process func*/
|
|
336 static void
|
|
337 msn_soap_write_cb(gpointer data, gint source, GaimInputCondition cond)
|
|
338 {
|
|
339 MsnSoapConn *soapconn = data;
|
|
340 int len, total_len;
|
|
341
|
|
342 total_len = strlen(soapconn->write_buf);
|
|
343
|
|
344 /*
|
|
345 * write the content to SSL server,
|
|
346 */
|
|
347 len = gaim_ssl_write(soapconn->gsc,
|
|
348 soapconn->write_buf + soapconn->written_len,
|
|
349 total_len - soapconn->written_len);
|
|
350
|
|
351 if (len < 0 && errno == EAGAIN)
|
|
352 return;
|
|
353 else if (len <= 0){
|
|
354 /*SSL write error!*/
|
|
355 gaim_input_remove(soapconn->output_handler);
|
|
356 soapconn->output_handler = -1;
|
|
357 /* TODO: notify of the error */
|
|
358 return;
|
|
359 }
|
|
360 soapconn->written_len += len;
|
|
361
|
|
362 if (soapconn->written_len < total_len)
|
|
363 return;
|
|
364
|
|
365 gaim_input_remove(soapconn->output_handler);
|
|
366 soapconn->output_handler = -1;
|
|
367
|
|
368 /*clear the write buff*/
|
|
369 msn_soap_free_write_buf(soapconn);
|
|
370
|
|
371 /* Write finish!
|
|
372 * callback for write done
|
|
373 */
|
|
374 if(soapconn->written_cb != NULL){
|
|
375 soapconn->written_cb(soapconn, source, 0);
|
|
376 }
|
|
377 }
|
|
378
|
|
379 /*write the buffer to SOAP connection*/
|
|
380 void
|
|
381 msn_soap_write(MsnSoapConn * soapconn, char *write_buf, GaimInputFunction written_cb)
|
|
382 {
|
|
383 soapconn->write_buf = write_buf;
|
|
384 soapconn->written_len = 0;
|
|
385 soapconn->written_cb = written_cb;
|
19785
|
386
|
|
387 /*clear the read buffer first*/
|
19784
|
388 /*start the write*/
|
|
389 soapconn->output_handler = gaim_input_add(soapconn->gsc->fd, GAIM_INPUT_WRITE,
|
|
390 msn_soap_write_cb, soapconn);
|
|
391 msn_soap_write_cb(soapconn, soapconn->gsc->fd, GAIM_INPUT_WRITE);
|
|
392 }
|
|
393
|
19785
|
394 /*Post the soap action*/
|
|
395 void
|
|
396 msn_soap_post(MsnSoapConn *soapconn,const char * body,GaimInputFunction written_cb)
|
|
397 {
|
|
398 char * soap_head = NULL;
|
|
399 char * soap_body = NULL;
|
|
400 char * request_str = NULL;
|
|
401
|
19790
|
402 gaim_debug_info("MaYuan","msn_soap_post()...\n");
|
19785
|
403 soap_body = g_strdup_printf(body);
|
|
404 soap_head = g_strdup_printf(
|
|
405 "POST %s HTTP/1.1\r\n"
|
|
406 "SOAPAction: %s\r\n"
|
|
407 "Content-Type:text/xml; charset=utf-8\r\n"
|
|
408 "Cookie: MSPAuth=%s\r\n"
|
|
409 "User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1)\r\n"
|
|
410 "Accept: text/*\r\n"
|
|
411 "Host: %s\r\n"
|
|
412 "Content-Length: %d\r\n"
|
|
413 "Connection: Keep-Alive\r\n"
|
|
414 "Cache-Control: no-cache\r\n\r\n",
|
|
415 soapconn->login_path,
|
|
416 soapconn->soap_action,
|
|
417 soapconn->session->passport_info.mspauth,
|
|
418 soapconn->login_host,
|
|
419 strlen(soap_body)
|
|
420 );
|
|
421 request_str = g_strdup_printf("%s%s", soap_head,soap_body);
|
|
422 g_free(soapconn->login_path);
|
|
423 g_free(soapconn->soap_action);
|
|
424 g_free(soap_head);
|
|
425 g_free(soap_body);
|
|
426
|
|
427 /*free read buffer*/
|
|
428 msn_soap_free_read_buf(soapconn);
|
19788
|
429 gaim_debug_info("MaYuan","send to server{%s}\n",request_str);
|
19785
|
430 msn_soap_write(soapconn,request_str,written_cb);
|
|
431 }
|
|
432
|