Created
September 22, 2012 13:28
-
-
Save cubehouse/3766168 to your computer and use it in GitHub Desktop.
eJabberd Auth.php for WordPress authentication
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/php | |
| <?php | |
| /* | |
| Copyright (c) <2005> LISSY Alexandre, "lissyx" <alexandrelissy@free.fr> | |
| Permission is hereby granted, free of charge, to any person obtaining a copy of | |
| this software andassociated documentation files (the "Software"), to deal in the | |
| Software without restriction, including without limitation the rights to use, | |
| copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the | |
| Software, and to permit persons to whom the Software is furnished to do so, | |
| subject to thefollowing conditions: | |
| The above copyright notice and this permission notice shall be included in all | |
| copies or substantial portions of the Software. | |
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | |
| IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS | |
| FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR | |
| COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER | |
| IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | |
| CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | |
| */ | |
| error_reporting(0); | |
| $auth = new JabberAuth(); | |
| $auth->play(); // We simply start process ! | |
| class JabberAuth { | |
| var $debug = false; /* Debug mode */ | |
| var $debugfile = "/var/log/pipe-debug.log"; /* Debug output */ | |
| var $logging = false; /* Do we log requests ? */ | |
| var $logfile = "/var/log/pipe-log.log" ; /* Log file ... */ | |
| /* | |
| * For both debug and logging, ejabberd have to be able to write. | |
| */ | |
| var $jabber_user; /* This is the jabber user passed to the script. filled by $this->command() */ | |
| var $jabber_pass; /* This is the jabber user password passed to the script. filled by $this->command() */ | |
| var $jabber_server; /* This is the jabber server passed to the script. filled by $this->command(). Useful for VirtualHosts */ | |
| var $jid; /* Simply the JID, if you need it, you have to fill. */ | |
| var $data; /* This is what SM component send to us. */ | |
| var $dateformat = "M d H:i:s"; /* Check date() for string format. */ | |
| var $command; /* This is the command sent ... */ | |
| var $mysock; /* MySQL connection ressource */ | |
| var $stdin; /* stdin file pointer */ | |
| var $stdout; /* stdout file pointer */ | |
| function JabberAuth(){ | |
| @define_syslog_variables(); | |
| @openlog("pipe-auth", LOG_NDELAY, LOG_SYSLOG); | |
| if($this->debug) { | |
| @error_reporting(E_ALL); | |
| @ini_set("log_errors", "1"); | |
| @ini_set("error_log", $this->debugfile); | |
| } | |
| $this->logg("Starting pipe-auth ..."); // We notice that it's starting ... | |
| $this->openstd(); | |
| } | |
| function stop(){ | |
| $this->logg("Shutting down ..."); // Sorry, have to go ... | |
| closelog(); | |
| $this->closestd(); // Simply close files | |
| exit(0); // and exit cleanly | |
| } | |
| function openstd(){ | |
| $this->stdout = @fopen("php://stdout", "w"); // We open STDOUT so we can read | |
| $this->stdin = @fopen("php://stdin", "r"); // and STDIN so we can talk ! | |
| } | |
| function readstdin(){ | |
| $l = @fgets($this->stdin, 3); // We take the length of string | |
| $length = @unpack("n", $l); // ejabberd give us something to play with ... | |
| $len = $length["1"]; // and we now know how long to read. | |
| if($len > 0) { // if not, we'll fill logfile ... and disk full is just funny once | |
| $this->logg("Reading $len bytes ... "); // We notice ... | |
| $data = @fgets($this->stdin, $len+1); | |
| // $data = iconv("UTF-8", "ISO-8859-15", $data); // To be tested, not sure if still needed. | |
| $this->data = $data; // We set what we got. | |
| $this->logg("IN: ".$data); | |
| } | |
| } | |
| function closestd(){ | |
| @fclose($this->stdin); // We close everything ... | |
| @fclose($this->stdout); | |
| } | |
| function out($message){ | |
| @fwrite($this->stdout, $message); // We reply ... | |
| $dump = @unpack("nn", $message); | |
| $dump = $dump["n"]; | |
| $this->logg("OUT: ". $dump); | |
| } | |
| function myalive(){ | |
| return true; // I'm not sure what to do with this | |
| } | |
| function play(){ | |
| do { | |
| $this->readstdin(); // get data | |
| $length = strlen($this->data); // compute data length | |
| if($length > 0 ) { // for debug mainly ... | |
| $this->logg("GO: ".$this->data); | |
| $this->logg("data length is : ".$length); | |
| } | |
| $ret = $this->command(); // play with data ! | |
| $this->logg("RE: " . $ret); // this is what WE send. | |
| $this->out($ret); // send what we reply. | |
| $this->data = NULL; // more clean. ... | |
| } while (true); | |
| } | |
| function command(){ | |
| $data = $this->splitcomm(); // This is an array, where each node is part of what SM sent to us : | |
| // 0 => the command, | |
| // and the others are arguments .. e.g. : user, server, password ... | |
| if($this->myalive()) { // Check we can play with MySQL | |
| if(strlen($data[0]) > 0 ) { | |
| $this->logg("Command was : ".$data[0]); | |
| } | |
| switch($data[0]) { | |
| case "isuser": // this is the "isuser" command, used to check for user existance | |
| $this->jabber_user = $data[1]; | |
| $this->jabber_server = $data[2]; | |
| $parms = $data[1]; // only for logging purpose | |
| $return = $this->checkuser(); | |
| break; | |
| case "auth": // check login, password | |
| $this->jabber_user = $data[1]; | |
| $this->jabber_pass = $data[3]; | |
| $this->jabber_server = $data[2]; | |
| $parms = $data[1].":".$data[2].":".md5($data[3]); // only for logging purpose | |
| $return = $this->checkpass(); | |
| break; | |
| case "setpass": | |
| $return = false; // We do not want jabber to be able to change password | |
| break; | |
| default: | |
| $this->stop(); // if it's not something known, we have to leave. | |
| // never had a problem with this using ejabberd, but might lead to problem ? | |
| break; | |
| } | |
| $return = ($return) ? 1 : 0; | |
| if(strlen($data[0]) > 0 && strlen($parms) > 0) { | |
| $this->logg("Command : ".$data[0].":".$parms." ==> ".$return." "); | |
| } | |
| return @pack("nn", 2, $return); | |
| } else { | |
| // $this->prevenir(); // Maybe useful to tell somewhere there's a problem ... | |
| return @pack("nn", 2, 0); // it's so bad. | |
| } | |
| } | |
| function checkpass(){ | |
| $client = new IXR_Client('https://'.$this->jabber_server.'/xmlrpc.php'); | |
| if (!$client->query('xmpp.user_login', $this->jabber_user, $this->jabber_pass)){ | |
| return false; | |
| } | |
| return true; | |
| } | |
| function checkuser(){ | |
| $client = new IXR_Client('https://'.$this->jabber_server.'/xmlrpc.php'); | |
| if (!$client->query('xmpp.user_check', $this->jabber_user, "")){ | |
| return false; | |
| } | |
| return true; | |
| } | |
| function splitcomm(){ // simply split command and arugments into an array.{ | |
| return explode(":", $this->data); | |
| } | |
| function logg($message){ | |
| if($this->logging) { | |
| @syslog(LOG_INFO, $message); | |
| } | |
| } | |
| } | |
| /** | |
| * IXR - The Inutio XML-RPC Library | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| * | |
| * @copyright Incutio Ltd 2002-2005 | |
| * @version 1.7 (beta) 23rd May 2005 | |
| * @author Simon Willison | |
| * @link http://scripts.incutio.com/xmlrpc/ Site | |
| * @link http://scripts.incutio.com/xmlrpc/manual.php Manual | |
| * @license BSD License http://www.opensource.org/licenses/bsd-license.php | |
| */ | |
| /** | |
| * IXR_Value | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Value { | |
| var $data; | |
| var $type; | |
| function IXR_Value ($data, $type = false) { | |
| $this->data = $data; | |
| if (!$type) { | |
| $type = $this->calculateType(); | |
| } | |
| $this->type = $type; | |
| if ($type == 'struct') { | |
| /* Turn all the values in the array in to new IXR_Value objects */ | |
| foreach ($this->data as $key => $value) { | |
| $this->data[$key] = new IXR_Value($value); | |
| } | |
| } | |
| if ($type == 'array') { | |
| for ($i = 0, $j = count($this->data); $i < $j; $i++) { | |
| $this->data[$i] = new IXR_Value($this->data[$i]); | |
| } | |
| } | |
| } | |
| function calculateType() { | |
| if ($this->data === true || $this->data === false) { | |
| return 'boolean'; | |
| } | |
| if (is_integer($this->data)) { | |
| return 'int'; | |
| } | |
| if (is_double($this->data)) { | |
| return 'double'; | |
| } | |
| // Deal with IXR object types base64 and date | |
| if (is_object($this->data) && is_a($this->data, 'IXR_Date')) { | |
| return 'date'; | |
| } | |
| if (is_object($this->data) && is_a($this->data, 'IXR_Base64')) { | |
| return 'base64'; | |
| } | |
| // If it is a normal PHP object convert it in to a struct | |
| if (is_object($this->data)) { | |
| $this->data = get_object_vars($this->data); | |
| return 'struct'; | |
| } | |
| if (!is_array($this->data)) { | |
| return 'string'; | |
| } | |
| /* We have an array - is it an array or a struct ? */ | |
| if ($this->isStruct($this->data)) { | |
| return 'struct'; | |
| } else { | |
| return 'array'; | |
| } | |
| } | |
| function getXml() { | |
| /* Return XML for this value */ | |
| switch ($this->type) { | |
| case 'boolean': | |
| return '<boolean>'.(($this->data) ? '1' : '0').'</boolean>'; | |
| break; | |
| case 'int': | |
| return '<int>'.$this->data.'</int>'; | |
| break; | |
| case 'double': | |
| return '<double>'.$this->data.'</double>'; | |
| break; | |
| case 'string': | |
| return '<string>'.htmlspecialchars($this->data).'</string>'; | |
| break; | |
| case 'array': | |
| $return = '<array><data>'."\n"; | |
| foreach ($this->data as $item) { | |
| $return .= ' <value>'.$item->getXml()."</value>\n"; | |
| } | |
| $return .= '</data></array>'; | |
| return $return; | |
| break; | |
| case 'struct': | |
| $return = '<struct>'."\n"; | |
| foreach ($this->data as $name => $value) { | |
| $name = htmlspecialchars($name); | |
| $return .= " <member><name>$name</name><value>"; | |
| $return .= $value->getXml()."</value></member>\n"; | |
| } | |
| $return .= '</struct>'; | |
| return $return; | |
| break; | |
| case 'date': | |
| case 'base64': | |
| return $this->data->getXml(); | |
| break; | |
| } | |
| return false; | |
| } | |
| function isStruct($array) { | |
| /* Nasty function to check if an array is a struct or not */ | |
| $expected = 0; | |
| foreach ($array as $key => $value) { | |
| if ((string)$key != (string)$expected) { | |
| return true; | |
| } | |
| $expected++; | |
| } | |
| return false; | |
| } | |
| } | |
| /** | |
| * IXR_Message | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Message { | |
| var $message; | |
| var $messageType; // methodCall / methodResponse / fault | |
| var $faultCode; | |
| var $faultString; | |
| var $methodName; | |
| var $params; | |
| // Current variable stacks | |
| var $_arraystructs = array(); // The stack used to keep track of the current array/struct | |
| var $_arraystructstypes = array(); // Stack keeping track of if things are structs or array | |
| var $_currentStructName = array(); // A stack as well | |
| var $_param; | |
| var $_value; | |
| var $_currentTag; | |
| var $_currentTagContents; | |
| // The XML parser | |
| var $_parser; | |
| function IXR_Message (&$message) { | |
| $this->message = &$message; | |
| } | |
| function parse() { | |
| // first remove the XML declaration | |
| // this method avoids the RAM usage of preg_replace on very large messages | |
| $header = preg_replace( '/<\?xml.*?\?'.'>/', '', substr( $this->message, 0, 100 ), 1 ); | |
| $this->message = substr_replace($this->message, $header, 0, 100); | |
| if (trim($this->message) == '') { | |
| return false; | |
| } | |
| $this->_parser = xml_parser_create(); | |
| // Set XML parser to take the case of tags in to account | |
| xml_parser_set_option($this->_parser, XML_OPTION_CASE_FOLDING, false); | |
| // Set XML parser callback functions | |
| xml_set_object($this->_parser, $this); | |
| xml_set_element_handler($this->_parser, 'tag_open', 'tag_close'); | |
| xml_set_character_data_handler($this->_parser, 'cdata'); | |
| $chunk_size = 262144; // 256Kb, parse in chunks to avoid the RAM usage on very large messages | |
| do { | |
| if ( strlen($this->message) <= $chunk_size ) | |
| $final=true; | |
| $part = substr( $this->message, 0, $chunk_size ); | |
| $this->message = substr( $this->message, $chunk_size ); | |
| if ( !xml_parse( $this->_parser, $part, $final ) ) | |
| return false; | |
| if ( $final ) | |
| break; | |
| } while ( true ); | |
| xml_parser_free($this->_parser); | |
| // Grab the error messages, if any | |
| if ($this->messageType == 'fault') { | |
| $this->faultCode = $this->params[0]['faultCode']; | |
| $this->faultString = $this->params[0]['faultString']; | |
| } | |
| return true; | |
| } | |
| function tag_open($parser, $tag, $attr) { | |
| $this->_currentTagContents = ''; | |
| $this->currentTag = $tag; | |
| switch($tag) { | |
| case 'methodCall': | |
| case 'methodResponse': | |
| case 'fault': | |
| $this->messageType = $tag; | |
| break; | |
| /* Deal with stacks of arrays and structs */ | |
| case 'data': // data is to all intents and puposes more interesting than array | |
| $this->_arraystructstypes[] = 'array'; | |
| $this->_arraystructs[] = array(); | |
| break; | |
| case 'struct': | |
| $this->_arraystructstypes[] = 'struct'; | |
| $this->_arraystructs[] = array(); | |
| break; | |
| } | |
| } | |
| function cdata($parser, $cdata) { | |
| $this->_currentTagContents .= $cdata; | |
| } | |
| function tag_close($parser, $tag) { | |
| $valueFlag = false; | |
| switch($tag) { | |
| case 'int': | |
| case 'i4': | |
| $value = (int) trim($this->_currentTagContents); | |
| $valueFlag = true; | |
| break; | |
| case 'double': | |
| $value = (double) trim($this->_currentTagContents); | |
| $valueFlag = true; | |
| break; | |
| case 'string': | |
| $value = $this->_currentTagContents; | |
| $valueFlag = true; | |
| break; | |
| case 'dateTime.iso8601': | |
| $value = new IXR_Date(trim($this->_currentTagContents)); | |
| // $value = $iso->getTimestamp(); | |
| $valueFlag = true; | |
| break; | |
| case 'value': | |
| // "If no type is indicated, the type is string." | |
| if (trim($this->_currentTagContents) != '') { | |
| $value = (string)$this->_currentTagContents; | |
| $valueFlag = true; | |
| } | |
| break; | |
| case 'boolean': | |
| $value = (boolean) trim($this->_currentTagContents); | |
| $valueFlag = true; | |
| break; | |
| case 'base64': | |
| $value = base64_decode( trim( $this->_currentTagContents ) ); | |
| $valueFlag = true; | |
| break; | |
| /* Deal with stacks of arrays and structs */ | |
| case 'data': | |
| case 'struct': | |
| $value = array_pop($this->_arraystructs); | |
| array_pop($this->_arraystructstypes); | |
| $valueFlag = true; | |
| break; | |
| case 'member': | |
| array_pop($this->_currentStructName); | |
| break; | |
| case 'name': | |
| $this->_currentStructName[] = trim($this->_currentTagContents); | |
| break; | |
| case 'methodName': | |
| $this->methodName = trim($this->_currentTagContents); | |
| break; | |
| } | |
| if ($valueFlag) { | |
| if (count($this->_arraystructs) > 0) { | |
| // Add value to struct or array | |
| if ($this->_arraystructstypes[count($this->_arraystructstypes)-1] == 'struct') { | |
| // Add to struct | |
| $this->_arraystructs[count($this->_arraystructs)-1][$this->_currentStructName[count($this->_currentStructName)-1]] = $value; | |
| } else { | |
| // Add to array | |
| $this->_arraystructs[count($this->_arraystructs)-1][] = $value; | |
| } | |
| } else { | |
| // Just add as a paramater | |
| $this->params[] = $value; | |
| } | |
| } | |
| $this->_currentTagContents = ''; | |
| } | |
| } | |
| /** | |
| * IXR_Server | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Server { | |
| var $data; | |
| var $callbacks = array(); | |
| var $message; | |
| var $capabilities; | |
| function IXR_Server($callbacks = false, $data = false) { | |
| $this->setCapabilities(); | |
| if ($callbacks) { | |
| $this->callbacks = $callbacks; | |
| } | |
| $this->setCallbacks(); | |
| $this->serve($data); | |
| } | |
| function serve($data = false) { | |
| if (!$data) { | |
| global $HTTP_RAW_POST_DATA; | |
| if (!$HTTP_RAW_POST_DATA) { | |
| header( 'Content-Type: text/plain' ); | |
| die('XML-RPC server accepts POST requests only.'); | |
| } | |
| $data = &$HTTP_RAW_POST_DATA; | |
| } | |
| $this->message = new IXR_Message($data); | |
| if (!$this->message->parse()) { | |
| $this->error(-32700, 'parse error. not well formed'); | |
| } | |
| if ($this->message->messageType != 'methodCall') { | |
| $this->error(-32600, 'server error. invalid xml-rpc. not conforming to spec. Request must be a methodCall'); | |
| } | |
| $result = $this->call($this->message->methodName, $this->message->params); | |
| // Is the result an error? | |
| if (is_a($result, 'IXR_Error')) { | |
| $this->error($result); | |
| } | |
| // Encode the result | |
| $r = new IXR_Value($result); | |
| $resultxml = $r->getXml(); | |
| // Create the XML | |
| $xml = <<<EOD | |
| <methodResponse> | |
| <params> | |
| <param> | |
| <value> | |
| $resultxml | |
| </value> | |
| </param> | |
| </params> | |
| </methodResponse> | |
| EOD; | |
| // Send it | |
| $this->output($xml); | |
| } | |
| function call($methodname, $args) { | |
| if (!$this->hasMethod($methodname)) { | |
| return new IXR_Error(-32601, 'server error. requested method '. | |
| $methodname.' does not exist.'); | |
| } | |
| $method = $this->callbacks[$methodname]; | |
| // Perform the callback and send the response | |
| if (count($args) == 1) { | |
| // If only one paramater just send that instead of the whole array | |
| $args = $args[0]; | |
| } | |
| // Are we dealing with a function or a method? | |
| if ( is_string( $method ) && substr($method, 0, 5) == 'this:' ) { | |
| // It's a class method - check it exists | |
| $method = substr($method, 5); | |
| if (!method_exists($this, $method)) { | |
| return new IXR_Error(-32601, 'server error. requested class method "'. | |
| $method.'" does not exist.'); | |
| } | |
| // Call the method | |
| $result = $this->$method($args); | |
| } else { | |
| // It's a function - does it exist? | |
| if (is_array($method)) { | |
| if (!method_exists($method[0], $method[1])) { | |
| return new IXR_Error(-32601, 'server error. requested object method "'. | |
| $method[1].'" does not exist.'); | |
| } | |
| } else if (!function_exists($method)) { | |
| return new IXR_Error(-32601, 'server error. requested function "'. | |
| $method.'" does not exist.'); | |
| } | |
| // Call the function | |
| $result = call_user_func($method, $args); | |
| } | |
| return $result; | |
| } | |
| function error($error, $message = false) { | |
| // Accepts either an error object or an error code and message | |
| if ($message && !is_object($error)) { | |
| $error = new IXR_Error($error, $message); | |
| } | |
| $this->output($error->getXml()); | |
| } | |
| function output($xml) { | |
| $xml = '<?xml version="1.0"?>'."\n".$xml; | |
| $length = strlen($xml); | |
| header('Connection: close'); | |
| header('Content-Length: '.$length); | |
| header('Content-Type: text/xml'); | |
| header('Date: '.date('r')); | |
| echo $xml; | |
| exit; | |
| } | |
| function hasMethod($method) { | |
| return in_array($method, array_keys($this->callbacks)); | |
| } | |
| function setCapabilities() { | |
| // Initialises capabilities array | |
| $this->capabilities = array( | |
| 'xmlrpc' => array( | |
| 'specUrl' => 'http://www.xmlrpc.com/spec', | |
| 'specVersion' => 1 | |
| ), | |
| 'faults_interop' => array( | |
| 'specUrl' => 'http://xmlrpc-epi.sourceforge.net/specs/rfc.fault_codes.php', | |
| 'specVersion' => 20010516 | |
| ), | |
| 'system.multicall' => array( | |
| 'specUrl' => 'http://www.xmlrpc.com/discuss/msgReader$1208', | |
| 'specVersion' => 1 | |
| ), | |
| ); | |
| } | |
| function getCapabilities($args) { | |
| return $this->capabilities; | |
| } | |
| function setCallbacks() { | |
| $this->callbacks['system.getCapabilities'] = 'this:getCapabilities'; | |
| $this->callbacks['system.listMethods'] = 'this:listMethods'; | |
| $this->callbacks['system.multicall'] = 'this:multiCall'; | |
| } | |
| function listMethods($args) { | |
| // Returns a list of methods - uses array_reverse to ensure user defined | |
| // methods are listed before server defined methods | |
| return array_reverse(array_keys($this->callbacks)); | |
| } | |
| function multiCall($methodcalls) { | |
| // See http://www.xmlrpc.com/discuss/msgReader$1208 | |
| $return = array(); | |
| foreach ($methodcalls as $call) { | |
| $method = $call['methodName']; | |
| $params = $call['params']; | |
| if ($method == 'system.multicall') { | |
| $result = new IXR_Error(-32600, 'Recursive calls to system.multicall are forbidden'); | |
| } else { | |
| $result = $this->call($method, $params); | |
| } | |
| if (is_a($result, 'IXR_Error')) { | |
| $return[] = array( | |
| 'faultCode' => $result->code, | |
| 'faultString' => $result->message | |
| ); | |
| } else { | |
| $return[] = array($result); | |
| } | |
| } | |
| return $return; | |
| } | |
| } | |
| /** | |
| * IXR_Request | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Request { | |
| var $method; | |
| var $args; | |
| var $xml; | |
| function IXR_Request($method, $args) { | |
| $this->method = $method; | |
| $this->args = $args; | |
| $this->xml = <<<EOD | |
| <?xml version="1.0"?> | |
| <methodCall> | |
| <methodName>{$this->method}</methodName> | |
| <params> | |
| EOD; | |
| foreach ($this->args as $arg) { | |
| $this->xml .= '<param><value>'; | |
| $v = new IXR_Value($arg); | |
| $this->xml .= $v->getXml(); | |
| $this->xml .= "</value></param>\n"; | |
| } | |
| $this->xml .= '</params></methodCall>'; | |
| } | |
| function getLength() { | |
| return strlen($this->xml); | |
| } | |
| function getXml() { | |
| return $this->xml; | |
| } | |
| } | |
| /** | |
| * IXR_Client | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Client { | |
| var $server; | |
| var $port; | |
| var $path; | |
| var $useragent; | |
| var $headers; | |
| var $response; | |
| var $message = false; | |
| var $debug = false; | |
| var $timeout; | |
| // Storage place for an error message | |
| var $error = false; | |
| function IXR_Client($server, $path = false, $port = 80, $timeout = false) { | |
| if (!$path) { | |
| // Assume we have been given a URL instead | |
| $bits = parse_url($server); | |
| $this->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 = '/'; | |
| } | |
| } else { | |
| $this->server = $server; | |
| $this->path = $path; | |
| $this->port = $port; | |
| } | |
| $this->useragent = 'The Incutio XML-RPC PHP Library'; | |
| $this->timeout = $timeout; | |
| } | |
| function query() { | |
| $args = func_get_args(); | |
| $method = array_shift($args); | |
| $request = new IXR_Request($method, $args); | |
| $length = $request->getLength(); | |
| $xml = $request->getXml(); | |
| $r = "\r\n"; | |
| $request = "POST {$this->path} HTTP/1.0$r"; | |
| $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 '<pre class="ixr_request">'.htmlspecialchars($request)."\n</pre>\n\n"; | |
| } | |
| if ($this->timeout) { | |
| $fp = @fsockopen($this->server, $this->port, $errno, $errstr, $this->timeout); | |
| } else { | |
| $fp = @fsockopen($this->server, $this->port, $errno, $errstr); | |
| } | |
| if (!$fp) { | |
| $this->error = new IXR_Error(-32300, "transport error - could not open socket: $errno $errstr"); | |
| return false; | |
| } | |
| fputs($fp, $request); | |
| $contents = ''; | |
| $debug_contents = ''; | |
| $gotFirstLine = false; | |
| $gettingHeaders = true; | |
| while (!feof($fp)) { | |
| $line = fgets($fp, 4096); | |
| if (!$gotFirstLine) { | |
| // Check line for '200' | |
| if (strstr($line, '200') === false) { | |
| $this->error = new IXR_Error(-32301, 'transport error - HTTP status code was not 200'); | |
| return false; | |
| } | |
| $gotFirstLine = true; | |
| } | |
| if (trim($line) == '') { | |
| $gettingHeaders = false; | |
| } | |
| if (!$gettingHeaders) { | |
| // WP#12559 remove trim so as to not strip newlines from received response. | |
| $contents .= $line; | |
| } | |
| if ($this->debug) { | |
| $debug_contents .= $line; | |
| } | |
| } | |
| if ($this->debug) { | |
| echo '<pre class="ixr_response">'.htmlspecialchars($debug_contents)."\n</pre>\n\n"; | |
| } | |
| // Now parse what we've got back | |
| $this->message = new IXR_Message($contents); | |
| if (!$this->message->parse()) { | |
| // XML error | |
| $this->error = new IXR_Error(-32700, 'parse error. not well formed'); | |
| return false; | |
| } | |
| // Is the message a fault? | |
| if ($this->message->messageType == 'fault') { | |
| $this->error = new IXR_Error($this->message->faultCode, $this->message->faultString); | |
| return false; | |
| } | |
| // Message must be OK | |
| return true; | |
| } | |
| function getResponse() { | |
| // methodResponses can only have one param - return that | |
| return $this->message->params[0]; | |
| } | |
| function isError() { | |
| return (is_object($this->error)); | |
| } | |
| function getErrorCode() { | |
| return $this->error->code; | |
| } | |
| function getErrorMessage() { | |
| return $this->error->message; | |
| } | |
| } | |
| /** | |
| * IXR_Error | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Error { | |
| var $code; | |
| var $message; | |
| function IXR_Error($code, $message) { | |
| $this->code = $code; | |
| // WP adds htmlspecialchars(). See #5666 | |
| $this->message = htmlspecialchars($message); | |
| } | |
| function getXml() { | |
| $xml = <<<EOD | |
| <methodResponse> | |
| <fault> | |
| <value> | |
| <struct> | |
| <member> | |
| <name>faultCode</name> | |
| <value><int>{$this->code}</int></value> | |
| </member> | |
| <member> | |
| <name>faultString</name> | |
| <value><string>{$this->message}</string></value> | |
| </member> | |
| </struct> | |
| </value> | |
| </fault> | |
| </methodResponse> | |
| EOD; | |
| return $xml; | |
| } | |
| } | |
| /** | |
| * IXR_Date | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Date { | |
| var $year; | |
| var $month; | |
| var $day; | |
| var $hour; | |
| var $minute; | |
| var $second; | |
| var $timezone; | |
| function IXR_Date($time) { | |
| // $time can be a PHP timestamp or an ISO one | |
| if (is_numeric($time)) { | |
| $this->parseTimestamp($time); | |
| } else { | |
| $this->parseIso($time); | |
| } | |
| } | |
| function parseTimestamp($timestamp) { | |
| $this->year = date('Y', $timestamp); | |
| $this->month = date('m', $timestamp); | |
| $this->day = date('d', $timestamp); | |
| $this->hour = date('H', $timestamp); | |
| $this->minute = date('i', $timestamp); | |
| $this->second = date('s', $timestamp); | |
| // WP adds timezone. See #2036 | |
| $this->timezone = ''; | |
| } | |
| function parseIso($iso) { | |
| $this->year = substr($iso, 0, 4); | |
| $this->month = substr($iso, 4, 2); | |
| $this->day = substr($iso, 6, 2); | |
| $this->hour = substr($iso, 9, 2); | |
| $this->minute = substr($iso, 12, 2); | |
| $this->second = substr($iso, 15, 2); | |
| // WP adds timezone. See #2036 | |
| $this->timezone = substr($iso, 17); | |
| } | |
| function getIso() { | |
| // WP adds timezone. See #2036 | |
| return $this->year.$this->month.$this->day.'T'.$this->hour.':'.$this->minute.':'.$this->second.$this->timezone; | |
| } | |
| function getXml() { | |
| return '<dateTime.iso8601>'.$this->getIso().'</dateTime.iso8601>'; | |
| } | |
| function getTimestamp() { | |
| return mktime($this->hour, $this->minute, $this->second, $this->month, $this->day, $this->year); | |
| } | |
| } | |
| /** | |
| * IXR_Base64 | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_Base64 { | |
| var $data; | |
| function IXR_Base64($data) { | |
| $this->data = $data; | |
| } | |
| function getXml() { | |
| return '<base64>'.base64_encode($this->data).'</base64>'; | |
| } | |
| } | |
| /** | |
| * IXR_IntrospectionServer | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_IntrospectionServer extends IXR_Server { | |
| var $signatures; | |
| var $help; | |
| function IXR_IntrospectionServer() { | |
| $this->setCallbacks(); | |
| $this->setCapabilities(); | |
| $this->capabilities['introspection'] = array( | |
| 'specUrl' => 'http://xmlrpc.usefulinc.com/doc/reserved.html', | |
| 'specVersion' => 1 | |
| ); | |
| $this->addCallback( | |
| 'system.methodSignature', | |
| 'this:methodSignature', | |
| array('array', 'string'), | |
| 'Returns an array describing the return type and required parameters of a method' | |
| ); | |
| $this->addCallback( | |
| 'system.getCapabilities', | |
| 'this:getCapabilities', | |
| array('struct'), | |
| 'Returns a struct describing the XML-RPC specifications supported by this server' | |
| ); | |
| $this->addCallback( | |
| 'system.listMethods', | |
| 'this:listMethods', | |
| array('array'), | |
| 'Returns an array of available methods on this server' | |
| ); | |
| $this->addCallback( | |
| 'system.methodHelp', | |
| 'this:methodHelp', | |
| array('string', 'string'), | |
| 'Returns a documentation string for the specified method' | |
| ); | |
| } | |
| function addCallback($method, $callback, $args, $help) { | |
| $this->callbacks[$method] = $callback; | |
| $this->signatures[$method] = $args; | |
| $this->help[$method] = $help; | |
| } | |
| function call($methodname, $args) { | |
| // Make sure it's in an array | |
| if ($args && !is_array($args)) { | |
| $args = array($args); | |
| } | |
| // Over-rides default call method, adds signature check | |
| if (!$this->hasMethod($methodname)) { | |
| return new IXR_Error(-32601, 'server error. requested method "'.$this->message->methodName.'" not specified.'); | |
| } | |
| $method = $this->callbacks[$methodname]; | |
| $signature = $this->signatures[$methodname]; | |
| $returnType = array_shift($signature); | |
| // Check the number of arguments | |
| if (count($args) != count($signature)) { | |
| return new IXR_Error(-32602, 'server error. wrong number of method parameters'); | |
| } | |
| // Check the argument types | |
| $ok = true; | |
| $argsbackup = $args; | |
| for ($i = 0, $j = count($args); $i < $j; $i++) { | |
| $arg = array_shift($args); | |
| $type = array_shift($signature); | |
| switch ($type) { | |
| case 'int': | |
| case 'i4': | |
| if (is_array($arg) || !is_int($arg)) { | |
| $ok = false; | |
| } | |
| break; | |
| case 'base64': | |
| case 'string': | |
| if (!is_string($arg)) { | |
| $ok = false; | |
| } | |
| break; | |
| case 'boolean': | |
| if ($arg !== false && $arg !== true) { | |
| $ok = false; | |
| } | |
| break; | |
| case 'float': | |
| case 'double': | |
| if (!is_float($arg)) { | |
| $ok = false; | |
| } | |
| break; | |
| case 'date': | |
| case 'dateTime.iso8601': | |
| if (!is_a($arg, 'IXR_Date')) { | |
| $ok = false; | |
| } | |
| break; | |
| } | |
| if (!$ok) { | |
| return new IXR_Error(-32602, 'server error. invalid method parameters'); | |
| } | |
| } | |
| // It passed the test - run the "real" method call | |
| return parent::call($methodname, $argsbackup); | |
| } | |
| function methodSignature($method) { | |
| if (!$this->hasMethod($method)) { | |
| return new IXR_Error(-32601, 'server error. requested method "'.$method.'" not specified.'); | |
| } | |
| // We should be returning an array of types | |
| $types = $this->signatures[$method]; | |
| $return = array(); | |
| foreach ($types as $type) { | |
| switch ($type) { | |
| case 'string': | |
| $return[] = 'string'; | |
| break; | |
| case 'int': | |
| case 'i4': | |
| $return[] = 42; | |
| break; | |
| case 'double': | |
| $return[] = 3.1415; | |
| break; | |
| case 'dateTime.iso8601': | |
| $return[] = new IXR_Date(time()); | |
| break; | |
| case 'boolean': | |
| $return[] = true; | |
| break; | |
| case 'base64': | |
| $return[] = new IXR_Base64('base64'); | |
| break; | |
| case 'array': | |
| $return[] = array('array'); | |
| break; | |
| case 'struct': | |
| $return[] = array('struct' => 'struct'); | |
| break; | |
| } | |
| } | |
| return $return; | |
| } | |
| function methodHelp($method) { | |
| return $this->help[$method]; | |
| } | |
| } | |
| /** | |
| * IXR_ClientMulticall | |
| * | |
| * @package IXR | |
| * @since 1.5 | |
| */ | |
| class IXR_ClientMulticall extends IXR_Client { | |
| var $calls = array(); | |
| function IXR_ClientMulticall($server, $path = false, $port = 80) { | |
| parent::IXR_Client($server, $path, $port); | |
| $this->useragent = 'The Incutio XML-RPC PHP Library (multicall client)'; | |
| } | |
| function addCall() { | |
| $args = func_get_args(); | |
| $methodName = array_shift($args); | |
| $struct = array( | |
| 'methodName' => $methodName, | |
| 'params' => $args | |
| ); | |
| $this->calls[] = $struct; | |
| } | |
| function query() { | |
| // Prepare multicall, then call the parent::query() method | |
| return parent::query('system.multicall', $this->calls); | |
| } | |
| } | |
| ?> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment