server = $bits['host']; $this->port = isset($bits['port']) ? $bits['port'] : 80; $this->path = isset($bits['path']) ? $bits['path'] : '/'; // Make absolutely sure we have a path if (!$this->path) { $this->path = '/'; } if (!empty($bits['query'])) { $this->path .= '?' . $bits['query']; } } else { $this->server = $server; $this->path = $path; $this->port = $port; } $this->useragent = 'The Incutio XML-RPC PHP Library'; $this->timeout = $timeout; $this->timeout_io = $timeout_io; } public function query() { $args = func_get_args(); $method = array_shift($args); $request = new Request($method, $args); $length = $request->getLength(); $xml = $request->getXml(); $r = "\r\n"; $request = "POST {$this->path} HTTP/1.0$r"; // Merged from WP #8145 - allow custom headers $this->headers['Host'] = $this->server; $this->headers['Content-Type'] = 'text/xml'; $this->headers['User-Agent'] = $this->useragent; $this->headers['Content-Length'] = $length; foreach ($this->headers as $header => $value) { $request .= "{$header}: {$value}{$r}"; } $request .= $r; $request .= $xml; // Now send the request if ($this->debug) { echo '
' . htmlspecialchars($request) . "\n
\n\n"; } if ($this->timeout) { try { $fp = fsockopen($this->server, $this->port, $errno, $errstr, $this->timeout); } catch (\Exception $e) { $fp = false; } } else { try { $fp = fsockopen($this->server, $this->port, $errno, $errstr); } catch (\Exception $e) { $fp = false; } } if (!$fp) { return $this->handleError(-32300, 'transport error - could not open socket'); } if (null !== $this->timeout_io) { stream_set_timeout($fp, $this->timeout_io); } fputs($fp, $request); $contents = ''; $debugContents = ''; $gotFirstLine = false; $gettingHeaders = true; while (!feof($fp)) { $line = fgets($fp, 4096); if (!$gotFirstLine) { // Check line for '200' if (strstr($line, '200') === false) { return $this->handleError(-32300, 'transport error - HTTP status code was not 200'); } $gotFirstLine = true; } if (trim($line) == '') { $gettingHeaders = false; } if (!$gettingHeaders) { // merged from WP #12559 - remove trim $contents .= $line; } if ($this->debug) { $debugContents .= $line; } } if ($this->debug) { echo '
' . htmlspecialchars($debugContents) . "\n
\n\n"; } // Now parse what we've got back $this->message = new Message($contents); if (!$this->message->parse()) { // XML error return $this->handleError(-32700, 'Parse error. Message not well formed'); } // Is the message a fault? if ($this->message->messageType == 'fault') { return $this->handleError($this->message->faultCode, $this->message->faultString); } // Message must be OK return true; } public function getResponse() { // methodResponses can only have one param - return that return $this->message->params[0]; } public function isError() { return (is_object($this->error)); } protected function handleError($errorCode, $errorMessage) { $this->error = new Error($errorCode, $errorMessage); return false; } public function getError() { return $this->error; } public function getErrorCode() { return $this->error->code; } public function getErrorMessage() { return $this->error->message; } /** * Gets the current timeout set for data transfer * @return int|null */ public function getTimeoutIo() { return $this->timeout_io; } /** * Sets the timeout for data transfer * @param int $timeout_io * @return $this */ public function setTimeoutIo($timeout_io) { $this->timeout_io = $timeout_io; } }