1<?php 2 3 4 5 6/** 7* transport class for sending/receiving data via HTTP and HTTPS 8* NOTE: PHP must be compiled with the CURL extension for HTTPS support 9* 10* @author Dietrich Ayala <dietrich@ganx4.com> 11* @author Scott Nichol <snichol@users.sourceforge.net> 12* @version $Id: class.soap_transport_http.php,v 1.66 2007/11/06 14:17:53 snichol Exp $ 13* @access public 14*/ 15class soap_transport_http extends nusoap_base { 16 17 var $url = ''; 18 var $uri = ''; 19 var $digest_uri = ''; 20 var $scheme = ''; 21 var $host = ''; 22 var $port = ''; 23 var $path = ''; 24 var $request_method = 'POST'; 25 var $protocol_version = '1.0'; 26 var $encoding = ''; 27 var $outgoing_headers = array(); 28 var $incoming_headers = array(); 29 var $incoming_cookies = array(); 30 var $outgoing_payload = ''; 31 var $incoming_payload = ''; 32 var $response_status_line; // HTTP response status line 33 var $useSOAPAction = true; 34 var $persistentConnection = false; 35 var $ch = false; // cURL handle 36 var $ch_options = array(); // cURL custom options 37 var $use_curl = false; // force cURL use 38 var $proxy = null; // proxy information (associative array) 39 var $username = ''; 40 var $password = ''; 41 var $authtype = ''; 42 var $digestRequest = array(); 43 var $certRequest = array(); // keys must be cainfofile (optional), sslcertfile, sslkeyfile, passphrase, certpassword (optional), verifypeer (optional), verifyhost (optional) 44 // cainfofile: certificate authority file, e.g. '$pathToPemFiles/rootca.pem' 45 // sslcertfile: SSL certificate file, e.g. '$pathToPemFiles/mycert.pem' 46 // sslkeyfile: SSL key file, e.g. '$pathToPemFiles/mykey.pem' 47 // passphrase: SSL key password/passphrase 48 // certpassword: SSL certificate password 49 // verifypeer: default is 1 50 // verifyhost: default is 1 51 52 /** 53 * constructor 54 * 55 * @param string $url The URL to which to connect 56 * @param array $curl_options User-specified cURL options 57 * @param boolean $use_curl Whether to try to force cURL use 58 * @access public 59 */ 60 function soap_transport_http($url, $curl_options = NULL, $use_curl = false){ 61 parent::nusoap_base(); 62 $this->debug("ctor url=$url use_curl=$use_curl curl_options:"); 63 $this->appendDebug($this->varDump($curl_options)); 64 $this->setURL($url); 65 if (is_array($curl_options)) { 66 $this->ch_options = $curl_options; 67 } 68 $this->use_curl = $use_curl; 69 ereg('\$Revisio' . 'n: ([^ ]+)', $this->revision, $rev); 70 $this->setHeader('User-Agent', $this->title.'/'.$this->version.' ('.$rev[1].')'); 71 } 72 73 /** 74 * sets a cURL option 75 * 76 * @param mixed $option The cURL option (always integer?) 77 * @param mixed $value The cURL option value 78 * @access private 79 */ 80 function setCurlOption($option, $value) { 81 $this->debug("setCurlOption option=$option, value="); 82 $this->appendDebug($this->varDump($value)); 83 curl_setopt($this->ch, $option, $value); 84 } 85 86 /** 87 * sets an HTTP header 88 * 89 * @param string $name The name of the header 90 * @param string $value The value of the header 91 * @access private 92 */ 93 function setHeader($name, $value) { 94 $this->outgoing_headers[$name] = $value; 95 $this->debug("set header $name: $value"); 96 } 97 98 /** 99 * unsets an HTTP header 100 * 101 * @param string $name The name of the header 102 * @access private 103 */ 104 function unsetHeader($name) { 105 if (isset($this->outgoing_headers[$name])) { 106 $this->debug("unset header $name"); 107 unset($this->outgoing_headers[$name]); 108 } 109 } 110 111 /** 112 * sets the URL to which to connect 113 * 114 * @param string $url The URL to which to connect 115 * @access private 116 */ 117 function setURL($url) { 118 $this->url = $url; 119 120 $u = parse_url($url); 121 foreach($u as $k => $v){ 122 $this->debug("parsed URL $k = $v"); 123 $this->$k = $v; 124 } 125 126 // add any GET params to path 127 if(isset($u['query']) && $u['query'] != ''){ 128 $this->path .= '?' . $u['query']; 129 } 130 131 // set default port 132 if(!isset($u['port'])){ 133 if($u['scheme'] == 'https'){ 134 $this->port = 443; 135 } else { 136 $this->port = 80; 137 } 138 } 139 140 $this->uri = $this->path; 141 $this->digest_uri = $this->uri; 142 143 // build headers 144 if (!isset($u['port'])) { 145 $this->setHeader('Host', $this->host); 146 } else { 147 $this->setHeader('Host', $this->host.':'.$this->port); 148 } 149 150 if (isset($u['user']) && $u['user'] != '') { 151 $this->setCredentials(urldecode($u['user']), isset($u['pass']) ? urldecode($u['pass']) : ''); 152 } 153 } 154 155 /** 156 * gets the I/O method to use 157 * 158 * @return string I/O method to use (socket|curl|unknown) 159 * @access private 160 */ 161 function io_method() { 162 if ($this->use_curl || ($this->scheme == 'https') || ($this->scheme == 'http' && $this->authtype == 'ntlm') || ($this->scheme == 'http' && is_array($this->proxy) && $this->proxy['authtype'] == 'ntlm')) 163 return 'curl'; 164 if (($this->scheme == 'http' || $this->scheme == 'ssl') && $this->authtype != 'ntlm' && (!is_array($this->proxy) || $this->proxy['authtype'] != 'ntlm')) 165 return 'socket'; 166 return 'unknown'; 167 } 168 169 /** 170 * establish an HTTP connection 171 * 172 * @param integer $timeout set connection timeout in seconds 173 * @param integer $response_timeout set response timeout in seconds 174 * @return boolean true if connected, false if not 175 * @access private 176 */ 177 function connect($connection_timeout=0,$response_timeout=30){ 178 // For PHP 4.3 with OpenSSL, change https scheme to ssl, then treat like 179 // "regular" socket. 180 // TODO: disabled for now because OpenSSL must be *compiled* in (not just 181 // loaded), and until PHP5 stream_get_wrappers is not available. 182// if ($this->scheme == 'https') { 183// if (version_compare(phpversion(), '4.3.0') >= 0) { 184// if (extension_loaded('openssl')) { 185// $this->scheme = 'ssl'; 186// $this->debug('Using SSL over OpenSSL'); 187// } 188// } 189// } 190 $this->debug("connect connection_timeout $connection_timeout, response_timeout $response_timeout, scheme $this->scheme, host $this->host, port $this->port"); 191 if ($this->io_method() == 'socket') { 192 if (!is_array($this->proxy)) { 193 $host = $this->host; 194 $port = $this->port; 195 } else { 196 $host = $this->proxy['host']; 197 $port = $this->proxy['port']; 198 } 199 200 // use persistent connection 201 if($this->persistentConnection && isset($this->fp) && is_resource($this->fp)){ 202 if (!feof($this->fp)) { 203 $this->debug('Re-use persistent connection'); 204 return true; 205 } 206 fclose($this->fp); 207 $this->debug('Closed persistent connection at EOF'); 208 } 209 210 // munge host if using OpenSSL 211 if ($this->scheme == 'ssl') { 212 $host = 'ssl://' . $host; 213 } 214 $this->debug('calling fsockopen with host ' . $host . ' connection_timeout ' . $connection_timeout); 215 216 // open socket 217 if($connection_timeout > 0){ 218 $this->fp = @fsockopen( $host, $this->port, $this->errno, $this->error_str, $connection_timeout); 219 } else { 220 $this->fp = @fsockopen( $host, $this->port, $this->errno, $this->error_str); 221 } 222 223 // test pointer 224 if(!$this->fp) { 225 $msg = 'Couldn\'t open socket connection to server ' . $this->url; 226 if ($this->errno) { 227 $msg .= ', Error ('.$this->errno.'): '.$this->error_str; 228 } else { 229 $msg .= ' prior to connect(). This is often a problem looking up the host name.'; 230 } 231 $this->debug($msg); 232 $this->setError($msg); 233 return false; 234 } 235 236 // set response timeout 237 $this->debug('set response timeout to ' . $response_timeout); 238 socket_set_timeout( $this->fp, $response_timeout); 239 240 $this->debug('socket connected'); 241 return true; 242 } else if ($this->io_method() == 'curl') { 243 if (!extension_loaded('curl')) { 244// $this->setError('cURL Extension, or OpenSSL extension w/ PHP version >= 4.3 is required for HTTPS'); 245 $this->setError('The PHP cURL Extension is required for HTTPS or NLTM. You will need to re-build or update your PHP to included cURL.'); 246 return false; 247 } 248 // Avoid warnings when PHP does not have these options 249 if (defined('CURLOPT_CONNECTIONTIMEOUT')) 250 $CURLOPT_CONNECTIONTIMEOUT = CURLOPT_CONNECTIONTIMEOUT; 251 else 252 $CURLOPT_CONNECTIONTIMEOUT = 78; 253 if (defined('CURLOPT_HTTPAUTH')) 254 $CURLOPT_HTTPAUTH = CURLOPT_HTTPAUTH; 255 else 256 $CURLOPT_HTTPAUTH = 107; 257 if (defined('CURLOPT_PROXYAUTH')) 258 $CURLOPT_PROXYAUTH = CURLOPT_PROXYAUTH; 259 else 260 $CURLOPT_PROXYAUTH = 111; 261 if (defined('CURLAUTH_BASIC')) 262 $CURLAUTH_BASIC = CURLAUTH_BASIC; 263 else 264 $CURLAUTH_BASIC = 1; 265 if (defined('CURLAUTH_DIGEST')) 266 $CURLAUTH_DIGEST = CURLAUTH_DIGEST; 267 else 268 $CURLAUTH_DIGEST = 2; 269 if (defined('CURLAUTH_NTLM')) 270 $CURLAUTH_NTLM = CURLAUTH_NTLM; 271 else 272 $CURLAUTH_NTLM = 8; 273 274 $this->debug('connect using cURL'); 275 // init CURL 276 $this->ch = curl_init(); 277 // set url 278 $hostURL = ($this->port != '') ? "$this->scheme://$this->host:$this->port" : "$this->scheme://$this->host"; 279 // add path 280 $hostURL .= $this->path; 281 $this->setCurlOption(CURLOPT_URL, $hostURL); 282 // follow location headers (re-directs) 283 if (ini_get('safe_mode') || ini_get('open_basedir')) { 284 $this->debug('safe_mode or open_basedir set, so do not set CURLOPT_FOLLOWLOCATION'); 285 $this->debug('safe_mode = '); 286 $this->appendDebug($this->varDump(ini_get('safe_mode'))); 287 $this->debug('open_basedir = '); 288 $this->appendDebug($this->varDump(ini_get('open_basedir'))); 289 } else { 290 $this->setCurlOption(CURLOPT_FOLLOWLOCATION, 1); 291 } 292 // ask for headers in the response output 293 $this->setCurlOption(CURLOPT_HEADER, 1); 294 // ask for the response output as the return value 295 $this->setCurlOption(CURLOPT_RETURNTRANSFER, 1); 296 // encode 297 // We manage this ourselves through headers and encoding 298// if(function_exists('gzuncompress')){ 299// $this->setCurlOption(CURLOPT_ENCODING, 'deflate'); 300// } 301 // persistent connection 302 if ($this->persistentConnection) { 303 // I believe the following comment is now bogus, having applied to 304 // the code when it used CURLOPT_CUSTOMREQUEST to send the request. 305 // The way we send data, we cannot use persistent connections, since 306 // there will be some "junk" at the end of our request. 307 //$this->setCurlOption(CURL_HTTP_VERSION_1_1, true); 308 $this->persistentConnection = false; 309 $this->setHeader('Connection', 'close'); 310 } 311 // set timeouts 312 if ($connection_timeout != 0) { 313 $this->setCurlOption($CURLOPT_CONNECTIONTIMEOUT, $connection_timeout); 314 } 315 if ($response_timeout != 0) { 316 $this->setCurlOption(CURLOPT_TIMEOUT, $response_timeout); 317 } 318 319 if ($this->scheme == 'https') { 320 $this->debug('set cURL SSL verify options'); 321 // recent versions of cURL turn on peer/host checking by default, 322 // while PHP binaries are not compiled with a default location for the 323 // CA cert bundle, so disable peer/host checking. 324 //$this->setCurlOption(CURLOPT_CAINFO, 'f:\php-4.3.2-win32\extensions\curl-ca-bundle.crt'); 325 $this->setCurlOption(CURLOPT_SSL_VERIFYPEER, 0); 326 $this->setCurlOption(CURLOPT_SSL_VERIFYHOST, 0); 327 328 // support client certificates (thanks Tobias Boes, Doug Anarino, Eryan Ariobowo) 329 if ($this->authtype == 'certificate') { 330 $this->debug('set cURL certificate options'); 331 if (isset($this->certRequest['cainfofile'])) { 332 $this->setCurlOption(CURLOPT_CAINFO, $this->certRequest['cainfofile']); 333 } 334 if (isset($this->certRequest['verifypeer'])) { 335 $this->setCurlOption(CURLOPT_SSL_VERIFYPEER, $this->certRequest['verifypeer']); 336 } else { 337 $this->setCurlOption(CURLOPT_SSL_VERIFYPEER, 1); 338 } 339 if (isset($this->certRequest['verifyhost'])) { 340 $this->setCurlOption(CURLOPT_SSL_VERIFYHOST, $this->certRequest['verifyhost']); 341 } else { 342 $this->setCurlOption(CURLOPT_SSL_VERIFYHOST, 1); 343 } 344 if (isset($this->certRequest['sslcertfile'])) { 345 $this->setCurlOption(CURLOPT_SSLCERT, $this->certRequest['sslcertfile']); 346 } 347 if (isset($this->certRequest['sslkeyfile'])) { 348 $this->setCurlOption(CURLOPT_SSLKEY, $this->certRequest['sslkeyfile']); 349 } 350 if (isset($this->certRequest['passphrase'])) { 351 $this->setCurlOption(CURLOPT_SSLKEYPASSWD, $this->certRequest['passphrase']); 352 } 353 if (isset($this->certRequest['certpassword'])) { 354 $this->setCurlOption(CURLOPT_SSLCERTPASSWD, $this->certRequest['certpassword']); 355 } 356 } 357 } 358 if ($this->authtype && ($this->authtype != 'certificate')) { 359 if ($this->username) { 360 $this->debug('set cURL username/password'); 361 $this->setCurlOption(CURLOPT_USERPWD, "$this->username:$this->password"); 362 } 363 if ($this->authtype == 'basic') { 364 $this->debug('set cURL for Basic authentication'); 365 $this->setCurlOption($CURLOPT_HTTPAUTH, $CURLAUTH_BASIC); 366 } 367 if ($this->authtype == 'digest') { 368 $this->debug('set cURL for digest authentication'); 369 $this->setCurlOption($CURLOPT_HTTPAUTH, $CURLAUTH_DIGEST); 370 } 371 if ($this->authtype == 'ntlm') { 372 $this->debug('set cURL for NTLM authentication'); 373 $this->setCurlOption($CURLOPT_HTTPAUTH, $CURLAUTH_NTLM); 374 } 375 } 376 if (is_array($this->proxy)) { 377 $this->debug('set cURL proxy options'); 378 if ($this->proxy['port'] != '') { 379 $this->setCurlOption(CURLOPT_PROXY, $this->proxy['host'].':'.$this->proxy['port']); 380 } else { 381 $this->setCurlOption(CURLOPT_PROXY, $this->proxy['host']); 382 } 383 if ($this->proxy['username'] || $this->proxy['password']) { 384 $this->debug('set cURL proxy authentication options'); 385 $this->setCurlOption(CURLOPT_PROXYUSERPWD, $this->proxy['username'].':'.$this->proxy['password']); 386 if ($this->proxy['authtype'] == 'basic') { 387 $this->setCurlOption($CURLOPT_PROXYAUTH, $CURLAUTH_BASIC); 388 } 389 if ($this->proxy['authtype'] == 'ntlm') { 390 $this->setCurlOption($CURLOPT_PROXYAUTH, $CURLAUTH_NTLM); 391 } 392 } 393 } 394 $this->debug('cURL connection set up'); 395 return true; 396 } else { 397 $this->setError('Unknown scheme ' . $this->scheme); 398 $this->debug('Unknown scheme ' . $this->scheme); 399 return false; 400 } 401 } 402 403 /** 404 * sends the SOAP request and gets the SOAP response via HTTP[S] 405 * 406 * @param string $data message data 407 * @param integer $timeout set connection timeout in seconds 408 * @param integer $response_timeout set response timeout in seconds 409 * @param array $cookies cookies to send 410 * @return string data 411 * @access public 412 */ 413 function send($data, $timeout=0, $response_timeout=30, $cookies=NULL) { 414 415 $this->debug('entered send() with data of length: '.strlen($data)); 416 417 $this->tryagain = true; 418 $tries = 0; 419 while ($this->tryagain) { 420 $this->tryagain = false; 421 if ($tries++ < 2) { 422 // make connnection 423 if (!$this->connect($timeout, $response_timeout)){ 424 return false; 425 } 426 427 // send request 428 if (!$this->sendRequest($data, $cookies)){ 429 return false; 430 } 431 432 // get response 433 $respdata = $this->getResponse(); 434 } else { 435 $this->setError("Too many tries to get an OK response ($this->response_status_line)"); 436 } 437 } 438 $this->debug('end of send()'); 439 return $respdata; 440 } 441 442 443 /** 444 * sends the SOAP request and gets the SOAP response via HTTPS using CURL 445 * 446 * @param string $data message data 447 * @param integer $timeout set connection timeout in seconds 448 * @param integer $response_timeout set response timeout in seconds 449 * @param array $cookies cookies to send 450 * @return string data 451 * @access public 452 * @deprecated 453 */ 454 function sendHTTPS($data, $timeout=0, $response_timeout=30, $cookies) { 455 return $this->send($data, $timeout, $response_timeout, $cookies); 456 } 457 458 /** 459 * if authenticating, set user credentials here 460 * 461 * @param string $username 462 * @param string $password 463 * @param string $authtype (basic|digest|certificate|ntlm) 464 * @param array $digestRequest (keys must be nonce, nc, realm, qop) 465 * @param array $certRequest (keys must be cainfofile (optional), sslcertfile, sslkeyfile, passphrase, certpassword (optional), verifypeer (optional), verifyhost (optional): see corresponding options in cURL docs) 466 * @access public 467 */ 468 function setCredentials($username, $password, $authtype = 'basic', $digestRequest = array(), $certRequest = array()) { 469 $this->debug("setCredentials username=$username authtype=$authtype digestRequest="); 470 $this->appendDebug($this->varDump($digestRequest)); 471 $this->debug("certRequest="); 472 $this->appendDebug($this->varDump($certRequest)); 473 // cf. RFC 2617 474 if ($authtype == 'basic') { 475 $this->setHeader('Authorization', 'Basic '.base64_encode(str_replace(':','',$username).':'.$password)); 476 } elseif ($authtype == 'digest') { 477 if (isset($digestRequest['nonce'])) { 478 $digestRequest['nc'] = isset($digestRequest['nc']) ? $digestRequest['nc']++ : 1; 479 480 // calculate the Digest hashes (calculate code based on digest implementation found at: http://www.rassoc.com/gregr/weblog/stories/2002/07/09/webServicesSecurityHttpDigestAuthenticationWithoutActiveDirectory.html) 481 482 // A1 = unq(username-value) ":" unq(realm-value) ":" passwd 483 $A1 = $username. ':' . (isset($digestRequest['realm']) ? $digestRequest['realm'] : '') . ':' . $password; 484 485 // H(A1) = MD5(A1) 486 $HA1 = md5($A1); 487 488 // A2 = Method ":" digest-uri-value 489 $A2 = $this->request_method . ':' . $this->digest_uri; 490 491 // H(A2) 492 $HA2 = md5($A2); 493 494 // KD(secret, data) = H(concat(secret, ":", data)) 495 // if qop == auth: 496 // request-digest = <"> < KD ( H(A1), unq(nonce-value) 497 // ":" nc-value 498 // ":" unq(cnonce-value) 499 // ":" unq(qop-value) 500 // ":" H(A2) 501 // ) <"> 502 // if qop is missing, 503 // request-digest = <"> < KD ( H(A1), unq(nonce-value) ":" H(A2) ) > <"> 504 505 $unhashedDigest = ''; 506 $nonce = isset($digestRequest['nonce']) ? $digestRequest['nonce'] : ''; 507 $cnonce = $nonce; 508 if ($digestRequest['qop'] != '') { 509 $unhashedDigest = $HA1 . ':' . $nonce . ':' . sprintf("%08d", $digestRequest['nc']) . ':' . $cnonce . ':' . $digestRequest['qop'] . ':' . $HA2; 510 } else { 511 $unhashedDigest = $HA1 . ':' . $nonce . ':' . $HA2; 512 } 513 514 $hashedDigest = md5($unhashedDigest); 515 516 $opaque = ''; 517 if (isset($digestRequest['opaque'])) { 518 $opaque = ', opaque="' . $digestRequest['opaque'] . '"'; 519 } 520 521 $this->setHeader('Authorization', 'Digest username="' . $username . '", realm="' . $digestRequest['realm'] . '", nonce="' . $nonce . '", uri="' . $this->digest_uri . $opaque . '", cnonce="' . $cnonce . '", nc=' . sprintf("%08x", $digestRequest['nc']) . ', qop="' . $digestRequest['qop'] . '", response="' . $hashedDigest . '"'); 522 } 523 } elseif ($authtype == 'certificate') { 524 $this->certRequest = $certRequest; 525 $this->debug('Authorization header not set for certificate'); 526 } elseif ($authtype == 'ntlm') { 527 // do nothing 528 $this->debug('Authorization header not set for ntlm'); 529 } 530 $this->username = $username; 531 $this->password = $password; 532 $this->authtype = $authtype; 533 $this->digestRequest = $digestRequest; 534 } 535 536 /** 537 * set the soapaction value 538 * 539 * @param string $soapaction 540 * @access public 541 */ 542 function setSOAPAction($soapaction) { 543 $this->setHeader('SOAPAction', '"' . $soapaction . '"'); 544 } 545 546 /** 547 * use http encoding 548 * 549 * @param string $enc encoding style. supported values: gzip, deflate, or both 550 * @access public 551 */ 552 function setEncoding($enc='gzip, deflate') { 553 if (function_exists('gzdeflate')) { 554 $this->protocol_version = '1.1'; 555 $this->setHeader('Accept-Encoding', $enc); 556 if (!isset($this->outgoing_headers['Connection'])) { 557 $this->setHeader('Connection', 'close'); 558 $this->persistentConnection = false; 559 } 560 set_magic_quotes_runtime(0); 561 // deprecated 562 $this->encoding = $enc; 563 } 564 } 565 566 /** 567 * set proxy info here 568 * 569 * @param string $proxyhost use an empty string to remove proxy 570 * @param string $proxyport 571 * @param string $proxyusername 572 * @param string $proxypassword 573 * @param string $proxyauthtype (basic|ntlm) 574 * @access public 575 */ 576 function setProxy($proxyhost, $proxyport, $proxyusername = '', $proxypassword = '', $proxyauthtype = 'basic') { 577 if ($proxyhost) { 578 $this->proxy = array( 579 'host' => $proxyhost, 580 'port' => $proxyport, 581 'username' => $proxyusername, 582 'password' => $proxypassword, 583 'authtype' => $proxyauthtype 584 ); 585 if ($proxyusername != '' && $proxypassword != '' && $proxyauthtype = 'basic') { 586 $this->setHeader('Proxy-Authorization', ' Basic '.base64_encode($proxyusername.':'.$proxypassword)); 587 } 588 } else { 589 $this->debug('remove proxy'); 590 $proxy = null; 591 unsetHeader('Proxy-Authorization'); 592 } 593 } 594 595 596 /** 597 * Test if the given string starts with a header that is to be skipped. 598 * Skippable headers result from chunked transfer and proxy requests. 599 * 600 * @param string $data The string to check. 601 * @returns boolean Whether a skippable header was found. 602 * @access private 603 */ 604 function isSkippableCurlHeader(&$data) { 605 $skipHeaders = array( 'HTTP/1.1 100', 606 'HTTP/1.0 301', 607 'HTTP/1.1 301', 608 'HTTP/1.0 302', 609 'HTTP/1.1 302', 610 'HTTP/1.0 401', 611 'HTTP/1.1 401', 612 'HTTP/1.0 200 Connection established'); 613 foreach ($skipHeaders as $hd) { 614 $prefix = substr($data, 0, strlen($hd)); 615 if ($prefix == $hd) return true; 616 } 617 618 return false; 619 } 620 621 /** 622 * decode a string that is encoded w/ "chunked' transfer encoding 623 * as defined in RFC2068 19.4.6 624 * 625 * @param string $buffer 626 * @param string $lb 627 * @returns string 628 * @access public 629 * @deprecated 630 */ 631 function decodeChunked($buffer, $lb){ 632 // length := 0 633 $length = 0; 634 $new = ''; 635 636 // read chunk-size, chunk-extension (if any) and CRLF 637 // get the position of the linebreak 638 $chunkend = strpos($buffer, $lb); 639 if ($chunkend == FALSE) { 640 $this->debug('no linebreak found in decodeChunked'); 641 return $new; 642 } 643 $temp = substr($buffer,0,$chunkend); 644 $chunk_size = hexdec( trim($temp) ); 645 $chunkstart = $chunkend + strlen($lb); 646 // while (chunk-size > 0) { 647 while ($chunk_size > 0) { 648 $this->debug("chunkstart: $chunkstart chunk_size: $chunk_size"); 649 $chunkend = strpos( $buffer, $lb, $chunkstart + $chunk_size); 650 651 // Just in case we got a broken connection 652 if ($chunkend == FALSE) { 653 $chunk = substr($buffer,$chunkstart); 654 // append chunk-data to entity-body 655 $new .= $chunk; 656 $length += strlen($chunk); 657 break; 658 } 659 660 // read chunk-data and CRLF 661 $chunk = substr($buffer,$chunkstart,$chunkend-$chunkstart); 662 // append chunk-data to entity-body 663 $new .= $chunk; 664 // length := length + chunk-size 665 $length += strlen($chunk); 666 // read chunk-size and CRLF 667 $chunkstart = $chunkend + strlen($lb); 668 669 $chunkend = strpos($buffer, $lb, $chunkstart) + strlen($lb); 670 if ($chunkend == FALSE) { 671 break; //Just in case we got a broken connection 672 } 673 $temp = substr($buffer,$chunkstart,$chunkend-$chunkstart); 674 $chunk_size = hexdec( trim($temp) ); 675 $chunkstart = $chunkend; 676 } 677 return $new; 678 } 679 680 /** 681 * Writes the payload, including HTTP headers, to $this->outgoing_payload. 682 * 683 * @param string $data HTTP body 684 * @param string $cookie_str data for HTTP Cookie header 685 * @return void 686 * @access private 687 */ 688 function buildPayload($data, $cookie_str = '') { 689 // Note: for cURL connections, $this->outgoing_payload is ignored, 690 // as is the Content-Length header, but these are still created as 691 // debugging guides. 692 693 // add content-length header 694 $this->setHeader('Content-Length', strlen($data)); 695 696 // start building outgoing payload: 697 if ($this->proxy) { 698 $uri = $this->url; 699 } else { 700 $uri = $this->uri; 701 } 702 $req = "$this->request_method $uri HTTP/$this->protocol_version"; 703 $this->debug("HTTP request: $req"); 704 $this->outgoing_payload = "$req\r\n"; 705 706 // loop thru headers, serializing 707 foreach($this->outgoing_headers as $k => $v){ 708 $hdr = $k.': '.$v; 709 $this->debug("HTTP header: $hdr"); 710 $this->outgoing_payload .= "$hdr\r\n"; 711 } 712 713 // add any cookies 714 if ($cookie_str != '') { 715 $hdr = 'Cookie: '.$cookie_str; 716 $this->debug("HTTP header: $hdr"); 717 $this->outgoing_payload .= "$hdr\r\n"; 718 } 719 720 // header/body separator 721 $this->outgoing_payload .= "\r\n"; 722 723 // add data 724 $this->outgoing_payload .= $data; 725 } 726 727 /** 728 * sends the SOAP request via HTTP[S] 729 * 730 * @param string $data message data 731 * @param array $cookies cookies to send 732 * @return boolean true if OK, false if problem 733 * @access private 734 */ 735 function sendRequest($data, $cookies = NULL) { 736 // build cookie string 737 $cookie_str = $this->getCookiesForRequest($cookies, (($this->scheme == 'ssl') || ($this->scheme == 'https'))); 738 739 // build payload 740 $this->buildPayload($data, $cookie_str); 741 742 if ($this->io_method() == 'socket') { 743 // send payload 744 if(!fputs($this->fp, $this->outgoing_payload, strlen($this->outgoing_payload))) { 745 $this->setError('couldn\'t write message data to socket'); 746 $this->debug('couldn\'t write message data to socket'); 747 return false; 748 } 749 $this->debug('wrote data to socket, length = ' . strlen($this->outgoing_payload)); 750 return true; 751 } else if ($this->io_method() == 'curl') { 752 // set payload 753 // cURL does say this should only be the verb, and in fact it 754 // turns out that the URI and HTTP version are appended to this, which 755 // some servers refuse to work with (so we no longer use this method!) 756 //$this->setCurlOption(CURLOPT_CUSTOMREQUEST, $this->outgoing_payload); 757 $curl_headers = array(); 758 foreach($this->outgoing_headers as $k => $v){ 759 if ($k == 'Connection' || $k == 'Content-Length' || $k == 'Host' || $k == 'Authorization' || $k == 'Proxy-Authorization') { 760 $this->debug("Skip cURL header $k: $v"); 761 } else { 762 $curl_headers[] = "$k: $v"; 763 } 764 } 765 if ($cookie_str != '') { 766 $curl_headers[] = 'Cookie: ' . $cookie_str; 767 } 768 $this->setCurlOption(CURLOPT_HTTPHEADER, $curl_headers); 769 $this->debug('set cURL HTTP headers'); 770 if ($this->request_method == "POST") { 771 $this->setCurlOption(CURLOPT_POST, 1); 772 $this->setCurlOption(CURLOPT_POSTFIELDS, $data); 773 $this->debug('set cURL POST data'); 774 } else { 775 } 776 // insert custom user-set cURL options 777 foreach ($this->ch_options as $key => $val) { 778 $this->setCurlOption($key, $val); 779 } 780 781 $this->debug('set cURL payload'); 782 return true; 783 } 784 } 785 786 /** 787 * gets the SOAP response via HTTP[S] 788 * 789 * @return string the response (also sets member variables like incoming_payload) 790 * @access private 791 */ 792 function getResponse(){ 793 $this->incoming_payload = ''; 794 795 if ($this->io_method() == 'socket') { 796 // loop until headers have been retrieved 797 $data = ''; 798 while (!isset($lb)){ 799 800 // We might EOF during header read. 801 if(feof($this->fp)) { 802 $this->incoming_payload = $data; 803 $this->debug('found no headers before EOF after length ' . strlen($data)); 804 $this->debug("received before EOF:\n" . $data); 805 $this->setError('server failed to send headers'); 806 return false; 807 } 808 809 $tmp = fgets($this->fp, 256); 810 $tmplen = strlen($tmp); 811 $this->debug("read line of $tmplen bytes: " . trim($tmp)); 812 813 if ($tmplen == 0) { 814 $this->incoming_payload = $data; 815 $this->debug('socket read of headers timed out after length ' . strlen($data)); 816 $this->debug("read before timeout: " . $data); 817 $this->setError('socket read of headers timed out'); 818 return false; 819 } 820 821 $data .= $tmp; 822 $pos = strpos($data,"\r\n\r\n"); 823 if($pos > 1){ 824 $lb = "\r\n"; 825 } else { 826 $pos = strpos($data,"\n\n"); 827 if($pos > 1){ 828 $lb = "\n"; 829 } 830 } 831 // remove 100 headers 832 if (isset($lb) && ereg('^HTTP/1.1 100',$data)) { 833 unset($lb); 834 $data = ''; 835 }// 836 } 837 // store header data 838 $this->incoming_payload .= $data; 839 $this->debug('found end of headers after length ' . strlen($data)); 840 // process headers 841 $header_data = trim(substr($data,0,$pos)); 842 $header_array = explode($lb,$header_data); 843 $this->incoming_headers = array(); 844 $this->incoming_cookies = array(); 845 foreach($header_array as $header_line){ 846 $arr = explode(':',$header_line, 2); 847 if(count($arr) > 1){ 848 $header_name = strtolower(trim($arr[0])); 849 $this->incoming_headers[$header_name] = trim($arr[1]); 850 if ($header_name == 'set-cookie') { 851 // TODO: allow multiple cookies from parseCookie 852 $cookie = $this->parseCookie(trim($arr[1])); 853 if ($cookie) { 854 $this->incoming_cookies[] = $cookie; 855 $this->debug('found cookie: ' . $cookie['name'] . ' = ' . $cookie['value']); 856 } else { 857 $this->debug('did not find cookie in ' . trim($arr[1])); 858 } 859 } 860 } else if (isset($header_name)) { 861 // append continuation line to previous header 862 $this->incoming_headers[$header_name] .= $lb . ' ' . $header_line; 863 } 864 } 865 866 // loop until msg has been received 867 if (isset($this->incoming_headers['transfer-encoding']) && strtolower($this->incoming_headers['transfer-encoding']) == 'chunked') { 868 $content_length = 2147483647; // ignore any content-length header 869 $chunked = true; 870 $this->debug("want to read chunked content"); 871 } elseif (isset($this->incoming_headers['content-length'])) { 872 $content_length = $this->incoming_headers['content-length']; 873 $chunked = false; 874 $this->debug("want to read content of length $content_length"); 875 } else { 876 $content_length = 2147483647; 877 $chunked = false; 878 $this->debug("want to read content to EOF"); 879 } 880 $data = ''; 881 do { 882 if ($chunked) { 883 $tmp = fgets($this->fp, 256); 884 $tmplen = strlen($tmp); 885 $this->debug("read chunk line of $tmplen bytes"); 886 if ($tmplen == 0) { 887 $this->incoming_payload = $data; 888 $this->debug('socket read of chunk length timed out after length ' . strlen($data)); 889 $this->debug("read before timeout:\n" . $data); 890 $this->setError('socket read of chunk length timed out'); 891 return false; 892 } 893 $content_length = hexdec(trim($tmp)); 894 $this->debug("chunk length $content_length"); 895 } 896 $strlen = 0; 897 while (($strlen < $content_length) && (!feof($this->fp))) { 898 $readlen = min(8192, $content_length - $strlen); 899 $tmp = fread($this->fp, $readlen); 900 $tmplen = strlen($tmp); 901 $this->debug("read buffer of $tmplen bytes"); 902 if (($tmplen == 0) && (!feof($this->fp))) { 903 $this->incoming_payload = $data; 904 $this->debug('socket read of body timed out after length ' . strlen($data)); 905 $this->debug("read before timeout:\n" . $data); 906 $this->setError('socket read of body timed out'); 907 return false; 908 } 909 $strlen += $tmplen; 910 $data .= $tmp; 911 } 912 if ($chunked && ($content_length > 0)) { 913 $tmp = fgets($this->fp, 256); 914 $tmplen = strlen($tmp); 915 $this->debug("read chunk terminator of $tmplen bytes"); 916 if ($tmplen == 0) { 917 $this->incoming_payload = $data; 918 $this->debug('socket read of chunk terminator timed out after length ' . strlen($data)); 919 $this->debug("read before timeout:\n" . $data); 920 $this->setError('socket read of chunk terminator timed out'); 921 return false; 922 } 923 } 924 } while ($chunked && ($content_length > 0) && (!feof($this->fp))); 925 if (feof($this->fp)) { 926 $this->debug('read to EOF'); 927 } 928 $this->debug('read body of length ' . strlen($data)); 929 $this->incoming_payload .= $data; 930 $this->debug('received a total of '.strlen($this->incoming_payload).' bytes of data from server'); 931 932 // close filepointer 933 if( 934 (isset($this->incoming_headers['connection']) && strtolower($this->incoming_headers['connection']) == 'close') || 935 (! $this->persistentConnection) || feof($this->fp)){ 936 fclose($this->fp); 937 $this->fp = false; 938 $this->debug('closed socket'); 939 } 940 941 // connection was closed unexpectedly 942 if($this->incoming_payload == ''){ 943 $this->setError('no response from server'); 944 return false; 945 } 946 947 // decode transfer-encoding 948// if(isset($this->incoming_headers['transfer-encoding']) && strtolower($this->incoming_headers['transfer-encoding']) == 'chunked'){ 949// if(!$data = $this->decodeChunked($data, $lb)){ 950// $this->setError('Decoding of chunked data failed'); 951// return false; 952// } 953 //print "<pre>\nde-chunked:\n---------------\n$data\n\n---------------\n</pre>"; 954 // set decoded payload 955// $this->incoming_payload = $header_data.$lb.$lb.$data; 956// } 957 958 } else if ($this->io_method() == 'curl') { 959 // send and receive 960 $this->debug('send and receive with cURL'); 961 $this->incoming_payload = curl_exec($this->ch); 962 $data = $this->incoming_payload; 963 964 $cErr = curl_error($this->ch); 965 if ($cErr != '') { 966 $err = 'cURL ERROR: '.curl_errno($this->ch).': '.$cErr.'<br>'; 967 // TODO: there is a PHP bug that can cause this to SEGV for CURLINFO_CONTENT_TYPE 968 foreach(curl_getinfo($this->ch) as $k => $v){ 969 $err .= "$k: $v<br>"; 970 } 971 $this->debug($err); 972 $this->setError($err); 973 curl_close($this->ch); 974 return false; 975 } else { 976 //echo '<pre>'; 977 //var_dump(curl_getinfo($this->ch)); 978 //echo '</pre>'; 979 } 980 // close curl 981 $this->debug('No cURL error, closing cURL'); 982 curl_close($this->ch); 983 984 // try removing skippable headers 985 $savedata = $data; 986 while ($this->isSkippableCurlHeader($data)) { 987 $this->debug("Found HTTP header to skip"); 988 if ($pos = strpos($data,"\r\n\r\n")) { 989 $data = ltrim(substr($data,$pos)); 990 } elseif($pos = strpos($data,"\n\n") ) { 991 $data = ltrim(substr($data,$pos)); 992 } 993 } 994 995 if ($data == '') { 996 // have nothing left; just remove 100 header(s) 997 $data = $savedata; 998 while (ereg('^HTTP/1.1 100',$data)) { 999 if ($pos = strpos($data,"\r\n\r\n")) { 1000 $data = ltrim(substr($data,$pos)); 1001 } elseif($pos = strpos($data,"\n\n") ) { 1002 $data = ltrim(substr($data,$pos)); 1003 } 1004 } 1005 } 1006 1007 // separate content from HTTP headers 1008 if ($pos = strpos($data,"\r\n\r\n")) { 1009 $lb = "\r\n"; 1010 } elseif( $pos = strpos($data,"\n\n")) { 1011 $lb = "\n"; 1012 } else { 1013 $this->debug('no proper separation of headers and document'); 1014 $this->setError('no proper separation of headers and document'); 1015 return false; 1016 } 1017 $header_data = trim(substr($data,0,$pos)); 1018 $header_array = explode($lb,$header_data); 1019 $data = ltrim(substr($data,$pos)); 1020 $this->debug('found proper separation of headers and document'); 1021 $this->debug('cleaned data, stringlen: '.strlen($data)); 1022 // clean headers 1023 foreach ($header_array as $header_line) { 1024 $arr = explode(':',$header_line,2); 1025 if(count($arr) > 1){ 1026 $header_name = strtolower(trim($arr[0])); 1027 $this->incoming_headers[$header_name] = trim($arr[1]); 1028 if ($header_name == 'set-cookie') { 1029 // TODO: allow multiple cookies from parseCookie 1030 $cookie = $this->parseCookie(trim($arr[1])); 1031 if ($cookie) { 1032 $this->incoming_cookies[] = $cookie; 1033 $this->debug('found cookie: ' . $cookie['name'] . ' = ' . $cookie['value']); 1034 } else { 1035 $this->debug('did not find cookie in ' . trim($arr[1])); 1036 } 1037 } 1038 } else if (isset($header_name)) { 1039 // append continuation line to previous header 1040 $this->incoming_headers[$header_name] .= $lb . ' ' . $header_line; 1041 } 1042 } 1043 } 1044 1045 $this->response_status_line = $header_array[0]; 1046 $arr = explode(' ', $this->response_status_line, 3); 1047 $http_version = $arr[0]; 1048 $http_status = intval($arr[1]); 1049 $http_reason = count($arr) > 2 ? $arr[2] : ''; 1050 1051 // see if we need to resend the request with http digest authentication 1052 if (isset($this->incoming_headers['location']) && ($http_status == 301 || $http_status == 302)) { 1053 $this->debug("Got $http_status $http_reason with Location: " . $this->incoming_headers['location']); 1054 $this->setURL($this->incoming_headers['location']); 1055 $this->tryagain = true; 1056 return false; 1057 } 1058 1059 // see if we need to resend the request with http digest authentication 1060 if (isset($this->incoming_headers['www-authenticate']) && $http_status == 401) { 1061 $this->debug("Got 401 $http_reason with WWW-Authenticate: " . $this->incoming_headers['www-authenticate']); 1062 if (strstr($this->incoming_headers['www-authenticate'], "Digest ")) { 1063 $this->debug('Server wants digest authentication'); 1064 // remove "Digest " from our elements 1065 $digestString = str_replace('Digest ', '', $this->incoming_headers['www-authenticate']); 1066 1067 // parse elements into array 1068 $digestElements = explode(',', $digestString); 1069 foreach ($digestElements as $val) { 1070 $tempElement = explode('=', trim($val), 2); 1071 $digestRequest[$tempElement[0]] = str_replace("\"", '', $tempElement[1]); 1072 } 1073 1074 // should have (at least) qop, realm, nonce 1075 if (isset($digestRequest['nonce'])) { 1076 $this->setCredentials($this->username, $this->password, 'digest', $digestRequest); 1077 $this->tryagain = true; 1078 return false; 1079 } 1080 } 1081 $this->debug('HTTP authentication failed'); 1082 $this->setError('HTTP authentication failed'); 1083 return false; 1084 } 1085 1086 if ( 1087 ($http_status >= 300 && $http_status <= 307) || 1088 ($http_status >= 400 && $http_status <= 417) || 1089 ($http_status >= 501 && $http_status <= 505) 1090 ) { 1091 $this->setError("Unsupported HTTP response status $http_status $http_reason (soapclient->response has contents of the response)"); 1092 return false; 1093 } 1094 1095 // decode content-encoding 1096 if(isset($this->incoming_headers['content-encoding']) && $this->incoming_headers['content-encoding'] != ''){ 1097 if(strtolower($this->incoming_headers['content-encoding']) == 'deflate' || strtolower($this->incoming_headers['content-encoding']) == 'gzip'){ 1098 // if decoding works, use it. else assume data wasn't gzencoded 1099 if(function_exists('gzinflate')){ 1100 //$timer->setMarker('starting decoding of gzip/deflated content'); 1101 // IIS 5 requires gzinflate instead of gzuncompress (similar to IE 5 and gzdeflate v. gzcompress) 1102 // this means there are no Zlib headers, although there should be 1103 $this->debug('The gzinflate function exists'); 1104 $datalen = strlen($data); 1105 if ($this->incoming_headers['content-encoding'] == 'deflate') { 1106 if ($degzdata = @gzinflate($data)) { 1107 $data = $degzdata; 1108 $this->debug('The payload has been inflated to ' . strlen($data) . ' bytes'); 1109 if (strlen($data) < $datalen) { 1110 // test for the case that the payload has been compressed twice 1111 $this->debug('The inflated payload is smaller than the gzipped one; try again'); 1112 if ($degzdata = @gzinflate($data)) { 1113 $data = $degzdata; 1114 $this->debug('The payload has been inflated again to ' . strlen($data) . ' bytes'); 1115 } 1116 } 1117 } else { 1118 $this->debug('Error using gzinflate to inflate the payload'); 1119 $this->setError('Error using gzinflate to inflate the payload'); 1120 } 1121 } elseif ($this->incoming_headers['content-encoding'] == 'gzip') { 1122 if ($degzdata = @gzinflate(substr($data, 10))) { // do our best 1123 $data = $degzdata; 1124 $this->debug('The payload has been un-gzipped to ' . strlen($data) . ' bytes'); 1125 if (strlen($data) < $datalen) { 1126 // test for the case that the payload has been compressed twice 1127 $this->debug('The un-gzipped payload is smaller than the gzipped one; try again'); 1128 if ($degzdata = @gzinflate(substr($data, 10))) { 1129 $data = $degzdata; 1130 $this->debug('The payload has been un-gzipped again to ' . strlen($data) . ' bytes'); 1131 } 1132 } 1133 } else { 1134 $this->debug('Error using gzinflate to un-gzip the payload'); 1135 $this->setError('Error using gzinflate to un-gzip the payload'); 1136 } 1137 } 1138 //$timer->setMarker('finished decoding of gzip/deflated content'); 1139 //print "<xmp>\nde-inflated:\n---------------\n$data\n-------------\n</xmp>"; 1140 // set decoded payload 1141 $this->incoming_payload = $header_data.$lb.$lb.$data; 1142 } else { 1143 $this->debug('The server sent compressed data. Your php install must have the Zlib extension compiled in to support this.'); 1144 $this->setError('The server sent compressed data. Your php install must have the Zlib extension compiled in to support this.'); 1145 } 1146 } else { 1147 $this->debug('Unsupported Content-Encoding ' . $this->incoming_headers['content-encoding']); 1148 $this->setError('Unsupported Content-Encoding ' . $this->incoming_headers['content-encoding']); 1149 } 1150 } else { 1151 $this->debug('No Content-Encoding header'); 1152 } 1153 1154 if(strlen($data) == 0){ 1155 $this->debug('no data after headers!'); 1156 $this->setError('no data present after HTTP headers'); 1157 return false; 1158 } 1159 1160 return $data; 1161 } 1162 1163 /** 1164 * sets the content-type for the SOAP message to be sent 1165 * 1166 * @param string $type the content type, MIME style 1167 * @param mixed $charset character set used for encoding (or false) 1168 * @access public 1169 */ 1170 function setContentType($type, $charset = false) { 1171 $this->setHeader('Content-Type', $type . ($charset ? '; charset=' . $charset : '')); 1172 } 1173 1174 /** 1175 * specifies that an HTTP persistent connection should be used 1176 * 1177 * @return boolean whether the request was honored by this method. 1178 * @access public 1179 */ 1180 function usePersistentConnection(){ 1181 if (isset($this->outgoing_headers['Accept-Encoding'])) { 1182 return false; 1183 } 1184 $this->protocol_version = '1.1'; 1185 $this->persistentConnection = true; 1186 $this->setHeader('Connection', 'Keep-Alive'); 1187 return true; 1188 } 1189 1190 /** 1191 * parse an incoming Cookie into it's parts 1192 * 1193 * @param string $cookie_str content of cookie 1194 * @return array with data of that cookie 1195 * @access private 1196 */ 1197 /* 1198 * TODO: allow a Set-Cookie string to be parsed into multiple cookies 1199 */ 1200 function parseCookie($cookie_str) { 1201 $cookie_str = str_replace('; ', ';', $cookie_str) . ';'; 1202 $data = split(';', $cookie_str); 1203 $value_str = $data[0]; 1204 1205 $cookie_param = 'domain='; 1206 $start = strpos($cookie_str, $cookie_param); 1207 if ($start > 0) { 1208 $domain = substr($cookie_str, $start + strlen($cookie_param)); 1209 $domain = substr($domain, 0, strpos($domain, ';')); 1210 } else { 1211 $domain = ''; 1212 } 1213 1214 $cookie_param = 'expires='; 1215 $start = strpos($cookie_str, $cookie_param); 1216 if ($start > 0) { 1217 $expires = substr($cookie_str, $start + strlen($cookie_param)); 1218 $expires = substr($expires, 0, strpos($expires, ';')); 1219 } else { 1220 $expires = ''; 1221 } 1222 1223 $cookie_param = 'path='; 1224 $start = strpos($cookie_str, $cookie_param); 1225 if ( $start > 0 ) { 1226 $path = substr($cookie_str, $start + strlen($cookie_param)); 1227 $path = substr($path, 0, strpos($path, ';')); 1228 } else { 1229 $path = '/'; 1230 } 1231 1232 $cookie_param = ';secure;'; 1233 if (strpos($cookie_str, $cookie_param) !== FALSE) { 1234 $secure = true; 1235 } else { 1236 $secure = false; 1237 } 1238 1239 $sep_pos = strpos($value_str, '='); 1240 1241 if ($sep_pos) { 1242 $name = substr($value_str, 0, $sep_pos); 1243 $value = substr($value_str, $sep_pos + 1); 1244 $cookie= array( 'name' => $name, 1245 'value' => $value, 1246 'domain' => $domain, 1247 'path' => $path, 1248 'expires' => $expires, 1249 'secure' => $secure 1250 ); 1251 return $cookie; 1252 } 1253 return false; 1254 } 1255 1256 /** 1257 * sort out cookies for the current request 1258 * 1259 * @param array $cookies array with all cookies 1260 * @param boolean $secure is the send-content secure or not? 1261 * @return string for Cookie-HTTP-Header 1262 * @access private 1263 */ 1264 function getCookiesForRequest($cookies, $secure=false) { 1265 $cookie_str = ''; 1266 if ((! is_null($cookies)) && (is_array($cookies))) { 1267 foreach ($cookies as $cookie) { 1268 if (! is_array($cookie)) { 1269 continue; 1270 } 1271 $this->debug("check cookie for validity: ".$cookie['name'].'='.$cookie['value']); 1272 if ((isset($cookie['expires'])) && (! empty($cookie['expires']))) { 1273 if (strtotime($cookie['expires']) <= time()) { 1274 $this->debug('cookie has expired'); 1275 continue; 1276 } 1277 } 1278 if ((isset($cookie['domain'])) && (! empty($cookie['domain']))) { 1279 $domain = preg_quote($cookie['domain']); 1280 if (! preg_match("'.*$domain$'i", $this->host)) { 1281 $this->debug('cookie has different domain'); 1282 continue; 1283 } 1284 } 1285 if ((isset($cookie['path'])) && (! empty($cookie['path']))) { 1286 $path = preg_quote($cookie['path']); 1287 if (! preg_match("'^$path.*'i", $this->path)) { 1288 $this->debug('cookie is for a different path'); 1289 continue; 1290 } 1291 } 1292 if ((! $secure) && (isset($cookie['secure'])) && ($cookie['secure'])) { 1293 $this->debug('cookie is secure, transport is not'); 1294 continue; 1295 } 1296 $cookie_str .= $cookie['name'] . '=' . $cookie['value'] . '; '; 1297 $this->debug('add cookie to Cookie-String: ' . $cookie['name'] . '=' . $cookie['value']); 1298 } 1299 } 1300 return $cookie_str; 1301 } 1302} 1303 1304 1305?>