?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Do not check for non NULL pointer before HeepFree'ing it. It's
[wine/multimedia.git] / dlls / wininet / http.c
blob5b382cc2a89f3a8dda96cded302db87547b24520
1 /*
2 * Wininet - Http Implementation
3 *
4 * Copyright 1999 Corel Corporation
5 * Copyright 2002 CodeWeavers Inc.
6 * Copyright 2002 TransGaming Technologies Inc.
7 * Copyright 2004 Mike McCormack for CodeWeavers
8 *
9 * Ulrich Czekalla
10 * Aric Stewart
11 * David Hammerton
12 *
13 * This library is free software; you can redistribute it and/or
14 * modify it under the terms of the GNU Lesser General Public
15 * License as published by the Free Software Foundation; either
16 * version 2.1 of the License, or (at your option) any later version.
17 *
18 * This library is distributed in the hope that it will be useful,
19 * but WITHOUT ANY WARRANTY; without even the implied warranty of
20 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
21 * Lesser General Public License for more details.
22 *
23 * You should have received a copy of the GNU Lesser General Public
24 * License along with this library; if not, write to the Free Software
25 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
26 */
27
28 #include "config.h"
29 #include "wine/port.h"
30
31 #include <sys/types.h>
32 #ifdef HAVE_SYS_SOCKET_H
33 # include <sys/socket.h>
34 #endif
35 #include <stdarg.h>
36 #include <stdio.h>
37 #include <stdlib.h>
38 #ifdef HAVE_UNISTD_H
39 # include <unistd.h>
40 #endif
41 #include <errno.h>
42 #include <string.h>
43 #include <time.h>
44 #include <assert.h>
45
46 #include "windef.h"
47 #include "winbase.h"
48 #include "wininet.h"
49 #include "winreg.h"
50 #include "winerror.h"
51 #define NO_SHLWAPI_STREAM
52 #include "shlwapi.h"
53
54 #include "internet.h"
55 #include "wine/debug.h"
56 #include "wine/unicode.h"
57
58 WINE_DEFAULT_DEBUG_CHANNEL(wininet);
59
60 static const WCHAR g_szHttp[] = {' ','H','T','T','P','/','1','.','0',0 };
61 static const WCHAR g_szReferer[] = {'R','e','f','e','r','e','r',0};
62 static const WCHAR g_szAccept[] = {'A','c','c','e','p','t',0};
63 static const WCHAR g_szUserAgent[] = {'U','s','e','r','-','A','g','e','n','t',0};
64 static const WCHAR g_szHost[] = {'H','o','s','t',0};
65
66
67 #define HTTPHEADER g_szHttp
68 #define MAXHOSTNAME 100
69 #define MAX_FIELD_VALUE_LEN 256
70 #define MAX_FIELD_LEN 256
71
72 #define HTTP_REFERER g_szReferer
73 #define HTTP_ACCEPT g_szAccept
74 #define HTTP_USERAGENT g_szUserAgent
75
76 #define HTTP_ADDHDR_FLAG_ADD 0x20000000
77 #define HTTP_ADDHDR_FLAG_ADD_IF_NEW 0x10000000
78 #define HTTP_ADDHDR_FLAG_COALESCE 0x40000000
79 #define HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA 0x40000000
80 #define HTTP_ADDHDR_FLAG_COALESCE_WITH_SEMICOLON 0x01000000
81 #define HTTP_ADDHDR_FLAG_REPLACE 0x80000000
82 #define HTTP_ADDHDR_FLAG_REQ 0x02000000
83
84
85 static void HTTP_CloseHTTPRequestHandle(LPWININETHANDLEHEADER hdr);
86 static void HTTP_CloseHTTPSessionHandle(LPWININETHANDLEHEADER hdr);
87 BOOL HTTP_OpenConnection(LPWININETHTTPREQW lpwhr);
88 int HTTP_WriteDataToStream(LPWININETHTTPREQW lpwhr,
89 void *Buffer, int BytesToWrite);
90 int HTTP_ReadDataFromStream(LPWININETHTTPREQW lpwhr,
91 void *Buffer, int BytesToRead);
92 BOOL HTTP_GetResponseHeaders(LPWININETHTTPREQW lpwhr);
93 BOOL HTTP_ProcessHeader(LPWININETHTTPREQW lpwhr, LPCWSTR field, LPCWSTR value, DWORD dwModifier);
94 BOOL HTTP_ReplaceHeaderValue( LPHTTPHEADERW lphttpHdr, LPCWSTR lpsztmp );
95 void HTTP_CloseConnection(LPWININETHTTPREQW lpwhr);
96 LPWSTR * HTTP_InterpretHttpHeader(LPCWSTR buffer);
97 INT HTTP_GetStdHeaderIndex(LPCWSTR lpszField);
98 BOOL HTTP_InsertCustomHeader(LPWININETHTTPREQW lpwhr, LPHTTPHEADERW lpHdr);
99 INT HTTP_GetCustomHeaderIndex(LPWININETHTTPREQW lpwhr, LPCWSTR lpszField);
100 BOOL HTTP_DeleteCustomHeader(LPWININETHTTPREQW lpwhr, DWORD index);
101
102 /***********************************************************************
103 * HTTP_Tokenize (internal)
104 *
105 * Tokenize a string, allocating memory for the tokens.
106 */
107 static LPWSTR * HTTP_Tokenize(LPCWSTR string, LPCWSTR token_string)
108 {
109 LPWSTR * token_array;
110 int tokens = 0;
111 int i;
112 LPCWSTR next_token;
113
114 /* empty string has no tokens */
115 if (*string)
116 tokens++;
117 /* count tokens */
118 for (i = 0; string[i]; i++)
119 if (!strncmpW(string+i, token_string, strlenW(token_string)))
120 {
121 DWORD j;
122 tokens++;
123 /* we want to skip over separators, but not the null terminator */
124 for (j = 0; j < strlenW(token_string) - 1; j++)
125 if (!string[i+j])
126 break;
127 i += j;
128 }
129
130 /* add 1 for terminating NULL */
131 token_array = HeapAlloc(GetProcessHeap(), 0, (tokens+1) * sizeof(*token_array));
132 token_array[tokens] = NULL;
133 if (!tokens)
134 return token_array;
135 for (i = 0; i < tokens; i++)
136 {
137 int len;
138 next_token = strstrW(string, token_string);
139 if (!next_token) next_token = string+strlenW(string);
140 len = next_token - string;
141 token_array[i] = HeapAlloc(GetProcessHeap(), 0, (len+1)*sizeof(WCHAR));
142 memcpy(token_array[i], string, len*sizeof(WCHAR));
143 token_array[i][len] = '\0';
144 string = next_token+strlenW(token_string);
145 }
146 return token_array;
147 }
148
149 /***********************************************************************
150 * HTTP_FreeTokens (internal)
151 *
152 * Frees memory returned from HTTP_Tokenize.
153 */
154 static void HTTP_FreeTokens(LPWSTR * token_array)
155 {
156 int i;
157 for (i = 0; token_array[i]; i++)
158 HeapFree(GetProcessHeap(), 0, token_array[i]);
159 HeapFree(GetProcessHeap(), 0, token_array);
160 }
161
162 /***********************************************************************
163 * HTTP_HttpAddRequestHeadersW (internal)
164 */
165 static BOOL WINAPI HTTP_HttpAddRequestHeadersW(LPWININETHTTPREQW lpwhr,
166 LPCWSTR lpszHeader, DWORD dwHeaderLength, DWORD dwModifier)
167 {
168 LPWSTR lpszStart;
169 LPWSTR lpszEnd;
170 LPWSTR buffer;
171 BOOL bSuccess = FALSE;
172 DWORD len;
173
174 TRACE("copying header: %s\n", debugstr_w(lpszHeader));
175
176 if( dwHeaderLength == ~0UL )
177 len = strlenW(lpszHeader);
178 else
179 len = dwHeaderLength;
180 buffer = HeapAlloc( GetProcessHeap(), 0, sizeof(WCHAR)*(len+1) );
181 strncpyW( buffer, lpszHeader, len );
182 buffer[len]=0;
183
184 lpszStart = buffer;
185
186 do
187 {
188 LPWSTR * pFieldAndValue;
189
190 lpszEnd = lpszStart;
191
192 while (*lpszEnd != '\0')
193 {
194 if (*lpszEnd == '\r' && *(lpszEnd + 1) == '\n')
195 break;
196 lpszEnd++;
197 }
198
199 if (*lpszStart == '\0')
200 break;
201
202 if (*lpszEnd == '\r')
203 {
204 *lpszEnd = '\0';
205 lpszEnd += 2; /* Jump over \r\n */
206 }
207 TRACE("interpreting header %s\n", debugstr_w(lpszStart));
208 pFieldAndValue = HTTP_InterpretHttpHeader(lpszStart);
209 if (pFieldAndValue)
210 {
211 bSuccess = HTTP_ProcessHeader(lpwhr, pFieldAndValue[0],
212 pFieldAndValue[1], dwModifier | HTTP_ADDHDR_FLAG_REQ);
213 HTTP_FreeTokens(pFieldAndValue);
214 }
215
216 lpszStart = lpszEnd;
217 } while (bSuccess);
218
219 HeapFree(GetProcessHeap(), 0, buffer);
220
221 return bSuccess;
222 }
223
224 /***********************************************************************
225 * HttpAddRequestHeadersW (WININET.@)
226 *
227 * Adds one or more HTTP header to the request handler
228 *
229 * RETURNS
230 * TRUE on success
231 * FALSE on failure
232 *
233 */
234 BOOL WINAPI HttpAddRequestHeadersW(HINTERNET hHttpRequest,
235 LPCWSTR lpszHeader, DWORD dwHeaderLength, DWORD dwModifier)
236 {
237 BOOL bSuccess = FALSE;
238 LPWININETHTTPREQW lpwhr;
239
240 TRACE("%p, %s, %li, %li\n", hHttpRequest, debugstr_w(lpszHeader), dwHeaderLength,
241 dwModifier);
242
243 if (!lpszHeader)
244 return TRUE;
245
246 lpwhr = (LPWININETHTTPREQW) WININET_GetObject( hHttpRequest );
247 if (NULL == lpwhr || lpwhr->hdr.htype != WH_HHTTPREQ)
248 {
249 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
250 goto lend;
251 }
252 bSuccess = HTTP_HttpAddRequestHeadersW( lpwhr, lpszHeader, dwHeaderLength, dwModifier );
253 lend:
254 if( lpwhr )
255 WININET_Release( &lpwhr->hdr );
256
257 return bSuccess;
258 }
259
260 /***********************************************************************
261 * HttpAddRequestHeadersA (WININET.@)
262 *
263 * Adds one or more HTTP header to the request handler
264 *
265 * RETURNS
266 * TRUE on success
267 * FALSE on failure
268 *
269 */
270 BOOL WINAPI HttpAddRequestHeadersA(HINTERNET hHttpRequest,
271 LPCSTR lpszHeader, DWORD dwHeaderLength, DWORD dwModifier)
272 {
273 DWORD len;
274 LPWSTR hdr;
275 BOOL r;
276
277 TRACE("%p, %s, %li, %li\n", hHttpRequest, debugstr_a(lpszHeader), dwHeaderLength,
278 dwModifier);
279
280 len = MultiByteToWideChar( CP_ACP, 0, lpszHeader, dwHeaderLength, NULL, 0 );
281 hdr = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
282 MultiByteToWideChar( CP_ACP, 0, lpszHeader, dwHeaderLength, hdr, len );
283 if( dwHeaderLength != ~0UL )
284 dwHeaderLength = len;
285
286 r = HttpAddRequestHeadersW( hHttpRequest, hdr, dwHeaderLength, dwModifier );
287
288 HeapFree( GetProcessHeap(), 0, hdr );
289
290 return r;
291 }
292
293 /***********************************************************************
294 * HttpEndRequestA (WININET.@)
295 *
296 * Ends an HTTP request that was started by HttpSendRequestEx
297 *
298 * RETURNS
299 * TRUE if successful
300 * FALSE on failure
301 *
302 */
303 BOOL WINAPI HttpEndRequestA(HINTERNET hRequest, LPINTERNET_BUFFERSA lpBuffersOut,
304 DWORD dwFlags, DWORD dwContext)
305 {
306 FIXME("stub\n");
307 return FALSE;
308 }
309
310 /***********************************************************************
311 * HttpEndRequestW (WININET.@)
312 *
313 * Ends an HTTP request that was started by HttpSendRequestEx
314 *
315 * RETURNS
316 * TRUE if successful
317 * FALSE on failure
318 *
319 */
320 BOOL WINAPI HttpEndRequestW(HINTERNET hRequest, LPINTERNET_BUFFERSW lpBuffersOut,
321 DWORD dwFlags, DWORD dwContext)
322 {
323 FIXME("stub\n");
324 return FALSE;
325 }
326
327 /***********************************************************************
328 * HttpOpenRequestW (WININET.@)
329 *
330 * Open a HTTP request handle
331 *
332 * RETURNS
333 * HINTERNET a HTTP request handle on success
334 * NULL on failure
335 *
336 */
337 HINTERNET WINAPI HttpOpenRequestW(HINTERNET hHttpSession,
338 LPCWSTR lpszVerb, LPCWSTR lpszObjectName, LPCWSTR lpszVersion,
339 LPCWSTR lpszReferrer , LPCWSTR *lpszAcceptTypes,
340 DWORD dwFlags, DWORD dwContext)
341 {
342 LPWININETHTTPSESSIONW lpwhs;
343 HINTERNET handle = NULL;
344
345 TRACE("(%p, %s, %s, %s, %s, %p, %08lx, %08lx)\n", hHttpSession,
346 debugstr_w(lpszVerb), debugstr_w(lpszObjectName),
347 debugstr_w(lpszVersion), debugstr_w(lpszReferrer), lpszAcceptTypes,
348 dwFlags, dwContext);
349 if(lpszAcceptTypes!=NULL)
350 {
351 int i;
352 for(i=0;lpszAcceptTypes[i]!=NULL;i++)
353 TRACE("\taccept type: %s\n",debugstr_w(lpszAcceptTypes[i]));
354 }
355
356 lpwhs = (LPWININETHTTPSESSIONW) WININET_GetObject( hHttpSession );
357 if (NULL == lpwhs || lpwhs->hdr.htype != WH_HHTTPSESSION)
358 {
359 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
360 goto lend;
361 }
362
363 /*
364 * My tests seem to show that the windows version does not
365 * become asynchronous until after this point. And anyhow
366 * if this call was asynchronous then how would you get the
367 * necessary HINTERNET pointer returned by this function.
368 *
369 */
370 handle = HTTP_HttpOpenRequestW(lpwhs, lpszVerb, lpszObjectName,
371 lpszVersion, lpszReferrer, lpszAcceptTypes,
372 dwFlags, dwContext);
373 lend:
374 if( lpwhs )
375 WININET_Release( &lpwhs->hdr );
376 TRACE("returning %p\n", handle);
377 return handle;
378 }
379
380
381 /***********************************************************************
382 * HttpOpenRequestA (WININET.@)
383 *
384 * Open a HTTP request handle
385 *
386 * RETURNS
387 * HINTERNET a HTTP request handle on success
388 * NULL on failure
389 *
390 */
391 HINTERNET WINAPI HttpOpenRequestA(HINTERNET hHttpSession,
392 LPCSTR lpszVerb, LPCSTR lpszObjectName, LPCSTR lpszVersion,
393 LPCSTR lpszReferrer , LPCSTR *lpszAcceptTypes,
394 DWORD dwFlags, DWORD dwContext)
395 {
396 LPWSTR szVerb = NULL, szObjectName = NULL;
397 LPWSTR szVersion = NULL, szReferrer = NULL, *szAcceptTypes = NULL;
398 INT len;
399 INT acceptTypesCount;
400 HINTERNET rc = FALSE;
401 TRACE("(%p, %s, %s, %s, %s, %p, %08lx, %08lx)\n", hHttpSession,
402 debugstr_a(lpszVerb), debugstr_a(lpszObjectName),
403 debugstr_a(lpszVersion), debugstr_a(lpszReferrer), lpszAcceptTypes,
404 dwFlags, dwContext);
405
406 if (lpszVerb)
407 {
408 len = MultiByteToWideChar(CP_ACP, 0, lpszVerb, -1, NULL, 0 );
409 szVerb = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR) );
410 if ( !szVerb )
411 goto end;
412 MultiByteToWideChar(CP_ACP, 0, lpszVerb, -1, szVerb, len);
413 }
414
415 if (lpszObjectName)
416 {
417 len = MultiByteToWideChar(CP_ACP, 0, lpszObjectName, -1, NULL, 0 );
418 szObjectName = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR) );
419 if ( !szObjectName )
420 goto end;
421 MultiByteToWideChar(CP_ACP, 0, lpszObjectName, -1, szObjectName, len );
422 }
423
424 if (lpszVersion)
425 {
426 len = MultiByteToWideChar(CP_ACP, 0, lpszVersion, -1, NULL, 0 );
427 szVersion = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR));
428 if ( !szVersion )
429 goto end;
430 MultiByteToWideChar(CP_ACP, 0, lpszVersion, -1, szVersion, len );
431 }
432
433 if (lpszReferrer)
434 {
435 len = MultiByteToWideChar(CP_ACP, 0, lpszReferrer, -1, NULL, 0 );
436 szReferrer = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR));
437 if ( !szReferrer )
438 goto end;
439 MultiByteToWideChar(CP_ACP, 0, lpszReferrer, -1, szReferrer, len );
440 }
441
442 acceptTypesCount = 0;
443 if (lpszAcceptTypes)
444 {
445 /* find out how many there are */
446 while (lpszAcceptTypes[acceptTypesCount])
447 acceptTypesCount++;
448 szAcceptTypes = HeapAlloc(GetProcessHeap(), 0, sizeof(WCHAR *) * (acceptTypesCount+1));
449 acceptTypesCount = 0;
450 while (lpszAcceptTypes[acceptTypesCount])
451 {
452 len = MultiByteToWideChar(CP_ACP, 0, lpszAcceptTypes[acceptTypesCount],
453 -1, NULL, 0 );
454 szAcceptTypes[acceptTypesCount] = HeapAlloc(GetProcessHeap(), 0, len * sizeof(WCHAR));
455 if (!szAcceptTypes[acceptTypesCount] )
456 goto end;
457 MultiByteToWideChar(CP_ACP, 0, lpszAcceptTypes[acceptTypesCount],
458 -1, szAcceptTypes[acceptTypesCount], len );
459 acceptTypesCount++;
460 }
461 szAcceptTypes[acceptTypesCount] = NULL;
462 }
463 else szAcceptTypes = 0;
464
465 rc = HttpOpenRequestW(hHttpSession, szVerb, szObjectName,
466 szVersion, szReferrer,
467 (LPCWSTR*)szAcceptTypes, dwFlags, dwContext);
468
469 end:
470 if (szAcceptTypes)
471 {
472 acceptTypesCount = 0;
473 while (szAcceptTypes[acceptTypesCount])
474 {
475 HeapFree(GetProcessHeap(), 0, szAcceptTypes[acceptTypesCount]);
476 acceptTypesCount++;
477 }
478 HeapFree(GetProcessHeap(), 0, szAcceptTypes);
479 }
480 HeapFree(GetProcessHeap(), 0, szReferrer);
481 HeapFree(GetProcessHeap(), 0, szVersion);
482 HeapFree(GetProcessHeap(), 0, szObjectName);
483 HeapFree(GetProcessHeap(), 0, szVerb);
484
485 return rc;
486 }
487
488 /***********************************************************************
489 * HTTP_Base64
490 */
491 static UINT HTTP_Base64( LPCWSTR bin, LPWSTR base64 )
492 {
493 UINT n = 0, x;
494 static LPSTR HTTP_Base64Enc =
495 "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
496
497 while( bin[0] )
498 {
499 /* first 6 bits, all from bin[0] */
500 base64[n++] = HTTP_Base64Enc[(bin[0] & 0xfc) >> 2];
501 x = (bin[0] & 3) << 4;
502
503 /* next 6 bits, 2 from bin[0] and 4 from bin[1] */
504 if( !bin[1] )
505 {
506 base64[n++] = HTTP_Base64Enc[x];
507 base64[n++] = '=';
508 base64[n++] = '=';
509 break;
510 }
511 base64[n++] = HTTP_Base64Enc[ x | ( (bin[1]&0xf0) >> 4 ) ];
512 x = ( bin[1] & 0x0f ) << 2;
513
514 /* next 6 bits 4 from bin[1] and 2 from bin[2] */
515 if( !bin[2] )
516 {
517 base64[n++] = HTTP_Base64Enc[x];
518 base64[n++] = '=';
519 break;
520 }
521 base64[n++] = HTTP_Base64Enc[ x | ( (bin[2]&0xc0 ) >> 6 ) ];
522
523 /* last 6 bits, all from bin [2] */
524 base64[n++] = HTTP_Base64Enc[ bin[2] & 0x3f ];
525 bin += 3;
526 }
527 base64[n] = 0;
528 return n;
529 }
530
531 /***********************************************************************
532 * HTTP_EncodeBasicAuth
533 *
534 * Encode the basic authentication string for HTTP 1.1
535 */
536 static LPWSTR HTTP_EncodeBasicAuth( LPCWSTR username, LPCWSTR password)
537 {
538 UINT len;
539 LPWSTR in, out;
540 static const WCHAR szBasic[] = {'B','a','s','i','c',' ',0};
541 static const WCHAR szColon[] = {':',0};
542
543 len = lstrlenW( username ) + 1 + lstrlenW ( password ) + 1;
544 in = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
545 if( !in )
546 return NULL;
547
548 len = lstrlenW(szBasic) +
549 (lstrlenW( username ) + 1 + lstrlenW ( password ))*2 + 1 + 1;
550 out = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
551 if( out )
552 {
553 lstrcpyW( in, username );
554 lstrcatW( in, szColon );
555 lstrcatW( in, password );
556 lstrcpyW( out, szBasic );
557 HTTP_Base64( in, &out[strlenW(out)] );
558 }
559 HeapFree( GetProcessHeap(), 0, in );
560
561 return out;
562 }
563
564 /***********************************************************************
565 * HTTP_InsertProxyAuthorization
566 *
567 * Insert the basic authorization field in the request header
568 */
569 BOOL HTTP_InsertProxyAuthorization( LPWININETHTTPREQW lpwhr,
570 LPCWSTR username, LPCWSTR password )
571 {
572 HTTPHEADERW hdr;
573 INT index;
574 static const WCHAR szProxyAuthorization[] = {
575 'P','r','o','x','y','-','A','u','t','h','o','r','i','z','a','t','i','o','n',0 };
576
577 hdr.lpszValue = HTTP_EncodeBasicAuth( username, password );
578 hdr.lpszField = (WCHAR *)szProxyAuthorization;
579 hdr.wFlags = HDR_ISREQUEST;
580 hdr.wCount = 0;
581 if( !hdr.lpszValue )
582 return FALSE;
583
584 TRACE("Inserting %s = %s\n",
585 debugstr_w( hdr.lpszField ), debugstr_w( hdr.lpszValue ) );
586
587 /* remove the old proxy authorization header */
588 index = HTTP_GetCustomHeaderIndex( lpwhr, hdr.lpszField );
589 if( index >=0 )
590 HTTP_DeleteCustomHeader( lpwhr, index );
591
592 HTTP_InsertCustomHeader(lpwhr, &hdr);
593 HeapFree( GetProcessHeap(), 0, hdr.lpszValue );
594
595 return TRUE;
596 }
597
598 /***********************************************************************
599 * HTTP_DealWithProxy
600 */
601 static BOOL HTTP_DealWithProxy( LPWININETAPPINFOW hIC,
602 LPWININETHTTPSESSIONW lpwhs, LPWININETHTTPREQW lpwhr)
603 {
604 WCHAR buf[MAXHOSTNAME];
605 WCHAR proxy[MAXHOSTNAME + 15]; /* 15 == "http://" + sizeof(port#) + ":/\0" */
606 WCHAR* url;
607 static const WCHAR szNul[] = { 0 };
608 URL_COMPONENTSW UrlComponents;
609 static const WCHAR szHttp[] = { 'h','t','t','p',':','/','/',0 }, szSlash[] = { '/',0 } ;
610 static const WCHAR szFormat1[] = { 'h','t','t','p',':','/','/','%','s',0 };
611 static const WCHAR szFormat2[] = { 'h','t','t','p',':','/','/','%','s',':','%','d',0 };
612 int len;
613
614 memset( &UrlComponents, 0, sizeof UrlComponents );
615 UrlComponents.dwStructSize = sizeof UrlComponents;
616 UrlComponents.lpszHostName = buf;
617 UrlComponents.dwHostNameLength = MAXHOSTNAME;
618
619 if( CSTR_EQUAL != CompareStringW(LOCALE_SYSTEM_DEFAULT, NORM_IGNORECASE,
620 buf,strlenW(szHttp),szHttp,strlenW(szHttp)) )
621 sprintfW(proxy, szFormat1, hIC->lpszProxy);
622 else
623 strcpyW(proxy,buf);
624 if( !InternetCrackUrlW(proxy, 0, 0, &UrlComponents) )
625 return FALSE;
626 if( UrlComponents.dwHostNameLength == 0 )
627 return FALSE;
628
629 if( !lpwhr->lpszPath )
630 lpwhr->lpszPath = (LPWSTR)szNul;
631 TRACE("server='%s' path='%s'\n",
632 debugstr_w(lpwhs->lpszServerName), debugstr_w(lpwhr->lpszPath));
633 /* for constant 15 see above */
634 len = strlenW(lpwhs->lpszServerName) + strlenW(lpwhr->lpszPath) + 15;
635 url = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
636
637 if(UrlComponents.nPort == INTERNET_INVALID_PORT_NUMBER)
638 UrlComponents.nPort = INTERNET_DEFAULT_HTTP_PORT;
639
640 sprintfW(url, szFormat2, lpwhs->lpszServerName, lpwhs->nServerPort);
641
642 if( lpwhr->lpszPath[0] != '/' )
643 strcatW( url, szSlash );
644 strcatW(url, lpwhr->lpszPath);
645 if(lpwhr->lpszPath != szNul)
646 HeapFree(GetProcessHeap(), 0, lpwhr->lpszPath);
647 lpwhr->lpszPath = url;
648 /* FIXME: Do I have to free lpwhs->lpszServerName here ? */
649 lpwhs->lpszServerName = WININET_strdupW(UrlComponents.lpszHostName);
650 lpwhs->nServerPort = UrlComponents.nPort;
651
652 return TRUE;
653 }
654
655 /***********************************************************************
656 * HTTP_HttpOpenRequestW (internal)
657 *
658 * Open a HTTP request handle
659 *
660 * RETURNS
661 * HINTERNET a HTTP request handle on success
662 * NULL on failure
663 *
664 */
665 HINTERNET WINAPI HTTP_HttpOpenRequestW(LPWININETHTTPSESSIONW lpwhs,
666 LPCWSTR lpszVerb, LPCWSTR lpszObjectName, LPCWSTR lpszVersion,
667 LPCWSTR lpszReferrer , LPCWSTR *lpszAcceptTypes,
668 DWORD dwFlags, DWORD dwContext)
669 {
670 LPWININETAPPINFOW hIC = NULL;
671 LPWININETHTTPREQW lpwhr;
672 LPWSTR lpszCookies;
673 LPWSTR lpszUrl = NULL;
674 DWORD nCookieSize;
675 HINTERNET handle = NULL;
676 static const WCHAR szUrlForm[] = {'h','t','t','p',':','/','/','%','s',0};
677 DWORD len;
678 INTERNET_ASYNC_RESULT iar;
679
680 TRACE("--> \n");
681
682 assert( lpwhs->hdr.htype == WH_HHTTPSESSION );
683 hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
684
685 lpwhr = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(WININETHTTPREQW));
686 if (NULL == lpwhr)
687 {
688 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
689 goto lend;
690 }
691 lpwhr->hdr.htype = WH_HHTTPREQ;
692 lpwhr->hdr.lpwhparent = WININET_AddRef( &lpwhs->hdr );
693 lpwhr->hdr.dwFlags = dwFlags;
694 lpwhr->hdr.dwContext = dwContext;
695 lpwhr->hdr.dwRefCount = 1;
696 lpwhr->hdr.destroy = HTTP_CloseHTTPRequestHandle;
697 lpwhr->hdr.lpfnStatusCB = lpwhs->hdr.lpfnStatusCB;
698
699 handle = WININET_AllocHandle( &lpwhr->hdr );
700 if (NULL == handle)
701 {
702 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
703 goto lend;
704 }
705
706 NETCON_init(&lpwhr->netConnection, dwFlags & INTERNET_FLAG_SECURE);
707
708 if (NULL != lpszObjectName && strlenW(lpszObjectName)) {
709 HRESULT rc;
710
711 len = 0;
712 rc = UrlEscapeW(lpszObjectName, NULL, &len, URL_ESCAPE_SPACES_ONLY);
713 if (rc != E_POINTER)
714 len = strlenW(lpszObjectName)+1;
715 lpwhr->lpszPath = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
716 rc = UrlEscapeW(lpszObjectName, lpwhr->lpszPath, &len,
717 URL_ESCAPE_SPACES_ONLY);
718 if (rc)
719 {
720 ERR("Unable to escape string!(%s) (%ld)\n",debugstr_w(lpszObjectName),rc);
721 strcpyW(lpwhr->lpszPath,lpszObjectName);
722 }
723 }
724
725 if (NULL != lpszReferrer && strlenW(lpszReferrer))
726 HTTP_ProcessHeader(lpwhr, HTTP_REFERER, lpszReferrer, HTTP_ADDHDR_FLAG_COALESCE);
727
728 if(lpszAcceptTypes!=NULL)
729 {
730 int i;
731 for(i=0;lpszAcceptTypes[i]!=NULL;i++)
732 HTTP_ProcessHeader(lpwhr, HTTP_ACCEPT, lpszAcceptTypes[i], HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA|HTTP_ADDHDR_FLAG_REQ|HTTP_ADDHDR_FLAG_ADD_IF_NEW);
733 }
734
735 if (NULL == lpszVerb)
736 {
737 static const WCHAR szGet[] = {'G','E','T',0};
738 lpwhr->lpszVerb = WININET_strdupW(szGet);
739 }
740 else if (strlenW(lpszVerb))
741 lpwhr->lpszVerb = WININET_strdupW(lpszVerb);
742
743 if (NULL != lpszReferrer && strlenW(lpszReferrer))
744 {
745 WCHAR buf[MAXHOSTNAME];
746 URL_COMPONENTSW UrlComponents;
747
748 memset( &UrlComponents, 0, sizeof UrlComponents );
749 UrlComponents.dwStructSize = sizeof UrlComponents;
750 UrlComponents.lpszHostName = buf;
751 UrlComponents.dwHostNameLength = MAXHOSTNAME;
752
753 InternetCrackUrlW(lpszReferrer, 0, 0, &UrlComponents);
754 if (strlenW(UrlComponents.lpszHostName))
755 HTTP_ProcessHeader(lpwhr, g_szHost, UrlComponents.lpszHostName, HTTP_ADDREQ_FLAG_ADD | HTTP_ADDREQ_FLAG_REPLACE | HTTP_ADDHDR_FLAG_REQ);
756 }
757 else
758 HTTP_ProcessHeader(lpwhr, g_szHost, lpwhs->lpszServerName, HTTP_ADDREQ_FLAG_ADD | HTTP_ADDREQ_FLAG_REPLACE | HTTP_ADDHDR_FLAG_REQ);
759
760 if (NULL != hIC->lpszProxy && hIC->lpszProxy[0] != 0)
761 HTTP_DealWithProxy( hIC, lpwhs, lpwhr );
762
763 if (hIC->lpszAgent)
764 {
765 WCHAR *agent_header;
766 static const WCHAR user_agent[] = {'U','s','e','r','-','A','g','e','n','t',':',' ','%','s','\r','\n',0 };
767
768 len = strlenW(hIC->lpszAgent) + strlenW(user_agent);
769 agent_header = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
770 sprintfW(agent_header, user_agent, hIC->lpszAgent );
771
772 HTTP_HttpAddRequestHeadersW(lpwhr, agent_header, strlenW(agent_header),
773 HTTP_ADDREQ_FLAG_ADD);
774 HeapFree(GetProcessHeap(), 0, agent_header);
775 }
776
777 len = strlenW(lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue) + strlenW(szUrlForm);
778 lpszUrl = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
779 sprintfW( lpszUrl, szUrlForm, lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue );
780
781 if (!(lpwhr->hdr.dwFlags & INTERNET_FLAG_NO_COOKIES) &&
782 InternetGetCookieW(lpszUrl, NULL, NULL, &nCookieSize))
783 {
784 int cnt = 0;
785 static const WCHAR szCookie[] = {'C','o','o','k','i','e',':',' ',0};
786 static const WCHAR szcrlf[] = {'\r','\n',0};
787
788 lpszCookies = HeapAlloc(GetProcessHeap(), 0, (nCookieSize + 1 + 8)*sizeof(WCHAR));
789
790 cnt += sprintfW(lpszCookies, szCookie);
791 InternetGetCookieW(lpszUrl, NULL, lpszCookies + cnt, &nCookieSize);
792 strcatW(lpszCookies, szcrlf);
793
794 HTTP_HttpAddRequestHeadersW(lpwhr, lpszCookies, strlenW(lpszCookies),
795 HTTP_ADDREQ_FLAG_ADD);
796 HeapFree(GetProcessHeap(), 0, lpszCookies);
797 }
798 HeapFree(GetProcessHeap(), 0, lpszUrl);
799
800
801 iar.dwResult = (DWORD_PTR)handle;
802 iar.dwError = ERROR_SUCCESS;
803
804 SendAsyncCallback(&lpwhs->hdr, dwContext,
805 INTERNET_STATUS_HANDLE_CREATED, &iar,
806 sizeof(INTERNET_ASYNC_RESULT));
807
808 /*
809 * A STATUS_REQUEST_COMPLETE is NOT sent here as per my tests on windows
810 */
811
812 /*
813 * According to my tests. The name is not resolved until a request is Opened
814 */
815 SendAsyncCallback(&lpwhr->hdr, dwContext,
816 INTERNET_STATUS_RESOLVING_NAME,
817 lpwhs->lpszServerName,
818 strlenW(lpwhs->lpszServerName)+1);
819 if (!GetAddress(lpwhs->lpszServerName, lpwhs->nServerPort,
820 &lpwhs->phostent, &lpwhs->socketAddress))
821 {
822 INTERNET_SetLastError(ERROR_INTERNET_NAME_NOT_RESOLVED);
823 InternetCloseHandle( handle );
824 handle = NULL;
825 goto lend;
826 }
827
828 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
829 INTERNET_STATUS_NAME_RESOLVED,
830 &(lpwhs->socketAddress),
831 sizeof(struct sockaddr_in));
832
833 lend:
834 if( lpwhr )
835 WININET_Release( &lpwhr->hdr );
836
837 TRACE("<-- %p (%p)\n", handle, lpwhr);
838 return handle;
839 }
840
841 /***********************************************************************
842 * HTTP_HttpQueryInfoW (internal)
843 */
844 BOOL WINAPI HTTP_HttpQueryInfoW( LPWININETHTTPREQW lpwhr, DWORD dwInfoLevel,
845 LPVOID lpBuffer, LPDWORD lpdwBufferLength, LPDWORD lpdwIndex)
846 {
847 LPHTTPHEADERW lphttpHdr = NULL;
848 BOOL bSuccess = FALSE;
849
850 /* Find requested header structure */
851 if ((dwInfoLevel & ~HTTP_QUERY_MODIFIER_FLAGS_MASK) == HTTP_QUERY_CUSTOM)
852 {
853 INT index = HTTP_GetCustomHeaderIndex(lpwhr, (LPWSTR)lpBuffer);
854
855 if (index < 0)
856 return bSuccess;
857
858 lphttpHdr = &lpwhr->pCustHeaders[index];
859 }
860 else
861 {
862 INT index = dwInfoLevel & ~HTTP_QUERY_MODIFIER_FLAGS_MASK;
863
864 if (index == HTTP_QUERY_RAW_HEADERS_CRLF)
865 {
866 DWORD len = strlenW(lpwhr->lpszRawHeaders);
867 if (len + 1 > *lpdwBufferLength/sizeof(WCHAR))
868 {
869 *lpdwBufferLength = (len + 1) * sizeof(WCHAR);
870 INTERNET_SetLastError(ERROR_INSUFFICIENT_BUFFER);
871 return FALSE;
872 }
873 memcpy(lpBuffer, lpwhr->lpszRawHeaders, (len+1)*sizeof(WCHAR));
874 *lpdwBufferLength = len * sizeof(WCHAR);
875
876 TRACE("returning data: %s\n", debugstr_wn((WCHAR*)lpBuffer, len));
877
878 return TRUE;
879 }
880 else if (index == HTTP_QUERY_RAW_HEADERS)
881 {
882 static const WCHAR szCrLf[] = {'\r','\n',0};
883 LPWSTR * ppszRawHeaderLines = HTTP_Tokenize(lpwhr->lpszRawHeaders, szCrLf);
884 DWORD i, size = 0;
885 LPWSTR pszString = (WCHAR*)lpBuffer;
886
887 for (i = 0; ppszRawHeaderLines[i]; i++)
888 size += strlenW(ppszRawHeaderLines[i]) + 1;
889
890 if (size + 1 > *lpdwBufferLength/sizeof(WCHAR))
891 {
892 HTTP_FreeTokens(ppszRawHeaderLines);
893 *lpdwBufferLength = (size + 1) * sizeof(WCHAR);
894 INTERNET_SetLastError(ERROR_INSUFFICIENT_BUFFER);
895 return FALSE;
896 }
897
898 for (i = 0; ppszRawHeaderLines[i]; i++)
899 {
900 DWORD len = strlenW(ppszRawHeaderLines[i]);
901 memcpy(pszString, ppszRawHeaderLines[i], (len+1)*sizeof(WCHAR));
902 pszString += len+1;
903 }
904 *pszString = '\0';
905
906 TRACE("returning data: %s\n", debugstr_wn((WCHAR*)lpBuffer, size));
907
908 *lpdwBufferLength = size * sizeof(WCHAR);
909 HTTP_FreeTokens(ppszRawHeaderLines);
910
911 return TRUE;
912 }
913 else if (index >= 0 && index <= HTTP_QUERY_MAX && lpwhr->StdHeaders[index].lpszValue)
914 {
915 lphttpHdr = &lpwhr->StdHeaders[index];
916 }
917 else
918 {
919 SetLastError(ERROR_HTTP_HEADER_NOT_FOUND);
920 return bSuccess;
921 }
922 }
923
924 /* Ensure header satisifies requested attributes */
925 if ((dwInfoLevel & HTTP_QUERY_FLAG_REQUEST_HEADERS) &&
926 (~lphttpHdr->wFlags & HDR_ISREQUEST))
927 {
928 SetLastError(ERROR_HTTP_HEADER_NOT_FOUND);
929 return bSuccess;
930 }
931
932 /* coalesce value to reuqested type */
933 if (dwInfoLevel & HTTP_QUERY_FLAG_NUMBER)
934 {
935 *(int *)lpBuffer = atoiW(lphttpHdr->lpszValue);
936 bSuccess = TRUE;
937
938 TRACE(" returning number : %d\n", *(int *)lpBuffer);
939 }
940 else if (dwInfoLevel & HTTP_QUERY_FLAG_SYSTEMTIME)
941 {
942 time_t tmpTime;
943 struct tm tmpTM;
944 SYSTEMTIME *STHook;
945
946 tmpTime = ConvertTimeString(lphttpHdr->lpszValue);
947
948 tmpTM = *gmtime(&tmpTime);
949 STHook = (SYSTEMTIME *) lpBuffer;
950 if(STHook==NULL)
951 return bSuccess;
952
953 STHook->wDay = tmpTM.tm_mday;
954 STHook->wHour = tmpTM.tm_hour;
955 STHook->wMilliseconds = 0;
956 STHook->wMinute = tmpTM.tm_min;
957 STHook->wDayOfWeek = tmpTM.tm_wday;
958 STHook->wMonth = tmpTM.tm_mon + 1;
959 STHook->wSecond = tmpTM.tm_sec;
960 STHook->wYear = tmpTM.tm_year;
961
962 bSuccess = TRUE;
963
964 TRACE(" returning time : %04d/%02d/%02d - %d - %02d:%02d:%02d.%02d\n",
965 STHook->wYear, STHook->wMonth, STHook->wDay, STHook->wDayOfWeek,
966 STHook->wHour, STHook->wMinute, STHook->wSecond, STHook->wMilliseconds);
967 }
968 else if (dwInfoLevel & HTTP_QUERY_FLAG_COALESCE)
969 {
970 if (*lpdwIndex >= lphttpHdr->wCount)
971 {
972 INTERNET_SetLastError(ERROR_HTTP_HEADER_NOT_FOUND);
973 }
974 else
975 {
976 /* Copy strncpyW(lpBuffer, lphttpHdr[*lpdwIndex], len); */
977 (*lpdwIndex)++;
978 }
979 }
980 else
981 {
982 DWORD len = (strlenW(lphttpHdr->lpszValue) + 1) * sizeof(WCHAR);
983
984 if (len > *lpdwBufferLength)
985 {
986 *lpdwBufferLength = len;
987 INTERNET_SetLastError(ERROR_INSUFFICIENT_BUFFER);
988 return bSuccess;
989 }
990
991 memcpy(lpBuffer, lphttpHdr->lpszValue, len);
992 *lpdwBufferLength = len - sizeof(WCHAR);
993 bSuccess = TRUE;
994
995 TRACE(" returning string : '%s'\n", debugstr_w(lpBuffer));
996 }
997 return bSuccess;
998 }
999
1000 /***********************************************************************
1001 * HttpQueryInfoW (WININET.@)
1002 *
1003 * Queries for information about an HTTP request
1004 *
1005 * RETURNS
1006 * TRUE on success
1007 * FALSE on failure
1008 *
1009 */
1010 BOOL WINAPI HttpQueryInfoW(HINTERNET hHttpRequest, DWORD dwInfoLevel,
1011 LPVOID lpBuffer, LPDWORD lpdwBufferLength, LPDWORD lpdwIndex)
1012 {
1013 BOOL bSuccess = FALSE;
1014 LPWININETHTTPREQW lpwhr;
1015
1016 if (TRACE_ON(wininet)) {
1017 #define FE(x) { x, #x }
1018 static const wininet_flag_info query_flags[] = {
1019 FE(HTTP_QUERY_MIME_VERSION),
1020 FE(HTTP_QUERY_CONTENT_TYPE),
1021 FE(HTTP_QUERY_CONTENT_TRANSFER_ENCODING),
1022 FE(HTTP_QUERY_CONTENT_ID),
1023 FE(HTTP_QUERY_CONTENT_DESCRIPTION),
1024 FE(HTTP_QUERY_CONTENT_LENGTH),
1025 FE(HTTP_QUERY_CONTENT_LANGUAGE),
1026 FE(HTTP_QUERY_ALLOW),
1027 FE(HTTP_QUERY_PUBLIC),
1028 FE(HTTP_QUERY_DATE),
1029 FE(HTTP_QUERY_EXPIRES),
1030 FE(HTTP_QUERY_LAST_MODIFIED),
1031 FE(HTTP_QUERY_MESSAGE_ID),
1032 FE(HTTP_QUERY_URI),
1033 FE(HTTP_QUERY_DERIVED_FROM),
1034 FE(HTTP_QUERY_COST),
1035 FE(HTTP_QUERY_LINK),
1036 FE(HTTP_QUERY_PRAGMA),
1037 FE(HTTP_QUERY_VERSION),
1038 FE(HTTP_QUERY_STATUS_CODE),
1039 FE(HTTP_QUERY_STATUS_TEXT),
1040 FE(HTTP_QUERY_RAW_HEADERS),
1041 FE(HTTP_QUERY_RAW_HEADERS_CRLF),
1042 FE(HTTP_QUERY_CONNECTION),
1043 FE(HTTP_QUERY_ACCEPT),
1044 FE(HTTP_QUERY_ACCEPT_CHARSET),
1045 FE(HTTP_QUERY_ACCEPT_ENCODING),
1046 FE(HTTP_QUERY_ACCEPT_LANGUAGE),
1047 FE(HTTP_QUERY_AUTHORIZATION),
1048 FE(HTTP_QUERY_CONTENT_ENCODING),
1049 FE(HTTP_QUERY_FORWARDED),
1050 FE(HTTP_QUERY_FROM),
1051 FE(HTTP_QUERY_IF_MODIFIED_SINCE),
1052 FE(HTTP_QUERY_LOCATION),
1053 FE(HTTP_QUERY_ORIG_URI),
1054 FE(HTTP_QUERY_REFERER),
1055 FE(HTTP_QUERY_RETRY_AFTER),
1056 FE(HTTP_QUERY_SERVER),
1057 FE(HTTP_QUERY_TITLE),
1058 FE(HTTP_QUERY_USER_AGENT),
1059 FE(HTTP_QUERY_WWW_AUTHENTICATE),
1060 FE(HTTP_QUERY_PROXY_AUTHENTICATE),
1061 FE(HTTP_QUERY_ACCEPT_RANGES),
1062 FE(HTTP_QUERY_SET_COOKIE),
1063 FE(HTTP_QUERY_COOKIE),
1064 FE(HTTP_QUERY_REQUEST_METHOD),
1065 FE(HTTP_QUERY_REFRESH),
1066 FE(HTTP_QUERY_CONTENT_DISPOSITION),
1067 FE(HTTP_QUERY_AGE),
1068 FE(HTTP_QUERY_CACHE_CONTROL),
1069 FE(HTTP_QUERY_CONTENT_BASE),
1070 FE(HTTP_QUERY_CONTENT_LOCATION),
1071 FE(HTTP_QUERY_CONTENT_MD5),
1072 FE(HTTP_QUERY_CONTENT_RANGE),
1073 FE(HTTP_QUERY_ETAG),
1074 FE(HTTP_QUERY_HOST),
1075 FE(HTTP_QUERY_IF_MATCH),
1076 FE(HTTP_QUERY_IF_NONE_MATCH),
1077 FE(HTTP_QUERY_IF_RANGE),
1078 FE(HTTP_QUERY_IF_UNMODIFIED_SINCE),
1079 FE(HTTP_QUERY_MAX_FORWARDS),
1080 FE(HTTP_QUERY_PROXY_AUTHORIZATION),
1081 FE(HTTP_QUERY_RANGE),
1082 FE(HTTP_QUERY_TRANSFER_ENCODING),
1083 FE(HTTP_QUERY_UPGRADE),
1084 FE(HTTP_QUERY_VARY),
1085 FE(HTTP_QUERY_VIA),
1086 FE(HTTP_QUERY_WARNING),
1087 FE(HTTP_QUERY_CUSTOM)
1088 };
1089 static const wininet_flag_info modifier_flags[] = {
1090 FE(HTTP_QUERY_FLAG_REQUEST_HEADERS),
1091 FE(HTTP_QUERY_FLAG_SYSTEMTIME),
1092 FE(HTTP_QUERY_FLAG_NUMBER),
1093 FE(HTTP_QUERY_FLAG_COALESCE)
1094 };
1095 #undef FE
1096 DWORD info_mod = dwInfoLevel & HTTP_QUERY_MODIFIER_FLAGS_MASK;
1097 DWORD info = dwInfoLevel & HTTP_QUERY_HEADER_MASK;
1098 DWORD i;
1099
1100 TRACE("(%p, 0x%08lx)--> %ld\n", hHttpRequest, dwInfoLevel, dwInfoLevel);
1101 TRACE(" Attribute:");
1102 for (i = 0; i < (sizeof(query_flags) / sizeof(query_flags[0])); i++) {
1103 if (query_flags[i].val == info) {
1104 DPRINTF(" %s", query_flags[i].name);
1105 break;
1106 }
1107 }
1108 if (i == (sizeof(query_flags) / sizeof(query_flags[0]))) {
1109 DPRINTF(" Unknown (%08lx)", info);
1110 }
1111
1112 DPRINTF(" Modifier:");
1113 for (i = 0; i < (sizeof(modifier_flags) / sizeof(modifier_flags[0])); i++) {
1114 if (modifier_flags[i].val & info_mod) {
1115 DPRINTF(" %s", modifier_flags[i].name);
1116 info_mod &= ~ modifier_flags[i].val;
1117 }
1118 }
1119
1120 if (info_mod) {
1121 DPRINTF(" Unknown (%08lx)", info_mod);
1122 }
1123 DPRINTF("\n");
1124 }
1125
1126 lpwhr = (LPWININETHTTPREQW) WININET_GetObject( hHttpRequest );
1127 if (NULL == lpwhr || lpwhr->hdr.htype != WH_HHTTPREQ)
1128 {
1129 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1130 goto lend;
1131 }
1132
1133 bSuccess = HTTP_HttpQueryInfoW( lpwhr, dwInfoLevel,
1134 lpBuffer, lpdwBufferLength, lpdwIndex);
1135
1136 lend:
1137 if( lpwhr )
1138 WININET_Release( &lpwhr->hdr );
1139
1140 TRACE("%d <--\n", bSuccess);
1141 return bSuccess;
1142 }
1143
1144 /***********************************************************************
1145 * HttpQueryInfoA (WININET.@)
1146 *
1147 * Queries for information about an HTTP request
1148 *
1149 * RETURNS
1150 * TRUE on success
1151 * FALSE on failure
1152 *
1153 */
1154 BOOL WINAPI HttpQueryInfoA(HINTERNET hHttpRequest, DWORD dwInfoLevel,
1155 LPVOID lpBuffer, LPDWORD lpdwBufferLength, LPDWORD lpdwIndex)
1156 {
1157 BOOL result;
1158 DWORD len;
1159 WCHAR* bufferW;
1160
1161 if((dwInfoLevel & HTTP_QUERY_FLAG_NUMBER) ||
1162 (dwInfoLevel & HTTP_QUERY_FLAG_SYSTEMTIME))
1163 {
1164 return HttpQueryInfoW( hHttpRequest, dwInfoLevel, lpBuffer,
1165 lpdwBufferLength, lpdwIndex );
1166 }
1167
1168 len = (*lpdwBufferLength)*sizeof(WCHAR);
1169 bufferW = HeapAlloc( GetProcessHeap(), 0, len );
1170 result = HttpQueryInfoW( hHttpRequest, dwInfoLevel, bufferW,
1171 &len, lpdwIndex );
1172 if( result )
1173 {
1174 len = WideCharToMultiByte( CP_ACP,0, bufferW, len / sizeof(WCHAR) + 1,
1175 lpBuffer, *lpdwBufferLength, NULL, NULL );
1176 *lpdwBufferLength = len - 1;
1177
1178 TRACE("lpBuffer: %s\n", debugstr_a(lpBuffer));
1179 }
1180 else
1181 /* since the strings being returned from HttpQueryInfoW should be
1182 * only ASCII characters, it is reasonable to assume that all of
1183 * the Unicode characters can be reduced to a single byte */
1184 *lpdwBufferLength = len / sizeof(WCHAR);
1185
1186 HeapFree(GetProcessHeap(), 0, bufferW );
1187
1188 return result;
1189 }
1190
1191 /***********************************************************************
1192 * HttpSendRequestExA (WININET.@)
1193 *
1194 * Sends the specified request to the HTTP server and allows chunked
1195 * transfers
1196 */
1197 BOOL WINAPI HttpSendRequestExA(HINTERNET hRequest,
1198 LPINTERNET_BUFFERSA lpBuffersIn,
1199 LPINTERNET_BUFFERSA lpBuffersOut,
1200 DWORD dwFlags, DWORD dwContext)
1201 {
1202 FIXME("(%p, %p, %p, %08lx, %08lx): stub\n", hRequest, lpBuffersIn,
1203 lpBuffersOut, dwFlags, dwContext);
1204 return FALSE;
1205 }
1206
1207 /***********************************************************************
1208 * HttpSendRequestW (WININET.@)
1209 *
1210 * Sends the specified request to the HTTP server
1211 *
1212 * RETURNS
1213 * TRUE on success
1214 * FALSE on failure
1215 *
1216 */
1217 BOOL WINAPI HttpSendRequestW(HINTERNET hHttpRequest, LPCWSTR lpszHeaders,
1218 DWORD dwHeaderLength, LPVOID lpOptional ,DWORD dwOptionalLength)
1219 {
1220 LPWININETHTTPREQW lpwhr;
1221 LPWININETHTTPSESSIONW lpwhs = NULL;
1222 LPWININETAPPINFOW hIC = NULL;
1223 BOOL r;
1224
1225 TRACE("%p, %p (%s), %li, %p, %li)\n", hHttpRequest,
1226 lpszHeaders, debugstr_w(lpszHeaders), dwHeaderLength, lpOptional, dwOptionalLength);
1227
1228 lpwhr = (LPWININETHTTPREQW) WININET_GetObject( hHttpRequest );
1229 if (NULL == lpwhr || lpwhr->hdr.htype != WH_HHTTPREQ)
1230 {
1231 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1232 r = FALSE;
1233 goto lend;
1234 }
1235
1236 lpwhs = (LPWININETHTTPSESSIONW) lpwhr->hdr.lpwhparent;
1237 if (NULL == lpwhs || lpwhs->hdr.htype != WH_HHTTPSESSION)
1238 {
1239 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1240 r = FALSE;
1241 goto lend;
1242 }
1243
1244 hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
1245 if (NULL == hIC || hIC->hdr.htype != WH_HINIT)
1246 {
1247 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1248 r = FALSE;
1249 goto lend;
1250 }
1251
1252 if (hIC->hdr.dwFlags & INTERNET_FLAG_ASYNC)
1253 {
1254 WORKREQUEST workRequest;
1255 struct WORKREQ_HTTPSENDREQUESTW *req;
1256
1257 workRequest.asyncall = HTTPSENDREQUESTW;
1258 workRequest.hdr = WININET_AddRef( &lpwhr->hdr );
1259 req = &workRequest.u.HttpSendRequestW;
1260 if (lpszHeaders)
1261 req->lpszHeader = WININET_strdupW(lpszHeaders);
1262 else
1263 req->lpszHeader = 0;
1264 req->dwHeaderLength = dwHeaderLength;
1265 req->lpOptional = lpOptional;
1266 req->dwOptionalLength = dwOptionalLength;
1267
1268 INTERNET_AsyncCall(&workRequest);
1269 /*
1270 * This is from windows.
1271 */
1272 SetLastError(ERROR_IO_PENDING);
1273 r = FALSE;
1274 }
1275 else
1276 {
1277 r = HTTP_HttpSendRequestW(lpwhr, lpszHeaders,
1278 dwHeaderLength, lpOptional, dwOptionalLength);
1279 }
1280 lend:
1281 if( lpwhr )
1282 WININET_Release( &lpwhr->hdr );
1283 return r;
1284 }
1285
1286 /***********************************************************************
1287 * HttpSendRequestA (WININET.@)
1288 *
1289 * Sends the specified request to the HTTP server
1290 *
1291 * RETURNS
1292 * TRUE on success
1293 * FALSE on failure
1294 *
1295 */
1296 BOOL WINAPI HttpSendRequestA(HINTERNET hHttpRequest, LPCSTR lpszHeaders,
1297 DWORD dwHeaderLength, LPVOID lpOptional ,DWORD dwOptionalLength)
1298 {
1299 BOOL result;
1300 LPWSTR szHeaders=NULL;
1301 DWORD nLen=dwHeaderLength;
1302 if(lpszHeaders!=NULL)
1303 {
1304 nLen=MultiByteToWideChar(CP_ACP,0,lpszHeaders,dwHeaderLength,NULL,0);
1305 szHeaders=HeapAlloc(GetProcessHeap(),0,nLen*sizeof(WCHAR));
1306 MultiByteToWideChar(CP_ACP,0,lpszHeaders,dwHeaderLength,szHeaders,nLen);
1307 }
1308 result=HttpSendRequestW(hHttpRequest, szHeaders, nLen, lpOptional, dwOptionalLength);
1309 if(szHeaders!=NULL)
1310 HeapFree(GetProcessHeap(),0,szHeaders);
1311 return result;
1312 }
1313
1314 /***********************************************************************
1315 * HTTP_HandleRedirect (internal)
1316 */
1317 static BOOL HTTP_HandleRedirect(LPWININETHTTPREQW lpwhr, LPCWSTR lpszUrl, LPCWSTR lpszHeaders,
1318 DWORD dwHeaderLength, LPVOID lpOptional, DWORD dwOptionalLength)
1319 {
1320 LPWININETHTTPSESSIONW lpwhs = (LPWININETHTTPSESSIONW) lpwhr->hdr.lpwhparent;
1321 LPWININETAPPINFOW hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
1322 WCHAR path[2048];
1323
1324 if(lpszUrl[0]=='/')
1325 {
1326 /* if it's an absolute path, keep the same session info */
1327 strcpyW(path,lpszUrl);
1328 }
1329 else if (NULL != hIC->lpszProxy && hIC->lpszProxy[0] != 0)
1330 {
1331 TRACE("Redirect through proxy\n");
1332 strcpyW(path,lpszUrl);
1333 }
1334 else
1335 {
1336 URL_COMPONENTSW urlComponents;
1337 WCHAR protocol[32], hostName[MAXHOSTNAME], userName[1024];
1338 WCHAR password[1024], extra[1024];
1339 urlComponents.dwStructSize = sizeof(URL_COMPONENTSW);
1340 urlComponents.lpszScheme = protocol;
1341 urlComponents.dwSchemeLength = 32;
1342 urlComponents.lpszHostName = hostName;
1343 urlComponents.dwHostNameLength = MAXHOSTNAME;
1344 urlComponents.lpszUserName = userName;
1345 urlComponents.dwUserNameLength = 1024;
1346 urlComponents.lpszPassword = password;
1347 urlComponents.dwPasswordLength = 1024;
1348 urlComponents.lpszUrlPath = path;
1349 urlComponents.dwUrlPathLength = 2048;
1350 urlComponents.lpszExtraInfo = extra;
1351 urlComponents.dwExtraInfoLength = 1024;
1352 if(!InternetCrackUrlW(lpszUrl, strlenW(lpszUrl), 0, &urlComponents))
1353 return FALSE;
1354
1355 if (urlComponents.nPort == INTERNET_INVALID_PORT_NUMBER)
1356 urlComponents.nPort = INTERNET_DEFAULT_HTTP_PORT;
1357
1358 #if 0
1359 /*
1360 * This upsets redirects to binary files on sourceforge.net
1361 * and gives an html page instead of the target file
1362 * Examination of the HTTP request sent by native wininet.dll
1363 * reveals that it doesn't send a referrer in that case.
1364 * Maybe there's a flag that enables this, or maybe a referrer
1365 * shouldn't be added in case of a redirect.
1366 */
1367
1368 /* consider the current host as the referrer */
1369 if (NULL != lpwhs->lpszServerName && strlenW(lpwhs->lpszServerName))
1370 HTTP_ProcessHeader(lpwhr, HTTP_REFERER, lpwhs->lpszServerName,
1371 HTTP_ADDHDR_FLAG_REQ|HTTP_ADDREQ_FLAG_REPLACE|
1372 HTTP_ADDHDR_FLAG_ADD_IF_NEW);
1373 #endif
1374
1375 if (NULL != lpwhs->lpszServerName)
1376 HeapFree(GetProcessHeap(), 0, lpwhs->lpszServerName);
1377 lpwhs->lpszServerName = WININET_strdupW(hostName);
1378 if (NULL != lpwhs->lpszUserName)
1379 HeapFree(GetProcessHeap(), 0, lpwhs->lpszUserName);
1380 lpwhs->lpszUserName = WININET_strdupW(userName);
1381 lpwhs->nServerPort = urlComponents.nPort;
1382
1383 HTTP_ProcessHeader(lpwhr, g_szHost, hostName, HTTP_ADDREQ_FLAG_ADD | HTTP_ADDREQ_FLAG_REPLACE | HTTP_ADDHDR_FLAG_REQ);
1384
1385 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1386 INTERNET_STATUS_RESOLVING_NAME,
1387 lpwhs->lpszServerName,
1388 strlenW(lpwhs->lpszServerName)+1);
1389
1390 if (!GetAddress(lpwhs->lpszServerName, lpwhs->nServerPort,
1391 &lpwhs->phostent, &lpwhs->socketAddress))
1392 {
1393 INTERNET_SetLastError(ERROR_INTERNET_NAME_NOT_RESOLVED);
1394 return FALSE;
1395 }
1396
1397 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1398 INTERNET_STATUS_NAME_RESOLVED,
1399 &(lpwhs->socketAddress),
1400 sizeof(struct sockaddr_in));
1401
1402 }
1403
1404 if(lpwhr->lpszPath)
1405 HeapFree(GetProcessHeap(), 0, lpwhr->lpszPath);
1406 lpwhr->lpszPath=NULL;
1407 if (strlenW(path))
1408 {
1409 DWORD needed = 0;
1410 HRESULT rc;
1411
1412 rc = UrlEscapeW(path, NULL, &needed, URL_ESCAPE_SPACES_ONLY);
1413 if (rc != E_POINTER)
1414 needed = strlenW(path)+1;
1415 lpwhr->lpszPath = HeapAlloc(GetProcessHeap(), 0, needed*sizeof(WCHAR));
1416 rc = UrlEscapeW(path, lpwhr->lpszPath, &needed,
1417 URL_ESCAPE_SPACES_ONLY);
1418 if (rc)
1419 {
1420 ERR("Unable to escape string!(%s) (%ld)\n",debugstr_w(path),rc);
1421 strcpyW(lpwhr->lpszPath,path);
1422 }
1423 }
1424
1425 return HTTP_HttpSendRequestW(lpwhr, lpszHeaders, dwHeaderLength, lpOptional, dwOptionalLength);
1426 }
1427
1428 /***********************************************************************
1429 * HTTP_build_req (internal)
1430 *
1431 * concatenate all the strings in the request together
1432 */
1433 static LPWSTR HTTP_build_req( LPCWSTR *list, int len )
1434 {
1435 LPCWSTR *t;
1436 LPWSTR str;
1437
1438 for( t = list; *t ; t++ )
1439 len += strlenW( *t );
1440 len++;
1441
1442 str = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
1443 *str = 0;
1444
1445 for( t = list; *t ; t++ )
1446 strcatW( str, *t );
1447
1448 return str;
1449 }
1450
1451 /***********************************************************************
1452 * HTTP_HttpSendRequestW (internal)
1453 *
1454 * Sends the specified request to the HTTP server
1455 *
1456 * RETURNS
1457 * TRUE on success
1458 * FALSE on failure
1459 *
1460 */
1461 BOOL WINAPI HTTP_HttpSendRequestW(LPWININETHTTPREQW lpwhr, LPCWSTR lpszHeaders,
1462 DWORD dwHeaderLength, LPVOID lpOptional ,DWORD dwOptionalLength)
1463 {
1464 INT cnt;
1465 DWORD i;
1466 BOOL bSuccess = FALSE;
1467 LPWSTR requestString = NULL;
1468 INT responseLen;
1469 LPWININETHTTPSESSIONW lpwhs = NULL;
1470 LPWININETAPPINFOW hIC = NULL;
1471 BOOL loop_next = FALSE;
1472 int CustHeaderIndex;
1473 INTERNET_ASYNC_RESULT iar;
1474
1475 TRACE("--> %p\n", lpwhr);
1476
1477 assert(lpwhr->hdr.htype == WH_HHTTPREQ);
1478
1479 lpwhs = (LPWININETHTTPSESSIONW) lpwhr->hdr.lpwhparent;
1480 if (NULL == lpwhs || lpwhs->hdr.htype != WH_HHTTPSESSION)
1481 {
1482 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1483 return FALSE;
1484 }
1485
1486 hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
1487 if (NULL == hIC || hIC->hdr.htype != WH_HINIT)
1488 {
1489 INTERNET_SetLastError(ERROR_INTERNET_INCORRECT_HANDLE_TYPE);
1490 return FALSE;
1491 }
1492
1493 /* Clear any error information */
1494 INTERNET_SetLastError(0);
1495
1496
1497 /* We must have a verb */
1498 if (NULL == lpwhr->lpszVerb)
1499 {
1500 goto lend;
1501 }
1502
1503 /* if we are using optional stuff, we must add the fixed header of that option length */
1504 if (lpOptional && dwOptionalLength)
1505 {
1506 static const WCHAR szContentLength[] = {
1507 'C','o','n','t','e','n','t','-','L','e','n','g','t','h',':',' ','%','l','i','\r','\n',0};
1508 WCHAR contentLengthStr[sizeof szContentLength/2 /* includes \n\r */ + 20 /* int */ ];
1509 sprintfW(contentLengthStr, szContentLength, dwOptionalLength);
1510 HTTP_HttpAddRequestHeadersW(lpwhr, contentLengthStr, -1L, HTTP_ADDREQ_FLAG_ADD);
1511 }
1512
1513 do
1514 {
1515 static const WCHAR szSlash[] = { '/',0 };
1516 static const WCHAR szSpace[] = { ' ',0 };
1517 static const WCHAR szHttp[] = { 'h','t','t','p',':','/','/', 0 };
1518 static const WCHAR szcrlf[] = {'\r','\n', 0};
1519 static const WCHAR sztwocrlf[] = {'\r','\n','\r','\n', 0};
1520 static const WCHAR szSetCookie[] = {'S','e','t','-','C','o','o','k','i','e',0 };
1521 static const WCHAR szColon[] = { ':',' ',0 };
1522 LPCWSTR *req;
1523 LPWSTR p;
1524 DWORD len, n;
1525 char *ascii_req;
1526
1527 TRACE("Going to url %s %s\n", debugstr_w(lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue), debugstr_w(lpwhr->lpszPath));
1528 loop_next = FALSE;
1529
1530 /* If we don't have a path we set it to root */
1531 if (NULL == lpwhr->lpszPath)
1532 lpwhr->lpszPath = WININET_strdupW(szSlash);
1533 else /* remove \r and \n*/
1534 {
1535 int nLen = strlenW(lpwhr->lpszPath);
1536 while ((nLen >0 ) && ((lpwhr->lpszPath[nLen-1] == '\r')||(lpwhr->lpszPath[nLen-1] == '\n')))
1537 {
1538 nLen--;
1539 lpwhr->lpszPath[nLen]='\0';
1540 }
1541 }
1542
1543 if(CSTR_EQUAL != CompareStringW( LOCALE_SYSTEM_DEFAULT, NORM_IGNORECASE,
1544 lpwhr->lpszPath, strlenW(szHttp), szHttp, strlenW(szHttp) )
1545 && lpwhr->lpszPath[0] != '/') /* not an absolute path ?? --> fix it !! */
1546 {
1547 WCHAR *fixurl = HeapAlloc(GetProcessHeap(), 0,
1548 (strlenW(lpwhr->lpszPath) + 2)*sizeof(WCHAR));
1549 *fixurl = '/';
1550 strcpyW(fixurl + 1, lpwhr->lpszPath);
1551 HeapFree( GetProcessHeap(), 0, lpwhr->lpszPath );
1552 lpwhr->lpszPath = fixurl;
1553 }
1554
1555 /* add the headers the caller supplied */
1556 if( lpszHeaders && dwHeaderLength )
1557 {
1558 HTTP_HttpAddRequestHeadersW(lpwhr, lpszHeaders, dwHeaderLength,
1559 HTTP_ADDREQ_FLAG_ADD | HTTP_ADDHDR_FLAG_REPLACE);
1560 }
1561
1562 /* if there's a proxy username and password, add it to the headers */
1563 if (hIC && (hIC->lpszProxyUsername || hIC->lpszProxyPassword ))
1564 HTTP_InsertProxyAuthorization(lpwhr, hIC->lpszProxyUsername, hIC->lpszProxyPassword);
1565
1566 /* allocate space for an array of all the string pointers to be added */
1567 len = (HTTP_QUERY_MAX + lpwhr->nCustHeaders)*4 + 9;
1568 req = HeapAlloc( GetProcessHeap(), 0, len*sizeof(LPCWSTR) );
1569
1570 /* add the verb, path and HTTP/1.0 */
1571 n = 0;
1572 req[n++] = lpwhr->lpszVerb;
1573 req[n++] = szSpace;
1574 req[n++] = lpwhr->lpszPath;
1575 req[n++] = HTTPHEADER;
1576
1577 /* Append standard request headers */
1578 for (i = 0; i <= HTTP_QUERY_MAX; i++)
1579 {
1580 if (lpwhr->StdHeaders[i].wFlags & HDR_ISREQUEST)
1581 {
1582 req[n++] = szcrlf;
1583 req[n++] = lpwhr->StdHeaders[i].lpszField;
1584 req[n++] = szColon;
1585 req[n++] = lpwhr->StdHeaders[i].lpszValue;
1586
1587 TRACE("Adding header %s (%s)\n",
1588 debugstr_w(lpwhr->StdHeaders[i].lpszField),
1589 debugstr_w(lpwhr->StdHeaders[i].lpszValue));
1590 }
1591 }
1592
1593 /* Append custom request heades */
1594 for (i = 0; i < lpwhr->nCustHeaders; i++)
1595 {
1596 if (lpwhr->pCustHeaders[i].wFlags & HDR_ISREQUEST)
1597 {
1598 req[n++] = szcrlf;
1599 req[n++] = lpwhr->pCustHeaders[i].lpszField;
1600 req[n++] = szColon;
1601 req[n++] = lpwhr->pCustHeaders[i].lpszValue;
1602
1603 TRACE("Adding custom header %s (%s)\n",
1604 debugstr_w(lpwhr->pCustHeaders[i].lpszField),
1605 debugstr_w(lpwhr->pCustHeaders[i].lpszValue));
1606 }
1607 }
1608
1609 if( n >= len )
1610 ERR("oops. buffer overrun\n");
1611
1612 req[n] = NULL;
1613 requestString = HTTP_build_req( req, 4 );
1614 HeapFree( GetProcessHeap(), 0, req );
1615
1616 /*
1617 * Set (header) termination string for request
1618 * Make sure there's exactly two new lines at the end of the request
1619 */
1620 p = &requestString[strlenW(requestString)-1];
1621 while ( (*p == '\n') || (*p == '\r') )
1622 p--;
1623 strcpyW( p+1, sztwocrlf );
1624
1625 TRACE("Request header -> %s\n", debugstr_w(requestString) );
1626
1627 /* Send the request and store the results */
1628 if (!HTTP_OpenConnection(lpwhr))
1629 goto lend;
1630
1631 /* send the request as ASCII, tack on the optional data */
1632 if( !lpOptional )
1633 dwOptionalLength = 0;
1634 len = WideCharToMultiByte( CP_ACP, 0, requestString, -1,
1635 NULL, 0, NULL, NULL );
1636 ascii_req = HeapAlloc( GetProcessHeap(), 0, len + dwOptionalLength );
1637 WideCharToMultiByte( CP_ACP, 0, requestString, -1,
1638 ascii_req, len, NULL, NULL );
1639 if( lpOptional )
1640 memcpy( &ascii_req[len-1], lpOptional, dwOptionalLength );
1641 len = (len + dwOptionalLength - 1);
1642 ascii_req[len] = 0;
1643 TRACE("full request -> %s\n", ascii_req );
1644
1645 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1646 INTERNET_STATUS_SENDING_REQUEST, NULL, 0);
1647
1648 NETCON_send(&lpwhr->netConnection, ascii_req, len, 0, &cnt);
1649 HeapFree( GetProcessHeap(), 0, ascii_req );
1650
1651 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1652 INTERNET_STATUS_REQUEST_SENT,
1653 &len,sizeof(DWORD));
1654
1655 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1656 INTERNET_STATUS_RECEIVING_RESPONSE, NULL, 0);
1657
1658 if (cnt < 0)
1659 goto lend;
1660
1661 responseLen = HTTP_GetResponseHeaders(lpwhr);
1662 if (responseLen)
1663 bSuccess = TRUE;
1664
1665 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1666 INTERNET_STATUS_RESPONSE_RECEIVED, &responseLen,
1667 sizeof(DWORD));
1668
1669 /* process headers here. Is this right? */
1670 CustHeaderIndex = HTTP_GetCustomHeaderIndex(lpwhr, szSetCookie);
1671 if (!(lpwhr->hdr.dwFlags & INTERNET_FLAG_NO_COOKIES) && (CustHeaderIndex >= 0))
1672 {
1673 LPHTTPHEADERW setCookieHeader;
1674 int nPosStart = 0, nPosEnd = 0, len;
1675 static const WCHAR szFmt[] = { 'h','t','t','p',':','/','/','%','s','/',0};
1676
1677 setCookieHeader = &lpwhr->pCustHeaders[CustHeaderIndex];
1678
1679 while (setCookieHeader->lpszValue[nPosEnd] != '\0')
1680 {
1681 LPWSTR buf_cookie, cookie_name, cookie_data;
1682 LPWSTR buf_url;
1683 LPWSTR domain = NULL;
1684 int nEqualPos = 0;
1685 while (setCookieHeader->lpszValue[nPosEnd] != ';' && setCookieHeader->lpszValue[nPosEnd] != ',' &&
1686 setCookieHeader->lpszValue[nPosEnd] != '\0')
1687 {
1688 nPosEnd++;
1689 }
1690 if (setCookieHeader->lpszValue[nPosEnd] == ';')
1691 {
1692 /* fixme: not case sensitive, strcasestr is gnu only */
1693 int nDomainPosEnd = 0;
1694 int nDomainPosStart = 0, nDomainLength = 0;
1695 static const WCHAR szDomain[] = {'d','o','m','a','i','n','=',0};
1696 LPWSTR lpszDomain = strstrW(&setCookieHeader->lpszValue[nPosEnd], szDomain);
1697 if (lpszDomain)
1698 { /* they have specified their own domain, lets use it */
1699 while (lpszDomain[nDomainPosEnd] != ';' && lpszDomain[nDomainPosEnd] != ',' &&
1700 lpszDomain[nDomainPosEnd] != '\0')
1701 {
1702 nDomainPosEnd++;
1703 }
1704 nDomainPosStart = strlenW(szDomain);
1705 nDomainLength = (nDomainPosEnd - nDomainPosStart) + 1;
1706 domain = HeapAlloc(GetProcessHeap(), 0, (nDomainLength + 1)*sizeof(WCHAR));
1707 strncpyW(domain, &lpszDomain[nDomainPosStart], nDomainLength);
1708 domain[nDomainLength] = '\0';
1709 }
1710 }
1711 if (setCookieHeader->lpszValue[nPosEnd] == '\0') break;
1712 buf_cookie = HeapAlloc(GetProcessHeap(), 0, ((nPosEnd - nPosStart) + 1)*sizeof(WCHAR));
1713 strncpyW(buf_cookie, &setCookieHeader->lpszValue[nPosStart], (nPosEnd - nPosStart));
1714 buf_cookie[(nPosEnd - nPosStart)] = '\0';
1715 TRACE("%s\n", debugstr_w(buf_cookie));
1716 while (buf_cookie[nEqualPos] != '=' && buf_cookie[nEqualPos] != '\0')
1717 {
1718 nEqualPos++;
1719 }
1720 if (buf_cookie[nEqualPos] == '\0' || buf_cookie[nEqualPos + 1] == '\0')
1721 {
1722 HeapFree(GetProcessHeap(), 0, buf_cookie);
1723 break;
1724 }
1725
1726 cookie_name = HeapAlloc(GetProcessHeap(), 0, (nEqualPos + 1)*sizeof(WCHAR));
1727 strncpyW(cookie_name, buf_cookie, nEqualPos);
1728 cookie_name[nEqualPos] = '\0';
1729 cookie_data = &buf_cookie[nEqualPos + 1];
1730
1731
1732 len = strlenW((domain ? domain : lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue)) +
1733 strlenW(lpwhr->lpszPath) + 9;
1734 buf_url = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
1735 sprintfW(buf_url, szFmt, (domain ? domain : lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue)); /* FIXME PATH!!! */
1736 InternetSetCookieW(buf_url, cookie_name, cookie_data);
1737
1738 HeapFree(GetProcessHeap(), 0, buf_url);
1739 HeapFree(GetProcessHeap(), 0, buf_cookie);
1740 HeapFree(GetProcessHeap(), 0, cookie_name);
1741 HeapFree(GetProcessHeap(), 0, domain);
1742 nPosStart = nPosEnd;
1743 }
1744 }
1745 }
1746 while (loop_next);
1747
1748 lend:
1749
1750 HeapFree(GetProcessHeap(), 0, requestString);
1751
1752 /* TODO: send notification for P3P header */
1753
1754 if(!(hIC->hdr.dwFlags & INTERNET_FLAG_NO_AUTO_REDIRECT) && bSuccess)
1755 {
1756 DWORD dwCode,dwCodeLength=sizeof(DWORD),dwIndex=0;
1757 if(HTTP_HttpQueryInfoW(lpwhr,HTTP_QUERY_FLAG_NUMBER|HTTP_QUERY_STATUS_CODE,&dwCode,&dwCodeLength,&dwIndex) &&
1758 (dwCode==302 || dwCode==301))
1759 {
1760 WCHAR szNewLocation[2048];
1761 DWORD dwBufferSize=2048;
1762 dwIndex=0;
1763 if(HTTP_HttpQueryInfoW(lpwhr,HTTP_QUERY_LOCATION,szNewLocation,&dwBufferSize,&dwIndex))
1764 {
1765 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1766 INTERNET_STATUS_REDIRECT, szNewLocation,
1767 dwBufferSize);
1768 return HTTP_HandleRedirect(lpwhr, szNewLocation, lpszHeaders,
1769 dwHeaderLength, lpOptional, dwOptionalLength);
1770 }
1771 }
1772 }
1773
1774
1775 iar.dwResult = (DWORD)bSuccess;
1776 iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError();
1777
1778 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1779 INTERNET_STATUS_REQUEST_COMPLETE, &iar,
1780 sizeof(INTERNET_ASYNC_RESULT));
1781
1782 TRACE("<--\n");
1783 return bSuccess;
1784 }
1785
1786
1787 /***********************************************************************
1788 * HTTP_Connect (internal)
1789 *
1790 * Create http session handle
1791 *
1792 * RETURNS
1793 * HINTERNET a session handle on success
1794 * NULL on failure
1795 *
1796 */
1797 HINTERNET HTTP_Connect(LPWININETAPPINFOW hIC, LPCWSTR lpszServerName,
1798 INTERNET_PORT nServerPort, LPCWSTR lpszUserName,
1799 LPCWSTR lpszPassword, DWORD dwFlags, DWORD dwContext,
1800 DWORD dwInternalFlags)
1801 {
1802 BOOL bSuccess = FALSE;
1803 LPWININETHTTPSESSIONW lpwhs = NULL;
1804 HINTERNET handle = NULL;
1805
1806 TRACE("-->\n");
1807
1808 assert( hIC->hdr.htype == WH_HINIT );
1809
1810 hIC->hdr.dwContext = dwContext;
1811
1812 lpwhs = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(WININETHTTPSESSIONW));
1813 if (NULL == lpwhs)
1814 {
1815 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
1816 goto lerror;
1817 }
1818
1819 /*
1820 * According to my tests. The name is not resolved until a request is sent
1821 */
1822
1823 if (nServerPort == INTERNET_INVALID_PORT_NUMBER)
1824 nServerPort = INTERNET_DEFAULT_HTTP_PORT;
1825
1826 lpwhs->hdr.htype = WH_HHTTPSESSION;
1827 lpwhs->hdr.lpwhparent = WININET_AddRef( &hIC->hdr );
1828 lpwhs->hdr.dwFlags = dwFlags;
1829 lpwhs->hdr.dwContext = dwContext;
1830 lpwhs->hdr.dwInternalFlags = dwInternalFlags;
1831 lpwhs->hdr.dwRefCount = 1;
1832 lpwhs->hdr.destroy = HTTP_CloseHTTPSessionHandle;
1833 lpwhs->hdr.lpfnStatusCB = hIC->hdr.lpfnStatusCB;
1834
1835 handle = WININET_AllocHandle( &lpwhs->hdr );
1836 if (NULL == handle)
1837 {
1838 ERR("Failed to alloc handle\n");
1839 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
1840 goto lerror;
1841 }
1842
1843 if(hIC->lpszProxy && hIC->dwAccessType == INTERNET_OPEN_TYPE_PROXY) {
1844 if(strchrW(hIC->lpszProxy, ' '))
1845 FIXME("Several proxies not implemented.\n");
1846 if(hIC->lpszProxyBypass)
1847 FIXME("Proxy bypass is ignored.\n");
1848 }
1849 if (NULL != lpszServerName)
1850 lpwhs->lpszServerName = WININET_strdupW(lpszServerName);
1851 if (NULL != lpszUserName)
1852 lpwhs->lpszUserName = WININET_strdupW(lpszUserName);
1853 lpwhs->nServerPort = nServerPort;
1854
1855 /* Don't send a handle created callback if this handle was created with InternetOpenUrl */
1856 if (!(lpwhs->hdr.dwInternalFlags & INET_OPENURL))
1857 {
1858 INTERNET_ASYNC_RESULT iar;
1859
1860 iar.dwResult = (DWORD_PTR)handle;
1861 iar.dwError = ERROR_SUCCESS;
1862
1863 SendAsyncCallback(&lpwhs->hdr, dwContext,
1864 INTERNET_STATUS_HANDLE_CREATED, &iar,
1865 sizeof(INTERNET_ASYNC_RESULT));
1866 }
1867
1868 bSuccess = TRUE;
1869
1870 lerror:
1871 if( lpwhs )
1872 WININET_Release( &lpwhs->hdr );
1873
1874 /*
1875 * a INTERNET_STATUS_REQUEST_COMPLETE is NOT sent here as per my tests on
1876 * windows
1877 */
1878
1879 TRACE("%p --> %p (%p)\n", hIC, handle, lpwhs);
1880 return handle;
1881 }
1882
1883
1884 /***********************************************************************
1885 * HTTP_OpenConnection (internal)
1886 *
1887 * Connect to a web server
1888 *
1889 * RETURNS
1890 *
1891 * TRUE on success
1892 * FALSE on failure
1893 */
1894 BOOL HTTP_OpenConnection(LPWININETHTTPREQW lpwhr)
1895 {
1896 BOOL bSuccess = FALSE;
1897 LPWININETHTTPSESSIONW lpwhs;
1898 LPWININETAPPINFOW hIC = NULL;
1899
1900 TRACE("-->\n");
1901
1902
1903 if (NULL == lpwhr || lpwhr->hdr.htype != WH_HHTTPREQ)
1904 {
1905 INTERNET_SetLastError(ERROR_INVALID_PARAMETER);
1906 goto lend;
1907 }
1908
1909 lpwhs = (LPWININETHTTPSESSIONW)lpwhr->hdr.lpwhparent;
1910
1911 hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
1912 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1913 INTERNET_STATUS_CONNECTING_TO_SERVER,
1914 &(lpwhs->socketAddress),
1915 sizeof(struct sockaddr_in));
1916
1917 if (!NETCON_create(&lpwhr->netConnection, lpwhs->phostent->h_addrtype,
1918 SOCK_STREAM, 0))
1919 {
1920 WARN("Socket creation failed\n");
1921 goto lend;
1922 }
1923
1924 if (!NETCON_connect(&lpwhr->netConnection, (struct sockaddr *)&lpwhs->socketAddress,
1925 sizeof(lpwhs->socketAddress)))
1926 {
1927 WARN("Unable to connect to host (%s)\n", strerror(errno));
1928 goto lend;
1929 }
1930
1931 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1932 INTERNET_STATUS_CONNECTED_TO_SERVER,
1933 &(lpwhs->socketAddress),
1934 sizeof(struct sockaddr_in));
1935
1936 bSuccess = TRUE;
1937
1938 lend:
1939 TRACE("%d <--\n", bSuccess);
1940 return bSuccess;
1941 }
1942
1943
1944 /***********************************************************************
1945 * HTTP_clear_response_headers (internal)
1946 *
1947 * clear out any old response headers
1948 */
1949 static void HTTP_clear_response_headers( LPWININETHTTPREQW lpwhr )
1950 {
1951 DWORD i;
1952
1953 for( i=0; i<=HTTP_QUERY_MAX; i++ )
1954 {
1955 if( !lpwhr->StdHeaders[i].lpszField )
1956 continue;
1957 if( !lpwhr->StdHeaders[i].lpszValue )
1958 continue;
1959 if ( lpwhr->StdHeaders[i].wFlags & HDR_ISREQUEST )
1960 continue;
1961 HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[i], NULL );
1962 }
1963 for( i=0; i<lpwhr->nCustHeaders; i++)
1964 {
1965 if( !lpwhr->pCustHeaders[i].lpszField )
1966 continue;
1967 if( !lpwhr->pCustHeaders[i].lpszValue )
1968 continue;
1969 if ( lpwhr->pCustHeaders[i].wFlags & HDR_ISREQUEST )
1970 continue;
1971 HTTP_ReplaceHeaderValue( &lpwhr->pCustHeaders[i], NULL );
1972 }
1973 }
1974
1975 /***********************************************************************
1976 * HTTP_GetResponseHeaders (internal)
1977 *
1978 * Read server response
1979 *
1980 * RETURNS
1981 *
1982 * TRUE on success
1983 * FALSE on error
1984 */
1985 BOOL HTTP_GetResponseHeaders(LPWININETHTTPREQW lpwhr)
1986 {
1987 INT cbreaks = 0;
1988 WCHAR buffer[MAX_REPLY_LEN];
1989 DWORD buflen = MAX_REPLY_LEN;
1990 BOOL bSuccess = FALSE;
1991 INT rc = 0;
1992 static const WCHAR szCrLf[] = {'\r','\n',0};
1993 char bufferA[MAX_REPLY_LEN];
1994 LPWSTR status_code, status_text;
1995 DWORD cchMaxRawHeaders = 1024;
1996 LPWSTR lpszRawHeaders = HeapAlloc(GetProcessHeap(), 0, (cchMaxRawHeaders+1)*sizeof(WCHAR));
1997 DWORD cchRawHeaders = 0;
1998
1999 TRACE("-->\n");
2000
2001 /* clear old response headers (eg. from a redirect response) */
2002 HTTP_clear_response_headers( lpwhr );
2003
2004 if (!NETCON_connected(&lpwhr->netConnection))
2005 goto lend;
2006
2007 /*
2008 * HACK peek at the buffer
2009 */
2010 NETCON_recv(&lpwhr->netConnection, buffer, buflen, MSG_PEEK, &rc);
2011
2012 /*
2013 * We should first receive 'HTTP/1.x nnn OK' where nnn is the status code.
2014 */
2015 buflen = MAX_REPLY_LEN;
2016 memset(buffer, 0, MAX_REPLY_LEN);
2017 if (!NETCON_getNextLine(&lpwhr->netConnection, bufferA, &buflen))
2018 goto lend;
2019 MultiByteToWideChar( CP_ACP, 0, bufferA, buflen, buffer, MAX_REPLY_LEN );
2020
2021 /* regenerate raw headers */
2022 while (cchRawHeaders + buflen + strlenW(szCrLf) > cchMaxRawHeaders)
2023 {
2024 cchMaxRawHeaders *= 2;
2025 lpszRawHeaders = HeapReAlloc(GetProcessHeap(), 0, lpszRawHeaders, (cchMaxRawHeaders+1)*sizeof(WCHAR));
2026 }
2027 memcpy(lpszRawHeaders+cchRawHeaders, buffer, (buflen-1)*sizeof(WCHAR));
2028 cchRawHeaders += (buflen-1);
2029 memcpy(lpszRawHeaders+cchRawHeaders, szCrLf, sizeof(szCrLf));
2030 cchRawHeaders += sizeof(szCrLf)/sizeof(szCrLf[0])-1;
2031 lpszRawHeaders[cchRawHeaders] = '\0';
2032
2033 /* split the version from the status code */
2034 status_code = strchrW( buffer, ' ' );
2035 if( !status_code )
2036 goto lend;
2037 *status_code++=0;
2038
2039 /* split the status code from the status text */
2040 status_text = strchrW( status_code, ' ' );
2041 if( !status_text )
2042 goto lend;
2043 *status_text++=0;
2044
2045 TRACE("version [%s] status code [%s] status text [%s]\n",
2046 debugstr_w(buffer), debugstr_w(status_code), debugstr_w(status_text) );
2047 HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_VERSION], buffer );
2048 HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_STATUS_CODE], status_code );
2049 HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_STATUS_TEXT], status_text );
2050
2051 /* Parse each response line */
2052 do
2053 {
2054 buflen = MAX_REPLY_LEN;
2055 if (NETCON_getNextLine(&lpwhr->netConnection, bufferA, &buflen))
2056 {
2057 LPWSTR * pFieldAndValue;
2058
2059 TRACE("got line %s, now interpretting\n", debugstr_a(bufferA));
2060 MultiByteToWideChar( CP_ACP, 0, bufferA, buflen, buffer, MAX_REPLY_LEN );
2061
2062 while (cchRawHeaders + buflen + strlenW(szCrLf) > cchMaxRawHeaders)
2063 {
2064 cchMaxRawHeaders *= 2;
2065 lpszRawHeaders = HeapReAlloc(GetProcessHeap(), 0, lpszRawHeaders, (cchMaxRawHeaders+1)*sizeof(WCHAR));
2066 }
2067 memcpy(lpszRawHeaders+cchRawHeaders, buffer, (buflen-1)*sizeof(WCHAR));
2068 cchRawHeaders += (buflen-1);
2069 memcpy(lpszRawHeaders+cchRawHeaders, szCrLf, sizeof(szCrLf));
2070 cchRawHeaders += sizeof(szCrLf)/sizeof(szCrLf[0])-1;
2071 lpszRawHeaders[cchRawHeaders] = '\0';
2072
2073 pFieldAndValue = HTTP_InterpretHttpHeader(buffer);
2074 if (!pFieldAndValue)
2075 break;
2076
2077 HTTP_ProcessHeader(lpwhr, pFieldAndValue[0], pFieldAndValue[1],
2078 HTTP_ADDREQ_FLAG_ADD | HTTP_ADDREQ_FLAG_REPLACE);
2079
2080 HTTP_FreeTokens(pFieldAndValue);
2081 }
2082 else
2083 {
2084 cbreaks++;
2085 if (cbreaks >= 2)
2086 break;
2087 }
2088 }while(1);
2089
2090 if (lpwhr->lpszRawHeaders) HeapFree(GetProcessHeap(), 0, lpwhr->lpszRawHeaders);
2091 lpwhr->lpszRawHeaders = lpszRawHeaders;
2092 TRACE("raw headers: %s\n", debugstr_w(lpszRawHeaders));
2093 bSuccess = TRUE;
2094
2095 lend:
2096
2097 TRACE("<--\n");
2098 if (bSuccess)
2099 return rc;
2100 else
2101 return FALSE;
2102 }
2103
2104
2105 static void strip_spaces(LPWSTR start)
2106 {
2107 LPWSTR str = start;
2108 LPWSTR end;
2109
2110 while (*str == ' ' && *str != '\0')
2111 str++;
2112
2113 if (str != start)
2114 memmove(start, str, sizeof(WCHAR) * (strlenW(str) + 1));
2115
2116 end = start + strlenW(start) - 1;
2117 while (end >= start && *end == ' ')
2118 {
2119 *end = '\0';
2120 end--;
2121 }
2122 }
2123
2124
2125 /***********************************************************************
2126 * HTTP_InterpretHttpHeader (internal)
2127 *
2128 * Parse server response
2129 *
2130 * RETURNS
2131 *
2132 * Pointer to array of field, value, NULL on success.
2133 * NULL on error.
2134 */
2135 LPWSTR * HTTP_InterpretHttpHeader(LPCWSTR buffer)
2136 {
2137 LPWSTR * pTokenPair;
2138 LPWSTR pszColon;
2139 INT len;
2140
2141 pTokenPair = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*pTokenPair)*3);
2142
2143 pszColon = strchrW(buffer, ':');
2144 /* must have two tokens */
2145 if (!pszColon)
2146 {
2147 HTTP_FreeTokens(pTokenPair);
2148 return NULL;
2149 }
2150
2151 pTokenPair[0] = HeapAlloc(GetProcessHeap(), 0, (pszColon - buffer + 1) * sizeof(WCHAR));
2152 if (!pTokenPair[0])
2153 {
2154 HTTP_FreeTokens(pTokenPair);
2155 return NULL;
2156 }
2157 memcpy(pTokenPair[0], buffer, (pszColon - buffer) * sizeof(WCHAR));
2158 pTokenPair[0][pszColon - buffer] = '\0';
2159
2160 /* skip colon */
2161 pszColon++;
2162 len = strlenW(pszColon);
2163 pTokenPair[1] = HeapAlloc(GetProcessHeap(), 0, (len + 1) * sizeof(WCHAR));
2164 if (!pTokenPair[1])
2165 {
2166 HTTP_FreeTokens(pTokenPair);
2167 return NULL;
2168 }
2169 memcpy(pTokenPair[1], pszColon, (len + 1) * sizeof(WCHAR));
2170
2171 strip_spaces(pTokenPair[0]);
2172 strip_spaces(pTokenPair[1]);
2173
2174 TRACE("field(%s) Value(%s)\n", debugstr_w(pTokenPair[0]), debugstr_w(pTokenPair[1]));
2175 return pTokenPair;
2176 }
2177
2178
2179 /***********************************************************************
2180 * HTTP_GetStdHeaderIndex (internal)
2181 *
2182 * Lookup field index in standard http header array
2183 *
2184 * FIXME: This should be stuffed into a hash table
2185 */
2186 INT HTTP_GetStdHeaderIndex(LPCWSTR lpszField)
2187 {
2188 INT index = -1;
2189 static const WCHAR szContentLength[] = {
2190 'C','o','n','t','e','n','t','-','L','e','n','g','t','h',0};
2191 static const WCHAR szQueryRange[] = {
2192 'R','a','n','g','e',0};
2193 static const WCHAR szContentRange[] = {
2194 'C','o','n','t','e','n','t','-','R','a','n','g','e',0};
2195 static const WCHAR szContentType[] = {
2196 'C','o','n','t','e','n','t','-','T','y','p','e',0};
2197 static const WCHAR szLastModified[] = {
2198 'L','a','s','t','-','M','o','d','i','f','i','e','d',0};
2199 static const WCHAR szLocation[] = {'L','o','c','a','t','i','o','n',0};
2200 static const WCHAR szAccept[] = {'A','c','c','e','p','t',0};
2201 static const WCHAR szReferer[] = { 'R','e','f','e','r','e','r',0};
2202 static const WCHAR szContentTrans[] = { 'C','o','n','t','e','n','t','-',
2203 'T','r','a','n','s','f','e','r','-','E','n','c','o','d','i','n','g',0};
2204 static const WCHAR szDate[] = { 'D','a','t','e',0};
2205 static const WCHAR szServer[] = { 'S','e','r','v','e','r',0};
2206 static const WCHAR szConnection[] = { 'C','o','n','n','e','c','t','i','o','n',0};
2207 static const WCHAR szETag[] = { 'E','T','a','g',0};
2208 static const WCHAR szAcceptRanges[] = {
2209 'A','c','c','e','p','t','-','R','a','n','g','e','s',0 };
2210 static const WCHAR szExpires[] = { 'E','x','p','i','r','e','s',0 };
2211 static const WCHAR szMimeVersion[] = {
2212 'M','i','m','e','-','V','e','r','s','i','o','n', 0};
2213 static const WCHAR szPragma[] = { 'P','r','a','g','m','a', 0};
2214 static const WCHAR szCacheControl[] = {
2215 'C','a','c','h','e','-','C','o','n','t','r','o','l',0};
2216 static const WCHAR szUserAgent[] = { 'U','s','e','r','-','A','g','e','n','t',0};
2217 static const WCHAR szProxyAuth[] = {
2218 'P','r','o','x','y','-',
2219 'A','u','t','h','e','n','t','i','c','a','t','e', 0};
2220 static const WCHAR szContentEncoding[] = {
2221 'C','o','n','t','e','n','t','-','E','n','c','o','d','i','n','g',0};
2222 static const WCHAR szCookie[] = {'C','o','o','k','i','e',0};
2223 static const WCHAR szVary[] = {'V','a','r','y',0};
2224 static const WCHAR szVia[] = {'V','i','a',0};
2225
2226 if (!strcmpiW(lpszField, szContentLength))
2227 index = HTTP_QUERY_CONTENT_LENGTH;
2228 else if (!strcmpiW(lpszField,szQueryRange))
2229 index = HTTP_QUERY_RANGE;
2230 else if (!strcmpiW(lpszField,szContentRange))
2231 index = HTTP_QUERY_CONTENT_RANGE;
2232 else if (!strcmpiW(lpszField,szContentType))
2233 index = HTTP_QUERY_CONTENT_TYPE;
2234 else if (!strcmpiW(lpszField,szLastModified))
2235 index = HTTP_QUERY_LAST_MODIFIED;
2236 else if (!strcmpiW(lpszField,szLocation))
2237 index = HTTP_QUERY_LOCATION;
2238 else if (!strcmpiW(lpszField,szAccept))
2239 index = HTTP_QUERY_ACCEPT;
2240 else if (!strcmpiW(lpszField,szReferer))
2241 index = HTTP_QUERY_REFERER;
2242 else if (!strcmpiW(lpszField,szContentTrans))
2243 index = HTTP_QUERY_CONTENT_TRANSFER_ENCODING;
2244 else if (!strcmpiW(lpszField,szDate))
2245 index = HTTP_QUERY_DATE;
2246 else if (!strcmpiW(lpszField,szServer))
2247 index = HTTP_QUERY_SERVER;
2248 else if (!strcmpiW(lpszField,szConnection))
2249 index = HTTP_QUERY_CONNECTION;
2250 else if (!strcmpiW(lpszField,szETag))
2251 index = HTTP_QUERY_ETAG;
2252 else if (!strcmpiW(lpszField,szAcceptRanges))
2253 index = HTTP_QUERY_ACCEPT_RANGES;
2254 else if (!strcmpiW(lpszField,szExpires))
2255 index = HTTP_QUERY_EXPIRES;
2256 else if (!strcmpiW(lpszField,szMimeVersion))
2257 index = HTTP_QUERY_MIME_VERSION;
2258 else if (!strcmpiW(lpszField,szPragma))
2259 index = HTTP_QUERY_PRAGMA;
2260 else if (!strcmpiW(lpszField,szCacheControl))
2261 index = HTTP_QUERY_CACHE_CONTROL;
2262 else if (!strcmpiW(lpszField,szUserAgent))
2263 index = HTTP_QUERY_USER_AGENT;
2264 else if (!strcmpiW(lpszField,szProxyAuth))
2265 index = HTTP_QUERY_PROXY_AUTHENTICATE;
2266 else if (!strcmpiW(lpszField,szContentEncoding))
2267 index = HTTP_QUERY_CONTENT_ENCODING;
2268 else if (!strcmpiW(lpszField,szCookie))
2269 index = HTTP_QUERY_COOKIE;
2270 else if (!strcmpiW(lpszField,szVary))
2271 index = HTTP_QUERY_VARY;
2272 else if (!strcmpiW(lpszField,szVia))
2273 index = HTTP_QUERY_VIA;
2274 else if (!strcmpiW(lpszField,g_szHost))
2275 index = HTTP_QUERY_HOST;
2276 else
2277 {
2278 TRACE("Couldn't find %s in standard header table\n", debugstr_w(lpszField));
2279 }
2280
2281 return index;
2282 }
2283
2284 /***********************************************************************
2285 * HTTP_ReplaceHeaderValue (internal)
2286 */
2287 BOOL HTTP_ReplaceHeaderValue( LPHTTPHEADERW lphttpHdr, LPCWSTR value )
2288 {
2289 INT len = 0;
2290
2291 if( lphttpHdr->lpszValue )
2292 HeapFree( GetProcessHeap(), 0, lphttpHdr->lpszValue );
2293 lphttpHdr->lpszValue = NULL;
2294
2295 if( value )
2296 len = strlenW(value);
2297 if (len)
2298 {
2299 lphttpHdr->lpszValue = HeapAlloc(GetProcessHeap(), 0,
2300 (len+1)*sizeof(WCHAR));
2301 strcpyW(lphttpHdr->lpszValue, value);
2302 }
2303 return TRUE;
2304 }
2305
2306 /***********************************************************************
2307 * HTTP_ProcessHeader (internal)
2308 *
2309 * Stuff header into header tables according to <dwModifier>
2310 *
2311 */
2312
2313 #define COALESCEFLASG (HTTP_ADDHDR_FLAG_COALESCE|HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA|HTTP_ADDHDR_FLAG_COALESCE_WITH_SEMICOLON)
2314
2315 BOOL HTTP_ProcessHeader(LPWININETHTTPREQW lpwhr, LPCWSTR field, LPCWSTR value, DWORD dwModifier)
2316 {
2317 LPHTTPHEADERW lphttpHdr = NULL;
2318 BOOL bSuccess = FALSE;
2319 INT index;
2320
2321 TRACE("--> %s: %s - 0x%08lx\n", debugstr_w(field), debugstr_w(value), dwModifier);
2322
2323 /* Adjust modifier flags */
2324 if (dwModifier & COALESCEFLASG)
2325 dwModifier |= HTTP_ADDHDR_FLAG_ADD;
2326
2327 /* Try to get index into standard header array */
2328 index = HTTP_GetStdHeaderIndex(field);
2329 /* Don't let applications add Connection header to request */
2330 if ((index == HTTP_QUERY_CONNECTION) && (dwModifier & HTTP_ADDHDR_FLAG_REQ))
2331 return TRUE;
2332 else if (index >= 0)
2333 {
2334 lphttpHdr = &lpwhr->StdHeaders[index];
2335 }
2336 else /* Find or create new custom header */
2337 {
2338 index = HTTP_GetCustomHeaderIndex(lpwhr, field);
2339 if (index >= 0)
2340 {
2341 if (dwModifier & HTTP_ADDHDR_FLAG_ADD_IF_NEW)
2342 {
2343 return FALSE;
2344 }
2345 lphttpHdr = &lpwhr->pCustHeaders[index];
2346 }
2347 else
2348 {
2349 HTTPHEADERW hdr;
2350
2351 hdr.lpszField = (LPWSTR)field;
2352 hdr.lpszValue = (LPWSTR)value;
2353 hdr.wFlags = hdr.wCount = 0;
2354
2355 if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2356 hdr.wFlags |= HDR_ISREQUEST;
2357
2358 return HTTP_InsertCustomHeader(lpwhr, &hdr);
2359 }
2360 }
2361
2362 if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2363 lphttpHdr->wFlags |= HDR_ISREQUEST;
2364 else
2365 lphttpHdr->wFlags &= ~HDR_ISREQUEST;
2366
2367 if (!lphttpHdr->lpszValue && (dwModifier & (HTTP_ADDHDR_FLAG_ADD|HTTP_ADDHDR_FLAG_ADD_IF_NEW)))
2368 {
2369 INT slen;
2370
2371 if (!lpwhr->StdHeaders[index].lpszField)
2372 {
2373 lphttpHdr->lpszField = WININET_strdupW(field);
2374
2375 if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2376 lphttpHdr->wFlags |= HDR_ISREQUEST;
2377 }
2378
2379 slen = strlenW(value) + 1;
2380 lphttpHdr->lpszValue = HeapAlloc(GetProcessHeap(), 0, slen*sizeof(WCHAR));
2381 if (lphttpHdr->lpszValue)
2382 {
2383 strcpyW(lphttpHdr->lpszValue, value);
2384 bSuccess = TRUE;
2385 }
2386 else
2387 {
2388 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2389 }
2390 }
2391 else if (lphttpHdr->lpszValue)
2392 {
2393 if (dwModifier & HTTP_ADDHDR_FLAG_REPLACE)
2394 bSuccess = HTTP_ReplaceHeaderValue( lphttpHdr, value );
2395 else if (dwModifier & COALESCEFLASG)
2396 {
2397 LPWSTR lpsztmp;
2398 WCHAR ch = 0;
2399 INT len = 0;
2400 INT origlen = strlenW(lphttpHdr->lpszValue);
2401 INT valuelen = strlenW(value);
2402
2403 if (dwModifier & HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA)
2404 {
2405 ch = ',';
2406 lphttpHdr->wFlags |= HDR_COMMADELIMITED;
2407 }
2408 else if (dwModifier & HTTP_ADDHDR_FLAG_COALESCE_WITH_SEMICOLON)
2409 {
2410 ch = ';';
2411 lphttpHdr->wFlags |= HDR_COMMADELIMITED;
2412 }
2413
2414 len = origlen + valuelen + ((ch > 0) ? 1 : 0);
2415
2416 lpsztmp = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, lphttpHdr->lpszValue, (len+1)*sizeof(WCHAR));
2417 if (lpsztmp)
2418 {
2419 /* FIXME: Increment lphttpHdr->wCount. Perhaps lpszValue should be an array */
2420 if (ch > 0)
2421 {
2422 lphttpHdr->lpszValue[origlen] = ch;
2423 origlen++;
2424 }
2425
2426 memcpy(&lphttpHdr->lpszValue[origlen], value, valuelen*sizeof(WCHAR));
2427 lphttpHdr->lpszValue[len] = '\0';
2428 bSuccess = TRUE;
2429 }
2430 else
2431 {
2432 WARN("HeapReAlloc (%d bytes) failed\n",len+1);
2433 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2434 }
2435 }
2436 }
2437 TRACE("<-- %d\n",bSuccess);
2438 return bSuccess;
2439 }
2440
2441
2442 /***********************************************************************
2443 * HTTP_CloseConnection (internal)
2444 *
2445 * Close socket connection
2446 *
2447 */
2448 VOID HTTP_CloseConnection(LPWININETHTTPREQW lpwhr)
2449 {
2450 LPWININETHTTPSESSIONW lpwhs = NULL;
2451 LPWININETAPPINFOW hIC = NULL;
2452
2453 TRACE("%p\n",lpwhr);
2454
2455 lpwhs = (LPWININETHTTPSESSIONW) lpwhr->hdr.lpwhparent;
2456 hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
2457
2458 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
2459 INTERNET_STATUS_CLOSING_CONNECTION, 0, 0);
2460
2461 if (NETCON_connected(&lpwhr->netConnection))
2462 {
2463 NETCON_close(&lpwhr->netConnection);
2464 }
2465
2466 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
2467 INTERNET_STATUS_CONNECTION_CLOSED, 0, 0);
2468 }
2469
2470
2471 /***********************************************************************
2472 * HTTP_CloseHTTPRequestHandle (internal)
2473 *
2474 * Deallocate request handle
2475 *
2476 */
2477 static void HTTP_CloseHTTPRequestHandle(LPWININETHANDLEHEADER hdr)
2478 {
2479 DWORD i;
2480 LPWININETHTTPREQW lpwhr = (LPWININETHTTPREQW) hdr;
2481
2482 TRACE("\n");
2483
2484 if (NETCON_connected(&lpwhr->netConnection))
2485 HTTP_CloseConnection(lpwhr);
2486
2487 if (lpwhr->lpszPath)
2488 HeapFree(GetProcessHeap(), 0, lpwhr->lpszPath);
2489 if (lpwhr->lpszVerb)
2490 HeapFree(GetProcessHeap(), 0, lpwhr->lpszVerb);
2491 if (lpwhr->lpszRawHeaders)
2492 HeapFree(GetProcessHeap(), 0, lpwhr->lpszRawHeaders);
2493
2494 for (i = 0; i <= HTTP_QUERY_MAX; i++)
2495 {
2496 if (lpwhr->StdHeaders[i].lpszField)
2497 HeapFree(GetProcessHeap(), 0, lpwhr->StdHeaders[i].lpszField);
2498 if (lpwhr->StdHeaders[i].lpszValue)
2499 HeapFree(GetProcessHeap(), 0, lpwhr->StdHeaders[i].lpszValue);
2500 }
2501
2502 for (i = 0; i < lpwhr->nCustHeaders; i++)
2503 {
2504 if (lpwhr->pCustHeaders[i].lpszField)
2505 HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders[i].lpszField);
2506 if (lpwhr->pCustHeaders[i].lpszValue)
2507 HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders[i].lpszValue);
2508 }
2509
2510 HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders);
2511 HeapFree(GetProcessHeap(), 0, lpwhr);
2512 }
2513
2514
2515 /***********************************************************************
2516 * HTTP_CloseHTTPSessionHandle (internal)
2517 *
2518 * Deallocate session handle
2519 *
2520 */
2521 void HTTP_CloseHTTPSessionHandle(LPWININETHANDLEHEADER hdr)
2522 {
2523 LPWININETHTTPSESSIONW lpwhs = (LPWININETHTTPSESSIONW) hdr;
2524
2525 TRACE("%p\n", lpwhs);
2526
2527 if (lpwhs->lpszServerName)
2528 HeapFree(GetProcessHeap(), 0, lpwhs->lpszServerName);
2529 if (lpwhs->lpszUserName)
2530 HeapFree(GetProcessHeap(), 0, lpwhs->lpszUserName);
2531 HeapFree(GetProcessHeap(), 0, lpwhs);
2532 }
2533
2534
2535 /***********************************************************************
2536 * HTTP_GetCustomHeaderIndex (internal)
2537 *
2538 * Return index of custom header from header array
2539 *
2540 */
2541 INT HTTP_GetCustomHeaderIndex(LPWININETHTTPREQW lpwhr, LPCWSTR lpszField)
2542 {
2543 DWORD index;
2544
2545 TRACE("%s\n", debugstr_w(lpszField));
2546
2547 for (index = 0; index < lpwhr->nCustHeaders; index++)
2548 {
2549 if (!strcmpiW(lpwhr->pCustHeaders[index].lpszField, lpszField))
2550 break;
2551
2552 }
2553
2554 if (index >= lpwhr->nCustHeaders)
2555 index = -1;
2556
2557 TRACE("Return: %ld\n", index);
2558 return index;
2559 }
2560
2561
2562 /***********************************************************************
2563 * HTTP_InsertCustomHeader (internal)
2564 *
2565 * Insert header into array
2566 *
2567 */
2568 BOOL HTTP_InsertCustomHeader(LPWININETHTTPREQW lpwhr, LPHTTPHEADERW lpHdr)
2569 {
2570 INT count;
2571 LPHTTPHEADERW lph = NULL;
2572 BOOL r = FALSE;
2573
2574 TRACE("--> %s: %s\n", debugstr_w(lpHdr->lpszField), debugstr_w(lpHdr->lpszValue));
2575 count = lpwhr->nCustHeaders + 1;
2576 if (count > 1)
2577 lph = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, lpwhr->pCustHeaders, sizeof(HTTPHEADERW) * count);
2578 else
2579 lph = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(HTTPHEADERW) * count);
2580
2581 if (NULL != lph)
2582 {
2583 lpwhr->pCustHeaders = lph;
2584 lpwhr->pCustHeaders[count-1].lpszField = WININET_strdupW(lpHdr->lpszField);
2585 lpwhr->pCustHeaders[count-1].lpszValue = WININET_strdupW(lpHdr->lpszValue);
2586 lpwhr->pCustHeaders[count-1].wFlags = lpHdr->wFlags;
2587 lpwhr->pCustHeaders[count-1].wCount= lpHdr->wCount;
2588 lpwhr->nCustHeaders++;
2589 r = TRUE;
2590 }
2591 else
2592 {
2593 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2594 }
2595
2596 return r;
2597 }
2598
2599
2600 /***********************************************************************
2601 * HTTP_DeleteCustomHeader (internal)
2602 *
2603 * Delete header from array
2604 * If this function is called, the indexs may change.
2605 */
2606 BOOL HTTP_DeleteCustomHeader(LPWININETHTTPREQW lpwhr, DWORD index)
2607 {
2608 if( lpwhr->nCustHeaders <= 0 )
2609 return FALSE;
2610 if( lpwhr->nCustHeaders >= index )
2611 return FALSE;
2612 lpwhr->nCustHeaders--;
2613
2614 memmove( &lpwhr->pCustHeaders[index], &lpwhr->pCustHeaders[index+1],
2615 (lpwhr->nCustHeaders - index)* sizeof(HTTPHEADERW) );
2616 memset( &lpwhr->pCustHeaders[lpwhr->nCustHeaders], 0, sizeof(HTTPHEADERW) );
2617
2618 return TRUE;
2619 }
2620
2621 /***********************************************************************
2622 * IsHostInProxyBypassList (@)
2623 *
2624 * Undocumented
2625 *
2626 */
2627 BOOL WINAPI IsHostInProxyBypassList(DWORD flags, LPCSTR szHost, DWORD length)
2628 {
2629 FIXME("STUB: flags=%ld host=%s length=%ld\n",flags,szHost,length);
2630 return FALSE;
2631 }
Maarten's multimedia branch