Blame | Letzte Änderung | Log anzeigen | RSS feed
<?php//// +----------------------------------------------------------------------+// | PHP Version 4 |// +----------------------------------------------------------------------+// | Copyright (c) 1997-2003 The PHP Group |// +----------------------------------------------------------------------+// | This source file is subject to version 2.02 of the PHP license, |// | that is bundled with this package in the file LICENSE, and is |// | available at through the world-wide-web at |// | http://www.php.net/license/2_02.txt. |// | If you did not receive a copy of the PHP license and are unable to |// | obtain it through the world-wide-web, please send a note to |// | license@php.net so we can mail you a copy immediately. |// +----------------------------------------------------------------------+// | Authors: Shane Caraveo <Shane@Caraveo.com> |// +----------------------------------------------------------------------+//// $Id: HTTP.php 696 2011-09-08 09:08:23Z tiefland $///*** Needed Classes*/require_once 'PayPal/SOAP/Base.php';require_once 'PayPal/SDKProxyProperties.php';/*** HTTP Transport for SOAP** @access public* @package SOAP::Transport::HTTP* @author Shane Caraveo <shane@php.net>*/class SOAP_Transport_HTTP extends SOAP_Base{/*** Basic Auth string** @var array*/var $headers = array();/*** Cookies** @var array*/var $cookies;/**** @var int connection timeout in seconds - 0 = none*/var $timeout = 300;/*** Array containing urlparts - parse_url()** @var mixed*/var $urlparts = NULL;/*** Connection endpoint - URL** @var string*/var $url = '';/*** Incoming payload** @var string*/var $incoming_payload = '';/*** HTTP-Request User-Agent** @var string*/var $_userAgent = SOAP_LIBRARY_NAME;/*** HTTP Encoding** @var string*/var $encoding = SOAP_DEFAULT_ENCODING;/*** HTTP-Response Content-Type encoding** we assume UTF-8 if no encoding is set* @var string*/var $result_encoding = 'UTF-8';/*** HTTP-Response Content-Type*/var $result_content_type;var $result_headers = array();var $result_cookies = array();/*** SOAP_Transport_HTTP Constructor** @param string $URL http url to soap endpoint** @access public* @param string $URI* @param string $encoding encoding to use*/function SOAP_Transport_HTTP($URL, $encoding = SOAP_DEFAULT_ENCODING){parent::SOAP_Base('HTTP');$this->urlparts = @parse_url($URL);$this->url = $URL;$this->encoding = $encoding;}/*** send and receive soap data** @param string outgoing post data* @param array options** @return string|fault response* @access public*/function &send(&$msg, $options = null){if (!$this->_validateUrl()) {return $this->fault;}if (isset($options['timeout']))$this->timeout = (int)$options['timeout'];if (strcasecmp($this->urlparts['scheme'], 'HTTP') == 0) {return $this->_sendHTTP($msg, $options);} else if (strcasecmp($this->urlparts['scheme'], 'HTTPS') == 0) {return $this->_sendHTTPS($msg, $options);}return $this->_raiseSoapFault('Invalid url scheme '.$this->url);}/*** set data for http authentication* creates Authorization header** @param string $username username* @param string $password response data, minus http headers** @return none* @access public*/function setCredentials($username, $password){$this->headers['Authorization'] = 'Basic ' . base64_encode($username . ':' . $password);}/*** Add a cookie** @access public* @param string $name cookie name* @param mixed $value cookie value* @return void*/function addCookie($name, $value){$this->cookies[$name]=$value;}// private methods/*** Generates the correct headers for the cookies** @access private* @return void*/function _genCookieHeader(){foreach ($this->cookies as $name=>$value) {$cookies = (isset($cookies) ? $cookies. '; ' : '') .urlencode($name) . '=' . urlencode($value);}return $cookies;}/*** validate url data passed to constructor** @access private* @return boolean*/function _validateUrl(){if ( ! is_array($this->urlparts) ) {$this->_raiseSoapFault("Unable to parse URL " . $this->url);return false;}if (!isset($this->urlparts['host'])) {$this->_raiseSoapFault("No host in URL " . $this->url);return false;}if (!isset($this->urlparts['port'])) {if (strcasecmp($this->urlparts['scheme'], 'HTTP') == 0)$this->urlparts['port'] = 80;else if (strcasecmp($this->urlparts['scheme'], 'HTTPS') == 0)$this->urlparts['port'] = 443;}if (isset($this->urlparts['user'])) {$this->setCredentials(urldecode($this->urlparts['user']),urldecode($this->urlparts['pass']));}if (!isset($this->urlparts['path']) || !$this->urlparts['path'])$this->urlparts['path'] = '/';return true;}/*** Finds out what is the encoding.** Sets the object property accordingly.** @access private* @param array $headers headers* @return void*/function _parseEncoding($headers){$h = stristr($headers, 'Content-Type');preg_match_all('/^Content-Type:\s*(.*)$/im', $h, $ct, PREG_SET_ORDER);$n = count($ct);$ct = $ct[$n - 1];$this->result_content_type = str_replace("\r", '', $ct[1]);if (preg_match('/(.*?)(?:;\s?charset=)(.*)/i', $this->result_content_type, $m)) {// strip the string of \r$this->result_content_type = $m[1];if (count($m) > 2) {$enc = strtoupper(str_replace('"', '', $m[2]));if (in_array($enc, $this->_encodings)) {$this->result_encoding = $enc;}}}// deal with broken servers that don't set content type on faultsif (!$this->result_content_type) $this->result_content_type = 'text/xml';}/*** Parses the headers** @param array $headers the headers* @return void*/function _parseHeaders($headers){/* largely borrowed from HTTP_Request */$this->result_headers = array();$headers = split("\r?\n", $headers);foreach ($headers as $value) {if (strpos($value,':') === false) {$this->result_headers[0]=$value;continue;}list($name,$value) = split(':',$value);$headername = strtolower($name);$headervalue = trim($value);$this->result_headers[$headername]=$headervalue;if ($headername == 'set-cookie') {// Parse a SetCookie header to fill _cookies array$cookie = array('expires' => null,'domain' => $this->urlparts['host'],'path' => null,'secure' => false);// Only a name=value pairif (!strpos($headervalue, ';')) {list($cookie['name'], $cookie['value']) = array_map('trim', explode('=', $headervalue));$cookie['name'] = urldecode($cookie['name']);$cookie['value'] = urldecode($cookie['value']);// Some optional parameters are supplied} else {$elements = explode(';', $headervalue);list($cookie['name'], $cookie['value']) = array_map('trim', explode('=', $elements[0]));$cookie['name'] = urldecode($cookie['name']);$cookie['value'] = urldecode($cookie['value']);for ($i = 1; $i < count($elements);$i++) {list ($elName, $elValue) = array_map('trim', explode('=', $elements[$i]));if ('secure' == $elName) {$cookie['secure'] = true;} elseif ('expires' == $elName) {$cookie['expires'] = str_replace('"', '', $elValue);} elseif ('path' == $elName OR 'domain' == $elName) {$cookie[$elName] = urldecode($elValue);} else {$cookie[$elName] = $elValue;}}}$this->result_cookies[] = $cookie;}}}/*** Remove http headers from response** @return boolean* @access private*/function _parseResponse(){if (preg_match("/^(.*?)\r?\n\r?\n(.*)/s", $this->incoming_payload, $match)) {#$this->response = preg_replace("/[\r|\n]/", '', $match[2]);// find the response error, some servers response with 500 for soap faults//Check if proxy headers are found//If found, ignore those headersif (preg_match("/^(.*?)\r?\n\r?\n(.*)/s", $match[2], $match1)){if($match1[2] != ''){$match[1] = $match1[1];$match[2] = $match1[2];}}$this->response =& $match[2];// find the response error, some servers response with 500 for soap faults$this->_parseHeaders($match[1]);list($protocol, $code, $msg) = sscanf($this->result_headers[0], '%s %s %s');unset($this->result_headers[0]);switch($code) {case 100: // Continue$this->incoming_payload = $match[2];return $this->_parseResponse();case 400:$this->_raiseSoapFault("HTTP Response $code Bad Request");return false;break;case 401:$this->_raiseSoapFault("HTTP Response $code Authentication Failed");return false;break;case 403:$this->_raiseSoapFault("HTTP Response $code Forbidden");return false;break;case 404:$this->_raiseSoapFault("HTTP Response $code Not Found");return false;break;case 407:$this->_raiseSoapFault("HTTP Response $code Proxy Authentication Required");return false;break;case 408:$this->_raiseSoapFault("HTTP Response $code Request Timeout");return false;break;case 410:$this->_raiseSoapFault("HTTP Response $code Gone");return false;break;default:if ($code >= 400 && $code < 500) {$this->_raiseSoapFault("HTTP Response $code Not Found, Server message: $msg");return false;}}$this->_parseEncoding($match[1]);if ($this->result_content_type == 'application/dime') {// XXX quick hack insertion of DIMEif (PEAR::isError($this->_decodeDIMEMessage($this->response,$this->headers,$this->attachments))) {// _decodeDIMEMessage already raised $this->faultreturn false;}$this->result_content_type = $this->headers['content-type'];} else if (stristr($this->result_content_type,'multipart/related')) {$this->response = $this->incoming_payload;if (PEAR::isError($this->_decodeMimeMessage($this->response,$this->headers,$this->attachments))) {// _decodeMimeMessage already raised $this->faultreturn false;}} else if ($this->result_content_type != 'text/xml') {$this->_raiseSoapFault($this->response);return false;}// if no content, return falsereturn strlen($this->response) > 0;}$this->_raiseSoapFault('Invalid HTTP Response');return false;}/*** Create http request, including headers, for outgoing request** @param string &$msg outgoing SOAP package* @param $options* @return string outgoing_payload* @access private*/function &_getRequest(&$msg, $options){$action = isset($options['soapaction'])?$options['soapaction']:'';$fullpath = $this->urlparts['path'].(isset($this->urlparts['query'])?'?'.$this->urlparts['query']:'').(isset($this->urlparts['fragment'])?'#'.$this->urlparts['fragment']:'');if (isset($options['proxy_host'])) {$fullpath = 'http://' . $this->urlparts['host'] . ':' . $this->urlparts['port'] . $fullpath;}if (isset($options['proxy_user'])) {$this->headers['Proxy-Authorization'] = 'Basic ' . base64_encode($options['proxy_user'].":".$options['proxy_pass']);}if (isset($options['user'])) {$this->setCredentials($options['user'], $options['pass']);}$this->headers['User-Agent'] = $this->_userAgent;$this->headers['Host'] = $this->urlparts['host'];$this->headers['Content-Type'] = "text/xml; charset=$this->encoding";$this->headers['Content-Length'] = strlen($msg);$this->headers['SOAPAction'] = "\"$action\"";if (isset($options['headers'])) {$this->headers = array_merge($this->headers, $options['headers']);}$this->cookies = array();if (!isset($options['nocookies']) || !$options['nocookies']) {// add the cookies we got from the last requestif (isset($this->result_cookies)) {foreach ($this->result_cookies as $cookie) {if ($cookie['domain'] == $this->urlparts['host'])$this->cookies[$cookie['name']]=$cookie['value'];}}}// add cookies the user wants to setif (isset($options['cookies'])) {foreach ($options['cookies'] as $cookie) {if ($cookie['domain'] == $this->urlparts['host'])$this->cookies[$cookie['name']]=$cookie['value'];}}if (count($this->cookies)) {$this->headers['Cookie'] = $this->_genCookieHeader();}$headers = '';foreach ($this->headers as $k => $v) {$headers .= "$k: $v\r\n";}$this->outgoing_payload ="POST $fullpath HTTP/1.0\r\n".$headers."\r\n".$msg;return $this->outgoing_payload;}/*** Send outgoing request, and read/parse response** @param string &$msg outgoing SOAP package* @param string $action SOAP Action* @return string &$response response data, minus http headers* @access private*/function &_sendHTTP(&$msg, $options){$this->incoming_payload = '';$this->_getRequest($msg, $options);$host = $this->urlparts['host'];$port = $this->urlparts['port'];if (isset($options['proxy_host'])) {$host = $options['proxy_host'];$port = isset($options['proxy_port']) ? $options['proxy_port'] : 8080;}// sendif ($this->timeout > 0) {$fp = @fsockopen($host, $port, $this->errno, $this->errmsg, $this->timeout);} else {$fp = @fsockopen($host, $port, $this->errno, $this->errmsg);}if (!$fp) {return $this->_raiseSoapFault("Connect Error to $host:$port");}if ($this->timeout > 0) {// some builds of php do not support this, silence// the warning@socket_set_timeout($fp, $this->timeout);}if (!fputs($fp, $this->outgoing_payload, strlen($this->outgoing_payload))) {return $this->_raiseSoapFault("Error POSTing Data to $host");}// get reponse// XXX time consumerdo {$data = fread($fp, 4096);$_tmp_status = socket_get_status($fp);if ($_tmp_status['timed_out']) {return $this->_raiseSoapFault("Timed out read from $host");} else {$this->incoming_payload .= $data;}} while (!$_tmp_status['eof']);fclose($fp);if (!$this->_parseResponse()) {return $this->fault;}return $this->response;}/*** Send outgoing request, and read/parse response, via HTTPS** @param string &$msg outgoing SOAP package* @param string $action SOAP Action* @return string &$response response data, minus http headers* @access private*/function &_sendHTTPS(&$msg, $options){/* NOTE This function uses the CURL functions* Your php must be compiled with CURL*///adding proxy supprt for HTTPS connections.//if USE_PROXY set to TRUE in SDKProxyProperties.php(php-sdk\lib\PayPal),//then only proxy is setted.if(USE_PROXY){$options['proxy_host'] = PROXY_HOST;$options['proxy_port']= PROXY_PORT;$options['proxy_user'] = PROXY_USER;$options['proxy_pass']= PROXY_PASSWORD;}if (!extension_loaded('curl')) {return $this->_raiseSoapFault('CURL Extension is required for HTTPS');}$ch = curl_init();if (isset($options['proxy_host'])) {// $options['http_proxy'] == 'hostname:port'$host = $options['proxy_host'];$port = isset($options['proxy_port']) ? $options['proxy_port'] : 8080;curl_setopt($ch, CURLOPT_PROXY, $host . ":" . $port);}if (isset($options['proxy_user'])) {// $options['http_proxy_userpw'] == 'username:password'curl_setopt($ch, CURLOPT_PROXYUSERPWD, $options['proxy_user'] . ':' . $options['proxy_pass']);}if (isset($options['user'])) {curl_setopt($ch, CURLOPT_USERPWD, $options['user'] . ':' . $options['pass']);}if (!isset($options['soapaction'])) {$options['soapaction'] = '';}curl_setopt($ch, CURLOPT_HTTPHEADER , array('Content-Type: text/xml;charset=' . $this->encoding, 'SOAPAction: "'.$options['soapaction'].'"'));curl_setopt($ch, CURLOPT_USERAGENT , $this->_userAgent);if ($this->timeout) {curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout); //times out after 4s}curl_setopt($ch, CURLOPT_POSTFIELDS, $msg);curl_setopt($ch, CURLOPT_URL, $this->url);curl_setopt($ch, CURLOPT_POST, 1);curl_setopt($ch, CURLOPT_FAILONERROR, 0);curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);curl_setopt($ch, CURLOPT_HEADER, 1);if (defined('CURLOPT_HTTP_VERSION')) {curl_setopt($ch, CURLOPT_HTTP_VERSION, 1);}if (isset($options['curl'])) {foreach ($options['curl'] as $key => $val) {curl_setopt($ch, $key, $val);}}// Save the outgoing XML. This doesn't quite match _sendHTTP// as CURL generates the headers, but having the XML is// usually the most important part for tracing/debugging.$this->outgoing_payload = $msg;$this->incoming_payload = curl_exec($ch);if (!$this->incoming_payload) {$m = 'curl_exec error ' . curl_errno($ch) . ' ' . curl_error($ch);curl_close($ch);return $this->_raiseSoapFault($m);}curl_close($ch);if (!$this->_parseResponse()) {return $this->fault;}return $this->response;}}