git.oblomov.eu Git - wine/blob - dlls/wininet/http.c

   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     if (szReferrer) HeapFree(GetProcessHeap(), 0, szReferrer);
 481     if (szVersion) HeapFree(GetProcessHeap(), 0, szVersion);
 482     if (szObjectName) HeapFree(GetProcessHeap(), 0, szObjectName);
 483     if (szVerb) 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         /* allocate space for an array of all the string pointers to be added */
1563         len = (HTTP_QUERY_MAX + lpwhr->nCustHeaders)*4 + 9;
1564         req = HeapAlloc( GetProcessHeap(), 0, len*sizeof(LPCWSTR) );
1565
1566         /* add the verb, path and HTTP/1.0 */
1567         n = 0;
1568         req[n++] = lpwhr->lpszVerb;
1569         req[n++] = szSpace;
1570         req[n++] = lpwhr->lpszPath;
1571         req[n++] = HTTPHEADER;
1572
1573         /* Append standard request headers */
1574         for (i = 0; i <= HTTP_QUERY_MAX; i++)
1575         {
1576             if (lpwhr->StdHeaders[i].wFlags & HDR_ISREQUEST)
1577             {
1578                 req[n++] = szcrlf;
1579                 req[n++] = lpwhr->StdHeaders[i].lpszField;
1580                 req[n++] = szColon;
1581                 req[n++] = lpwhr->StdHeaders[i].lpszValue;
1582
1583                 TRACE("Adding header %s (%s)\n",
1584                        debugstr_w(lpwhr->StdHeaders[i].lpszField),
1585                        debugstr_w(lpwhr->StdHeaders[i].lpszValue));
1586             }
1587         }
1588
1589         /* Append custom request heades */
1590         for (i = 0; i < lpwhr->nCustHeaders; i++)
1591         {
1592             if (lpwhr->pCustHeaders[i].wFlags & HDR_ISREQUEST)
1593             {
1594                 req[n++] = szcrlf;
1595                 req[n++] = lpwhr->pCustHeaders[i].lpszField;
1596                 req[n++] = szColon;
1597                 req[n++] = lpwhr->pCustHeaders[i].lpszValue;
1598
1599                 TRACE("Adding custom header %s (%s)\n",
1600                        debugstr_w(lpwhr->pCustHeaders[i].lpszField),
1601                        debugstr_w(lpwhr->pCustHeaders[i].lpszValue));
1602             }
1603         }
1604
1605         if( n >= len )
1606             ERR("oops. buffer overrun\n");
1607
1608         req[n] = NULL;
1609         requestString = HTTP_build_req( req, 4 );
1610         HeapFree( GetProcessHeap(), 0, req );
1611
1612         /*
1613          * Set (header) termination string for request
1614          * Make sure there's exactly two new lines at the end of the request
1615          */
1616         p = &requestString[strlenW(requestString)-1];
1617         while ( (*p == '\n') || (*p == '\r') )
1618            p--;
1619         strcpyW( p+1, sztwocrlf );
1620
1621         TRACE("Request header -> %s\n", debugstr_w(requestString) );
1622
1623         /* Send the request and store the results */
1624         if (!HTTP_OpenConnection(lpwhr))
1625             goto lend;
1626
1627         /* send the request as ASCII, tack on the optional data */
1628         if( !lpOptional )
1629             dwOptionalLength = 0;
1630         len = WideCharToMultiByte( CP_ACP, 0, requestString, -1,
1631                                    NULL, 0, NULL, NULL );
1632         ascii_req = HeapAlloc( GetProcessHeap(), 0, len + dwOptionalLength );
1633         WideCharToMultiByte( CP_ACP, 0, requestString, -1,
1634                              ascii_req, len, NULL, NULL );
1635         if( lpOptional )
1636             memcpy( &ascii_req[len-1], lpOptional, dwOptionalLength );
1637         len = (len + dwOptionalLength - 1);
1638         ascii_req[len] = 0;
1639         TRACE("full request -> %s\n", ascii_req );
1640
1641         SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1642                           INTERNET_STATUS_SENDING_REQUEST, NULL, 0);
1643
1644         NETCON_send(&lpwhr->netConnection, ascii_req, len, 0, &cnt);
1645         HeapFree( GetProcessHeap(), 0, ascii_req );
1646
1647         SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1648                           INTERNET_STATUS_REQUEST_SENT,
1649                           &len,sizeof(DWORD));
1650
1651         SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1652                           INTERNET_STATUS_RECEIVING_RESPONSE, NULL, 0);
1653
1654         if (cnt < 0)
1655             goto lend;
1656
1657         responseLen = HTTP_GetResponseHeaders(lpwhr);
1658         if (responseLen)
1659             bSuccess = TRUE;
1660
1661         SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1662                           INTERNET_STATUS_RESPONSE_RECEIVED, &responseLen,
1663                           sizeof(DWORD));
1664
1665         /* process headers here. Is this right? */
1666         CustHeaderIndex = HTTP_GetCustomHeaderIndex(lpwhr, szSetCookie);
1667         if (!(lpwhr->hdr.dwFlags & INTERNET_FLAG_NO_COOKIES) && (CustHeaderIndex >= 0))
1668         {
1669             LPHTTPHEADERW setCookieHeader;
1670             int nPosStart = 0, nPosEnd = 0, len;
1671             static const WCHAR szFmt[] = { 'h','t','t','p',':','/','/','%','s','/',0};
1672
1673             setCookieHeader = &lpwhr->pCustHeaders[CustHeaderIndex];
1674
1675             while (setCookieHeader->lpszValue[nPosEnd] != '\0')
1676             {
1677                 LPWSTR buf_cookie, cookie_name, cookie_data;
1678                 LPWSTR buf_url;
1679                 LPWSTR domain = NULL;
1680                 int nEqualPos = 0;
1681                 while (setCookieHeader->lpszValue[nPosEnd] != ';' && setCookieHeader->lpszValue[nPosEnd] != ',' &&
1682                        setCookieHeader->lpszValue[nPosEnd] != '\0')
1683                 {
1684                     nPosEnd++;
1685                 }
1686                 if (setCookieHeader->lpszValue[nPosEnd] == ';')
1687                 {
1688                     /* fixme: not case sensitive, strcasestr is gnu only */
1689                     int nDomainPosEnd = 0;
1690                     int nDomainPosStart = 0, nDomainLength = 0;
1691                     static const WCHAR szDomain[] = {'d','o','m','a','i','n','=',0};
1692                     LPWSTR lpszDomain = strstrW(&setCookieHeader->lpszValue[nPosEnd], szDomain);
1693                     if (lpszDomain)
1694                     { /* they have specified their own domain, lets use it */
1695                         while (lpszDomain[nDomainPosEnd] != ';' && lpszDomain[nDomainPosEnd] != ',' &&
1696                                lpszDomain[nDomainPosEnd] != '\0')
1697                         {
1698                             nDomainPosEnd++;
1699                         }
1700                         nDomainPosStart = strlenW(szDomain);
1701                         nDomainLength = (nDomainPosEnd - nDomainPosStart) + 1;
1702                         domain = HeapAlloc(GetProcessHeap(), 0, (nDomainLength + 1)*sizeof(WCHAR));
1703                         strncpyW(domain, &lpszDomain[nDomainPosStart], nDomainLength);
1704                         domain[nDomainLength] = '\0';
1705                     }
1706                 }
1707                 if (setCookieHeader->lpszValue[nPosEnd] == '\0') break;
1708                 buf_cookie = HeapAlloc(GetProcessHeap(), 0, ((nPosEnd - nPosStart) + 1)*sizeof(WCHAR));
1709                 strncpyW(buf_cookie, &setCookieHeader->lpszValue[nPosStart], (nPosEnd - nPosStart));
1710                 buf_cookie[(nPosEnd - nPosStart)] = '\0';
1711                 TRACE("%s\n", debugstr_w(buf_cookie));
1712                 while (buf_cookie[nEqualPos] != '=' && buf_cookie[nEqualPos] != '\0')
1713                 {
1714                     nEqualPos++;
1715                 }
1716                 if (buf_cookie[nEqualPos] == '\0' || buf_cookie[nEqualPos + 1] == '\0')
1717                 {
1718                     HeapFree(GetProcessHeap(), 0, buf_cookie);
1719                     break;
1720                 }
1721
1722                 cookie_name = HeapAlloc(GetProcessHeap(), 0, (nEqualPos + 1)*sizeof(WCHAR));
1723                 strncpyW(cookie_name, buf_cookie, nEqualPos);
1724                 cookie_name[nEqualPos] = '\0';
1725                 cookie_data = &buf_cookie[nEqualPos + 1];
1726
1727
1728                 len = strlenW((domain ? domain : lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue)) +
1729                     strlenW(lpwhr->lpszPath) + 9;
1730                 buf_url = HeapAlloc(GetProcessHeap(), 0, len*sizeof(WCHAR));
1731                 sprintfW(buf_url, szFmt, (domain ? domain : lpwhr->StdHeaders[HTTP_QUERY_HOST].lpszValue)); /* FIXME PATH!!! */
1732                 InternetSetCookieW(buf_url, cookie_name, cookie_data);
1733
1734                 HeapFree(GetProcessHeap(), 0, buf_url);
1735                 HeapFree(GetProcessHeap(), 0, buf_cookie);
1736                 HeapFree(GetProcessHeap(), 0, cookie_name);
1737                 if (domain) HeapFree(GetProcessHeap(), 0, domain);
1738                 nPosStart = nPosEnd;
1739             }
1740         }
1741     }
1742     while (loop_next);
1743
1744 lend:
1745
1746     if (requestString)
1747         HeapFree(GetProcessHeap(), 0, requestString);
1748
1749     /* TODO: send notification for P3P header */
1750
1751     if(!(hIC->hdr.dwFlags & INTERNET_FLAG_NO_AUTO_REDIRECT) && bSuccess)
1752     {
1753         DWORD dwCode,dwCodeLength=sizeof(DWORD),dwIndex=0;
1754         if(HTTP_HttpQueryInfoW(lpwhr,HTTP_QUERY_FLAG_NUMBER|HTTP_QUERY_STATUS_CODE,&dwCode,&dwCodeLength,&dwIndex) &&
1755             (dwCode==302 || dwCode==301))
1756         {
1757             WCHAR szNewLocation[2048];
1758             DWORD dwBufferSize=2048;
1759             dwIndex=0;
1760             if(HTTP_HttpQueryInfoW(lpwhr,HTTP_QUERY_LOCATION,szNewLocation,&dwBufferSize,&dwIndex))
1761             {
1762                 SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1763                       INTERNET_STATUS_REDIRECT, szNewLocation,
1764                       dwBufferSize);
1765                 return HTTP_HandleRedirect(lpwhr, szNewLocation, lpszHeaders,
1766                                            dwHeaderLength, lpOptional, dwOptionalLength);
1767             }
1768         }
1769     }
1770
1771
1772     iar.dwResult = (DWORD)bSuccess;
1773     iar.dwError = bSuccess ? ERROR_SUCCESS : INTERNET_GetLastError();
1774
1775     SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1776                     INTERNET_STATUS_REQUEST_COMPLETE, &iar,
1777                     sizeof(INTERNET_ASYNC_RESULT));
1778
1779     TRACE("<--\n");
1780     return bSuccess;
1781 }
1782
1783
1784 /***********************************************************************
1785  *           HTTP_Connect  (internal)
1786  *
1787  * Create http session handle
1788  *
1789  * RETURNS
1790  *   HINTERNET a session handle on success
1791  *   NULL on failure
1792  *
1793  */
1794 HINTERNET HTTP_Connect(LPWININETAPPINFOW hIC, LPCWSTR lpszServerName,
1795         INTERNET_PORT nServerPort, LPCWSTR lpszUserName,
1796         LPCWSTR lpszPassword, DWORD dwFlags, DWORD dwContext,
1797         DWORD dwInternalFlags)
1798 {
1799     BOOL bSuccess = FALSE;
1800     LPWININETHTTPSESSIONW lpwhs = NULL;
1801     HINTERNET handle = NULL;
1802
1803     TRACE("-->\n");
1804
1805     assert( hIC->hdr.htype == WH_HINIT );
1806
1807     hIC->hdr.dwContext = dwContext;
1808
1809     lpwhs = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(WININETHTTPSESSIONW));
1810     if (NULL == lpwhs)
1811     {
1812         INTERNET_SetLastError(ERROR_OUTOFMEMORY);
1813         goto lerror;
1814     }
1815
1816    /*
1817     * According to my tests. The name is not resolved until a request is sent
1818     */
1819
1820     if (nServerPort == INTERNET_INVALID_PORT_NUMBER)
1821         nServerPort = INTERNET_DEFAULT_HTTP_PORT;
1822
1823     lpwhs->hdr.htype = WH_HHTTPSESSION;
1824     lpwhs->hdr.lpwhparent = WININET_AddRef( &hIC->hdr );
1825     lpwhs->hdr.dwFlags = dwFlags;
1826     lpwhs->hdr.dwContext = dwContext;
1827     lpwhs->hdr.dwInternalFlags = dwInternalFlags;
1828     lpwhs->hdr.dwRefCount = 1;
1829     lpwhs->hdr.destroy = HTTP_CloseHTTPSessionHandle;
1830     lpwhs->hdr.lpfnStatusCB = hIC->hdr.lpfnStatusCB;
1831
1832     handle = WININET_AllocHandle( &lpwhs->hdr );
1833     if (NULL == handle)
1834     {
1835         ERR("Failed to alloc handle\n");
1836         INTERNET_SetLastError(ERROR_OUTOFMEMORY);
1837         goto lerror;
1838     }
1839
1840     if(hIC->lpszProxy && hIC->dwAccessType == INTERNET_OPEN_TYPE_PROXY) {
1841         if(strchrW(hIC->lpszProxy, ' '))
1842             FIXME("Several proxies not implemented.\n");
1843         if(hIC->lpszProxyBypass)
1844             FIXME("Proxy bypass is ignored.\n");
1845     }
1846     if (NULL != lpszServerName)
1847         lpwhs->lpszServerName = WININET_strdupW(lpszServerName);
1848     if (NULL != lpszUserName)
1849         lpwhs->lpszUserName = WININET_strdupW(lpszUserName);
1850     lpwhs->nServerPort = nServerPort;
1851
1852     /* Don't send a handle created callback if this handle was created with InternetOpenUrl */
1853     if (!(lpwhs->hdr.dwInternalFlags & INET_OPENURL))
1854     {
1855         INTERNET_ASYNC_RESULT iar;
1856
1857         iar.dwResult = (DWORD_PTR)handle;
1858         iar.dwError = ERROR_SUCCESS;
1859
1860         SendAsyncCallback(&lpwhs->hdr, dwContext,
1861                       INTERNET_STATUS_HANDLE_CREATED, &iar,
1862                       sizeof(INTERNET_ASYNC_RESULT));
1863     }
1864
1865     bSuccess = TRUE;
1866
1867 lerror:
1868     if( lpwhs )
1869         WININET_Release( &lpwhs->hdr );
1870
1871 /*
1872  * a INTERNET_STATUS_REQUEST_COMPLETE is NOT sent here as per my tests on
1873  * windows
1874  */
1875
1876     TRACE("%p --> %p (%p)\n", hIC, handle, lpwhs);
1877     return handle;
1878 }
1879
1880
1881 /***********************************************************************
1882  *           HTTP_OpenConnection (internal)
1883  *
1884  * Connect to a web server
1885  *
1886  * RETURNS
1887  *
1888  *   TRUE  on success
1889  *   FALSE on failure
1890  */
1891 BOOL HTTP_OpenConnection(LPWININETHTTPREQW lpwhr)
1892 {
1893     BOOL bSuccess = FALSE;
1894     LPWININETHTTPSESSIONW lpwhs;
1895     LPWININETAPPINFOW hIC = NULL;
1896
1897     TRACE("-->\n");
1898
1899
1900     if (NULL == lpwhr ||  lpwhr->hdr.htype != WH_HHTTPREQ)
1901     {
1902         INTERNET_SetLastError(ERROR_INVALID_PARAMETER);
1903         goto lend;
1904     }
1905
1906     lpwhs = (LPWININETHTTPSESSIONW)lpwhr->hdr.lpwhparent;
1907
1908     hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
1909     SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1910                       INTERNET_STATUS_CONNECTING_TO_SERVER,
1911                       &(lpwhs->socketAddress),
1912                        sizeof(struct sockaddr_in));
1913
1914     if (!NETCON_create(&lpwhr->netConnection, lpwhs->phostent->h_addrtype,
1915                          SOCK_STREAM, 0))
1916     {
1917         WARN("Socket creation failed\n");
1918         goto lend;
1919     }
1920
1921     if (!NETCON_connect(&lpwhr->netConnection, (struct sockaddr *)&lpwhs->socketAddress,
1922                       sizeof(lpwhs->socketAddress)))
1923     {
1924        WARN("Unable to connect to host (%s)\n", strerror(errno));
1925        goto lend;
1926     }
1927
1928     SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
1929                       INTERNET_STATUS_CONNECTED_TO_SERVER,
1930                       &(lpwhs->socketAddress),
1931                        sizeof(struct sockaddr_in));
1932
1933     bSuccess = TRUE;
1934
1935 lend:
1936     TRACE("%d <--\n", bSuccess);
1937     return bSuccess;
1938 }
1939
1940
1941 /***********************************************************************
1942  *           HTTP_clear_response_headers (internal)
1943  *
1944  * clear out any old response headers
1945  */
1946 static void HTTP_clear_response_headers( LPWININETHTTPREQW lpwhr )
1947 {
1948     DWORD i;
1949
1950     for( i=0; i<=HTTP_QUERY_MAX; i++ )
1951     {
1952         if( !lpwhr->StdHeaders[i].lpszField )
1953             continue;
1954         if( !lpwhr->StdHeaders[i].lpszValue )
1955             continue;
1956         if ( lpwhr->StdHeaders[i].wFlags & HDR_ISREQUEST )
1957             continue;
1958         HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[i], NULL );
1959     }
1960     for( i=0; i<lpwhr->nCustHeaders; i++)
1961     {
1962         if( !lpwhr->pCustHeaders[i].lpszField )
1963             continue;
1964         if( !lpwhr->pCustHeaders[i].lpszValue )
1965             continue;
1966         if ( lpwhr->pCustHeaders[i].wFlags & HDR_ISREQUEST )
1967             continue;
1968         HTTP_ReplaceHeaderValue( &lpwhr->pCustHeaders[i], NULL );
1969     }
1970 }
1971
1972 /***********************************************************************
1973  *           HTTP_GetResponseHeaders (internal)
1974  *
1975  * Read server response
1976  *
1977  * RETURNS
1978  *
1979  *   TRUE  on success
1980  *   FALSE on error
1981  */
1982 BOOL HTTP_GetResponseHeaders(LPWININETHTTPREQW lpwhr)
1983 {
1984     INT cbreaks = 0;
1985     WCHAR buffer[MAX_REPLY_LEN];
1986     DWORD buflen = MAX_REPLY_LEN;
1987     BOOL bSuccess = FALSE;
1988     INT  rc = 0;
1989     static const WCHAR szCrLf[] = {'\r','\n',0};
1990     char bufferA[MAX_REPLY_LEN];
1991     LPWSTR status_code, status_text;
1992     DWORD cchMaxRawHeaders = 1024;
1993     LPWSTR lpszRawHeaders = HeapAlloc(GetProcessHeap(), 0, (cchMaxRawHeaders+1)*sizeof(WCHAR));
1994     DWORD cchRawHeaders = 0;
1995
1996     TRACE("-->\n");
1997
1998     /* clear old response headers (eg. from a redirect response) */
1999     HTTP_clear_response_headers( lpwhr );
2000
2001     if (!NETCON_connected(&lpwhr->netConnection))
2002         goto lend;
2003
2004     /*
2005      * HACK peek at the buffer
2006      */
2007     NETCON_recv(&lpwhr->netConnection, buffer, buflen, MSG_PEEK, &rc);
2008
2009     /*
2010      * We should first receive 'HTTP/1.x nnn OK' where nnn is the status code.
2011      */
2012     buflen = MAX_REPLY_LEN;
2013     memset(buffer, 0, MAX_REPLY_LEN);
2014     if (!NETCON_getNextLine(&lpwhr->netConnection, bufferA, &buflen))
2015         goto lend;
2016     MultiByteToWideChar( CP_ACP, 0, bufferA, buflen, buffer, MAX_REPLY_LEN );
2017
2018     /* regenerate raw headers */
2019     while (cchRawHeaders + buflen + strlenW(szCrLf) > cchMaxRawHeaders)
2020     {
2021         cchMaxRawHeaders *= 2;
2022         lpszRawHeaders = HeapReAlloc(GetProcessHeap(), 0, lpszRawHeaders, (cchMaxRawHeaders+1)*sizeof(WCHAR));
2023     }
2024     memcpy(lpszRawHeaders+cchRawHeaders, buffer, (buflen-1)*sizeof(WCHAR));
2025     cchRawHeaders += (buflen-1);
2026     memcpy(lpszRawHeaders+cchRawHeaders, szCrLf, sizeof(szCrLf));
2027     cchRawHeaders += sizeof(szCrLf)/sizeof(szCrLf[0])-1;
2028     lpszRawHeaders[cchRawHeaders] = '\0';
2029
2030     /* split the version from the status code */
2031     status_code = strchrW( buffer, ' ' );
2032     if( !status_code )
2033         goto lend;
2034     *status_code++=0;
2035
2036     /* split the status code from the status text */
2037     status_text = strchrW( status_code, ' ' );
2038     if( !status_text )
2039         goto lend;
2040     *status_text++=0;
2041
2042     TRACE("version [%s] status code [%s] status text [%s]\n",
2043          debugstr_w(buffer), debugstr_w(status_code), debugstr_w(status_text) );
2044     HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_VERSION], buffer );
2045     HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_STATUS_CODE], status_code );
2046     HTTP_ReplaceHeaderValue( &lpwhr->StdHeaders[HTTP_QUERY_STATUS_TEXT], status_text );
2047
2048     /* Parse each response line */
2049     do
2050     {
2051         buflen = MAX_REPLY_LEN;
2052         if (NETCON_getNextLine(&lpwhr->netConnection, bufferA, &buflen))
2053         {
2054             LPWSTR * pFieldAndValue;
2055
2056             TRACE("got line %s, now interpretting\n", debugstr_a(bufferA));
2057             MultiByteToWideChar( CP_ACP, 0, bufferA, buflen, buffer, MAX_REPLY_LEN );
2058
2059             while (cchRawHeaders + buflen + strlenW(szCrLf) > cchMaxRawHeaders)
2060             {
2061                 cchMaxRawHeaders *= 2;
2062                 lpszRawHeaders = HeapReAlloc(GetProcessHeap(), 0, lpszRawHeaders, (cchMaxRawHeaders+1)*sizeof(WCHAR));
2063             }
2064             memcpy(lpszRawHeaders+cchRawHeaders, buffer, (buflen-1)*sizeof(WCHAR));
2065             cchRawHeaders += (buflen-1);
2066             memcpy(lpszRawHeaders+cchRawHeaders, szCrLf, sizeof(szCrLf));
2067             cchRawHeaders += sizeof(szCrLf)/sizeof(szCrLf[0])-1;
2068             lpszRawHeaders[cchRawHeaders] = '\0';
2069
2070             pFieldAndValue = HTTP_InterpretHttpHeader(buffer);
2071             if (!pFieldAndValue)
2072                 break;
2073
2074             HTTP_ProcessHeader(lpwhr, pFieldAndValue[0], pFieldAndValue[1],
2075                 HTTP_ADDREQ_FLAG_ADD | HTTP_ADDREQ_FLAG_REPLACE);
2076
2077             HTTP_FreeTokens(pFieldAndValue);
2078         }
2079         else
2080         {
2081             cbreaks++;
2082             if (cbreaks >= 2)
2083                break;
2084         }
2085     }while(1);
2086
2087     if (lpwhr->lpszRawHeaders) HeapFree(GetProcessHeap(), 0, lpwhr->lpszRawHeaders);
2088     lpwhr->lpszRawHeaders = lpszRawHeaders;
2089     TRACE("raw headers: %s\n", debugstr_w(lpszRawHeaders));
2090     bSuccess = TRUE;
2091
2092 lend:
2093
2094     TRACE("<--\n");
2095     if (bSuccess)
2096         return rc;
2097     else
2098         return FALSE;
2099 }
2100
2101
2102 static void strip_spaces(LPWSTR start)
2103 {
2104     LPWSTR str = start;
2105     LPWSTR end;
2106
2107     while (*str == ' ' && *str != '\0')
2108         str++;
2109
2110     if (str != start)
2111         memmove(start, str, sizeof(WCHAR) * (strlenW(str) + 1));
2112
2113     end = start + strlenW(start) - 1;
2114     while (end >= start && *end == ' ')
2115     {
2116         *end = '\0';
2117         end--;
2118     }
2119 }
2120
2121
2122 /***********************************************************************
2123  *           HTTP_InterpretHttpHeader (internal)
2124  *
2125  * Parse server response
2126  *
2127  * RETURNS
2128  *
2129  *   Pointer to array of field, value, NULL on success.
2130  *   NULL on error.
2131  */
2132 LPWSTR * HTTP_InterpretHttpHeader(LPCWSTR buffer)
2133 {
2134     LPWSTR * pTokenPair;
2135     LPWSTR pszColon;
2136     INT len;
2137
2138     pTokenPair = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*pTokenPair)*3);
2139
2140     pszColon = strchrW(buffer, ':');
2141     /* must have two tokens */
2142     if (!pszColon)
2143     {
2144         HTTP_FreeTokens(pTokenPair);
2145         return NULL;
2146     }
2147
2148     pTokenPair[0] = HeapAlloc(GetProcessHeap(), 0, (pszColon - buffer + 1) * sizeof(WCHAR));
2149     if (!pTokenPair[0])
2150     {
2151         HTTP_FreeTokens(pTokenPair);
2152         return NULL;
2153     }
2154     memcpy(pTokenPair[0], buffer, (pszColon - buffer) * sizeof(WCHAR));
2155     pTokenPair[0][pszColon - buffer] = '\0';
2156
2157     /* skip colon */
2158     pszColon++;
2159     len = strlenW(pszColon);
2160     pTokenPair[1] = HeapAlloc(GetProcessHeap(), 0, (len + 1) * sizeof(WCHAR));
2161     if (!pTokenPair[1])
2162     {
2163         HTTP_FreeTokens(pTokenPair);
2164         return NULL;
2165     }
2166     memcpy(pTokenPair[1], pszColon, (len + 1) * sizeof(WCHAR));
2167
2168     strip_spaces(pTokenPair[0]);
2169     strip_spaces(pTokenPair[1]);
2170
2171     TRACE("field(%s) Value(%s)\n", debugstr_w(pTokenPair[0]), debugstr_w(pTokenPair[1]));
2172     return pTokenPair;
2173 }
2174
2175
2176 /***********************************************************************
2177  *           HTTP_GetStdHeaderIndex (internal)
2178  *
2179  * Lookup field index in standard http header array
2180  *
2181  * FIXME: This should be stuffed into a hash table
2182  */
2183 INT HTTP_GetStdHeaderIndex(LPCWSTR lpszField)
2184 {
2185     INT index = -1;
2186     static const WCHAR szContentLength[] = {
2187        'C','o','n','t','e','n','t','-','L','e','n','g','t','h',0};
2188     static const WCHAR szQueryRange[] = {
2189        'R','a','n','g','e',0};
2190     static const WCHAR szContentRange[] = {
2191        'C','o','n','t','e','n','t','-','R','a','n','g','e',0};
2192     static const WCHAR szContentType[] = {
2193        'C','o','n','t','e','n','t','-','T','y','p','e',0};
2194     static const WCHAR szLastModified[] = {
2195        'L','a','s','t','-','M','o','d','i','f','i','e','d',0};
2196     static const WCHAR szLocation[] = {'L','o','c','a','t','i','o','n',0};
2197     static const WCHAR szAccept[] = {'A','c','c','e','p','t',0};
2198     static const WCHAR szReferer[] = { 'R','e','f','e','r','e','r',0};
2199     static const WCHAR szContentTrans[] = { 'C','o','n','t','e','n','t','-',
2200        'T','r','a','n','s','f','e','r','-','E','n','c','o','d','i','n','g',0};
2201     static const WCHAR szDate[] = { 'D','a','t','e',0};
2202     static const WCHAR szServer[] = { 'S','e','r','v','e','r',0};
2203     static const WCHAR szConnection[] = { 'C','o','n','n','e','c','t','i','o','n',0};
2204     static const WCHAR szETag[] = { 'E','T','a','g',0};
2205     static const WCHAR szAcceptRanges[] = {
2206        'A','c','c','e','p','t','-','R','a','n','g','e','s',0 };
2207     static const WCHAR szExpires[] = { 'E','x','p','i','r','e','s',0 };
2208     static const WCHAR szMimeVersion[] = {
2209        'M','i','m','e','-','V','e','r','s','i','o','n', 0};
2210     static const WCHAR szPragma[] = { 'P','r','a','g','m','a', 0};
2211     static const WCHAR szCacheControl[] = {
2212        'C','a','c','h','e','-','C','o','n','t','r','o','l',0};
2213     static const WCHAR szUserAgent[] = { 'U','s','e','r','-','A','g','e','n','t',0};
2214     static const WCHAR szProxyAuth[] = {
2215        'P','r','o','x','y','-',
2216        'A','u','t','h','e','n','t','i','c','a','t','e', 0};
2217     static const WCHAR szContentEncoding[] = {
2218        'C','o','n','t','e','n','t','-','E','n','c','o','d','i','n','g',0};
2219     static const WCHAR szCookie[] = {'C','o','o','k','i','e',0};
2220     static const WCHAR szVary[] = {'V','a','r','y',0};
2221     static const WCHAR szVia[] = {'V','i','a',0};
2222
2223     if (!strcmpiW(lpszField, szContentLength))
2224         index = HTTP_QUERY_CONTENT_LENGTH;
2225     else if (!strcmpiW(lpszField,szQueryRange))
2226         index = HTTP_QUERY_RANGE;
2227     else if (!strcmpiW(lpszField,szContentRange))
2228         index = HTTP_QUERY_CONTENT_RANGE;
2229     else if (!strcmpiW(lpszField,szContentType))
2230         index = HTTP_QUERY_CONTENT_TYPE;
2231     else if (!strcmpiW(lpszField,szLastModified))
2232         index = HTTP_QUERY_LAST_MODIFIED;
2233     else if (!strcmpiW(lpszField,szLocation))
2234         index = HTTP_QUERY_LOCATION;
2235     else if (!strcmpiW(lpszField,szAccept))
2236         index = HTTP_QUERY_ACCEPT;
2237     else if (!strcmpiW(lpszField,szReferer))
2238         index = HTTP_QUERY_REFERER;
2239     else if (!strcmpiW(lpszField,szContentTrans))
2240         index = HTTP_QUERY_CONTENT_TRANSFER_ENCODING;
2241     else if (!strcmpiW(lpszField,szDate))
2242         index = HTTP_QUERY_DATE;
2243     else if (!strcmpiW(lpszField,szServer))
2244         index = HTTP_QUERY_SERVER;
2245     else if (!strcmpiW(lpszField,szConnection))
2246         index = HTTP_QUERY_CONNECTION;
2247     else if (!strcmpiW(lpszField,szETag))
2248         index = HTTP_QUERY_ETAG;
2249     else if (!strcmpiW(lpszField,szAcceptRanges))
2250         index = HTTP_QUERY_ACCEPT_RANGES;
2251     else if (!strcmpiW(lpszField,szExpires))
2252         index = HTTP_QUERY_EXPIRES;
2253     else if (!strcmpiW(lpszField,szMimeVersion))
2254         index = HTTP_QUERY_MIME_VERSION;
2255     else if (!strcmpiW(lpszField,szPragma))
2256         index = HTTP_QUERY_PRAGMA;
2257     else if (!strcmpiW(lpszField,szCacheControl))
2258         index = HTTP_QUERY_CACHE_CONTROL;
2259     else if (!strcmpiW(lpszField,szUserAgent))
2260         index = HTTP_QUERY_USER_AGENT;
2261     else if (!strcmpiW(lpszField,szProxyAuth))
2262         index = HTTP_QUERY_PROXY_AUTHENTICATE;
2263     else if (!strcmpiW(lpszField,szContentEncoding))
2264         index = HTTP_QUERY_CONTENT_ENCODING;
2265     else if (!strcmpiW(lpszField,szCookie))
2266         index = HTTP_QUERY_COOKIE;
2267     else if (!strcmpiW(lpszField,szVary))
2268         index = HTTP_QUERY_VARY;
2269     else if (!strcmpiW(lpszField,szVia))
2270         index = HTTP_QUERY_VIA;
2271     else if (!strcmpiW(lpszField,g_szHost))
2272         index = HTTP_QUERY_HOST;
2273     else
2274     {
2275         TRACE("Couldn't find %s in standard header table\n", debugstr_w(lpszField));
2276     }
2277
2278     return index;
2279 }
2280
2281 /***********************************************************************
2282  *           HTTP_ReplaceHeaderValue (internal)
2283  */
2284 BOOL HTTP_ReplaceHeaderValue( LPHTTPHEADERW lphttpHdr, LPCWSTR value )
2285 {
2286     INT len = 0;
2287
2288     if( lphttpHdr->lpszValue )
2289         HeapFree( GetProcessHeap(), 0, lphttpHdr->lpszValue );
2290     lphttpHdr->lpszValue = NULL;
2291
2292     if( value )
2293         len = strlenW(value);
2294     if (len)
2295     {
2296         lphttpHdr->lpszValue = HeapAlloc(GetProcessHeap(), 0,
2297                                         (len+1)*sizeof(WCHAR));
2298         strcpyW(lphttpHdr->lpszValue, value);
2299     }
2300     return TRUE;
2301 }
2302
2303 /***********************************************************************
2304  *           HTTP_ProcessHeader (internal)
2305  *
2306  * Stuff header into header tables according to <dwModifier>
2307  *
2308  */
2309
2310 #define COALESCEFLASG (HTTP_ADDHDR_FLAG_COALESCE|HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA|HTTP_ADDHDR_FLAG_COALESCE_WITH_SEMICOLON)
2311
2312 BOOL HTTP_ProcessHeader(LPWININETHTTPREQW lpwhr, LPCWSTR field, LPCWSTR value, DWORD dwModifier)
2313 {
2314     LPHTTPHEADERW lphttpHdr = NULL;
2315     BOOL bSuccess = FALSE;
2316     INT index;
2317
2318     TRACE("--> %s: %s - 0x%08lx\n", debugstr_w(field), debugstr_w(value), dwModifier);
2319
2320     /* Adjust modifier flags */
2321     if (dwModifier & COALESCEFLASG)
2322         dwModifier |= HTTP_ADDHDR_FLAG_ADD;
2323
2324     /* Try to get index into standard header array */
2325     index = HTTP_GetStdHeaderIndex(field);
2326     /* Don't let applications add Connection header to request */
2327     if ((index == HTTP_QUERY_CONNECTION) && (dwModifier & HTTP_ADDHDR_FLAG_REQ))
2328         return TRUE;
2329     else if (index >= 0)
2330     {
2331         lphttpHdr = &lpwhr->StdHeaders[index];
2332     }
2333     else /* Find or create new custom header */
2334     {
2335         index = HTTP_GetCustomHeaderIndex(lpwhr, field);
2336         if (index >= 0)
2337         {
2338             if (dwModifier & HTTP_ADDHDR_FLAG_ADD_IF_NEW)
2339             {
2340                 return FALSE;
2341             }
2342             lphttpHdr = &lpwhr->pCustHeaders[index];
2343         }
2344         else
2345         {
2346             HTTPHEADERW hdr;
2347
2348             hdr.lpszField = (LPWSTR)field;
2349             hdr.lpszValue = (LPWSTR)value;
2350             hdr.wFlags = hdr.wCount = 0;
2351
2352             if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2353                 hdr.wFlags |= HDR_ISREQUEST;
2354
2355             return HTTP_InsertCustomHeader(lpwhr, &hdr);
2356         }
2357     }
2358
2359     if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2360         lphttpHdr->wFlags |= HDR_ISREQUEST;
2361     else
2362         lphttpHdr->wFlags &= ~HDR_ISREQUEST;
2363
2364     if (!lphttpHdr->lpszValue && (dwModifier & (HTTP_ADDHDR_FLAG_ADD|HTTP_ADDHDR_FLAG_ADD_IF_NEW)))
2365     {
2366         INT slen;
2367
2368         if (!lpwhr->StdHeaders[index].lpszField)
2369         {
2370             lphttpHdr->lpszField = WININET_strdupW(field);
2371
2372             if (dwModifier & HTTP_ADDHDR_FLAG_REQ)
2373                 lphttpHdr->wFlags |= HDR_ISREQUEST;
2374         }
2375
2376         slen = strlenW(value) + 1;
2377         lphttpHdr->lpszValue = HeapAlloc(GetProcessHeap(), 0, slen*sizeof(WCHAR));
2378         if (lphttpHdr->lpszValue)
2379         {
2380             strcpyW(lphttpHdr->lpszValue, value);
2381             bSuccess = TRUE;
2382         }
2383         else
2384         {
2385             INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2386         }
2387     }
2388     else if (lphttpHdr->lpszValue)
2389     {
2390         if (dwModifier & HTTP_ADDHDR_FLAG_REPLACE)
2391             bSuccess = HTTP_ReplaceHeaderValue( lphttpHdr, value );
2392         else if (dwModifier & COALESCEFLASG)
2393         {
2394             LPWSTR lpsztmp;
2395             WCHAR ch = 0;
2396             INT len = 0;
2397             INT origlen = strlenW(lphttpHdr->lpszValue);
2398             INT valuelen = strlenW(value);
2399
2400             if (dwModifier & HTTP_ADDHDR_FLAG_COALESCE_WITH_COMMA)
2401             {
2402                 ch = ',';
2403                 lphttpHdr->wFlags |= HDR_COMMADELIMITED;
2404             }
2405             else if (dwModifier & HTTP_ADDHDR_FLAG_COALESCE_WITH_SEMICOLON)
2406             {
2407                 ch = ';';
2408                 lphttpHdr->wFlags |= HDR_COMMADELIMITED;
2409             }
2410
2411             len = origlen + valuelen + ((ch > 0) ? 1 : 0);
2412
2413             lpsztmp = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY,  lphttpHdr->lpszValue, (len+1)*sizeof(WCHAR));
2414             if (lpsztmp)
2415             {
2416                 /* FIXME: Increment lphttpHdr->wCount. Perhaps lpszValue should be an array */
2417                 if (ch > 0)
2418                 {
2419                     lphttpHdr->lpszValue[origlen] = ch;
2420                     origlen++;
2421                 }
2422
2423                 memcpy(&lphttpHdr->lpszValue[origlen], value, valuelen*sizeof(WCHAR));
2424                 lphttpHdr->lpszValue[len] = '\0';
2425                 bSuccess = TRUE;
2426             }
2427             else
2428             {
2429                 WARN("HeapReAlloc (%d bytes) failed\n",len+1);
2430                 INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2431             }
2432         }
2433     }
2434     TRACE("<-- %d\n",bSuccess);
2435     return bSuccess;
2436 }
2437
2438
2439 /***********************************************************************
2440  *           HTTP_CloseConnection (internal)
2441  *
2442  * Close socket connection
2443  *
2444  */
2445 VOID HTTP_CloseConnection(LPWININETHTTPREQW lpwhr)
2446 {
2447     LPWININETHTTPSESSIONW lpwhs = NULL;
2448     LPWININETAPPINFOW hIC = NULL;
2449
2450     TRACE("%p\n",lpwhr);
2451
2452     lpwhs = (LPWININETHTTPSESSIONW) lpwhr->hdr.lpwhparent;
2453     hIC = (LPWININETAPPINFOW) lpwhs->hdr.lpwhparent;
2454
2455     SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
2456                       INTERNET_STATUS_CLOSING_CONNECTION, 0, 0);
2457
2458     if (NETCON_connected(&lpwhr->netConnection))
2459     {
2460         NETCON_close(&lpwhr->netConnection);
2461     }
2462
2463     SendAsyncCallback(&lpwhr->hdr, lpwhr->hdr.dwContext,
2464                       INTERNET_STATUS_CONNECTION_CLOSED, 0, 0);
2465 }
2466
2467
2468 /***********************************************************************
2469  *           HTTP_CloseHTTPRequestHandle (internal)
2470  *
2471  * Deallocate request handle
2472  *
2473  */
2474 static void HTTP_CloseHTTPRequestHandle(LPWININETHANDLEHEADER hdr)
2475 {
2476     DWORD i;
2477     LPWININETHTTPREQW lpwhr = (LPWININETHTTPREQW) hdr;
2478
2479     TRACE("\n");
2480
2481     if (NETCON_connected(&lpwhr->netConnection))
2482         HTTP_CloseConnection(lpwhr);
2483
2484     if (lpwhr->lpszPath)
2485         HeapFree(GetProcessHeap(), 0, lpwhr->lpszPath);
2486     if (lpwhr->lpszVerb)
2487         HeapFree(GetProcessHeap(), 0, lpwhr->lpszVerb);
2488     if (lpwhr->lpszRawHeaders)
2489         HeapFree(GetProcessHeap(), 0, lpwhr->lpszRawHeaders);
2490
2491     for (i = 0; i <= HTTP_QUERY_MAX; i++)
2492     {
2493            if (lpwhr->StdHeaders[i].lpszField)
2494             HeapFree(GetProcessHeap(), 0, lpwhr->StdHeaders[i].lpszField);
2495            if (lpwhr->StdHeaders[i].lpszValue)
2496             HeapFree(GetProcessHeap(), 0, lpwhr->StdHeaders[i].lpszValue);
2497     }
2498
2499     for (i = 0; i < lpwhr->nCustHeaders; i++)
2500     {
2501            if (lpwhr->pCustHeaders[i].lpszField)
2502             HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders[i].lpszField);
2503            if (lpwhr->pCustHeaders[i].lpszValue)
2504             HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders[i].lpszValue);
2505     }
2506
2507     HeapFree(GetProcessHeap(), 0, lpwhr->pCustHeaders);
2508     HeapFree(GetProcessHeap(), 0, lpwhr);
2509 }
2510
2511
2512 /***********************************************************************
2513  *           HTTP_CloseHTTPSessionHandle (internal)
2514  *
2515  * Deallocate session handle
2516  *
2517  */
2518 void HTTP_CloseHTTPSessionHandle(LPWININETHANDLEHEADER hdr)
2519 {
2520     LPWININETHTTPSESSIONW lpwhs = (LPWININETHTTPSESSIONW) hdr;
2521
2522     TRACE("%p\n", lpwhs);
2523
2524     if (lpwhs->lpszServerName)
2525         HeapFree(GetProcessHeap(), 0, lpwhs->lpszServerName);
2526     if (lpwhs->lpszUserName)
2527         HeapFree(GetProcessHeap(), 0, lpwhs->lpszUserName);
2528     HeapFree(GetProcessHeap(), 0, lpwhs);
2529 }
2530
2531
2532 /***********************************************************************
2533  *           HTTP_GetCustomHeaderIndex (internal)
2534  *
2535  * Return index of custom header from header array
2536  *
2537  */
2538 INT HTTP_GetCustomHeaderIndex(LPWININETHTTPREQW lpwhr, LPCWSTR lpszField)
2539 {
2540     DWORD index;
2541
2542     TRACE("%s\n", debugstr_w(lpszField));
2543
2544     for (index = 0; index < lpwhr->nCustHeaders; index++)
2545     {
2546         if (!strcmpiW(lpwhr->pCustHeaders[index].lpszField, lpszField))
2547             break;
2548
2549     }
2550
2551     if (index >= lpwhr->nCustHeaders)
2552         index = -1;
2553
2554     TRACE("Return: %ld\n", index);
2555     return index;
2556 }
2557
2558
2559 /***********************************************************************
2560  *           HTTP_InsertCustomHeader (internal)
2561  *
2562  * Insert header into array
2563  *
2564  */
2565 BOOL HTTP_InsertCustomHeader(LPWININETHTTPREQW lpwhr, LPHTTPHEADERW lpHdr)
2566 {
2567     INT count;
2568     LPHTTPHEADERW lph = NULL;
2569     BOOL r = FALSE;
2570
2571     TRACE("--> %s: %s\n", debugstr_w(lpHdr->lpszField), debugstr_w(lpHdr->lpszValue));
2572     count = lpwhr->nCustHeaders + 1;
2573     if (count > 1)
2574         lph = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, lpwhr->pCustHeaders, sizeof(HTTPHEADERW) * count);
2575     else
2576         lph = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(HTTPHEADERW) * count);
2577
2578     if (NULL != lph)
2579     {
2580         lpwhr->pCustHeaders = lph;
2581         lpwhr->pCustHeaders[count-1].lpszField = WININET_strdupW(lpHdr->lpszField);
2582         lpwhr->pCustHeaders[count-1].lpszValue = WININET_strdupW(lpHdr->lpszValue);
2583         lpwhr->pCustHeaders[count-1].wFlags = lpHdr->wFlags;
2584         lpwhr->pCustHeaders[count-1].wCount= lpHdr->wCount;
2585         lpwhr->nCustHeaders++;
2586         r = TRUE;
2587     }
2588     else
2589     {
2590         INTERNET_SetLastError(ERROR_OUTOFMEMORY);
2591     }
2592
2593     return r;
2594 }
2595
2596
2597 /***********************************************************************
2598  *           HTTP_DeleteCustomHeader (internal)
2599  *
2600  * Delete header from array
2601  *  If this function is called, the indexs may change.
2602  */
2603 BOOL HTTP_DeleteCustomHeader(LPWININETHTTPREQW lpwhr, DWORD index)
2604 {
2605     if( lpwhr->nCustHeaders <= 0 )
2606         return FALSE;
2607     if( lpwhr->nCustHeaders >= index )
2608         return FALSE;
2609     lpwhr->nCustHeaders--;
2610
2611     memmove( &lpwhr->pCustHeaders[index], &lpwhr->pCustHeaders[index+1],
2612              (lpwhr->nCustHeaders - index)* sizeof(HTTPHEADERW) );
2613     memset( &lpwhr->pCustHeaders[lpwhr->nCustHeaders], 0, sizeof(HTTPHEADERW) );
2614
2615     return TRUE;
2616 }
2617
2618 /***********************************************************************
2619  *          IsHostInProxyBypassList (@)
2620  *
2621  * Undocumented
2622  *
2623  */
2624 BOOL WINAPI IsHostInProxyBypassList(DWORD flags, LPCSTR szHost, DWORD length)
2625 {
2626    FIXME("STUB: flags=%ld host=%s length=%ld\n",flags,szHost,length);
2627    return FALSE;
2628 }