nusoap_client

[nu]soapclient higher level class for easy usage.

Defined (2)

The class is defined in the following location(s).

/lib/nusoap/class.soapclient.php  
  1. class nusoap_client extends nusoap_base  { 
  2.  
  3.     var $username = '';                // Username for HTTP authentication 
  4.     var $password = '';                // Password for HTTP authentication 
  5.     var $authtype = '';                // Type of HTTP authentication 
  6.     var $certRequest = array();        // Certificate for HTTP SSL authentication 
  7.     var $requestHeaders = false;    // SOAP headers in request (text) 
  8.     var $responseHeaders = '';        // SOAP headers from response (incomplete namespace resolution) (text) 
  9.     var $responseHeader = NULL;        // SOAP Header from response (parsed) 
  10.     var $document = '';                // SOAP body response portion (incomplete namespace resolution) (text) 
  11.     var $endpoint; 
  12.     var $forceEndpoint = '';        // overrides WSDL endpoint 
  13.     var $proxyhost = ''; 
  14.     var $proxyport = ''; 
  15.     var $proxyusername = ''; 
  16.     var $proxypassword = ''; 
  17.     var $portName = '';                // port name to use in WSDL 
  18.     var $xml_encoding = '';            // character set encoding of incoming (response) messages 
  19.     var $http_encoding = false; 
  20.     var $timeout = 0;                // HTTP connection timeout 
  21.     var $response_timeout = 30;        // HTTP response timeout 
  22.     var $endpointType = '';            // soap|wsdl, empty for WSDL initialization error 
  23.     var $persistentConnection = false; 
  24.     var $defaultRpcParams = false;    // This is no longer used 
  25.     var $request = '';                // HTTP request 
  26.     var $response = '';                // HTTP response 
  27.     var $responseData = '';            // SOAP payload of response 
  28.     var $cookies = array();            // Cookies from response or for request 
  29.     var $decode_utf8 = true;        // toggles whether the parser decodes element content w/ utf8_decode() 
  30.     var $operations = array();        // WSDL operations, empty for WSDL initialization error 
  31.     var $curl_options = array();    // User-specified cURL options 
  32.     var $bindingType = '';            // WSDL operation binding type 
  33.     var $use_curl = false;            // whether to always try to use cURL 
  34.  
  35.     /** 
  36.      * fault related variables 
  37.      */ 
  38.     /** 
  39.      * @var      fault 
  40.      * @access   public 
  41.      */ 
  42.     var $fault; 
  43.     /** 
  44.      * @var      faultcode 
  45.      * @access   public 
  46.      */ 
  47.     var $faultcode; 
  48.     /** 
  49.      * @var      faultstring 
  50.      * @access   public 
  51.      */ 
  52.     var $faultstring; 
  53.     /** 
  54.      * @var      faultdetail 
  55.      * @access   public 
  56.      */ 
  57.     var $faultdetail; 
  58.  
  59.     /** 
  60.     * constructor 
  61.     * 
  62.     * @param    mixed $endpoint SOAP server or WSDL URL (string), or wsdl instance (object) 
  63.     * @param    mixed $wsdl optional, set to 'wsdl' or true if using WSDL 
  64.     * @param    string $proxyhost optional 
  65.     * @param    string $proxyport optional 
  66.     * @param    string $proxyusername optional 
  67.     * @param    string $proxypassword optional 
  68.     * @param    integer $timeout set the connection timeout 
  69.     * @param    integer $response_timeout set the response timeout 
  70.     * @param    string $portName optional portName in WSDL document 
  71.     * @access   public 
  72.     */ 
  73.     function nusoap_client($endpoint, $wsdl = false, $proxyhost = false, $proxyport = false, $proxyusername = false, $proxypassword = false, $timeout = 0, $response_timeout = 30, $portName = '') { 
  74.         parent::nusoap_base(); 
  75.         $this->endpoint = $endpoint; 
  76.         $this->proxyhost = $proxyhost; 
  77.         $this->proxyport = $proxyport; 
  78.         $this->proxyusername = $proxyusername; 
  79.         $this->proxypassword = $proxypassword; 
  80.         $this->timeout = $timeout; 
  81.         $this->response_timeout = $response_timeout; 
  82.         $this->portName = $portName; 
  83.  
  84.         $this->debug("ctor wsdl=$wsdl timeout=$timeout response_timeout=$response_timeout"); 
  85.         $this->appendDebug('endpoint=' . $this->varDump($endpoint)); 
  86.  
  87.         // make values 
  88.         if($wsdl) { 
  89.             if (is_object($endpoint) && (get_class($endpoint) == 'wsdl')) { 
  90.                 $this->wsdl = $endpoint; 
  91.                 $this->endpoint = $this->wsdl->wsdl; 
  92.                 $this->wsdlFile = $this->endpoint; 
  93.                 $this->debug('existing wsdl instance created from ' . $this->endpoint); 
  94.                 $this->checkWSDL(); 
  95.             } else { 
  96.                 $this->wsdlFile = $this->endpoint; 
  97.                 $this->wsdl = null; 
  98.                 $this->debug('will use lazy evaluation of wsdl from ' . $this->endpoint); 
  99.             } 
  100.             $this->endpointType = 'wsdl'; 
  101.         } else { 
  102.             $this->debug("instantiate SOAP with endpoint at $endpoint"); 
  103.             $this->endpointType = 'soap'; 
  104.         } 
  105.     } 
  106.  
  107.     /** 
  108.     * calls method, returns PHP native type 
  109.     * 
  110.     * @param    string $operation SOAP server URL or path 
  111.     * @param    mixed $params An array, associative or simple, of the parameters 
  112.     *                          for the method call, or a string that is the XML 
  113.     *                          for the call.  For rpc style, this call will 
  114.     *                          wrap the XML in a tag named after the method, as 
  115.     *                          well as the SOAP Envelope and Body.  For document 
  116.     *                          style, this will only wrap with the Envelope and Body. 
  117.     *                          IMPORTANT: when using an array with document style,  
  118.     *                          in which case there 
  119.     *                         is really one parameter, the root of the fragment 
  120.     *                         used in the call, which encloses what programmers 
  121.     *                         normally think of parameters.  A parameter array 
  122.     *                         *must* include the wrapper. 
  123.     * @param    string $namespace optional method namespace (WSDL can override) 
  124.     * @param    string $soapAction optional SOAPAction value (WSDL can override) 
  125.     * @param    mixed $headers optional string of XML with SOAP header content, or array of soapval objects for SOAP headers, or associative array 
  126.     * @param    boolean $rpcParams optional (no longer used) 
  127.     * @param    string    $style optional (rpc|document) the style to use when serializing parameters (WSDL can override) 
  128.     * @param    string    $use optional (encoded|literal) the use when serializing parameters (WSDL can override) 
  129.     * @return    mixed    response from SOAP call, normally an associative array mirroring the structure of the XML response, false for certain fatal errors 
  130.     * @access   public 
  131.     */ 
  132.     function call($operation, $params=array(), $namespace='http://tempuri.org', $soapAction='', $headers=false, $rpcParams=null, $style='rpc', $use='encoded') { 
  133.         $this->operation = $operation; 
  134.         $this->fault = false; 
  135.         $this->setError(''); 
  136.         $this->request = ''; 
  137.         $this->response = ''; 
  138.         $this->responseData = ''; 
  139.         $this->faultstring = ''; 
  140.         $this->faultcode = ''; 
  141.         $this->opData = array(); 
  142.          
  143.         $this->debug("call: operation=$operation, namespace=$namespace, soapAction=$soapAction, rpcParams=$rpcParams, style=$style, use=$use, endpointType=$this->endpointType"); 
  144.         $this->appendDebug('params=' . $this->varDump($params)); 
  145.         $this->appendDebug('headers=' . $this->varDump($headers)); 
  146.         if ($headers) { 
  147.             $this->requestHeaders = $headers; 
  148.         } 
  149.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  150.             $this->loadWSDL(); 
  151.             if ($this->getError()) 
  152.                 return false; 
  153.         } 
  154.         // serialize parameters 
  155.         if($this->endpointType == 'wsdl' && $opData = $this->getOperationData($operation)) { 
  156.             // use WSDL for operation 
  157.             $this->opData = $opData; 
  158.             $this->debug("found operation"); 
  159.             $this->appendDebug('opData=' . $this->varDump($opData)); 
  160.             if (isset($opData['soapAction'])) { 
  161.                 $soapAction = $opData['soapAction']; 
  162.             } 
  163.             if (! $this->forceEndpoint) { 
  164.                 $this->endpoint = $opData['endpoint']; 
  165.             } else { 
  166.                 $this->endpoint = $this->forceEndpoint; 
  167.             } 
  168.             $namespace = isset($opData['input']['namespace']) ? $opData['input']['namespace'] :    $namespace; 
  169.             $style = $opData['style']; 
  170.             $use = $opData['input']['use']; 
  171.             // add ns to ns array 
  172.             if($namespace != '' && !isset($this->wsdl->namespaces[$namespace])) { 
  173.                 $nsPrefix = 'ns' . rand(1000, 9999); 
  174.                 $this->wsdl->namespaces[$nsPrefix] = $namespace; 
  175.             } 
  176.             $nsPrefix = $this->wsdl->getPrefixFromNamespace($namespace); 
  177.             // serialize payload 
  178.             if (is_string($params)) { 
  179.                 $this->debug("serializing param string for WSDL operation $operation"); 
  180.                 $payload = $params; 
  181.             } elseif (is_array($params)) { 
  182.                 $this->debug("serializing param array for WSDL operation $operation"); 
  183.                 $payload = $this->wsdl->serializeRPCParameters($operation, 'input', $params, $this->bindingType); 
  184.             } else { 
  185.                 $this->debug('params must be array or string'); 
  186.                 $this->setError('params must be array or string'); 
  187.                 return false; 
  188.             } 
  189.             $usedNamespaces = $this->wsdl->usedNamespaces; 
  190.             if (isset($opData['input']['encodingStyle'])) { 
  191.                 $encodingStyle = $opData['input']['encodingStyle']; 
  192.             } else { 
  193.                 $encodingStyle = ''; 
  194.             } 
  195.             $this->appendDebug($this->wsdl->getDebug()); 
  196.             $this->wsdl->clearDebug(); 
  197.             if ($errstr = $this->wsdl->getError()) { 
  198.                 $this->debug('got wsdl error: '.$errstr); 
  199.                 $this->setError('wsdl error: '.$errstr); 
  200.                 return false; 
  201.             } 
  202.         } elseif($this->endpointType == 'wsdl') { 
  203.             // operation not in WSDL 
  204.             $this->appendDebug($this->wsdl->getDebug()); 
  205.             $this->wsdl->clearDebug(); 
  206.             $this->setError('operation '.$operation.' not present in WSDL.'); 
  207.             $this->debug("operation '$operation' not present in WSDL."); 
  208.             return false; 
  209.         } else { 
  210.             // no WSDL 
  211.             //$this->namespaces['ns1'] = $namespace; 
  212.             $nsPrefix = 'ns' . rand(1000, 9999); 
  213.             // serialize  
  214.             $payload = ''; 
  215.             if (is_string($params)) { 
  216.                 $this->debug("serializing param string for operation $operation"); 
  217.                 $payload = $params; 
  218.             } elseif (is_array($params)) { 
  219.                 $this->debug("serializing param array for operation $operation"); 
  220.                 foreach($params as $k => $v) { 
  221.                     $payload .= $this->serialize_val($v, $k, false, false, false, false, $use); 
  222.                 } 
  223.             } else { 
  224.                 $this->debug('params must be array or string'); 
  225.                 $this->setError('params must be array or string'); 
  226.                 return false; 
  227.             } 
  228.             $usedNamespaces = array(); 
  229.             if ($use == 'encoded') { 
  230.                 $encodingStyle = 'http://schemas.xmlsoap.org/soap/encoding/'; 
  231.             } else { 
  232.                 $encodingStyle = ''; 
  233.             } 
  234.         } 
  235.         // wrap RPC calls with method element 
  236.         if ($style == 'rpc') { 
  237.             if ($use == 'literal') { 
  238.                 $this->debug("wrapping RPC request with literal method element"); 
  239.                 if ($namespace) { 
  240.                     // http://www.ws-i.org/Profiles/BasicProfile-1.1-2004-08-24.html R2735 says rpc/literal accessor elements should not be in a namespace 
  241.                     $payload = "<$nsPrefix:$operation xmlns:$nsPrefix=\"$namespace\">" . 
  242.                                 $payload . 
  243.                                 "</$nsPrefix:$operation>"; 
  244.                 } else { 
  245.                     $payload = "<$operation>" . $payload . "</$operation>"; 
  246.                 } 
  247.             } else { 
  248.                 $this->debug("wrapping RPC request with encoded method element"); 
  249.                 if ($namespace) { 
  250.                     $payload = "<$nsPrefix:$operation xmlns:$nsPrefix=\"$namespace\">" . 
  251.                                 $payload . 
  252.                                 "</$nsPrefix:$operation>"; 
  253.                 } else { 
  254.                     $payload = "<$operation>" . 
  255.                                 $payload . 
  256.                                 "</$operation>"; 
  257.                 } 
  258.             } 
  259.         } 
  260.         // serialize envelope 
  261.         $soapmsg = $this->serializeEnvelope($payload, $this->requestHeaders, $usedNamespaces, $style, $use, $encodingStyle); 
  262.         $this->debug("endpoint=$this->endpoint, soapAction=$soapAction, namespace=$namespace, style=$style, use=$use, encodingStyle=$encodingStyle"); 
  263.         $this->debug('SOAP message length=' . strlen($soapmsg) . ' contents (max 1000 bytes)=' . substr($soapmsg, 0, 1000)); 
  264.         // send 
  265.         $return = $this->send($this->getHTTPBody($soapmsg), $soapAction, $this->timeout, $this->response_timeout); 
  266.         if($errstr = $this->getError()) { 
  267.             $this->debug('Error: '.$errstr); 
  268.             return false; 
  269.         } else { 
  270.             $this->return = $return; 
  271.             $this->debug('sent message successfully and got a(n) '.gettype($return)); 
  272.                $this->appendDebug('return=' . $this->varDump($return)); 
  273.              
  274.             // fault? 
  275.             if(is_array($return) && isset($return['faultcode'])) { 
  276.                 $this->debug('got fault'); 
  277.                 $this->setError($return['faultcode'].': '.$return['faultstring']); 
  278.                 $this->fault = true; 
  279.                 foreach($return as $k => $v) { 
  280.                     $this->$k = $v; 
  281.                     $this->debug("$k = $v<br>"); 
  282.                 } 
  283.                 return $return; 
  284.             } elseif ($style == 'document') { 
  285.                 // NOTE: if the response is defined to have multiple parts (i.e. unwrapped),  
  286.                 // we are only going to return the first part here...sorry about that 
  287.                 return $return; 
  288.             } else { 
  289.                 // array of return values 
  290.                 if(is_array($return)) { 
  291.                     // multiple 'out' parameters, which we return wrapped up 
  292.                     // in the array 
  293.                     if(sizeof($return) > 1) { 
  294.                         return $return; 
  295.                     } 
  296.                     // single 'out' parameter (normally the return value) 
  297.                     $return = array_shift($return); 
  298.                     $this->debug('return shifted value: '); 
  299.                     $this->appendDebug($this->varDump($return)); 
  300.                        return $return; 
  301.                 // nothing returned (ie, echoVoid) 
  302.                 } else { 
  303.                     return ""; 
  304.                 } 
  305.             } 
  306.         } 
  307.     } 
  308.  
  309.     /** 
  310.     * check WSDL passed as an instance or pulled from an endpoint 
  311.     * 
  312.     * @access   private 
  313.     */ 
  314.     function checkWSDL() { 
  315.         $this->appendDebug($this->wsdl->getDebug()); 
  316.         $this->wsdl->clearDebug(); 
  317.         $this->debug('checkWSDL'); 
  318.         // catch errors 
  319.         if ($errstr = $this->wsdl->getError()) { 
  320.             $this->appendDebug($this->wsdl->getDebug()); 
  321.             $this->wsdl->clearDebug(); 
  322.             $this->debug('got wsdl error: '.$errstr); 
  323.             $this->setError('wsdl error: '.$errstr); 
  324.         } elseif ($this->operations = $this->wsdl->getOperations($this->portName, 'soap')) { 
  325.             $this->appendDebug($this->wsdl->getDebug()); 
  326.             $this->wsdl->clearDebug(); 
  327.             $this->bindingType = 'soap'; 
  328.             $this->debug('got '.count($this->operations).' operations from wsdl '.$this->wsdlFile.' for binding type '.$this->bindingType); 
  329.         } elseif ($this->operations = $this->wsdl->getOperations($this->portName, 'soap12')) { 
  330.             $this->appendDebug($this->wsdl->getDebug()); 
  331.             $this->wsdl->clearDebug(); 
  332.             $this->bindingType = 'soap12'; 
  333.             $this->debug('got '.count($this->operations).' operations from wsdl '.$this->wsdlFile.' for binding type '.$this->bindingType); 
  334.             $this->debug('**************** WARNING: SOAP 1.2 BINDING *****************'); 
  335.         } else { 
  336.             $this->appendDebug($this->wsdl->getDebug()); 
  337.             $this->wsdl->clearDebug(); 
  338.             $this->debug('getOperations returned false'); 
  339.             $this->setError('no operations defined in the WSDL document!'); 
  340.         } 
  341.     } 
  342.  
  343.     /** 
  344.      * instantiate wsdl object and parse wsdl file 
  345.      * 
  346.      * @access    public 
  347.      */ 
  348.     function loadWSDL() { 
  349.         $this->debug('instantiating wsdl class with doc: '.$this->wsdlFile); 
  350.         $this->wsdl = new wsdl('', $this->proxyhost, $this->proxyport, $this->proxyusername, $this->proxypassword, $this->timeout, $this->response_timeout, $this->curl_options, $this->use_curl); 
  351.         $this->wsdl->setCredentials($this->username, $this->password, $this->authtype, $this->certRequest); 
  352.         $this->wsdl->fetchWSDL($this->wsdlFile); 
  353.         $this->checkWSDL(); 
  354.     } 
  355.  
  356.     /** 
  357.     * get available data pertaining to an operation 
  358.     * 
  359.     * @param    string $operation operation name 
  360.     * @return    array array of data pertaining to the operation 
  361.     * @access   public 
  362.     */ 
  363.     function getOperationData($operation) { 
  364.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  365.             $this->loadWSDL(); 
  366.             if ($this->getError()) 
  367.                 return false; 
  368.         } 
  369.         if(isset($this->operations[$operation])) { 
  370.             return $this->operations[$operation]; 
  371.         } 
  372.         $this->debug("No data for operation: $operation"); 
  373.     } 
  374.  
  375.     /** 
  376.     * send the SOAP message 
  377.     * 
  378.     * Note: if the operation has multiple return values 
  379.     * the return value of this method will be an array 
  380.     * of those values. 
  381.     * 
  382.     * @param    string $msg a SOAPx4 soapmsg object 
  383.     * @param    string $soapaction SOAPAction value 
  384.     * @param    integer $timeout set connection timeout in seconds 
  385.     * @param    integer $response_timeout set response timeout in seconds 
  386.     * @return    mixed native PHP types. 
  387.     * @access   private 
  388.     */ 
  389.     function send($msg, $soapaction = '', $timeout=0, $response_timeout=30) { 
  390.         $this->checkCookies(); 
  391.         // detect transport 
  392.         switch(true) { 
  393.             // http(s) 
  394.             case preg_match('/^http/', $this->endpoint): 
  395.                 $this->debug('transporting via HTTP'); 
  396.                 if($this->persistentConnection == true && is_object($this->persistentConnection)) { 
  397.                     $http =& $this->persistentConnection; 
  398.                 } else { 
  399.                     $http = new soap_transport_http($this->endpoint, $this->curl_options, $this->use_curl); 
  400.                     if ($this->persistentConnection) { 
  401.                         $http->usePersistentConnection(); 
  402.                     } 
  403.                 } 
  404.                 $http->setContentType($this->getHTTPContentType(), $this->getHTTPContentTypeCharset()); 
  405.                 $http->setSOAPAction($soapaction); 
  406.                 if($this->proxyhost && $this->proxyport) { 
  407.                     $http->setProxy($this->proxyhost, $this->proxyport, $this->proxyusername, $this->proxypassword); 
  408.                 } 
  409.                 if($this->authtype != '') { 
  410.                     $http->setCredentials($this->username, $this->password, $this->authtype, array(), $this->certRequest); 
  411.                 } 
  412.                 if($this->http_encoding != '') { 
  413.                     $http->setEncoding($this->http_encoding); 
  414.                 } 
  415.                 $this->debug('sending message, length='.strlen($msg)); 
  416.                 if(preg_match('/^http:/', $this->endpoint)) { 
  417.                 //if(strpos($this->endpoint, 'http:')) { 
  418.                     $this->responseData = $http->send($msg, $timeout, $response_timeout, $this->cookies); 
  419.                 } elseif(preg_match('/^https/', $this->endpoint)) { 
  420.                 //} elseif(strpos($this->endpoint, 'https:')) { 
  421.                     //if(phpversion() == '4.3.0-dev') { 
  422.                         //$response = $http->send($msg, $timeout, $response_timeout); 
  423.                            //$this->request = $http->outgoing_payload; 
  424.                         //$this->response = $http->incoming_payload; 
  425.                     //} else 
  426.                     $this->responseData = $http->sendHTTPS($msg, $timeout, $response_timeout, $this->cookies); 
  427.                 } else { 
  428.                     $this->setError('no http/s in endpoint url'); 
  429.                 } 
  430.                 $this->request = $http->outgoing_payload; 
  431.                 $this->response = $http->incoming_payload; 
  432.                 $this->appendDebug($http->getDebug()); 
  433.                 $this->UpdateCookies($http->incoming_cookies); 
  434.  
  435.                 // save transport object if using persistent connections 
  436.                 if ($this->persistentConnection) { 
  437.                     $http->clearDebug(); 
  438.                     if (!is_object($this->persistentConnection)) { 
  439.                         $this->persistentConnection = $http; 
  440.                     } 
  441.                 } 
  442.                  
  443.                 if($err = $http->getError()) { 
  444.                     $this->setError('HTTP Error: '.$err); 
  445.                     return false; 
  446.                 } elseif($this->getError()) { 
  447.                     return false; 
  448.                 } else { 
  449.                     $this->debug('got response, length='. strlen($this->responseData).' type='.$http->incoming_headers['content-type']); 
  450.                     return $this->parseResponse($http->incoming_headers, $this->responseData); 
  451.                 } 
  452.             break; 
  453.             default: 
  454.                 $this->setError('no transport found, or selected transport is not yet supported!'); 
  455.             return false; 
  456.             break; 
  457.         } 
  458.     } 
  459.  
  460.     /** 
  461.     * processes SOAP message returned from server 
  462.     * 
  463.     * @param    array    $headers    The HTTP headers 
  464.     * @param    string    $data        unprocessed response data from server 
  465.     * @return    mixed    value of the message, decoded into a PHP type 
  466.     * @access   private 
  467.     */ 
  468.     function parseResponse($headers, $data) { 
  469.         $this->debug('Entering parseResponse() for data of length ' . strlen($data) . ' headers:'); 
  470.         $this->appendDebug($this->varDump($headers)); 
  471.         if (!isset($headers['content-type'])) { 
  472.             $this->setError('Response not of type text/xml (no content-type header)'); 
  473.             return false; 
  474.         } 
  475.         if (!strstr($headers['content-type'], 'text/xml')) { 
  476.             $this->setError('Response not of type text/xml: ' . $headers['content-type']); 
  477.             return false; 
  478.         } 
  479.         if (strpos($headers['content-type'], '=')) { 
  480.             $enc = str_replace('"', '', substr(strstr($headers["content-type"], '='), 1)); 
  481.             $this->debug('Got response encoding: ' . $enc); 
  482.             if(preg_match('/^(ISO-8859-1|US-ASCII|UTF-8)$/i', $enc)) { 
  483.                 $this->xml_encoding = strtoupper($enc); 
  484.             } else { 
  485.                 $this->xml_encoding = 'US-ASCII'; 
  486.             } 
  487.         } else { 
  488.             // should be US-ASCII for HTTP 1.0 or ISO-8859-1 for HTTP 1.1 
  489.             $this->xml_encoding = 'ISO-8859-1'; 
  490.         } 
  491.         $this->debug('Use encoding: ' . $this->xml_encoding . ' when creating nusoap_parser'); 
  492.         $parser = new nusoap_parser($data, $this->xml_encoding, $this->operation, $this->decode_utf8); 
  493.         // add parser debug data to our debug 
  494.         $this->appendDebug($parser->getDebug()); 
  495.         // if parse errors 
  496.         if($errstr = $parser->getError()) { 
  497.             $this->setError( $errstr); 
  498.             // destroy the parser object 
  499.             unset($parser); 
  500.             return false; 
  501.         } else { 
  502.             // get SOAP headers 
  503.             $this->responseHeaders = $parser->getHeaders(); 
  504.             // get SOAP headers 
  505.             $this->responseHeader = $parser->get_soapheader(); 
  506.             // get decoded message 
  507.             $return = $parser->get_soapbody(); 
  508.             // add document for doclit support 
  509.             $this->document = $parser->document; 
  510.             // destroy the parser object 
  511.             unset($parser); 
  512.             // return decode message 
  513.             return $return; 
  514.         } 
  515.      } 
  516.  
  517.     /** 
  518.     * sets user-specified cURL options 
  519.     * 
  520.     * @param    mixed $option The cURL option (always integer?) 
  521.     * @param    mixed $value The cURL option value 
  522.     * @access   public 
  523.     */ 
  524.     function setCurlOption($option, $value) { 
  525.         $this->debug("setCurlOption option=$option, value="); 
  526.         $this->appendDebug($this->varDump($value)); 
  527.         $this->curl_options[$option] = $value; 
  528.     } 
  529.  
  530.     /** 
  531.     * sets the SOAP endpoint, which can override WSDL 
  532.     * 
  533.     * @param    string $endpoint The endpoint URL to use, or empty string or false to prevent override 
  534.     * @access   public 
  535.     */ 
  536.     function setEndpoint($endpoint) { 
  537.         $this->debug("setEndpoint(\"$endpoint\")"); 
  538.         $this->forceEndpoint = $endpoint; 
  539.     } 
  540.  
  541.     /** 
  542.     * set the SOAP headers 
  543.     * 
  544.     * @param    mixed $headers String of XML with SOAP header content, or array of soapval objects for SOAP headers 
  545.     * @access   public 
  546.     */ 
  547.     function setHeaders($headers) { 
  548.         $this->debug("setHeaders headers="); 
  549.         $this->appendDebug($this->varDump($headers)); 
  550.         $this->requestHeaders = $headers; 
  551.     } 
  552.  
  553.     /** 
  554.     * get the SOAP response headers (namespace resolution incomplete) 
  555.     * 
  556.     * @return    string 
  557.     * @access   public 
  558.     */ 
  559.     function getHeaders() { 
  560.         return $this->responseHeaders; 
  561.     } 
  562.  
  563.     /** 
  564.     * get the SOAP response Header (parsed) 
  565.     * 
  566.     * @return    mixed 
  567.     * @access   public 
  568.     */ 
  569.     function getHeader() { 
  570.         return $this->responseHeader; 
  571.     } 
  572.  
  573.     /** 
  574.     * set proxy info here 
  575.     * 
  576.     * @param    string $proxyhost 
  577.     * @param    string $proxyport 
  578.     * @param    string $proxyusername 
  579.     * @param    string $proxypassword 
  580.     * @access   public 
  581.     */ 
  582.     function setHTTPProxy($proxyhost, $proxyport, $proxyusername = '', $proxypassword = '') { 
  583.         $this->proxyhost = $proxyhost; 
  584.         $this->proxyport = $proxyport; 
  585.         $this->proxyusername = $proxyusername; 
  586.         $this->proxypassword = $proxypassword; 
  587.     } 
  588.  
  589.     /** 
  590.     * if authenticating, set user credentials here 
  591.     * 
  592.     * @param    string $username 
  593.     * @param    string $password 
  594.     * @param    string $authtype (basic|digest|certificate|ntlm) 
  595.     * @param    array $certRequest (keys must be cainfofile (optional), sslcertfile, sslkeyfile, passphrase, verifypeer (optional), verifyhost (optional): see corresponding options in cURL docs) 
  596.     * @access   public 
  597.     */ 
  598.     function setCredentials($username, $password, $authtype = 'basic', $certRequest = array()) { 
  599.         $this->debug("setCredentials username=$username authtype=$authtype certRequest="); 
  600.         $this->appendDebug($this->varDump($certRequest)); 
  601.         $this->username = $username; 
  602.         $this->password = $password; 
  603.         $this->authtype = $authtype; 
  604.         $this->certRequest = $certRequest; 
  605.     } 
  606.      
  607.     /** 
  608.     * use HTTP encoding 
  609.     * 
  610.     * @param    string $enc HTTP encoding 
  611.     * @access   public 
  612.     */ 
  613.     function setHTTPEncoding($enc='gzip, deflate') { 
  614.         $this->debug("setHTTPEncoding(\"$enc\")"); 
  615.         $this->http_encoding = $enc; 
  616.     } 
  617.      
  618.     /** 
  619.     * Set whether to try to use cURL connections if possible 
  620.     * 
  621.     * @param    boolean $use Whether to try to use cURL 
  622.     * @access   public 
  623.     */ 
  624.     function setUseCURL($use) { 
  625.         $this->debug("setUseCURL($use)"); 
  626.         $this->use_curl = $use; 
  627.     } 
  628.  
  629.     /** 
  630.     * use HTTP persistent connections if possible 
  631.     * 
  632.     * @access   public 
  633.     */ 
  634.     function useHTTPPersistentConnection() { 
  635.         $this->debug("useHTTPPersistentConnection"); 
  636.         $this->persistentConnection = true; 
  637.     } 
  638.      
  639.     /** 
  640.     * gets the default RPC parameter setting. 
  641.     * If true, default is that call params are like RPC even for document style. 
  642.     * Each call() can override this value. 
  643.     * 
  644.     * This is no longer used. 
  645.     * 
  646.     * @return boolean 
  647.     * @access public 
  648.     * @deprecated 
  649.     */ 
  650.     function getDefaultRpcParams() { 
  651.         return $this->defaultRpcParams; 
  652.     } 
  653.  
  654.     /** 
  655.     * sets the default RPC parameter setting. 
  656.     * If true, default is that call params are like RPC even for document style 
  657.     * Each call() can override this value. 
  658.     * 
  659.     * This is no longer used. 
  660.     * 
  661.     * @param    boolean $rpcParams 
  662.     * @access public 
  663.     * @deprecated 
  664.     */ 
  665.     function setDefaultRpcParams($rpcParams) { 
  666.         $this->defaultRpcParams = $rpcParams; 
  667.     } 
  668.      
  669.     /** 
  670.     * dynamically creates an instance of a proxy class,  
  671.     * allowing user to directly call methods from wsdl 
  672.     * 
  673.     * @return   object soap_proxy object 
  674.     * @access   public 
  675.     */ 
  676.     function getProxy() { 
  677.         $r = rand(); 
  678.         $evalStr = $this->_getProxyClassCode($r); 
  679.         //$this->debug("proxy class: $evalStr"); 
  680.         if ($this->getError()) { 
  681.             $this->debug("Error from _getProxyClassCode, so return NULL"); 
  682.             return null; 
  683.         } 
  684.         // eval the class 
  685.         eval($evalStr); 
  686.         // instantiate proxy object 
  687.         eval("\$proxy = new nusoap_proxy_$r('');"); 
  688.         // transfer current wsdl data to the proxy thereby avoiding parsing the wsdl twice 
  689.         $proxy->endpointType = 'wsdl'; 
  690.         $proxy->wsdlFile = $this->wsdlFile; 
  691.         $proxy->wsdl = $this->wsdl; 
  692.         $proxy->operations = $this->operations; 
  693.         $proxy->defaultRpcParams = $this->defaultRpcParams; 
  694.         // transfer other state 
  695.         $proxy->soap_defencoding = $this->soap_defencoding; 
  696.         $proxy->username = $this->username; 
  697.         $proxy->password = $this->password; 
  698.         $proxy->authtype = $this->authtype; 
  699.         $proxy->certRequest = $this->certRequest; 
  700.         $proxy->requestHeaders = $this->requestHeaders; 
  701.         $proxy->endpoint = $this->endpoint; 
  702.         $proxy->forceEndpoint = $this->forceEndpoint; 
  703.         $proxy->proxyhost = $this->proxyhost; 
  704.         $proxy->proxyport = $this->proxyport; 
  705.         $proxy->proxyusername = $this->proxyusername; 
  706.         $proxy->proxypassword = $this->proxypassword; 
  707.         $proxy->http_encoding = $this->http_encoding; 
  708.         $proxy->timeout = $this->timeout; 
  709.         $proxy->response_timeout = $this->response_timeout; 
  710.         $proxy->persistentConnection = &$this->persistentConnection; 
  711.         $proxy->decode_utf8 = $this->decode_utf8; 
  712.         $proxy->curl_options = $this->curl_options; 
  713.         $proxy->bindingType = $this->bindingType; 
  714.         $proxy->use_curl = $this->use_curl; 
  715.         return $proxy; 
  716.     } 
  717.  
  718.     /** 
  719.     * dynamically creates proxy class code 
  720.     * 
  721.     * @return   string PHP/NuSOAP code for the proxy class 
  722.     * @access   private 
  723.     */ 
  724.     function _getProxyClassCode($r) { 
  725.         $this->debug("in getProxy endpointType=$this->endpointType"); 
  726.         $this->appendDebug("wsdl=" . $this->varDump($this->wsdl)); 
  727.         if ($this->endpointType != 'wsdl') { 
  728.             $evalStr = 'A proxy can only be created for a WSDL client'; 
  729.             $this->setError($evalStr); 
  730.             $evalStr = "echo \"$evalStr\";"; 
  731.             return $evalStr; 
  732.         } 
  733.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  734.             $this->loadWSDL(); 
  735.             if ($this->getError()) { 
  736.                 return "echo \"" . $this->getError() . "\";"; 
  737.             } 
  738.         } 
  739.         $evalStr = ''; 
  740.         foreach ($this->operations as $operation => $opData) { 
  741.             if ($operation != '') { 
  742.                 // create param string and param comment string 
  743.                 if (sizeof($opData['input']['parts']) > 0) { 
  744.                     $paramStr = ''; 
  745.                     $paramArrayStr = ''; 
  746.                     $paramCommentStr = ''; 
  747.                     foreach ($opData['input']['parts'] as $name => $type) { 
  748.                         $paramStr .= "\$$name, "; 
  749.                         $paramArrayStr .= "'$name' => \$$name, "; 
  750.                         $paramCommentStr .= "$type \$$name, "; 
  751.                     } 
  752.                     $paramStr = substr($paramStr, 0, strlen($paramStr)-2); 
  753.                     $paramArrayStr = substr($paramArrayStr, 0, strlen($paramArrayStr)-2); 
  754.                     $paramCommentStr = substr($paramCommentStr, 0, strlen($paramCommentStr)-2); 
  755.                 } else { 
  756.                     $paramStr = ''; 
  757.                     $paramArrayStr = ''; 
  758.                     $paramCommentStr = 'void'; 
  759.                 } 
  760.                 $opData['namespace'] = !isset($opData['namespace']) ? 'http://testuri.com' : $opData['namespace']; 
  761.                 $evalStr .= "// $paramCommentStr 
  762.     function " . str_replace('.', '__', $operation) . "($paramStr) { 
  763.         \$params = array($paramArrayStr); 
  764.         return \$this->call('$operation', \$params, '".$opData['namespace']."', '".(isset($opData['soapAction']) ? $opData['soapAction'] : '')."'); 
  765.     } 
  766.     "; 
  767.                 unset($paramStr); 
  768.                 unset($paramCommentStr); 
  769.             } 
  770.         } 
  771.         $evalStr = 'class nusoap_proxy_'.$r.' extends nusoap_client { 
  772.     '.$evalStr.' 
  773. }'; 
  774.         return $evalStr; 
  775.     } 
  776.  
  777.     /** 
  778.     * dynamically creates proxy class code 
  779.     * 
  780.     * @return   string PHP/NuSOAP code for the proxy class 
  781.     * @access   public 
  782.     */ 
  783.     function getProxyClassCode() { 
  784.         $r = rand(); 
  785.         return $this->_getProxyClassCode($r); 
  786.     } 
  787.  
  788.     /** 
  789.     * gets the HTTP body for the current request. 
  790.     * 
  791.     * @param string $soapmsg The SOAP payload 
  792.     * @return string The HTTP body, which includes the SOAP payload 
  793.     * @access private 
  794.     */ 
  795.     function getHTTPBody($soapmsg) { 
  796.         return $soapmsg; 
  797.     } 
  798.      
  799.     /** 
  800.     * gets the HTTP content type for the current request. 
  801.     * 
  802.     * Note: getHTTPBody must be called before this. 
  803.     * 
  804.     * @return string the HTTP content type for the current request. 
  805.     * @access private 
  806.     */ 
  807.     function getHTTPContentType() { 
  808.         return 'text/xml'; 
  809.     } 
  810.      
  811.     /** 
  812.     * gets the HTTP content type charset for the current request. 
  813.     * returns false for non-text content types. 
  814.     * 
  815.     * Note: getHTTPBody must be called before this. 
  816.     * 
  817.     * @return string the HTTP content type charset for the current request. 
  818.     * @access private 
  819.     */ 
  820.     function getHTTPContentTypeCharset() { 
  821.         return $this->soap_defencoding; 
  822.     } 
  823.  
  824.     /** 
  825.     * whether or not parser should decode utf8 element content 
  826.     * 
  827.     * @return   always returns true 
  828.     * @access   public 
  829.     */ 
  830.     function decodeUTF8($bool) { 
  831.         $this->decode_utf8 = $bool; 
  832.         return true; 
  833.     } 
  834.  
  835.     /** 
  836.      * adds a new Cookie into $this->cookies array 
  837.      * 
  838.      * @param    string $name Cookie Name 
  839.      * @param    string $value Cookie Value 
  840.      * @return    boolean if cookie-set was successful returns true, else false 
  841.      * @access    public 
  842.      */ 
  843.     function setCookie($name, $value) { 
  844.         if (strlen($name) == 0) { 
  845.             return false; 
  846.         } 
  847.         $this->cookies[] = array('name' => $name, 'value' => $value); 
  848.         return true; 
  849.     } 
  850.  
  851.     /** 
  852.      * gets all Cookies 
  853.      * 
  854.      * @return   array with all internal cookies 
  855.      * @access   public 
  856.      */ 
  857.     function getCookies() { 
  858.         return $this->cookies; 
  859.     } 
  860.  
  861.     /** 
  862.      * checks all Cookies and delete those which are expired 
  863.      * 
  864.      * @return   boolean always return true 
  865.      * @access   private 
  866.      */ 
  867.     function checkCookies() { 
  868.         if (sizeof($this->cookies) == 0) { 
  869.             return true; 
  870.         } 
  871.         $this->debug('checkCookie: check ' . sizeof($this->cookies) . ' cookies'); 
  872.         $curr_cookies = $this->cookies; 
  873.         $this->cookies = array(); 
  874.         foreach ($curr_cookies as $cookie) { 
  875.             if (! is_array($cookie)) { 
  876.                 $this->debug('Remove cookie that is not an array'); 
  877.                 continue; 
  878.             } 
  879.             if ((isset($cookie['expires'])) && (! empty($cookie['expires']))) { 
  880.                 if (strtotime($cookie['expires']) > time()) { 
  881.                     $this->cookies[] = $cookie; 
  882.                 } else { 
  883.                     $this->debug('Remove expired cookie ' . $cookie['name']); 
  884.                 } 
  885.             } else { 
  886.                 $this->cookies[] = $cookie; 
  887.             } 
  888.         } 
  889.         $this->debug('checkCookie: '.sizeof($this->cookies).' cookies left in array'); 
  890.         return true; 
  891.     } 
  892.  
  893.     /** 
  894.      * updates the current cookies with a new set 
  895.      * 
  896.      * @param    array $cookies new cookies with which to update current ones 
  897.      * @return    boolean always return true 
  898.      * @access    private 
  899.      */ 
  900.     function UpdateCookies($cookies) { 
  901.         if (sizeof($this->cookies) == 0) { 
  902.             // no existing cookies: take whatever is new 
  903.             if (sizeof($cookies) > 0) { 
  904.                 $this->debug('Setting new cookie(s)'); 
  905.                 $this->cookies = $cookies; 
  906.             } 
  907.             return true; 
  908.         } 
  909.         if (sizeof($cookies) == 0) { 
  910.             // no new cookies: keep what we've got 
  911.             return true; 
  912.         } 
  913.         // merge 
  914.         foreach ($cookies as $newCookie) { 
  915.             if (!is_array($newCookie)) { 
  916.                 continue; 
  917.             } 
  918.             if ((!isset($newCookie['name'])) || (!isset($newCookie['value']))) { 
  919.                 continue; 
  920.             } 
  921.             $newName = $newCookie['name']; 
  922.  
  923.             $found = false; 
  924.             for ($i = 0; $i < count($this->cookies); $i++) { 
  925.                 $cookie = $this->cookies[$i]; 
  926.                 if (!is_array($cookie)) { 
  927.                     continue; 
  928.                 } 
  929.                 if (!isset($cookie['name'])) { 
  930.                     continue; 
  931.                 } 
  932.                 if ($newName != $cookie['name']) { 
  933.                     continue; 
  934.                 } 
  935.                 $newDomain = isset($newCookie['domain']) ? $newCookie['domain'] : 'NODOMAIN'; 
  936.                 $domain = isset($cookie['domain']) ? $cookie['domain'] : 'NODOMAIN'; 
  937.                 if ($newDomain != $domain) { 
  938.                     continue; 
  939.                 } 
  940.                 $newPath = isset($newCookie['path']) ? $newCookie['path'] : 'NOPATH'; 
  941.                 $path = isset($cookie['path']) ? $cookie['path'] : 'NOPATH'; 
  942.                 if ($newPath != $path) { 
  943.                     continue; 
  944.                 } 
  945.                 $this->cookies[$i] = $newCookie; 
  946.                 $found = true; 
  947.                 $this->debug('Update cookie ' . $newName . '=' . $newCookie['value']); 
  948.                 break; 
  949.             } 
  950.             if (! $found) { 
  951.                 $this->debug('Add cookie ' . $newName . '=' . $newCookie['value']); 
  952.                 $this->cookies[] = $newCookie; 
  953.             } 
  954.         } 
  955.         return true; 
  956.     } 
  957. } 
/lib/nusoap/nusoap.php  
  1. class nusoap_client extends nusoap_base  { 
  2.  
  3.     var $username = '';                // Username for HTTP authentication 
  4.     var $password = '';                // Password for HTTP authentication 
  5.     var $authtype = '';                // Type of HTTP authentication 
  6.     var $certRequest = array();        // Certificate for HTTP SSL authentication 
  7.     var $requestHeaders = false;    // SOAP headers in request (text) 
  8.     var $responseHeaders = '';        // SOAP headers from response (incomplete namespace resolution) (text) 
  9.     var $responseHeader = NULL;        // SOAP Header from response (parsed) 
  10.     var $document = '';                // SOAP body response portion (incomplete namespace resolution) (text) 
  11.     var $endpoint; 
  12.     var $forceEndpoint = '';        // overrides WSDL endpoint 
  13.     var $proxyhost = ''; 
  14.     var $proxyport = ''; 
  15.     var $proxyusername = ''; 
  16.     var $proxypassword = ''; 
  17.     var $portName = '';                // port name to use in WSDL 
  18.     var $xml_encoding = '';            // character set encoding of incoming (response) messages 
  19.     var $http_encoding = false; 
  20.     var $timeout = 0;                // HTTP connection timeout 
  21.     var $response_timeout = 30;        // HTTP response timeout 
  22.     var $endpointType = '';            // soap|wsdl, empty for WSDL initialization error 
  23.     var $persistentConnection = false; 
  24.     var $defaultRpcParams = false;    // This is no longer used 
  25.     var $request = '';                // HTTP request 
  26.     var $response = '';                // HTTP response 
  27.     var $responseData = '';            // SOAP payload of response 
  28.     var $cookies = array();            // Cookies from response or for request 
  29.     var $decode_utf8 = true;        // toggles whether the parser decodes element content w/ utf8_decode() 
  30.     var $operations = array();        // WSDL operations, empty for WSDL initialization error 
  31.     var $curl_options = array();    // User-specified cURL options 
  32.     var $bindingType = '';            // WSDL operation binding type 
  33.     var $use_curl = false;            // whether to always try to use cURL 
  34.  
  35.     /** 
  36.      * fault related variables 
  37.      */ 
  38.     /** 
  39.      * @var      fault 
  40.      * @access   public 
  41.      */ 
  42.     var $fault; 
  43.     /** 
  44.      * @var      faultcode 
  45.      * @access   public 
  46.      */ 
  47.     var $faultcode; 
  48.     /** 
  49.      * @var      faultstring 
  50.      * @access   public 
  51.      */ 
  52.     var $faultstring; 
  53.     /** 
  54.      * @var      faultdetail 
  55.      * @access   public 
  56.      */ 
  57.     var $faultdetail; 
  58.  
  59.     /** 
  60.     * constructor 
  61.     * 
  62.     * @param    mixed $endpoint SOAP server or WSDL URL (string), or wsdl instance (object) 
  63.     * @param    mixed $wsdl optional, set to 'wsdl' or true if using WSDL 
  64.     * @param    string $proxyhost optional 
  65.     * @param    string $proxyport optional 
  66.     * @param    string $proxyusername optional 
  67.     * @param    string $proxypassword optional 
  68.     * @param    integer $timeout set the connection timeout 
  69.     * @param    integer $response_timeout set the response timeout 
  70.     * @param    string $portName optional portName in WSDL document 
  71.     * @access   public 
  72.     */ 
  73.     function nusoap_client($endpoint, $wsdl = false, $proxyhost = false, $proxyport = false, $proxyusername = false, $proxypassword = false, $timeout = 0, $response_timeout = 30, $portName = '') { 
  74.         parent::nusoap_base(); 
  75.         $this->endpoint = $endpoint; 
  76.         $this->proxyhost = $proxyhost; 
  77.         $this->proxyport = $proxyport; 
  78.         $this->proxyusername = $proxyusername; 
  79.         $this->proxypassword = $proxypassword; 
  80.         $this->timeout = $timeout; 
  81.         $this->response_timeout = $response_timeout; 
  82.         $this->portName = $portName; 
  83.  
  84.         $this->debug("ctor wsdl=$wsdl timeout=$timeout response_timeout=$response_timeout"); 
  85.         $this->appendDebug('endpoint=' . $this->varDump($endpoint)); 
  86.  
  87.         // make values 
  88.         if($wsdl) { 
  89.             if (is_object($endpoint) && (get_class($endpoint) == 'wsdl')) { 
  90.                 $this->wsdl = $endpoint; 
  91.                 $this->endpoint = $this->wsdl->wsdl; 
  92.                 $this->wsdlFile = $this->endpoint; 
  93.                 $this->debug('existing wsdl instance created from ' . $this->endpoint); 
  94.                 $this->checkWSDL(); 
  95.             } else { 
  96.                 $this->wsdlFile = $this->endpoint; 
  97.                 $this->wsdl = null; 
  98.                 $this->debug('will use lazy evaluation of wsdl from ' . $this->endpoint); 
  99.             } 
  100.             $this->endpointType = 'wsdl'; 
  101.         } else { 
  102.             $this->debug("instantiate SOAP with endpoint at $endpoint"); 
  103.             $this->endpointType = 'soap'; 
  104.         } 
  105.     } 
  106.  
  107.     /** 
  108.     * calls method, returns PHP native type 
  109.     * 
  110.     * @param    string $operation SOAP server URL or path 
  111.     * @param    mixed $params An array, associative or simple, of the parameters 
  112.     *                          for the method call, or a string that is the XML 
  113.     *                          for the call.  For rpc style, this call will 
  114.     *                          wrap the XML in a tag named after the method, as 
  115.     *                          well as the SOAP Envelope and Body.  For document 
  116.     *                          style, this will only wrap with the Envelope and Body. 
  117.     *                          IMPORTANT: when using an array with document style,  
  118.     *                          in which case there 
  119.     *                         is really one parameter, the root of the fragment 
  120.     *                         used in the call, which encloses what programmers 
  121.     *                         normally think of parameters.  A parameter array 
  122.     *                         *must* include the wrapper. 
  123.     * @param    string $namespace optional method namespace (WSDL can override) 
  124.     * @param    string $soapAction optional SOAPAction value (WSDL can override) 
  125.     * @param    mixed $headers optional string of XML with SOAP header content, or array of soapval objects for SOAP headers, or associative array 
  126.     * @param    boolean $rpcParams optional (no longer used) 
  127.     * @param    string    $style optional (rpc|document) the style to use when serializing parameters (WSDL can override) 
  128.     * @param    string    $use optional (encoded|literal) the use when serializing parameters (WSDL can override) 
  129.     * @return    mixed    response from SOAP call, normally an associative array mirroring the structure of the XML response, false for certain fatal errors 
  130.     * @access   public 
  131.     */ 
  132.     function call($operation, $params=array(), $namespace='http://tempuri.org', $soapAction='', $headers=false, $rpcParams=null, $style='rpc', $use='encoded') { 
  133.         $this->operation = $operation; 
  134.         $this->fault = false; 
  135.         $this->setError(''); 
  136.         $this->request = ''; 
  137.         $this->response = ''; 
  138.         $this->responseData = ''; 
  139.         $this->faultstring = ''; 
  140.         $this->faultcode = ''; 
  141.         $this->opData = array(); 
  142.          
  143.         $this->debug("call: operation=$operation, namespace=$namespace, soapAction=$soapAction, rpcParams=$rpcParams, style=$style, use=$use, endpointType=$this->endpointType"); 
  144.         $this->appendDebug('params=' . $this->varDump($params)); 
  145.         $this->appendDebug('headers=' . $this->varDump($headers)); 
  146.         if ($headers) { 
  147.             $this->requestHeaders = $headers; 
  148.         } 
  149.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  150.             $this->loadWSDL(); 
  151.             if ($this->getError()) 
  152.                 return false; 
  153.         } 
  154.         // serialize parameters 
  155.         if($this->endpointType == 'wsdl' && $opData = $this->getOperationData($operation)) { 
  156.             // use WSDL for operation 
  157.             $this->opData = $opData; 
  158.             $this->debug("found operation"); 
  159.             $this->appendDebug('opData=' . $this->varDump($opData)); 
  160.             if (isset($opData['soapAction'])) { 
  161.                 $soapAction = $opData['soapAction']; 
  162.             } 
  163.             if (! $this->forceEndpoint) { 
  164.                 $this->endpoint = $opData['endpoint']; 
  165.             } else { 
  166.                 $this->endpoint = $this->forceEndpoint; 
  167.             } 
  168.             $namespace = isset($opData['input']['namespace']) ? $opData['input']['namespace'] :    $namespace; 
  169.             $style = $opData['style']; 
  170.             $use = $opData['input']['use']; 
  171.             // add ns to ns array 
  172.             if($namespace != '' && !isset($this->wsdl->namespaces[$namespace])) { 
  173.                 $nsPrefix = 'ns' . rand(1000, 9999); 
  174.                 $this->wsdl->namespaces[$nsPrefix] = $namespace; 
  175.             } 
  176.             $nsPrefix = $this->wsdl->getPrefixFromNamespace($namespace); 
  177.             // serialize payload 
  178.             if (is_string($params)) { 
  179.                 $this->debug("serializing param string for WSDL operation $operation"); 
  180.                 $payload = $params; 
  181.             } elseif (is_array($params)) { 
  182.                 $this->debug("serializing param array for WSDL operation $operation"); 
  183.                 $payload = $this->wsdl->serializeRPCParameters($operation, 'input', $params, $this->bindingType); 
  184.             } else { 
  185.                 $this->debug('params must be array or string'); 
  186.                 $this->setError('params must be array or string'); 
  187.                 return false; 
  188.             } 
  189.             $usedNamespaces = $this->wsdl->usedNamespaces; 
  190.             if (isset($opData['input']['encodingStyle'])) { 
  191.                 $encodingStyle = $opData['input']['encodingStyle']; 
  192.             } else { 
  193.                 $encodingStyle = ''; 
  194.             } 
  195.             $this->appendDebug($this->wsdl->getDebug()); 
  196.             $this->wsdl->clearDebug(); 
  197.             if ($errstr = $this->wsdl->getError()) { 
  198.                 $this->debug('got wsdl error: '.$errstr); 
  199.                 $this->setError('wsdl error: '.$errstr); 
  200.                 return false; 
  201.             } 
  202.         } elseif($this->endpointType == 'wsdl') { 
  203.             // operation not in WSDL 
  204.             $this->appendDebug($this->wsdl->getDebug()); 
  205.             $this->wsdl->clearDebug(); 
  206.             $this->setError('operation '.$operation.' not present in WSDL.'); 
  207.             $this->debug("operation '$operation' not present in WSDL."); 
  208.             return false; 
  209.         } else { 
  210.             // no WSDL 
  211.             //$this->namespaces['ns1'] = $namespace; 
  212.             $nsPrefix = 'ns' . rand(1000, 9999); 
  213.             // serialize  
  214.             $payload = ''; 
  215.             if (is_string($params)) { 
  216.                 $this->debug("serializing param string for operation $operation"); 
  217.                 $payload = $params; 
  218.             } elseif (is_array($params)) { 
  219.                 $this->debug("serializing param array for operation $operation"); 
  220.                 foreach($params as $k => $v) { 
  221.                     $payload .= $this->serialize_val($v, $k, false, false, false, false, $use); 
  222.                 } 
  223.             } else { 
  224.                 $this->debug('params must be array or string'); 
  225.                 $this->setError('params must be array or string'); 
  226.                 return false; 
  227.             } 
  228.             $usedNamespaces = array(); 
  229.             if ($use == 'encoded') { 
  230.                 $encodingStyle = 'http://schemas.xmlsoap.org/soap/encoding/'; 
  231.             } else { 
  232.                 $encodingStyle = ''; 
  233.             } 
  234.         } 
  235.         // wrap RPC calls with method element 
  236.         if ($style == 'rpc') { 
  237.             if ($use == 'literal') { 
  238.                 $this->debug("wrapping RPC request with literal method element"); 
  239.                 if ($namespace) { 
  240.                     // http://www.ws-i.org/Profiles/BasicProfile-1.1-2004-08-24.html R2735 says rpc/literal accessor elements should not be in a namespace 
  241.                     $payload = "<$nsPrefix:$operation xmlns:$nsPrefix=\"$namespace\">" . 
  242.                                 $payload . 
  243.                                 "</$nsPrefix:$operation>"; 
  244.                 } else { 
  245.                     $payload = "<$operation>" . $payload . "</$operation>"; 
  246.                 } 
  247.             } else { 
  248.                 $this->debug("wrapping RPC request with encoded method element"); 
  249.                 if ($namespace) { 
  250.                     $payload = "<$nsPrefix:$operation xmlns:$nsPrefix=\"$namespace\">" . 
  251.                                 $payload . 
  252.                                 "</$nsPrefix:$operation>"; 
  253.                 } else { 
  254.                     $payload = "<$operation>" . 
  255.                                 $payload . 
  256.                                 "</$operation>"; 
  257.                 } 
  258.             } 
  259.         } 
  260.         // serialize envelope 
  261.         $soapmsg = $this->serializeEnvelope($payload, $this->requestHeaders, $usedNamespaces, $style, $use, $encodingStyle); 
  262.         $this->debug("endpoint=$this->endpoint, soapAction=$soapAction, namespace=$namespace, style=$style, use=$use, encodingStyle=$encodingStyle"); 
  263.         $this->debug('SOAP message length=' . strlen($soapmsg) . ' contents (max 1000 bytes)=' . substr($soapmsg, 0, 1000)); 
  264.         // send 
  265.         $return = $this->send($this->getHTTPBody($soapmsg), $soapAction, $this->timeout, $this->response_timeout); 
  266.         if($errstr = $this->getError()) { 
  267.             $this->debug('Error: '.$errstr); 
  268.             return false; 
  269.         } else { 
  270.             $this->return = $return; 
  271.             $this->debug('sent message successfully and got a(n) '.gettype($return)); 
  272.                $this->appendDebug('return=' . $this->varDump($return)); 
  273.              
  274.             // fault? 
  275.             if(is_array($return) && isset($return['faultcode'])) { 
  276.                 $this->debug('got fault'); 
  277.                 $this->setError($return['faultcode'].': '.$return['faultstring']); 
  278.                 $this->fault = true; 
  279.                 foreach($return as $k => $v) { 
  280.                     $this->$k = $v; 
  281.                     $this->debug("$k = $v<br>"); 
  282.                 } 
  283.                 return $return; 
  284.             } elseif ($style == 'document') { 
  285.                 // NOTE: if the response is defined to have multiple parts (i.e. unwrapped),  
  286.                 // we are only going to return the first part here...sorry about that 
  287.                 return $return; 
  288.             } else { 
  289.                 // array of return values 
  290.                 if(is_array($return)) { 
  291.                     // multiple 'out' parameters, which we return wrapped up 
  292.                     // in the array 
  293.                     if(sizeof($return) > 1) { 
  294.                         return $return; 
  295.                     } 
  296.                     // single 'out' parameter (normally the return value) 
  297.                     $return = array_shift($return); 
  298.                     $this->debug('return shifted value: '); 
  299.                     $this->appendDebug($this->varDump($return)); 
  300.                        return $return; 
  301.                 // nothing returned (ie, echoVoid) 
  302.                 } else { 
  303.                     return ""; 
  304.                 } 
  305.             } 
  306.         } 
  307.     } 
  308.  
  309.     /** 
  310.     * check WSDL passed as an instance or pulled from an endpoint 
  311.     * 
  312.     * @access   private 
  313.     */ 
  314.     function checkWSDL() { 
  315.         $this->appendDebug($this->wsdl->getDebug()); 
  316.         $this->wsdl->clearDebug(); 
  317.         $this->debug('checkWSDL'); 
  318.         // catch errors 
  319.         if ($errstr = $this->wsdl->getError()) { 
  320.             $this->appendDebug($this->wsdl->getDebug()); 
  321.             $this->wsdl->clearDebug(); 
  322.             $this->debug('got wsdl error: '.$errstr); 
  323.             $this->setError('wsdl error: '.$errstr); 
  324.         } elseif ($this->operations = $this->wsdl->getOperations($this->portName, 'soap')) { 
  325.             $this->appendDebug($this->wsdl->getDebug()); 
  326.             $this->wsdl->clearDebug(); 
  327.             $this->bindingType = 'soap'; 
  328.             $this->debug('got '.count($this->operations).' operations from wsdl '.$this->wsdlFile.' for binding type '.$this->bindingType); 
  329.         } elseif ($this->operations = $this->wsdl->getOperations($this->portName, 'soap12')) { 
  330.             $this->appendDebug($this->wsdl->getDebug()); 
  331.             $this->wsdl->clearDebug(); 
  332.             $this->bindingType = 'soap12'; 
  333.             $this->debug('got '.count($this->operations).' operations from wsdl '.$this->wsdlFile.' for binding type '.$this->bindingType); 
  334.             $this->debug('**************** WARNING: SOAP 1.2 BINDING *****************'); 
  335.         } else { 
  336.             $this->appendDebug($this->wsdl->getDebug()); 
  337.             $this->wsdl->clearDebug(); 
  338.             $this->debug('getOperations returned false'); 
  339.             $this->setError('no operations defined in the WSDL document!'); 
  340.         } 
  341.     } 
  342.  
  343.     /** 
  344.      * instantiate wsdl object and parse wsdl file 
  345.      * 
  346.      * @access    public 
  347.      */ 
  348.     function loadWSDL() { 
  349.         $this->debug('instantiating wsdl class with doc: '.$this->wsdlFile); 
  350.         $this->wsdl = new wsdl('', $this->proxyhost, $this->proxyport, $this->proxyusername, $this->proxypassword, $this->timeout, $this->response_timeout, $this->curl_options, $this->use_curl); 
  351.         $this->wsdl->setCredentials($this->username, $this->password, $this->authtype, $this->certRequest); 
  352.         $this->wsdl->fetchWSDL($this->wsdlFile); 
  353.         $this->checkWSDL(); 
  354.     } 
  355.  
  356.     /** 
  357.     * get available data pertaining to an operation 
  358.     * 
  359.     * @param    string $operation operation name 
  360.     * @return    array array of data pertaining to the operation 
  361.     * @access   public 
  362.     */ 
  363.     function getOperationData($operation) { 
  364.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  365.             $this->loadWSDL(); 
  366.             if ($this->getError()) 
  367.                 return false; 
  368.         } 
  369.         if(isset($this->operations[$operation])) { 
  370.             return $this->operations[$operation]; 
  371.         } 
  372.         $this->debug("No data for operation: $operation"); 
  373.     } 
  374.  
  375.     /** 
  376.     * send the SOAP message 
  377.     * 
  378.     * Note: if the operation has multiple return values 
  379.     * the return value of this method will be an array 
  380.     * of those values. 
  381.     * 
  382.     * @param    string $msg a SOAPx4 soapmsg object 
  383.     * @param    string $soapaction SOAPAction value 
  384.     * @param    integer $timeout set connection timeout in seconds 
  385.     * @param    integer $response_timeout set response timeout in seconds 
  386.     * @return    mixed native PHP types. 
  387.     * @access   private 
  388.     */ 
  389.     function send($msg, $soapaction = '', $timeout=0, $response_timeout=30) { 
  390.         $this->checkCookies(); 
  391.         // detect transport 
  392.         switch(true) { 
  393.             // http(s) 
  394.             case preg_match('/^http/', $this->endpoint): 
  395.                 $this->debug('transporting via HTTP'); 
  396.                 if($this->persistentConnection == true && is_object($this->persistentConnection)) { 
  397.                     $http =& $this->persistentConnection; 
  398.                 } else { 
  399.                     $http = new soap_transport_http($this->endpoint, $this->curl_options, $this->use_curl); 
  400.                     if ($this->persistentConnection) { 
  401.                         $http->usePersistentConnection(); 
  402.                     } 
  403.                 } 
  404.                 $http->setContentType($this->getHTTPContentType(), $this->getHTTPContentTypeCharset()); 
  405.                 $http->setSOAPAction($soapaction); 
  406.                 if($this->proxyhost && $this->proxyport) { 
  407.                     $http->setProxy($this->proxyhost, $this->proxyport, $this->proxyusername, $this->proxypassword); 
  408.                 } 
  409.                 if($this->authtype != '') { 
  410.                     $http->setCredentials($this->username, $this->password, $this->authtype, array(), $this->certRequest); 
  411.                 } 
  412.                 if($this->http_encoding != '') { 
  413.                     $http->setEncoding($this->http_encoding); 
  414.                 } 
  415.                 $this->debug('sending message, length='.strlen($msg)); 
  416.                 if(preg_match('/^http:/', $this->endpoint)) { 
  417.                 //if(strpos($this->endpoint, 'http:')) { 
  418.                     $this->responseData = $http->send($msg, $timeout, $response_timeout, $this->cookies); 
  419.                 } elseif(preg_match('/^https/', $this->endpoint)) { 
  420.                 //} elseif(strpos($this->endpoint, 'https:')) { 
  421.                     //if(phpversion() == '4.3.0-dev') { 
  422.                         //$response = $http->send($msg, $timeout, $response_timeout); 
  423.                            //$this->request = $http->outgoing_payload; 
  424.                         //$this->response = $http->incoming_payload; 
  425.                     //} else 
  426.                     $this->responseData = $http->sendHTTPS($msg, $timeout, $response_timeout, $this->cookies); 
  427.                 } else { 
  428.                     $this->setError('no http/s in endpoint url'); 
  429.                 } 
  430.                 $this->request = $http->outgoing_payload; 
  431.                 $this->response = $http->incoming_payload; 
  432.                 $this->appendDebug($http->getDebug()); 
  433.                 $this->UpdateCookies($http->incoming_cookies); 
  434.  
  435.                 // save transport object if using persistent connections 
  436.                 if ($this->persistentConnection) { 
  437.                     $http->clearDebug(); 
  438.                     if (!is_object($this->persistentConnection)) { 
  439.                         $this->persistentConnection = $http; 
  440.                     } 
  441.                 } 
  442.                  
  443.                 if($err = $http->getError()) { 
  444.                     $this->setError('HTTP Error: '.$err); 
  445.                     return false; 
  446.                 } elseif($this->getError()) { 
  447.                     return false; 
  448.                 } else { 
  449.                     $this->debug('got response, length='. strlen($this->responseData).' type='.$http->incoming_headers['content-type']); 
  450.                     return $this->parseResponse($http->incoming_headers, $this->responseData); 
  451.                 } 
  452.             break; 
  453.             default: 
  454.                 $this->setError('no transport found, or selected transport is not yet supported!'); 
  455.             return false; 
  456.             break; 
  457.         } 
  458.     } 
  459.  
  460.     /** 
  461.     * processes SOAP message returned from server 
  462.     * 
  463.     * @param    array    $headers    The HTTP headers 
  464.     * @param    string    $data        unprocessed response data from server 
  465.     * @return    mixed    value of the message, decoded into a PHP type 
  466.     * @access   private 
  467.     */ 
  468.     function parseResponse($headers, $data) { 
  469.         $this->debug('Entering parseResponse() for data of length ' . strlen($data) . ' headers:'); 
  470.         $this->appendDebug($this->varDump($headers)); 
  471.         if (!isset($headers['content-type'])) { 
  472.             $this->setError('Response not of type text/xml (no content-type header)'); 
  473.             return false; 
  474.         } 
  475.         if (!strstr($headers['content-type'], 'text/xml')) { 
  476.             $this->setError('Response not of type text/xml: ' . $headers['content-type']); 
  477.             return false; 
  478.         } 
  479.         if (strpos($headers['content-type'], '=')) { 
  480.             $enc = str_replace('"', '', substr(strstr($headers["content-type"], '='), 1)); 
  481.             $this->debug('Got response encoding: ' . $enc); 
  482.             if(preg_match('/^(ISO-8859-1|US-ASCII|UTF-8)$/i', $enc)) { 
  483.                 $this->xml_encoding = strtoupper($enc); 
  484.             } else { 
  485.                 $this->xml_encoding = 'US-ASCII'; 
  486.             } 
  487.         } else { 
  488.             // should be US-ASCII for HTTP 1.0 or ISO-8859-1 for HTTP 1.1 
  489.             $this->xml_encoding = 'UTF-8'; 
  490.         } 
  491.         $this->debug('Use encoding: ' . $this->xml_encoding . ' when creating nusoap_parser'); 
  492.         $parser = new nusoap_parser($data, $this->xml_encoding, $this->operation, $this->decode_utf8); 
  493.         // add parser debug data to our debug 
  494.         $this->appendDebug($parser->getDebug()); 
  495.         // if parse errors 
  496.         if($errstr = $parser->getError()) { 
  497.             $this->setError( $errstr); 
  498.             // destroy the parser object 
  499.             unset($parser); 
  500.             return false; 
  501.         } else { 
  502.             // get SOAP headers 
  503.             $this->responseHeaders = $parser->getHeaders(); 
  504.             // get SOAP headers 
  505.             $this->responseHeader = $parser->get_soapheader(); 
  506.             // get decoded message 
  507.             $return = $parser->get_soapbody(); 
  508.             // add document for doclit support 
  509.             $this->document = $parser->document; 
  510.             // destroy the parser object 
  511.             unset($parser); 
  512.             // return decode message 
  513.             return $return; 
  514.         } 
  515.      } 
  516.  
  517.     /** 
  518.     * sets user-specified cURL options 
  519.     * 
  520.     * @param    mixed $option The cURL option (always integer?) 
  521.     * @param    mixed $value The cURL option value 
  522.     * @access   public 
  523.     */ 
  524.     function setCurlOption($option, $value) { 
  525.         $this->debug("setCurlOption option=$option, value="); 
  526.         $this->appendDebug($this->varDump($value)); 
  527.         $this->curl_options[$option] = $value; 
  528.     } 
  529.  
  530.     /** 
  531.     * sets the SOAP endpoint, which can override WSDL 
  532.     * 
  533.     * @param    string $endpoint The endpoint URL to use, or empty string or false to prevent override 
  534.     * @access   public 
  535.     */ 
  536.     function setEndpoint($endpoint) { 
  537.         $this->debug("setEndpoint(\"$endpoint\")"); 
  538.         $this->forceEndpoint = $endpoint; 
  539.     } 
  540.  
  541.     /** 
  542.     * set the SOAP headers 
  543.     * 
  544.     * @param    mixed $headers String of XML with SOAP header content, or array of soapval objects for SOAP headers 
  545.     * @access   public 
  546.     */ 
  547.     function setHeaders($headers) { 
  548.         $this->debug("setHeaders headers="); 
  549.         $this->appendDebug($this->varDump($headers)); 
  550.         $this->requestHeaders = $headers; 
  551.     } 
  552.  
  553.     /** 
  554.     * get the SOAP response headers (namespace resolution incomplete) 
  555.     * 
  556.     * @return    string 
  557.     * @access   public 
  558.     */ 
  559.     function getHeaders() { 
  560.         return $this->responseHeaders; 
  561.     } 
  562.  
  563.     /** 
  564.     * get the SOAP response Header (parsed) 
  565.     * 
  566.     * @return    mixed 
  567.     * @access   public 
  568.     */ 
  569.     function getHeader() { 
  570.         return $this->responseHeader; 
  571.     } 
  572.  
  573.     /** 
  574.     * set proxy info here 
  575.     * 
  576.     * @param    string $proxyhost 
  577.     * @param    string $proxyport 
  578.     * @param    string $proxyusername 
  579.     * @param    string $proxypassword 
  580.     * @access   public 
  581.     */ 
  582.     function setHTTPProxy($proxyhost, $proxyport, $proxyusername = '', $proxypassword = '') { 
  583.         $this->proxyhost = $proxyhost; 
  584.         $this->proxyport = $proxyport; 
  585.         $this->proxyusername = $proxyusername; 
  586.         $this->proxypassword = $proxypassword; 
  587.     } 
  588.  
  589.     /** 
  590.     * if authenticating, set user credentials here 
  591.     * 
  592.     * @param    string $username 
  593.     * @param    string $password 
  594.     * @param    string $authtype (basic|digest|certificate|ntlm) 
  595.     * @param    array $certRequest (keys must be cainfofile (optional), sslcertfile, sslkeyfile, passphrase, verifypeer (optional), verifyhost (optional): see corresponding options in cURL docs) 
  596.     * @access   public 
  597.     */ 
  598.     function setCredentials($username, $password, $authtype = 'basic', $certRequest = array()) { 
  599.         $this->debug("setCredentials username=$username authtype=$authtype certRequest="); 
  600.         $this->appendDebug($this->varDump($certRequest)); 
  601.         $this->username = $username; 
  602.         $this->password = $password; 
  603.         $this->authtype = $authtype; 
  604.         $this->certRequest = $certRequest; 
  605.     } 
  606.      
  607.     /** 
  608.     * use HTTP encoding 
  609.     * 
  610.     * @param    string $enc HTTP encoding 
  611.     * @access   public 
  612.     */ 
  613.     function setHTTPEncoding($enc='gzip, deflate') { 
  614.         $this->debug("setHTTPEncoding(\"$enc\")"); 
  615.         $this->http_encoding = $enc; 
  616.     } 
  617.      
  618.     /** 
  619.     * Set whether to try to use cURL connections if possible 
  620.     * 
  621.     * @param    boolean $use Whether to try to use cURL 
  622.     * @access   public 
  623.     */ 
  624.     function setUseCURL($use) { 
  625.         $this->debug("setUseCURL($use)"); 
  626.         $this->use_curl = $use; 
  627.     } 
  628.  
  629.     /** 
  630.     * use HTTP persistent connections if possible 
  631.     * 
  632.     * @access   public 
  633.     */ 
  634.     function useHTTPPersistentConnection() { 
  635.         $this->debug("useHTTPPersistentConnection"); 
  636.         $this->persistentConnection = true; 
  637.     } 
  638.      
  639.     /** 
  640.     * gets the default RPC parameter setting. 
  641.     * If true, default is that call params are like RPC even for document style. 
  642.     * Each call() can override this value. 
  643.     * 
  644.     * This is no longer used. 
  645.     * 
  646.     * @return boolean 
  647.     * @access public 
  648.     * @deprecated 
  649.     */ 
  650.     function getDefaultRpcParams() { 
  651.         return $this->defaultRpcParams; 
  652.     } 
  653.  
  654.     /** 
  655.     * sets the default RPC parameter setting. 
  656.     * If true, default is that call params are like RPC even for document style 
  657.     * Each call() can override this value. 
  658.     * 
  659.     * This is no longer used. 
  660.     * 
  661.     * @param    boolean $rpcParams 
  662.     * @access public 
  663.     * @deprecated 
  664.     */ 
  665.     function setDefaultRpcParams($rpcParams) { 
  666.         $this->defaultRpcParams = $rpcParams; 
  667.     } 
  668.      
  669.     /** 
  670.     * dynamically creates an instance of a proxy class,  
  671.     * allowing user to directly call methods from wsdl 
  672.     * 
  673.     * @return   object soap_proxy object 
  674.     * @access   public 
  675.     */ 
  676.     function getProxy() { 
  677.         $r = rand(); 
  678.         $evalStr = $this->_getProxyClassCode($r); 
  679.         //$this->debug("proxy class: $evalStr"); 
  680.         if ($this->getError()) { 
  681.             $this->debug("Error from _getProxyClassCode, so return NULL"); 
  682.             return null; 
  683.         } 
  684.         // eval the class 
  685.         eval($evalStr); 
  686.         // instantiate proxy object 
  687.         eval("\$proxy = new nusoap_proxy_$r('');"); 
  688.         // transfer current wsdl data to the proxy thereby avoiding parsing the wsdl twice 
  689.         $proxy->endpointType = 'wsdl'; 
  690.         $proxy->wsdlFile = $this->wsdlFile; 
  691.         $proxy->wsdl = $this->wsdl; 
  692.         $proxy->operations = $this->operations; 
  693.         $proxy->defaultRpcParams = $this->defaultRpcParams; 
  694.         // transfer other state 
  695.         $proxy->soap_defencoding = $this->soap_defencoding; 
  696.         $proxy->username = $this->username; 
  697.         $proxy->password = $this->password; 
  698.         $proxy->authtype = $this->authtype; 
  699.         $proxy->certRequest = $this->certRequest; 
  700.         $proxy->requestHeaders = $this->requestHeaders; 
  701.         $proxy->endpoint = $this->endpoint; 
  702.         $proxy->forceEndpoint = $this->forceEndpoint; 
  703.         $proxy->proxyhost = $this->proxyhost; 
  704.         $proxy->proxyport = $this->proxyport; 
  705.         $proxy->proxyusername = $this->proxyusername; 
  706.         $proxy->proxypassword = $this->proxypassword; 
  707.         $proxy->http_encoding = $this->http_encoding; 
  708.         $proxy->timeout = $this->timeout; 
  709.         $proxy->response_timeout = $this->response_timeout; 
  710.         $proxy->persistentConnection = &$this->persistentConnection; 
  711.         $proxy->decode_utf8 = $this->decode_utf8; 
  712.         $proxy->curl_options = $this->curl_options; 
  713.         $proxy->bindingType = $this->bindingType; 
  714.         $proxy->use_curl = $this->use_curl; 
  715.         return $proxy; 
  716.     } 
  717.  
  718.     /** 
  719.     * dynamically creates proxy class code 
  720.     * 
  721.     * @return   string PHP/NuSOAP code for the proxy class 
  722.     * @access   private 
  723.     */ 
  724.     function _getProxyClassCode($r) { 
  725.         $this->debug("in getProxy endpointType=$this->endpointType"); 
  726.         $this->appendDebug("wsdl=" . $this->varDump($this->wsdl)); 
  727.         if ($this->endpointType != 'wsdl') { 
  728.             $evalStr = 'A proxy can only be created for a WSDL client'; 
  729.             $this->setError($evalStr); 
  730.             $evalStr = "echo \"$evalStr\";"; 
  731.             return $evalStr; 
  732.         } 
  733.         if ($this->endpointType == 'wsdl' && is_null($this->wsdl)) { 
  734.             $this->loadWSDL(); 
  735.             if ($this->getError()) { 
  736.                 return "echo \"" . $this->getError() . "\";"; 
  737.             } 
  738.         } 
  739.         $evalStr = ''; 
  740.         foreach ($this->operations as $operation => $opData) { 
  741.             if ($operation != '') { 
  742.                 // create param string and param comment string 
  743.                 if (sizeof($opData['input']['parts']) > 0) { 
  744.                     $paramStr = ''; 
  745.                     $paramArrayStr = ''; 
  746.                     $paramCommentStr = ''; 
  747.                     foreach ($opData['input']['parts'] as $name => $type) { 
  748.                         $paramStr .= "\$$name, "; 
  749.                         $paramArrayStr .= "'$name' => \$$name, "; 
  750.                         $paramCommentStr .= "$type \$$name, "; 
  751.                     } 
  752.                     $paramStr = substr($paramStr, 0, strlen($paramStr)-2); 
  753.                     $paramArrayStr = substr($paramArrayStr, 0, strlen($paramArrayStr)-2); 
  754.                     $paramCommentStr = substr($paramCommentStr, 0, strlen($paramCommentStr)-2); 
  755.                 } else { 
  756.                     $paramStr = ''; 
  757.                     $paramArrayStr = ''; 
  758.                     $paramCommentStr = 'void'; 
  759.                 } 
  760.                 $opData['namespace'] = !isset($opData['namespace']) ? 'http://testuri.com' : $opData['namespace']; 
  761.                 $evalStr .= "// $paramCommentStr 
  762.     function " . str_replace('.', '__', $operation) . "($paramStr) { 
  763.         \$params = array($paramArrayStr); 
  764.         return \$this->call('$operation', \$params, '".$opData['namespace']."', '".(isset($opData['soapAction']) ? $opData['soapAction'] : '')."'); 
  765.     } 
  766.     "; 
  767.                 unset($paramStr); 
  768.                 unset($paramCommentStr); 
  769.             } 
  770.         } 
  771.         $evalStr = 'class nusoap_proxy_'.$r.' extends nusoap_client { 
  772.     '.$evalStr.' 
  773. }'; 
  774.         return $evalStr; 
  775.     } 
  776.  
  777.     /** 
  778.     * dynamically creates proxy class code 
  779.     * 
  780.     * @return   string PHP/NuSOAP code for the proxy class 
  781.     * @access   public 
  782.     */ 
  783.     function getProxyClassCode() { 
  784.         $r = rand(); 
  785.         return $this->_getProxyClassCode($r); 
  786.     } 
  787.  
  788.     /** 
  789.     * gets the HTTP body for the current request. 
  790.     * 
  791.     * @param string $soapmsg The SOAP payload 
  792.     * @return string The HTTP body, which includes the SOAP payload 
  793.     * @access private 
  794.     */ 
  795.     function getHTTPBody($soapmsg) { 
  796.         return $soapmsg; 
  797.     } 
  798.      
  799.     /** 
  800.     * gets the HTTP content type for the current request. 
  801.     * 
  802.     * Note: getHTTPBody must be called before this. 
  803.     * 
  804.     * @return string the HTTP content type for the current request. 
  805.     * @access private 
  806.     */ 
  807.     function getHTTPContentType() { 
  808.         return 'text/xml'; 
  809.     } 
  810.      
  811.     /** 
  812.     * gets the HTTP content type charset for the current request. 
  813.     * returns false for non-text content types. 
  814.     * 
  815.     * Note: getHTTPBody must be called before this. 
  816.     * 
  817.     * @return string the HTTP content type charset for the current request. 
  818.     * @access private 
  819.     */ 
  820.     function getHTTPContentTypeCharset() { 
  821.         return $this->soap_defencoding; 
  822.     } 
  823.  
  824.     /** 
  825.     * whether or not parser should decode utf8 element content 
  826.     * 
  827.     * @return   always returns true 
  828.     * @access   public 
  829.     */ 
  830.     function decodeUTF8($bool) { 
  831.         $this->decode_utf8 = $bool; 
  832.         return true; 
  833.     } 
  834.  
  835.     /** 
  836.      * adds a new Cookie into $this->cookies array 
  837.      * 
  838.      * @param    string $name Cookie Name 
  839.      * @param    string $value Cookie Value 
  840.      * @return    boolean if cookie-set was successful returns true, else false 
  841.      * @access    public 
  842.      */ 
  843.     function setCookie($name, $value) { 
  844.         if (strlen($name) == 0) { 
  845.             return false; 
  846.         } 
  847.         $this->cookies[] = array('name' => $name, 'value' => $value); 
  848.         return true; 
  849.     } 
  850.  
  851.     /** 
  852.      * gets all Cookies 
  853.      * 
  854.      * @return   array with all internal cookies 
  855.      * @access   public 
  856.      */ 
  857.     function getCookies() { 
  858.         return $this->cookies; 
  859.     } 
  860.  
  861.     /** 
  862.      * checks all Cookies and delete those which are expired 
  863.      * 
  864.      * @return   boolean always return true 
  865.      * @access   private 
  866.      */ 
  867.     function checkCookies() { 
  868.         if (sizeof($this->cookies) == 0) { 
  869.             return true; 
  870.         } 
  871.         $this->debug('checkCookie: check ' . sizeof($this->cookies) . ' cookies'); 
  872.         $curr_cookies = $this->cookies; 
  873.         $this->cookies = array(); 
  874.         foreach ($curr_cookies as $cookie) { 
  875.             if (! is_array($cookie)) { 
  876.                 $this->debug('Remove cookie that is not an array'); 
  877.                 continue; 
  878.             } 
  879.             if ((isset($cookie['expires'])) && (! empty($cookie['expires']))) { 
  880.                 if (strtotime($cookie['expires']) > time()) { 
  881.                     $this->cookies[] = $cookie; 
  882.                 } else { 
  883.                     $this->debug('Remove expired cookie ' . $cookie['name']); 
  884.                 } 
  885.             } else { 
  886.                 $this->cookies[] = $cookie; 
  887.             } 
  888.         } 
  889.         $this->debug('checkCookie: '.sizeof($this->cookies).' cookies left in array'); 
  890.         return true; 
  891.     } 
  892.  
  893.     /** 
  894.      * updates the current cookies with a new set 
  895.      * 
  896.      * @param    array $cookies new cookies with which to update current ones 
  897.      * @return    boolean always return true 
  898.      * @access    private 
  899.      */ 
  900.     function UpdateCookies($cookies) { 
  901.         if (sizeof($this->cookies) == 0) { 
  902.             // no existing cookies: take whatever is new 
  903.             if (sizeof($cookies) > 0) { 
  904.                 $this->debug('Setting new cookie(s)'); 
  905.                 $this->cookies = $cookies; 
  906.             } 
  907.             return true; 
  908.         } 
  909.         if (sizeof($cookies) == 0) { 
  910.             // no new cookies: keep what we've got 
  911.             return true; 
  912.         } 
  913.         // merge 
  914.         foreach ($cookies as $newCookie) { 
  915.             if (!is_array($newCookie)) { 
  916.                 continue; 
  917.             } 
  918.             if ((!isset($newCookie['name'])) || (!isset($newCookie['value']))) { 
  919.                 continue; 
  920.             } 
  921.             $newName = $newCookie['name']; 
  922.  
  923.             $found = false; 
  924.             for ($i = 0; $i < count($this->cookies); $i++) { 
  925.                 $cookie = $this->cookies[$i]; 
  926.                 if (!is_array($cookie)) { 
  927.                     continue; 
  928.                 } 
  929.                 if (!isset($cookie['name'])) { 
  930.                     continue; 
  931.                 } 
  932.                 if ($newName != $cookie['name']) { 
  933.                     continue; 
  934.                 } 
  935.                 $newDomain = isset($newCookie['domain']) ? $newCookie['domain'] : 'NODOMAIN'; 
  936.                 $domain = isset($cookie['domain']) ? $cookie['domain'] : 'NODOMAIN'; 
  937.                 if ($newDomain != $domain) { 
  938.                     continue; 
  939.                 } 
  940.                 $newPath = isset($newCookie['path']) ? $newCookie['path'] : 'NOPATH'; 
  941.                 $path = isset($cookie['path']) ? $cookie['path'] : 'NOPATH'; 
  942.                 if ($newPath != $path) { 
  943.                     continue; 
  944.                 } 
  945.                 $this->cookies[$i] = $newCookie; 
  946.                 $found = true; 
  947.                 $this->debug('Update cookie ' . $newName . '=' . $newCookie['value']); 
  948.                 break; 
  949.             } 
  950.             if (! $found) { 
  951.                 $this->debug('Add cookie ' . $newName . '=' . $newCookie['value']); 
  952.                 $this->cookies[] = $newCookie; 
  953.             } 
  954.         } 
  955.         return true; 
  956.     } 
  957. }