X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=inc%2Fhttp-functions.php;h=042e4b72e8bfb62cce0c88f9f5903abc7646a5a2;hb=987bf5583fce2696a1c6b2b72b123747b4cd4536;hp=317ba55e83d1599c86c31cec6240d7e0496616d4;hpb=87cbf843e53502d58f264b818f189b3396fdd697;p=mailer.git diff --git a/inc/http-functions.php b/inc/http-functions.php index 317ba55e83..042e4b72e8 100644 --- a/inc/http-functions.php +++ b/inc/http-functions.php @@ -10,13 +10,8 @@ * -------------------------------------------------------------------- * * Kurzbeschreibung : HTTP-relevante Funktionen * * -------------------------------------------------------------------- * - * $Revision:: $ * - * $Date:: $ * - * $Tag:: 0.2.1-FINAL $ * - * $Author:: $ * - * -------------------------------------------------------------------- * * Copyright (c) 2003 - 2009 by Roland Haeder * - * Copyright (c) 2009 - 2012 by Mailer Developer Team * + * Copyright (c) 2009 - 2015 by Mailer Developer Team * * For more information visit: http://mxchange.org * * * * This program is free software; you can redistribute it and/or modify * @@ -144,22 +139,22 @@ function removeHttpHostNameFromUrl ($url) { } // Sends a HTTP request (GET, POST, HEAD are currently supported) -function sendHttpRequest ($requestType, $baseUrl, $requestData = array(), $removeHeader = FALSE) { +function sendHttpRequest ($requestType, $baseUrl, $requestData = array(), $removeHeader = FALSE, $allowOnlyHttpOkay = TRUE) { // Init response $response = array(); // Start "detecting" the request type switch ($requestType) { case 'HEAD': // Send a HTTP/1.1 HEAD request - $response = sendHeadRequest($baseUrl, $requestData); + $response = sendHttpHeadRequest($baseUrl, $requestData, $allowOnlyHttpOkay); break; case 'GET': // Send a HTTP/1.1 GET request - $response = sendGetRequest($baseUrl, $requestData, $removeHeader); + $response = sendHttpGetRequest($baseUrl, $requestData, $removeHeader, $allowOnlyHttpOkay); break; case 'POST': // Send a HTTP/1.1 POST request - $response = sendPostRequest($baseUrl, $requestData, $removeHeader); + $response = sendHttpPostRequest($baseUrl, $requestData, $removeHeader, $allowOnlyHttpOkay); break; default: // Unsupported HTTP request, this is really bad and needs fixing @@ -172,9 +167,10 @@ function sendHttpRequest ($requestType, $baseUrl, $requestData = array(), $remov } // Sends a HEAD request -function sendHeadRequest ($baseUrl, $requestData = array()) { +function sendHttpHeadRequest ($baseUrl, $requestData = array(), $allowOnlyHttpOkay = TRUE) { // Generate full GET URL $getUrl = generateGetUrlFromBaseUrlData($baseUrl, $requestData); + //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'getUrl=' . $getUrl); // Is there http[s]:// in front of the URL? if (isFullQualifiedUrl($getUrl)) { @@ -204,16 +200,17 @@ function sendHeadRequest ($baseUrl, $requestData = array()) { $request .= getConfig('HTTP_EOL'); // Send the raw request - $response = sendRawRequest($host, $request); + $response = sendRawRequest($host, $request, $allowOnlyHttpOkay); // Return the result to the caller function return $response; } // Send a GET request -function sendGetRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE) { +function sendHttpGetRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE, $allowOnlyHttpOkay = TRUE) { // Generate full GET URL $getUrl = generateGetUrlFromBaseUrlData($baseUrl, $requestData); + //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'getUrl=' . $getUrl); // Is there http[s]:// in front of the URL? if (isFullQualifiedUrl($getUrl)) { @@ -243,7 +240,7 @@ function sendGetRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE $request .= getConfig('HTTP_EOL'); // Send the raw request - $response = sendRawRequest($host, $request); + $response = sendRawRequest($host, $request, $allowOnlyHttpOkay); // Should we remove header lines? if ($removeHeader === TRUE) { @@ -256,7 +253,7 @@ function sendGetRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE } // Send a POST request, sometimes even POST requests have no parameters -function sendPostRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE) { +function sendHttpPostRequest ($baseUrl, $requestData = array(), $removeHeader = FALSE, $allowOnlyHttpOkay = TRUE) { // Copy baseUrl to getUrl $getUrl = $baseUrl; @@ -276,7 +273,7 @@ function sendPostRequest ($baseUrl, $requestData = array(), $removeHeader = FALS $body = http_build_query($requestData, '', '&'); // Generate POST request header - $request = 'POST ' . (isProxyUsed() === TRUE ? $baseUrl : '') . trim($baseUrl) . ' HTTP/1.0' . getConfig('HTTP_EOL'); + $request = 'POST ' . (isProxyUsed() === TRUE ? $getUrl : '') . trim($getUrl) . ' HTTP/1.0' . getConfig('HTTP_EOL'); $request .= 'Host: ' . $host . getConfig('HTTP_EOL'); $request .= 'Referer: ' . getUrl() . '/admin.php' . getConfig('HTTP_EOL'); if (isConfigEntrySet('FULL_VERSION')) { @@ -296,7 +293,7 @@ function sendPostRequest ($baseUrl, $requestData = array(), $removeHeader = FALS $request .= $body; // Send the raw request - $response = sendRawRequest($host, $request); + $response = sendRawRequest($host, $request, $allowOnlyHttpOkay); // Should we remove header lines? if ($removeHeader === TRUE) { @@ -309,7 +306,7 @@ function sendPostRequest ($baseUrl, $requestData = array(), $removeHeader = FALS } // Sends a raw request (string) to given host (hostnames will be solved) -function sendRawRequest ($host, $request) { +function sendRawRequest ($host, $request, $allowOnlyHttpOkay = TRUE) { //* DEBUG: */ die('host='.$host.',request=
'.$request.''); // Init errno and errdesc with 'all fine' values $errno = '0'; @@ -319,7 +316,7 @@ function sendRawRequest ($host, $request) { $port = 80; // Initialize array - $response = array('', '', ''); + $response = array(); // Default is non-broken HTTP server implementation $GLOBALS['is_http_server_broken'] = FALSE; @@ -341,8 +338,14 @@ function sendRawRequest ($host, $request) { // Get resolver instance $resolver = new HostnameResolver(); - // Get proxy host - $proxyHost = compileRawCode(getProxyHost()); + // Default is no proxy + $proxyHost = NULL; + + // Is the configuration entry set? + if ((!isInstaller()) && (isConfigEntrySet('proxy_host'))) { + // Get proxy host + $proxyHost = compileRawCode(getProxyHost()); + } // END - if // Open connection if (isProxyUsed() === TRUE) { @@ -364,11 +367,11 @@ function sendRawRequest ($host, $request) { if (!is_resource($resource)) { // Failed! logDebugMessage(__FUNCTION__, __LINE__, $errdesc . ' (' . $errno . ')'); - return $response; + return array('', '', ''); } elseif ((!stream_set_blocking($resource, 0)) || (!stream_set_timeout($resource, 1))) { // Cannot set non-blocking mode or timeout logDebugMessage(__FUNCTION__, __LINE__, socket_strerror(socket_last_error())); - return $response; + return array('', '', ''); } // Shall proxy be used? @@ -407,8 +410,11 @@ function sendRawRequest ($host, $request) { // Get line from stream $line = fgets($resource, 128); - // Ignore empty lines because of non-blocking mode - if (empty($line)) { + /* + * Ignore empty lines because of non-blocking mode, you cannot use + * empty() here as it would also see \r\n as "empty". + */ + if (strlen($line) == 0) { // uslepp a little to avoid 100% CPU load usleep(10); @@ -423,7 +429,7 @@ function sendRawRequest ($host, $request) { } // END - if // Add it to response - //* DEBUG: */ print 'line='.$line.'
'.print_r($request, TRUE).''); //* DEBUG: */ debugOutput('Response:
'.print_r($response, TRUE).''); // Proxy agent found or something went wrong? - if (!isset($response[0])) { + if (!isFilledArray($response)) { // No response, maybe timeout $response = array('', '', ''); logDebugMessage(__FUNCTION__, __LINE__, 'Invalid empty response array, maybe timed out?'); @@ -467,7 +457,7 @@ function sendRawRequest ($host, $request) { } // END - if // Was the request successfull? - if ((!isInStringIgnoreCase('200 OK', $response[0])) || (empty($response[0]))) { + if ((!isHttpStatusOkay($response[0])) && ($allowOnlyHttpOkay === TRUE)) { // Not found / access forbidden logDebugMessage(__FUNCTION__, __LINE__, 'Unexpected status code ' . $response[0] . ' detected. "200 OK" was expected.'); $response = array('', '', ''); @@ -480,6 +470,12 @@ function sendRawRequest ($host, $request) { return $response; } +// Is HTTP status okay? +function isHttpStatusOkay ($header) { + // Determine it + return in_array(strtoupper(trim($header)), array('HTTP/1.1 200 OK', 'HTTP/1.0 200 OK')); +} + // Sets up a proxy tunnel for given hostname and through resource function setupProxyTunnel ($host, $proxyHost, $port, $resource) { // Initialize array @@ -537,27 +533,60 @@ function unchunkHttpResponse ($response) { // Found! $isChunked = TRUE; break; - } // END - if + } elseif (empty($line)) { + // Empty line found (header->body) + break; + } } // END - foreach + // Save whole body + $body = removeHttpHeaderFromResponse($response); + // Is it chunked? + //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'isChunked=' . intval($isChunked)); if ($isChunked === TRUE) { + // Make sure, that body is an array + assert(is_array($body)); + // Good, we still have the HTTP headers in there, so we need to get rid // of them temporarly //* DEBUG: */ die('
'.htmlentities(print_r(removeHttpHeaderFromResponse($response), TRUE)).''); - $tempResponse = http_chunked_decode(implode('', removeHttpHeaderFromResponse($response))); + $tempResponse = http_chunked_decode(implode('', $body)); // We got a string back from http_chunked_decode(), so we need to convert it back to an array - //* DEBUG: */ die('tempResponse['.strlen($tempResponse).']=
'.replaceReturnNewLine(htmlentities($tempResponse)).''); + //* DEBUG: */ die('tempResponse['.strlen($tempResponse).'/'.gettype($tempResponse).']=
'.replaceReturnNewLine(htmlentities($tempResponse)).''); // Re-add the headers - $response = merge_array($GLOBALS['http_headers'], stringToArray(chr(10), $tempResponse)); - } // END - if + $response = mergeHttpHeadersWithBody($tempResponse); + } elseif (is_array($body)) { + /* + * Make sure the body is in one array element as many other functions + * get disturbed by it. + */ + + // Put all array elements from body together + $body = implode('', $body); + + // Now merge the extracted headers + fixed body together + $response = mergeHttpHeadersWithBody($body); + } // Return the unchunked array return $response; } +// Merges HTTP header lines with given body (string) +function mergeHttpHeadersWithBody ($body) { + // Add empty entry to mimic header->body + $GLOBALS['http_headers'][] = getConfig('HTTP_EOL'); + + // Make sure at least one header is there (which is still not valid but okay here) + assert(isFilledArray($GLOBALS['http_headers'])); + + // Merge both together + return merge_array($GLOBALS['http_headers'], array(count($GLOBALS['http_headers']) => $body)); +} + // Removes HTTP header lines from a response array (e.g. output from send