<?php
/* vim: set noexpandtab tabstop=2 softtabstop=2 shiftwidth=2: */
////////////////////////////////////////////////////////////////
//
// File: WEB ACCESS 2.1.3
// Date: 13.10.2011
// Author: Gilles Masson
// Updated: Xymph
//
////////////////////////////////////////////////////////////////
// This class and functions can be used to make asynchronous xml or http
// (POST or GET) queries.
// This means that you call a function to send the query, and a callback
// function will automatically be called when the response has arrived,
// without having your program waiting for the response.
// You can also use it for synchronous queries (see below).
// The class handles (for each URL) keepalive and compression (when possible).
// It supports Cookies, and so can use sessions like php one (anyway the cookie
// is not stored, so its maximal life is the life of the program).
//
//
// usage: $_webaccess = new Webaccess();
// $_webaccess->request($url, array('func_name',xxx), $datas, $is_xmlrpc, $keepalive_min_timeout);
// $url: the web script URL.
// $datas: string to send in http body (xml, xml_rpc or POST data)
// $is_xmlrpc: true if it's an xml or xml-rpc request, false if it's a
// standard html GET or POST
// $keepalive_min_timeout: minimal value of server keepalive timeout to
// send a keepalive request,
// else make a request with close connection.
// func_name is the callback function name, which will be called this way:
// func_name(array('Code'=>code,'Reason'=>reason,'Headers'=>headers,'Message'=>message), xxx)
// where:
// xxx is the same as given previously in callback description.
// code is the returned http code
// (http://www.w3.org/Protocols/rfc2616/rfc2616-sec6.html#sec6)
// reason is the returned http reason
// (http://www.w3.org/Protocols/rfc2616/rfc2616-sec6.html#sec6)
// headers are the http headers of the reply
// message is the returned text body
//
// IMPORTANT: to have this work, the main part of your program must include a
// $_webaccess->select() call periodically, which work exactly like stream_select().
// This is because the send and receive are asynchronous and will be completed
// later in the select() when datas are ready to be received and sent.
// This class can be used to make a synchronous query too. For that use null
// for the callback, so make the request this way:
// $response = $_webaccess->request($url, null, $datas, $is_xmlrpc, $keepalive_min_timeout);
// where $response is an array('Code'=>code,'Reason'=>reason,'Headers'=>headers,'Message'=>message)
// like the one passed to the callback function of the asynchronous request.
// If you use only synchronous queries then there is no need to call select()
// as the function will return when the reply will be fully returned.
// If the connection itself fail, the array response will include a 'Error' string.
// Other functions:
// list($host, $port, $path) = getHostPortPath($url);
// gzdecode() workaround
global $_web_access_compress_xmlrpc_request, $_web_access_compress_reply,
$_web_access_keepalive, $_web_access_keepalive_timeout,
$_web_access_keepalive_max, $_web_access_retry_timeout,
$_web_access_retry_timeout_max, $_web_access_post_xmlrpc;
// Will compress xmlrpc request ('never','accept','force','force-gzip','force-deflate')
// If set to 'accept' the first request will be made without, and the eventual
// 'Accept-Encoding' in reply will permit to decide if request compression can
// be used (and if gzip or deflate)
$_web_access_compress_xmlrpc_request = 'accept';
// Will ask server for compressed reply (false, true)
// If true then will add a 'Accept-Encoding' header to tell the server to
// compress the reply if it supports it.
$_web_access_compress_reply = true;
// Keep alive connection ? else close it after the reply.
// Unless false, first request will be with keepalive, to get server timeout
// and max values after timeout will be compared with the request
// $keepalive_min_timeout value to decide if keepalive have to be used or not.
// Note that Apache2 timeout is short (about 15s).
// The classes will open, re-open or use existing connection as needed.
$_web_access_keepalive = true;
// timeout(s) without request before close, for keepalive
$_web_access_keepalive_timeout = 600;
// max requests before close, for keepalive
$_web_access_keepalive_max = 2000;
// For asynchronous call, in case of error, timeout before retrying.
// It will be x2 for each error (on request or auto retry) until max,
// then stop automatic retry, and next request calls will return false.
// When stopped, a retry() or synchronous request will force a retry.
$_web_access_retry_timeout = 20;
$_web_access_retry_timeout_max = 5*60;
// Use text/html with xmlrpc=, instead of of pure text/xml request (false, true)
// Standard xml-rpc use pure text/xml request, where the xml is simply the body
// of the http request (and it's how the xml-rpc reply will be made). As a
// facility Dedimania also supports to get the xml in a html GET or POST,
// where xmlrpc= will contain a urlsafe base64 of the xml. Default to false,
// so use pure text/xml.
$_web_access_post_xmlrpc = false;
// Note that in each request the text/xml or xmlrpc= will be used only if
// $is_xmlrpc is true. If false then the request will be a standard
// application/x-www-form-urlencoded html GET or POST request; in that case
// you have to build the URL (GET) and/or body data (POST) yourself.
// If $is_xmlrpc is a string, then it's used as the Content-type: value.
require_once('includes/urlsafebase64.php');
class Webaccess {
var $_WebaccessList;
function Webaccess() {
$this->_WebaccessList = array();
}
function request($url, $callback, $datas, $is_xmlrpc = false, $keepalive_min_timeout = 300, $opentimeout = 3, $waittimeout = 5, $agent = 'XMLaccess') {
global $aseco, $_web_access_keepalive, $_web_access_keepalive_timeout, $_web_access_keepalive_max;
list($host, $port, $path) = getHostPortPath($url);
if ($host === false)
$aseco->console('Webaccess request(): Bad URL: ' . $url);
else {
$server = $host . ':' . $port;
// create object if needed
if (!isset($this->_WebaccessList[$server]) || $this->_WebaccessList[$server] === null) {
$this->_WebaccessList[$server] = new WebaccessUrl($this, $host, $port,
$_web_access_keepalive,
$_web_access_keepalive_timeout,
$_web_access_keepalive_max,
$agent);
}
// increase the default timeout for sync/wait request
if ($callback == null && $waittimeout == 5)
$waittimeout = 12;
// call request
if ($this->_WebaccessList[$server] !== null) {
$query = array('Path' => $path,
'Callback' => $callback,
'QueryData' => $datas,
'IsXmlrpc' => $is_xmlrpc,
'KeepaliveMinTimeout' => $keepalive_min_timeout,
'OpenTimeout' => $opentimeout,
'WaitTimeout' => $waittimeout
);
return $this->_WebaccessList[$server]->request($query);
}
}
return false;
} // request
function retry($url) {
global $aseco;
list($host, $port, $path) = getHostPortPath($url);
if ($host === false) {
$aseco->console('Webaccess retry(): Bad URL: ' . $url);
} else {
$server = $host . ':' . $port;
if (isset($this->_WebaccessList[$server]))
$this->_WebaccessList[$server]->retry();
}
} // retry
function select(&$read, &$write, &$except, $tv_sec, $tv_usec = 0) {
$timeout = (int)($tv_sec*1000000 + $tv_usec);
if ($read == null)
$read = array();
if ($write == null)
$write = array();
if ($except == null)
$except = array();
$read = $this->_getWebaccessReadSockets($read);
$write = $this->_getWebaccessWriteSockets($write);
//$except = $this->_getWebaccessReadSockets($except);
//print_r($this->_WebaccessList);
//print_r($read);
//print_r($write);
//print_r($except);
// if no socket to select then return
if (count($read) + count($write) + count($except) == 0) {
// sleep the asked timeout...
if ($timeout > 1000)
usleep($timeout);
return 0;
}
$utime = (int)(microtime(true)*1000000);
$nb = @stream_select($read, $write, $except, $tv_sec, $tv_usec);
if ($nb === false) {
// in case stream_select "forgot" to wait, sleep the remaining asked timeout...
$dtime = (int)(microtime(true)*1000000) - $utime;
$timeout -= $dtime;
if ($timeout > 1000)
usleep($timeout);
return false;
}
$this->_manageWebaccessSockets($read, $write, $except);
// workaround for stream_select bug with amd64, replace $nb with sum of arrays
return count($read) + count($write) + count($except);
} // select
private function _manageWebaccessSockets(&$receive, &$send, &$except) {
// send pending data on all webaccess sockets
if (is_array($send) && count($send) > 0) {
foreach ($send as $key => $socket) {
$i = $this->_findWebaccessSocket($socket);
if ($i !== false) {
if (isset($this->_WebaccessList[$i]->_spool[0]['State']) &&
$this->_WebaccessList[$i]->_spool[0]['State'] == 'OPEN')
$this->_WebaccessList[$i]->_open();
else
$this->_WebaccessList[$i]->_send();
unset($send[$key]);
}
}
}
// read data from all needed webaccess sockets
if (is_array($receive) && count($receive) > 0) {
foreach ($receive as $key => $socket) {
$i = $this->_findWebaccessSocket($socket);
if ($i !== false) {
$this->_WebaccessList[$i]->_receive();
unset($receive[$key]);
}
}
}
} // _manageWebaccessSockets
private function _findWebaccessSocket($socket) {
foreach ($this->_WebaccessList as $key => $wau) {
if ($wau->_socket == $socket)
return $key;
}
return false;
} // _findWebaccessSocket
private function _getWebaccessReadSockets($socks) {
foreach ($this->_WebaccessList as $key => $wau) {
if ($wau->_state == 'OPENED' && $wau->_socket)
$socks[] = $wau->_socket;
}
return $socks;
} // _getWebaccessReadSockets
private function _getWebaccessWriteSockets($socks) {
foreach ($this->_WebaccessList as $key => $wau) {
if (isset($wau->_spool[0]['State']) &&
($wau->_spool[0]['State'] == 'OPEN' ||
$wau->_spool[0]['State'] == 'BAD' ||
$wau->_spool[0]['State'] == 'SEND')) {
if (($wau->_state == 'CLOSED' || $wau->_state == 'BAD') && !$wau->_socket)
$wau->_open();
if ($wau->_state == 'OPENED' && $wau->_socket)
$socks[] = $wau->_socket;
}
}
return $socks;
} // _getWebaccessWriteSockets
function getAllSpools() {
$num = 0;
$bad = 0;
foreach ($this->_WebaccessList as $key => $wau) {
if ($wau->_state == 'OPENED' || $wau->_state == 'CLOSED')
$num += count($wau->_spool);
elseif ($wau->_state == 'BAD')
$bad += count($wau->_spool);
}
return array($num, $bad);
} // getAllSpools
} // class Webaccess
// useful data to handle received headers
$_wa_header_separator = array('cookie' => ';', 'set-cookie' => ';');
$_wa_header_multi = array('set-cookie' => true);
class WebaccessUrl {
//-----------------------------
// Fields
//-----------------------------
var $wa;
var $_host;
var $_port;
var $_compress_request;
var $_socket;
var $_state;
var $_keepalive;
var $_keepalive_timeout;
var $_keepalive_max;
var $_serv_keepalive_timeout;
var $_serv_keepalive_max;
var $_spool;
var $_wait;
var $_response;
var $_query_num;
var $_request_time;
var $_cookies;
var $_webaccess_str;
var $_bad_time;
var $_bad_timeout;
var $_read_time;
var $_agent;
// $_state values:
// 'OPENED' : socket is opened
// 'CLOSED' : socket is closed (asked, completed, or closed by server)
// 'BAD' : socket is closed, bad/error or beginning state
// $query['State'] values: (note: $query is added in $_spool, so $this->_spool[0] is the first $query to handle)
// 'BAD' : bad/error or beginning state
// 'OPEN' : should prepare request data then send them
// 'SEND' : request data are prepared, send them
// 'RECEIVE': request data are sent, receive reply data
// 'DONE' : request completed
//-----------------------------
// Methods
//-----------------------------
function WebaccessUrl(&$wa, $host, $port, $keepalive = true, $keepalive_timeout = 600, $keepalive_max = 300, $agent = 'XMLaccess') {
global $_web_access_compress_xmlrpc_request, $_web_access_retry_timeout;
$this->wa = &$wa;
$this->_host = $host;
$this->_port = $port;
$this->_webaccess_str = 'Webaccess (' . $this->_host . ':' . $this->_port . '): ';
$this->_agent = $agent;
// request compression setting
if ($_web_access_compress_xmlrpc_request == 'accept')
$this->_compress_request = 'accept';
elseif ($_web_access_compress_xmlrpc_request == 'force') {
if (function_exists('gzencode'))
$this->_compress_request = 'gzip';
elseif (function_exists('gzdeflate'))
$this->_compress_request = 'deflate';
else
$this->_compress_request = false;
}
elseif ($_web_access_compress_xmlrpc_request == 'force-gzip' && function_exists('gzencode'))
$this->_compress_request = 'gzip';
elseif ($_web_access_compress_xmlrpc_request == 'force-deflate' && function_exists('gzdeflate'))
$this->_compress_request = 'deflate';
else
$this->_compress_request = false;
$this->_socket = null;
$this->_state = 'CLOSED';
$this->_keepalive = $keepalive;
$this->_keepalive_timeout = $keepalive_timeout;
$this->_keepalive_max = $keepalive_max;
$this->_serv_keepalive_timeout = $keepalive_timeout;
$this->_serv_keepalive_max = $keepalive_max;
$this->_spool = array();
$this->_wait = false;
$this->_response = '';
$this->_query_num = 0;
$this->_query_time = time();
$this->_cookies = array();
$this->_bad_time = time();
$this->_bad_timeout = 0;
$this->_read_time = 0;
} // WebaccessUrl
// put connection in BAD state
function _bad($errstr, $isbad = true) {
global $aseco, $_web_access_retry_timeout;
$aseco->console($this->_webaccess_str . $errstr);
$this->infos();
if ($this->_socket)
@fclose($this->_socket);
$this->_socket = null;
if ($isbad) {
if (isset($this->_spool[0]['State']))
$this->_spool[0]['State'] = 'BAD';
$this->_state = 'BAD';
$this->_bad_time = time();
if ($this->_bad_timeout < $_web_access_retry_timeout)
$this->_bad_timeout = $_web_access_retry_timeout;
else
$this->_bad_timeout *= 2;
} else {
if (isset($this->_spool[0]['State']))
$this->_spool[0]['State'] = 'OPEN';
$this->_state = 'CLOSED';
}
$this->_callCallback($this->_webaccess_str . $errstr);
} // _bad
function retry() {
global $_web_access_retry_timeout;
if ($this->_state == 'BAD') {
$this->_bad_time = time();
$this->_bad_timeout = 0;
}
} // retry
//$query = array('Path' => $path,
// 'Callback' => $callback,
// 'QueryData' => $datas,
// 'IsXmlrpc' => $is_xmlrpc,
// 'KeepaliveMinTimeout' => $keepalive_min_timeout,
// 'OpenTimeout' => $opentimeout,
// 'WaitTimeout' => $waittimeout );
// will add: 'State', 'HDatas', 'Datas', 'DatasSize', 'DatasSent',
// 'Response', 'ResponseSize', 'Headers', 'Close', 'Times'
function request(&$query) {
global $aseco, $_web_access_compress_reply, $_web_access_post_xmlrpc, $_web_access_retry_timeout, $_web_access_retry_timeout_max;
$query['State'] = 'BAD';
$query['HDatas'] = '';
$query['Datas'] = '';
$query['DatasSize'] = 0;
$query['DatasSent'] = 0;
$query['Response'] = '';
$query['ResponseSize'] = 0;
$query['Headers'] = array();
$query['Close'] = false;
$query['Times'] = array('open' => array(-1.0,-1.0), 'send' => array(-1.0,-1.0), 'receive' => array(-1.0,-1.0,0));
// if asynch, in error, and maximal timeout, then forget the request and return false
if (($query['Callback'] != null) && ($this->_state == 'BAD')) {
if ($this->_bad_timeout > $_web_access_retry_timeout_max) {
$aseco->console($this->_webaccess_str . 'Request refused for consecutive errors (' . $this->_bad_timeout . ' / ' . $_web_access_retry_timeout_max . ')');
return false;
} else {
// if not max then accept the request and try a request (minimum $_web_access_retry_timeout/2 after previous try)
$time = time();
$timeout = ($this->_bad_timeout / 2) - ($time - $this->_bad_time);
if ($timeout < 0)
$timeout = 0;
$this->_bad_time = $time - $this->_bad_timeout + $timeout;
}
}
// build data to send
if (($query['Callback'] == null) || (is_array($query['Callback']) &&
isset($query['Callback'][0]) &&
is_callable($query['Callback'][0]))) {
if (is_string($query['QueryData']) && strlen($query['QueryData']) > 0) {
$msg = "POST " . $query['Path'] . " HTTP/1.1\r\n";
$msg .= "Host: " . $this->_host . "\r\n";
$msg .= "User-Agent: " . $this->_agent . "\r\n";
$msg .= "Cache-Control: no-cache\r\n";
if ($_web_access_compress_reply) {
// ask compression of response if gzdecode() and/or gzinflate() is available
if (function_exists('gzdecode') && function_exists('gzinflate'))
$msg .= "Accept-Encoding: deflate, gzip\r\n";
elseif (function_exists('gzdecode'))
$msg .= "Accept-Encoding: gzip\r\n";
elseif (function_exists('gzinflate'))
$msg .= "Accept-Encoding: deflate\r\n";
}
//echo "\nData:\n\n" . $query['QueryData'] . "\n";
if ($query['IsXmlrpc'] === true) {
if ($_web_access_post_xmlrpc) {
$msg .= "Content-type: application/x-www-form-urlencoded; charset=UTF-8\r\n";
//echo "\n=========================== Data =================================\n\n" . $datas . "\n";
//$d2 = urlsafe_base64_encode($datas);
//$d3 = urlsafe_base64_decode($d2);
//echo "\n--------------------------- Data ---------------------------------\n\n" . $d3 . "\n";
$query['QueryData'] = 'xmlrpc=' . urlsafe_base64_encode($query['QueryData']);
}
else {
$msg .= "Content-type: text/xml; charset=UTF-8\r\n";
}
if ($this->_compress_request == 'gzip' && function_exists('gzencode')) {
$msg .= "Content-Encoding: gzip\r\n";
$query['QueryData'] = gzencode($query['QueryData']);
} elseif ($this->_compress_request == 'deflate' && function_exists('gzdeflate')) {
$msg .= "Content-Encoding: deflate\r\n";
$query['QueryData'] = gzdeflate($query['QueryData']);
}
}
elseif (is_string($query['IsXmlrpc'])) {
$msg .= "Content-type: " . $query['IsXmlrpc'] . "\r\n";
$msg .= "Accept: */*\r\n";
} else {
$msg .= "Content-type: application/x-www-form-urlencoded; charset=UTF-8\r\n";
}
$msg .= "Content-length: " . strlen($query['QueryData']) . "\r\n";
$query['HDatas'] = $msg;
$query['State'] = 'OPEN';
$query['Retries'] = 0;
//print_r($msg);
// add the query in spool
$this->_spool[] = &$query;
if ($query['Callback'] == null) {
$this->_wait = true;
$this->_open($query['OpenTimeout'], $query['WaitTimeout']); // wait more in not callback mode
$this->_spool = array();
$this->_wait = false;
return $query['Response'];
} else
$this->_open();
} else {
$aseco->console($this->_webaccess_str . 'Bad data');
return false;
}
} else {
$aseco->console($this->_webaccess_str . 'Bad callback function: ' . $query['Callback']);
return false;
}
return true;
} // request
// open the socket (close it before if needed)
private function _open_socket($opentimeout = 0.0) {
global $aseco;
// if socket not opened, then open it (2 tries)
if (!$this->_socket || $this->_state != 'OPENED') {
$time = microtime(true);
$this->_spool[0]['Times']['open'][0] = $time;
$errno = '';
$errstr = '';
$this->_socket = @fsockopen($this->_host, $this->_port, $errno, $errstr, 1.8); // first try
if (!$this->_socket) {
if ($opentimeout >= 1.0)
$this->_socket = @fsockopen($this->_host, $this->_port, $errno, $errstr, $opentimeout);
if (!$this->_socket) {
$this->_bad('Error(' . $errno . ') ' . $errstr . ', connection failed!');
return;
}
}
$this->_state = 'OPENED';
//$aseco->console($this->_webaccess_str . 'connection opened!');
// new socket connection: reset all pending request original values
for ($i = 0; $i < count($this->_spool); $i++) {
$this->_spool[$i]['State'] = 'OPEN';
$this->_spool[$i]['DatasSent'] = 0;
$this->_spool[$i]['Response'] = '';
$this->_spool[$i]['Headers'] = array();
}
$this->_response = '';
$this->_query_num = 0;
$this->_query_time = time();
$time = microtime(true);
$this->_spool[0]['Times']['open'][1] = $time - $this->_spool[0]['Times']['open'][0];
}
} // _open_socket
// open the connection (if not already opened) and send
function _open($opentimeout = 0.0, $waittimeout = 5.0) {
global $aseco, $_web_access_retry_timeout_max;
if (!isset($this->_spool[0]['State']))
return false;
$time = time();
// if asynch, in error, then return false until timeout or if >max)
if (!$this->_wait && $this->_state == 'BAD' &&
(($this->_bad_timeout > $_web_access_retry_timeout_max) ||
(($time - $this->_bad_time) < $this->_bad_timeout))) {
//$aseco->console($this->_webaccess_str . 'wait to retry (' . ($time - $this->_bad_time) . ' / ' . $this->_bad_timeout . ')');
return false;
}
// if the socket is probably in timeout, close it
if ($this->_socket && $this->_state == 'OPENED' &&
($this->_serv_keepalive_timeout <= ($time - $this->_query_time))) {
//$aseco->console($this->_webaccess_str . 'timeout, close it!');
$this->_state = 'CLOSED';
@fclose($this->_socket);
$this->_socket = null;
}
// if socket is not opened, open it
if (!$this->_socket || $this->_state != 'OPENED')
$this->_open_socket($opentimeout);
// if socket is open, send data if possible
if ($this->_socket) {
$this->_read_time = microtime(true);
// if wait (synchronous query) then go on all pending write/read until the last
if ($this->_wait) {
@stream_set_timeout($this->_socket, 0, 10000); // timeout 10 ms
while (isset($this->_spool[0]['State']) &&
($this->_spool[0]['State'] == 'OPEN' ||
$this->_spool[0]['State'] == 'SEND' ||
$this->_spool[0]['State'] == 'RECEIVE')) {
//echo 'State=' . $this->_spool[0]['State'] . " (" . count($this->_spool) . ")\n";
if (!$this->_socket || $this->_state != 'OPENED')
$this->_open_socket($opentimeout);
if ($this->_spool[0]['State'] == 'OPEN') {
$time = microtime(true);
$this->_spool[0]['Times']['send'][0] = $time;
$this->_send($waittimeout);
}
elseif ($this->_spool[0]['State'] == 'SEND')
$this->_send($waittimeout);
elseif ($this->_spool[0]['State'] == 'RECEIVE')
$this->_receive($waittimeout*4);
// if timeout then error
if (($difftime = microtime(true) - $this->_read_time) > $waittimeout) {
$this->_bad('Request timeout, in _open (' . round($difftime) . ' > ' . $waittimeout . 's) state=' . $this->_spool[0]['State']);
return;
}
}
if ($this->_socket)
@stream_set_timeout($this->_socket, 0, 2000); // timeout 2 ms
}
// else just do a send on the current
elseif (isset($this->_spool[0]['State']) && $this->_spool[0]['State'] == 'OPEN') {
@stream_set_timeout($this->_socket, 0, 2000); // timeout 2 ms
$this->_send($waittimeout);
}
}
} // _open
function _send($waittimeout = 20) {
if (!isset($this->_spool[0]['State']))
return;
// if OPEN then become SEND
if ($this->_spool[0]['State'] == 'OPEN') {
$this->_spool[0]['State'] = 'SEND';
$time = microtime(true);
$this->_spool[0]['Times']['send'][0] = $time;
$this->_spool[0]['Response'] = '';
$this->_spool[0]['Headers'] = array();
// finish to prepare header and data to send
$msg = $this->_spool[0]['HDatas'];
if (!$this->_keepalive || ($this->_spool[0]['KeepaliveMinTimeout'] < 0) ||
($this->_serv_keepalive_timeout < $this->_spool[0]['KeepaliveMinTimeout']) ||
($this->_serv_keepalive_max <= ($this->_query_num + 2)) ||
($this->_serv_keepalive_timeout <= (time() - $this->_query_time + 2))) {
$msg .= "Connection: close\r\n";
$this->_spool[0]['Close'] = true;
}
else {
$msg .= 'Keep-Alive: timeout=' . $this->_keepalive_timeout . ', max=' . $this->_keepalive_max
. "\r\nConnection: Keep-Alive\r\n";
}
// add cookie header
if (count($this->_cookies) > 0) {
$cookie_msg = '';
$sep = '';
foreach ($this->_cookies as $name => $cookie) {
if (!isset($cookie['path']) ||
strncmp($this->_spool[0]['Path'], $cookie['path'], strlen($cookie['path'])) == 0) {
$cookie_msg .= $sep . $name . '=' . $cookie['Value'];
$sep = '; ';
}
}
if ($cookie_msg != '')
$msg .= "Cookie: $cookie_msg\r\n";
}
$msg .= "\r\n";
$msg .= $this->_spool[0]['QueryData'];
$this->_spool[0]['Datas'] = $msg;
$this->_spool[0]['DatasSize'] = strlen($msg);
$this->_spool[0]['DatasSent'] = 0;
//print_r($msg);
}
// if not SEND then stop
if ($this->_spool[0]['State'] != 'SEND')
return;
do {
$sent = @stream_socket_sendto($this->_socket,
substr($this->_spool[0]['Datas'], $this->_spool[0]['DatasSent'],
($this->_spool[0]['DatasSize'] - $this->_spool[0]['DatasSent'])));
if ($sent == false) {
$time = microtime(true);
$this->_spool[0]['Times']['send'][1] = $time - $this->_spool[0]['Times']['send'][0];
//var_dump($this->_spool[0]['Datas']);
$this->_bad('Error(' . $errno . ') ' . $errstr . ', could not send data! ('
. $sent . ' / ' . ($this->_spool[0]['DatasSize'] - $this->_spool[0]['DatasSent']) . ', '
. $this->_spool[0]['DatasSent'] . ' / ' . $this->_spool[0]['DatasSize'] . ')');
if ($this->_wait)
return;
break;
} else {
$this->_spool[0]['DatasSent'] += $sent;
if ($this->_spool[0]['DatasSent'] >= $this->_spool[0]['DatasSize']) {
// All is sent, prepare to receive the reply
$this->_query_num++;
$this->_query_time = time();
$time = microtime(true);
$this->_spool[0]['Times']['send'][1] = $time - $this->_spool[0]['Times']['send'][0];
//@stream_set_blocking($this->_socket, 0);
$this->_spool[0]['State'] = 'RECEIVE';
$this->_spool[0]['Times']['receive'][0] = $time;
}
// if timeout then error
elseif (($difftime = microtime(true) - $this->_read_time) > $waittimeout) {
$this->_bad('Request timeout, in _send (' . round($difftime) . ' > ' . $waittimeout . 's)');
}
}
// if not async-callback then continue until all is sent
} while ($this->_wait && isset($this->_spool[0]['State']) && ($this->_spool[0]['State'] == 'SEND'));
} // _send
function _receive($waittimeout = 40) {
global $aseco, $_Webaccess_last_response;
if (!$this->_socket || $this->_state != 'OPENED')
return;
$state = false;
$time0 = microtime(true);
$timeout = ($this->_wait) ? $waittimeout : 0;
do {
$r = array($this->_socket);
$w = null;
$e = null;
$nb = @stream_select($r, $w, $e, $timeout);
if ($nb === 0)
$nb = count($r);
while (!@feof($this->_socket) && $nb !== false && $nb > 0) {
$timeout = 0;
if (count($r) > 0) {
$res = @stream_socket_recvfrom($this->_socket, 8192);
if ($res == '') { // should not happen habitually, but...
break;
} elseif ($res !== false) {
$this->_response .= $res;
}
else {
if (isset($this->_spool[0])) {
$time = microtime(true);
$this->_spool[0]['Times']['receive'][1] = $time - $this->_spool[0]['Times']['receive'][0];
}
$this->_bad('Error(' . $errno . ') ' . $errstr . ', could not read all data!');
return;
}
}
// if timeout then error
if (($difftime = microtime(true) - $this->_read_time) > $waittimeout) {
$this->_bad('Request timeout, in _receive (' . round($difftime) . ' > ' . $waittimeout . 's)');
break;
}
$r = array($this->_socket);
$w = null;
$e = null;
$nb = @stream_select($r, $w, $e, $timeout);
if ($nb === 0)
$nb = count($r);
}
if (isset($this->_spool[0]['Times']['receive'][2])) {
$time = microtime(true);
$this->_spool[0]['Times']['receive'][2] += ($time - $time0);
}
// get headers and full message
$state = $this->_handleHeaders();
//echo "receive9\n";
//var_dump($state);
} while ($this->_wait && $state === false && $this->_socket && !@feof($this->_socket));
if (!isset($this->_spool[0]['State']) || $this->_spool[0]['State'] != 'RECEIVE') {
// in case of (probably keepalive) connection closed by server
if ($this->_socket && @feof($this->_socket)){
//$aseco->console($this->_webaccess_str . 'Socket closed by server (' . $this->_host . ')');
$this->_state = 'CLOSED';
@fclose($this->_socket);
$this->_socket = null;
}
return;
}
// terminated but incomplete! more than probably closed by server...
if ($state === false && $this->_socket && @feof($this->_socket)) {
$this->_state = 'CLOSED';
if (isset($this->_spool[0])) {
$time = microtime(true);
$this->_spool[0]['State'] = 'OPEN';
$this->_spool[0]['Times']['receive'][1] = $time - $this->_spool[0]['Times']['receive'][0];
}
if (strlen($this->_response) > 0) // if not 0 sized then show error message
$this->_bad('Error: closed with incomplete read: re-open socket and re-send! (' . strlen($this->_response) . ')');
else
$this->_bad('Closed by server when reading: re-open socket and re-send! (' . strlen($this->_response) . ')', false);
$this->_spool[0]['Retries']++;
if ($this->_spool[0]['Retries'] > 2) {
// 3 tries failed, remove entry from spool
$aseco->console($this->_webaccess_str . "failed {$this->_spool[0]['Retries']} times: skip current request");
array_shift($this->_spool);
}
return;
}
// reply is complete :)
if ($state === true) {
$this->_bad_timeout = 0; // reset error timeout
$this->_spool[0]['Times']['receive'][1] = $time - $this->_spool[0]['Times']['receive'][0];
$this->_spool[0]['State'] = 'DONE';
// store http/xml response in global $_Webaccess_last_response for debugging use
$_Webaccess_last_response = $this->_spool[0]['Response'];
//debugPrint('Webaccess->_receive - Response', $_Webaccess_last_response);
// call callback func
$this->_callCallback();
$this->_query_time = time();
if (!$this->_keepalive || $this->_spool[0]['Close']) {
//if ($this->_spool[0]['Close'])
// $aseco->console($this->_webaccess_str . 'close connection (asked in headers)');
$this->_state = 'CLOSED';
@fclose($this->_socket);
$this->_socket = null;
}
$this->infos();
// request completed, remove it from spool!
array_shift($this->_spool);
}
} // _receive
private function _callCallback($error = null) {
// store optional error message
if ($error !== null)
$this->_spool[0]['Response']['Error'] = $error;
// call callback func
if (isset($this->_spool[0]['Callback'])) {
$callbackinfo = $this->_spool[0]['Callback'];
if (isset($callbackinfo[0]) && is_callable($callbackinfo[0])) {
$callback_func = $callbackinfo[0];
$callbackinfo[0] = $this->_spool[0]['Response'];
call_user_func_array($callback_func, $callbackinfo);
}
}
}
private function _handleHeaders() {
global $aseco, $_wa_header_separator, $_wa_header_multi;
if (!isset($this->_spool[0]['State']))
return false;
if (strlen($this->_response) < 8) // not enough data, continue read
return false;
if (strncmp($this->_response, 'HTTP/', 5) != 0) { // not HTTP!
$this->_bad("Error, not HTTP response ! **********\n" . substr($this->_response, 0, 300) . "\n***************\n");
return null;
}
// separate headers and data
$datas = explode("\r\n\r\n", $this->_response, 2);
if (count($datas) < 2) {
$datas = explode("\n\n", $this->_response, 2);
if (count($datas) < 2) {
$datas = explode("\r\r", $this->_response, 2);
if (count($datas) < 2)
return false; // not complete headers, continue read
}
}
// get headers if not done on previous read
if (!isset($this->_spool[0]['Headers']['Command'][0])) {
// separate headers
//echo "Get Headers! (" . strlen($datas[0]) . ")\n";
$headers = array();
$heads = explode("\n", str_replace("\r", "\n", str_replace("\r\n", "\n", $datas[0])));
if (count($heads) < 2) {
$this->_bad("Error, uncomplete headers! **********\n" . $datas[0] . "\n***************\n");
return null;
}
$headers['Command'] = explode(' ', $heads[0], 3);
for ($i = 1; $i < count($heads); $i++) {
$header = explode(':', $heads[$i], 2);
if (count($header) > 1) {
$headername = strtolower(trim($header[0]));
if (isset($_wa_header_separator[$headername]))
$sep = $_wa_header_separator[$headername];
else
$sep = ',';
if (isset($_wa_header_multi[$headername]) && $_wa_header_multi[$headername]) {
if (!isset($headers[$headername]))
$headers[$headername] = array();
$headers[$headername][] = explode($sep, trim($header[1]));
} else
$headers[$headername] = explode($sep, trim($header[1]));
}
}
if (isset($headers['content-length'][0]))
$headers['content-length'][0] += 0; // convert to int
$this->_spool[0]['Headers'] = $headers;
// add header specific info in case of Dedimania reply
if (isset($headers['server'][0]))
$this->_webaccess_str = 'Webaccess (' . $this->_host . ':' . $this->_port .'/'. $headers['server'][0] . '): ';
}
else {
$headers = &$this->_spool[0]['Headers'];
//echo "Previous Headers! (" . strlen($datas[0]) . ")\n";
}
// get real message
$datasize = strlen($datas[1]);
if (isset($headers['content-length'][0]) && $headers['content-length'][0] >= 0) {
//echo 'mess_size0=' . strlen($datas[1]) . "\n";
if ($headers['content-length'][0] > $datasize) // incomplete message
return false;
elseif ($headers['content-length'][0] < $datasize) {
$message = substr($datas[1], 0, $headers['content-length'][0]);
// remaining buffer for next reply
$this->_response = substr($datas[1], $headers['content-length'][0]);
}
else {
$message = $datas[1];
$this->_response = '';
}
$this->_spool[0]['ResponseSize'] = strlen($datas[0]) + 4 + $headers['content-length'][0];
}
// get real message when reply is chunked
elseif (isset($headers['transfer-encoding'][0]) && $headers['transfer-encoding'][0] == 'chunked') {
// get chunk size and make message with chunks data
$size = -1;
$chunkpos = 0;
if (($datapos = strpos($datas[1], "\r\n", $chunkpos)) !== false) {
$message = '';
$chunk = explode(';', substr($datas[1], $chunkpos, $datapos - $chunkpos));
$size = hexdec($chunk[0]);
//debugPrint("Webaccess->Response - chunk - $chunkpos, $datapos, $size (" . strlen($datas[1]) . ")", $chunk);
while ($size > 0) {
if ($datapos + 2 + $size > $datasize) // incomplete message
return false;
$message .= substr($datas[1], $datapos + 2, $size);
$chunkpos = $datapos + 2 + $size + 2;
if (($datapos = strpos($datas[1], "\r\n", $chunkpos)) !== false) {
$chunk = explode(';', substr($datas[1], $chunkpos, $datapos - $chunkpos));
$size = hexdec($chunk[0]);
} else
$size = -1;
//debugPrint("Webaccess->Response - chunk - $chunkpos, $datapos, $size (" . strlen($datas[1]) . ")", $chunk);
}
}
if ($size < 0) // error bad size or incomplete message
return false;
if (strpos($datas[1], "\r\n\r\n", $chunkpos) === false) // incomplete message: end is missing
return false;
// store complete message size
$msize = strlen($message);
$headers['transfer-encoding'][1] = 'total_size=' . $msize; // add message size after 'chunked' for information
$this->_spool[0]['ResponseSize'] = strlen($datas[0]) + 4 + $msize;
// after the message itself...
$message_end = explode("\r\n\r\n", substr($datas[1], $chunkpos), 2);
// add end headers if any
$heads = explode("\n", str_replace("\r", "\n", str_replace("\r\n", "\n", $message_end[0])));
for ($i = 1; $i < count($heads); $i++) {
$header = explode(':', $heads[$i], 2);
if (count($header) > 1) {
$headername = strtolower(trim($header[0]));
if (isset($_wa_header_separator[$headername]))
$sep = $_wa_header_separator[$headername];
else
$sep = ',';
if (isset($_wa_header_multi[$headername]) && $_wa_header_multi[$headername]) {
if (!isset($headers[$headername]))
$headers[$headername] = array();
$headers[$headername][] = explode($sep, trim($header[1]));
} else
$headers[$headername] = explode($sep, trim($header[1]));
}
}
$this->_spool[0]['Headers'] = $headers;
// remaining buffer for next reply
if (isset($message_end[1]) && strlen($message_end[1]) > 0) {
$this->_response = $message_end[1];
}
else
$this->_response = '';
}
// no content-length and not chunked!
else {
$this->_bad("Error, bad http, no content-length and not chunked! **********\n" . $datas[0] . "\n***************\n");
return null;
}
//echo 'mess_size1=' . strlen($message) . "\n";
// if Content-Encoding: gzip or Content-Encoding: deflate
if (isset($headers['content-encoding'][0])) {
if ($headers['content-encoding'][0] == 'gzip')
$message = @gzdecode($message);
elseif ($headers['content-encoding'][0] == 'deflate')
$message = @gzinflate($message);
}
// if Accept-Encoding: gzip or deflate
if ($this->_compress_request == 'accept' && isset($headers['accept-encoding'][0])) {
foreach ($headers['accept-encoding'] as $comp) {
$comp = trim($comp);
if ($comp == 'gzip' && function_exists('gzencode')) {
$this->_compress_request = 'gzip';
break;
}
elseif ($comp == 'deflate' && function_exists('gzdeflate')) {
$this->_compress_request = 'deflate';
break;
}
}
if ($this->_compress_request == 'accept')
$this->_compress_request = false;
$aseco->console($this->_webaccess_str . 'send: ' . ($this->_compress_request === false ? 'no compression' : $this->_compress_request)
. ', receive: ' . (isset($headers['content-encoding'][0]) ? $headers['content-encoding'][0] : 'no compression'));
}
// get cookies values
if (isset($headers['set-cookie'])) {
foreach ($headers['set-cookie'] as $cookie) {
$cook = explode('=', $cookie[0], 2);
if (count($cook) > 1) {
// set main cookie value
$cookname = trim($cook[0]);
if (!isset($this->_cookies[$cookname]))
$this->_cookies[$cookname] = array();
$this->_cookies[$cookname]['Value'] = trim($cook[1]);
// set cookie options
for ($i = 1; $i < count($cookie); $i++) {
$cook = explode('=', $cookie[$i], 2);
$cookarg = strtolower(trim($cook[0]));
if (isset($cook[1]))
$this->_cookies[$cookname][$cookarg] = trim($cook[1]);
}
}
}
//debugPrint('SET-COOKIES: ', $headers['set-cookie']);
//debugPrint('STORED COOKIES: ', $this->_cookies);
}
// if the server reply ask to close, then close
if (!isset($headers['connection'][0]) || $headers['connection'][0] == 'close') {
//if (!$this->_spool[0]['Close'])
// $aseco->console($this->_webaccess_str . 'server ask to close connection');
$this->_spool[0]['Close'] = true;
}
// verify server keepalive value and use them if lower
if (isset($headers['keep-alive'])) {
$kasize = count($headers['keep-alive']);
for ($i = 0; $i < $kasize; $i++) {
$keep = explode('=', $headers['keep-alive'][$i], 2);
if (count($keep) > 1)
$headers['keep-alive'][trim(strtolower($keep[0]))] = intval(trim($keep[1]));
}
if (isset($headers['keep-alive']['timeout']))
$this->_serv_keepalive_timeout = $headers['keep-alive']['timeout'];
if (isset($headers['keep-alive']['max']))
$this->_serv_keepalive_max = $headers['keep-alive']['max'];
//$aseco->console($this->_webaccess_str . 'max=' . $this->_serv_keepalive_max . ', timeout=' . $this->_serv_keepalive_timeout . "\n");
}
// store complete reply message for the request
$this->_spool[0]['Response'] = array('Code' => intval($headers['Command'][1]),
'Reason' => $headers['Command'][2],
'Headers' => $headers,
'Message' => $message
);
//echo 'mess_size2=' . strlen($message) . "\n";
return true;
} // _handleHeaders
function infos() {
global $aseco;
$size = (isset($this->_spool[0]['Response']['Message'])) ? strlen($this->_spool[0]['Response']['Message']) : 0;
$msg = $this->_webaccess_str
. sprintf('[%s,%s]: %0.3f / %0.3f / %0.3f (%0.3f) / %d [%d,%d,%d]',
$this->_state, $this->_spool[0]['State'],
$this->_spool[0]['Times']['open'][1],
$this->_spool[0]['Times']['send'][1],
$this->_spool[0]['Times']['receive'][1],
$this->_spool[0]['Times']['receive'][2],
$this->_query_num, $this->_spool[0]['DatasSize'],
$size, $this->_spool[0]['ResponseSize']);
//$aseco->console($msg);
} // infos
} // class WebaccessUrl
// use: list($host, $port, $path) = getHostPortPath($url);
function getHostPortPath($url) {
$http_pos = strpos($url, 'http://');
if ($http_pos !== false) {
$script = explode('/', substr($url, $http_pos + 7), 2);
if (isset($script[1]))
$path = '/' . $script[1];
else
$path = '/';
$serv = explode(':', $script[0], 2);
$host = $serv[0];
if (isset($serv[1]))
$port = (int)$serv[1];
else
$port = 80;
if (strlen($host) > 2)
return array($host, $port, $path);
}
return array(false, false, false);
} // getHostPortPath
// gzdecode() workaround
if (!function_exists('gzdecode') && function_exists('gzinflate')) {
function gzdecode($data) {
$len = strlen($data);
if ($len < 18 || strcmp(substr($data, 0, 2), "\x1f\x8b")) {
return null; // Not GZIP format (See RFC 1952)
}
$method = ord(substr($data, 2, 1)); // Compression method
$flags = ord(substr($data, 3, 1)); // Flags
if ($flags & 31 != $flags) {
// Reserved bits are set -- NOT ALLOWED by RFC 1952
return null;
}
// NOTE: $mtime may be negative (PHP integer limitations)
$mtime = unpack('V', substr($data, 4, 4));
$mtime = $mtime[1];
$xfl = substr($data, 8, 1);
$os = substr($data, 8, 1);
$headerlen = 10;
$extralen = 0;
$extra = '';
if ($flags & 4) {
// 2-byte length prefixed EXTRA data in header
if ($len - $headerlen - 2 < 8) {
return false; // Invalid format
}
$extralen = unpack('v', substr($data, 8, 2));
$extralen = $extralen[1];
if ($len - $headerlen - 2 - $extralen < 8) {
return false; // Invalid format
}
$extra = substr($data, 10, $extralen);
$headerlen += $extralen + 2;
}
$filenamelen = 0;
$filename = '';
if ($flags & 8) {
// C-style string file NAME data in header
if ($len - $headerlen - 1 < 8) {
return false; // Invalid format
}
$filenamelen = strpos(substr($data, 8 + $extralen), chr(0));
if ($filenamelen === false || $len - $headerlen - $filenamelen - 1 < 8) {
return false; // Invalid format
}
$filename = substr($data, $headerlen, $filenamelen);
$headerlen += $filenamelen + 1;
}
$commentlen = 0;
$comment = '';
if ($flags & 16) {
// C-style string COMMENT data in header
if ($len - $headerlen - 1 < 8) {
return false; // Invalid format
}
$commentlen = strpos(substr($data, 8 + $extralen + $filenamelen), chr(0));
if ($commentlen === false || $len - $headerlen - $commentlen - 1 < 8) {
return false; // Invalid header format
}
$comment = substr($data, $headerlen, $commentlen);
$headerlen += $commentlen + 1;
}
$headercrc = '';
if ($flags & 1) {
// 2-bytes (lowest order) of CRC32 on header present
if ($len - $headerlen - 2 < 8) {
return false; // Invalid format
}
$calccrc = crc32(substr($data, 0, $headerlen)) & 0xffff;
$headercrc = unpack('v', substr($data, $headerlen, 2));
$headercrc = $headercrc[1];
if ($headercrc != $calccrc) {
return false; // Bad header CRC
}
$headerlen += 2;
}
// GZIP FOOTER - These be negative due to PHP's limitations
$datacrc = unpack('V', substr($data, -8, 4));
$datacrc = $datacrc[1];
$isize = unpack('V', substr($data, -4));
$isize = $isize[1];
// Perform the decompression:
$bodylen = $len - $headerlen - 8;
if ($bodylen < 1) {
// This should never happen - IMPLEMENTATION BUG!
return null;
}
$body = substr($data, $headerlen, $bodylen);
$data = '';
if ($bodylen > 0) {
switch ($method) {
case 8:
// Currently the only supported compression method:
$data = gzinflate($body);
break;
default:
// Unknown compression method
return false;
}
} else {
// I'm not sure if zero-byte body content is allowed.
// Allow it for now... Do nothing...
}
// Verify decompressed size and CRC32:
// NOTE: This may fail with large data sizes depending on how
// PHP's integer limitations affect strlen() since $isize
// may be negative for large sizes
if ($isize != strlen($data) || crc32($data) != $datacrc) {
// Bad format! Length or CRC doesn't match!
return false;
}
return $data;
} // gzdecode
}
?>