Permalink
Find file
Fetching contributors…
Cannot retrieve contributors at this time
296 lines (251 sloc) 8.6 KB
<?php
define('USER_AGENT', 'Disqus-WPPlugin/2.0-dev');
define('SOCKET_TIMEOUT', 10);
function dsq_get_query_string($postdata) {
$postdata_str = '';
if($postdata) {
foreach($postdata as $key=>$value) {
$postdata_str .= urlencode($key) . '=' . urlencode($value) . '&';
}
}
return $postdata_str;
}
function dsq_get_post_content($boundary, $postdata, $file_name, $file_field) {
if(empty($file_name) || empty($file_field)) {
return dsq_get_query_string($postdata);
}
$content = array();
$content[] = '--' . $boundary;
foreach($postdata as $key=>$value) {
$content[] = 'Content-Disposition: form-data; name="' . $key . '"' . "\r\n\r\n" . $value;
$content[] = '--' . $boundary;
}
$content[] = 'Content-Disposition: form-data; name="' . $file_field . '"; filename="' . $file_name . '"';
// HACK: We only need to handle text/plain files right now.
$content[] = "Content-Type: text/plain\r\n";
$content[] = file_get_contents($file_name);
$content[] = '--' . $boundary . '--';
$content = implode("\r\n", $content);
return $content;
}
function dsq_get_http_headers_for_request($boundary, $content, $file_name, $file_field) {
$headers = array();
$headers[] = 'User-Agent: ' . USER_AGENT;
$headers[] = 'Connection: close';
if($content) {
$headers[] = 'Content-Length: ' . strlen($content);
if($file_name && $file_field) {
$headers[] = 'Content-Type: multipart/form-data; boundary=' . $boundary;
} else {
$headers[] = 'Content-Type: application/x-www-form-urlencoded';
}
}
return implode("\r\n", $headers);
}
function _dsq_curl_urlopen($url, $postdata, &$response, $file_name, $file_field) {
$c = curl_init($url);
$postdata_str = dsq_get_query_string($postdata);
$c_options = array(
CURLOPT_USERAGENT => USER_AGENT,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_POST => ($postdata_str ? 1 : 0),
CURLOPT_HEADER => true,
CURLOPT_HTTPHEADER => array('Expect:'),
CURLOPT_TIMEOUT => SOCKET_TIMEOUT
);
if($postdata) {
$c_options[CURLOPT_POSTFIELDS] = $postdata_str;
}
if($file_name && $file_field) {
$postdata[$file_field] = '@' . $file_name;
$c_options[CURLOPT_POSTFIELDS] = $postdata;
$c_options[CURLOPT_RETURNTRANSFER] = 1;
}
curl_setopt_array($c, $c_options);
$data = curl_exec($c);
list($headers, $response['data']) = explode("\r\n\r\n", $data, 2);
$response['headers'] = _dsq_get_response_headers($headers, $response);
$response['code'] = curl_getinfo($c, CURLINFO_HTTP_CODE);
}
function _dsq_get_response_headers($headers, &$response) {
$headers = explode("\r\n", $headers);
list($unused, $response['code'], $unused) = explode(' ', $headers[0], 3);
$headers = array_slice($headers, 1);
// Convert headers into associative array.
foreach($headers as $unused=>$header) {
$header = explode(':', $header);
$header[0] = trim($header[0]);
$header[1] = trim($header[1]);
$headers[strtolower($header[0])] = $header[1];
}
return $headers;
}
function _dsq_fsockopen_urlopen($url, $postdata, &$response, $file_name, $file_field) {
$buf = '';
$req = '';
$length = 0;
$boundary = '----------' . md5(time());
$postdata_str = dsq_get_post_content($boundary, $postdata, $file_name, $file_field);
$url_pieces = parse_url($url);
// Set default port for supported schemes if none is provided.
if(!isset($url_pieces['port'])) {
switch($url_pieces['scheme']) {
case 'http':
$url_pieces['port'] = 80;
break;
case 'https':
$url_pieces['port'] = 443;
$url_pieces['host'] = 'ssl://' . $url_pieces['host'];
break;
}
}
// Set default path if trailing slash is not provided.
if(!isset($url_pieces['path'])) { $url_pieces['path'] = '/'; }
// Determine if we need to include the port in the Host header or not.
if(($url_pieces['port'] == 80 && $url_pieces['scheme'] == 'http') ||
($url_pieces['port'] == 443 && $url_pieces['scheme'] == 'https')) {
$host = $url_pieces['host'];
} else {
$host = $url_pieces['host'] . ':' . $url_pieces['port'];
}
$fp = @fsockopen($url_pieces['host'], $url_pieces['port'], $errno, $errstr, SOCKET_TIMEOUT);
if(!$fp) { return false; }
$path = $url_pieces['path'];
if ($url_pieces['query']) $path .= '?'.$url_pieces['query'];
$req .= ($postdata_str ? 'POST' : 'GET') . ' ' . $path . " HTTP/1.1\r\n";
$req .= 'Host: ' . $host . "\r\n";
$req .= dsq_get_http_headers_for_request($boundary, $postdata_str, $file_name, $file_field);
if($postdata_str) {
$req .= "\r\n\r\n" . $postdata_str;
}
$req .= "\r\n\r\n";
fwrite($fp, $req);
while(!feof($fp)) {
$buf .= fgets($fp, 4096);
}
// Parse headers from the response buffers.
list($headers, $response['data']) = explode("\r\n\r\n", $buf, 2);
// Get status code from headers.
$headers = _dsq_get_response_headers($headers, $response);
// If transfer-coding is set to chunked, we need to join the message body
// together.
if(isset($headers['transfer-encoding']) && 'chunked' == strtolower($headers['transfer-encoding'])) {
$chunk_data = $response['data'];
$joined_data = '';
while(true) {
// Strip length from body.
list($chunk_length, $chunk_data) = explode("\r\n", $chunk_data, 2);
$chunk_length = hexdec($chunk_length);
if(!$chunk_length || !strlen($chunk_data)) { break; }
$joined_data .= substr($chunk_data, 0, $chunk_length);
$chunk_data = substr($chunk_data, $chunk_length + 1);
$length += $chunk_length;
}
$response['data'] = $joined_data;
} else {
$length = $headers['content-length'];
}
$response['headers'] = $headers;
}
function _dsq_fopen_urlopen($url, $postdata, &$response, $file_name, $file_field) {
$params = array();
if($file_name && $file_field) {
$boundary = '----------' . md5(time());
$content = dsq_get_post_content($boundary, $postdata, $file_name, $file_field);
$header = dsq_get_http_headers_for_request($boundary, $content, $file_name, $file_field);
$params = array('http' => array(
'method' => 'POST',
'header' => $header,
'content' => $content,
'timeout' => SOCKET_TIMEOUT
));
} else {
if($postdata) {
$params = array('http' => array(
'method' => 'POST',
'header' => 'Content-Type: application/x-www-form-urlencoded',
'content' => dsq_get_query_string($postdata),
'timeout' => SOCKET_TIMEOUT
));
}
}
ini_set('user_agent', USER_AGENT);
$ctx = stream_context_create($params);
$fp = fopen($url, 'rb', false, $ctx);
if(!$fp) {
return false;
}
// Get status code from headers.
list($unused, $response['code'], $unused) = explode(' ', $http_response_header[0], 3);
$headers = array_slice($http_response_header, 1);
// Convert headers into associative array.
foreach($headers as $unused=>$header) {
$header = explode(':', $header);
$header[0] = trim($header[0]);
$header[1] = trim($header[1]);
$headers[strtolower($header[0])] = strtolower($header[1]);
}
$response['data'] = stream_get_contents($fp);
$response['headers'] = $headers;
}
/**
* Wrapper to provide a single interface for making an HTTP request.
*
* Attempts to use cURL, fopen(), or fsockopen(), whichever is available
* first.
*
* @param string $url URL to make request to.
* @param array $postdata (optional) If postdata is provided, the request
* method is POST with the key/value pairs as
* the data.
* @param array $file (optional) Should provide associative array
* with two keys: name and field. Name should
* be the name of the file and field is the name
* of the field to POST.
*/
function dsq_urlopen($url, $postdata=false, $file=false) {
$response = array(
'data' => '',
'code' => 0
);
if($file) {
extract($file, EXTR_PREFIX_ALL, 'file');
}
if(empty($file_name) || empty($file_field)) {
$file_name = false;
$file_field = false;
}
//
// Try curl, fsockopen, fopen + stream (PHP5 only), exec wget
if(function_exists('curl_init')) {
if (!function_exists('curl_setopt_array')) {
function curl_setopt_array(&$ch, $curl_options)
{
foreach ($curl_options as $option => $value) {
if (!curl_setopt($ch, $option, $value)) {
return false;
}
}
return true;
}
}
_dsq_curl_urlopen($url, $postdata, $response, $file_name, $file_field);
} else if(ini_get('allow_url_fopen') && function_exists('stream_get_contents')) {
_dsq_fopen_urlopen($url, $postdata, $response, $file_name, $file_field);
} else {
// TODO: Find the failure condition for fsockopen() (sockets?)
_dsq_fsockopen_urlopen($url, $postdata, $response, $file_name, $file_field);
}
// returns array with keys data and code (from headers)
return $response;
}
function dsq_url_method() {
if(function_exists('curl_init')) {
return 'curl';
} else if(ini_get('allow_url_fopen') && function_exists('stream_get_contents')) {
return 'fopen';
} else {
return 'fsockopen';
}
}
?>