+++ /dev/null
-<?php
-
-abstract class IPF_Server_Abstract implements IPF_Server_Interface
-{
- protected static $magic_methods = array(
- '__construct',
- '__destruct',
- '__get',
- '__set',
- '__call',
- '__sleep',
- '__wakeup',
- '__isset',
- '__unset',
- '__tostring',
- '__clone',
- '__set_state',
- );
-
- public static function lowerCase(&$value, &$key)
- {
- return $value = strtolower($value);
- }
-}
+++ /dev/null
-<?php
-
-interface IPF_Server_Interface
-{
- public function addFunction($function, $namespace = '');
- public function setClass($class, $namespace = '', $argv = null);
- public function fault($fault = null, $code = 404);
- public function handle($request = false);
- public function getFunctions();
- public function loadFunctions($definition);
- public function setPersistence($mode);
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection
-{
- public static function reflectClass($class, $argv = false, $namespace = '')
- {
- if (is_object($class)) {
- $reflection = new ReflectionObject($class);
- } elseif (class_exists($class)) {
- $reflection = new ReflectionClass($class);
- } else {
- throw new IPF_Exception('Invalid class or object passed to attachClass()');
- }
-
- if ($argv && !is_array($argv)) {
- throw new IPF_Exception('Invalid argv argument passed to reflectClass');
- }
- return new IPF_Server_Reflection_Class($reflection, $namespace, $argv);
- }
-
- public static function reflectFunction($function, $argv = false, $namespace = '')
- {
- if (!is_string($function) || !function_exists($function)) {
- throw new IPF_Exception('Invalid function "' . $function . '" passed to reflectFunction');
- }
- if ($argv && !is_array($argv)) {
- throw new IPF_Exception('Invalid argv argument passed to reflectClass');
- }
- return new IPF_Server_Reflection_Function(new ReflectionFunction($function), $namespace, $argv);
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Class
-{
- protected $_config = array();
- protected $_methods = array();
- protected $_namespace = null;
- protected $_reflection;
- public function __construct(ReflectionClass $reflection, $namespace = null, $argv = false)
- {
- $this->_reflection = $reflection;
- $this->setNamespace($namespace);
-
- foreach ($reflection->getMethods() as $method) {
- // Don't aggregate magic methods
- if ('__' == substr($method->getName(), 0, 2)) {
- continue;
- }
-
- if ($method->isPublic()) {
- // Get signatures and description
- $this->_methods[] = new IPF_Server_Reflection_Method($this, $method, $this->getNamespace(), $argv);
- }
- }
- }
-
- public function __call($method, $args)
- {
- if (method_exists($this->_reflection, $method)) {
- return call_user_func_array(array($this->_reflection, $method), $args);
- }
- throw new IPF_Exception('Invalid reflection method');
- }
-
- public function __get($key)
- {
- if (isset($this->_config[$key])) {
- return $this->_config[$key];
- }
-
- return null;
- }
-
- public function __set($key, $value)
- {
- $this->_config[$key] = $value;
- }
-
- public function getMethods()
- {
- return $this->_methods;
- }
-
- public function getNamespace()
- {
- return $this->_namespace;
- }
-
- public function setNamespace($namespace)
- {
- if (empty($namespace)) {
- $this->_namespace = '';
- return;
- }
-
- if (!is_string($namespace) || !preg_match('/[a-z0-9_\.]+/i', $namespace)) {
- throw new IPF_Exception('Invalid namespace');
- }
-
- $this->_namespace = $namespace;
- }
-
- public function __wakeup()
- {
- $this->_reflection = new ReflectionClass($this->getName());
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Function extends IPF_Server_Reflection_Function_Abstract{
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Function_Abstract
-{
- protected $_reflection;
- protected $_argv = array();
- protected $_config = array();
- protected $_class;
- protected $_description = '';
- protected $_namespace;
-
- protected $_prototypes = array();
-
- private $_return;
- private $_returnDesc;
- private $_paramDesc;
- private $_sigParams;
- private $_sigParamsDepth;
-
- public function __construct(Reflector $r, $namespace = null, $argv = array())
- {
- // In PHP 5.1.x, ReflectionMethod extends ReflectionFunction. In 5.2.x,
- // both extend ReflectionFunctionAbstract. So, we can't do normal type
- // hinting in the prototype, but instead need to do some explicit
- // testing here.
- if ((!$r instanceof ReflectionFunction)
- && (!$r instanceof ReflectionMethod)) {
- throw new IPF_Exception('Invalid reflection class');
- }
- $this->_reflection = $r;
-
- // Determine namespace
- if (null !== $namespace){
- $this->setNamespace($namespace);
- }
-
- // Determine arguments
- if (is_array($argv)) {
- $this->_argv = $argv;
- }
-
- // If method call, need to store some info on the class
- if ($r instanceof ReflectionMethod) {
- $this->_class = $r->getDeclaringClass()->getName();
- }
-
- // Perform some introspection
- $this->_reflect();
- }
-
- protected function _addTree(IPF_Server_Reflection_Node $parent, $level = 0)
- {
- if ($level >= $this->_sigParamsDepth) {
- return;
- }
-
- foreach ($this->_sigParams[$level] as $value) {
- $node = new IPF_Server_Reflection_Node($value, $parent);
- if ((null !== $value) && ($this->_sigParamsDepth > $level + 1)) {
- $this->_addTree($node, $level + 1);
- }
- }
- }
-
- protected function _buildTree()
- {
- $returnTree = array();
- foreach ((array) $this->_return as $value) {
- $node = new IPF_Server_Reflection_Node($value);
- $this->_addTree($node);
- $returnTree[] = $node;
- }
-
- return $returnTree;
- }
-
- protected function _buildSignatures($return, $returnDesc, $paramTypes, $paramDesc)
- {
- $this->_return = $return;
- $this->_returnDesc = $returnDesc;
- $this->_paramDesc = $paramDesc;
- $this->_sigParams = $paramTypes;
- $this->_sigParamsDepth = count($paramTypes);
- $signatureTrees = $this->_buildTree();
- $signatures = array();
-
- $endPoints = array();
- foreach ($signatureTrees as $root) {
- $tmp = $root->getEndPoints();
- if (empty($tmp)) {
- $endPoints = array_merge($endPoints, array($root));
- } else {
- $endPoints = array_merge($endPoints, $tmp);
- }
- }
-
- foreach ($endPoints as $node) {
- if (!$node instanceof IPF_Server_Reflection_Node) {
- continue;
- }
-
- $signature = array();
- do {
- array_unshift($signature, $node->getValue());
- $node = $node->getParent();
- } while ($node instanceof IPF_Server_Reflection_Node);
-
- $signatures[] = $signature;
- }
-
- // Build prototypes
- $params = $this->_reflection->getParameters();
- foreach ($signatures as $signature) {
- $return = new IPF_Server_Reflection_ReturnValue(array_shift($signature), $this->_returnDesc);
- $tmp = array();
- foreach ($signature as $key => $type) {
- $param = new IPF_Server_Reflection_Parameter($params[$key], $type, $this->_paramDesc[$key]);
- $param->setPosition($key);
- $tmp[] = $param;
- }
-
- $this->_prototypes[] = new IPF_Server_Reflection_Prototype($return, $tmp);
- }
- }
-
- protected function _reflect()
- {
- $function = $this->_reflection;
- $helpText = '';
- $signatures = array();
- $returnDesc = '';
- $paramCount = $function->getNumberOfParameters();
- $paramCountRequired = $function->getNumberOfRequiredParameters();
- $parameters = $function->getParameters();
- $docBlock = $function->getDocComment();
-
- if (!empty($docBlock)) {
- // Get help text
- if (preg_match(':/\*\*\s*\r?\n\s*\*\s(.*?)\r?\n\s*\*(\s@|/):s', $docBlock, $matches))
- {
- $helpText = $matches[1];
- $helpText = preg_replace('/(^\s*\*\s)/m', '', $helpText);
- $helpText = preg_replace('/\r?\n\s*\*\s*(\r?\n)*/s', "\n", $helpText);
- $helpText = trim($helpText);
- }
-
- // Get return type(s) and description
- $return = 'void';
- if (preg_match('/@return\s+(\S+)/', $docBlock, $matches)) {
- $return = explode('|', $matches[1]);
- if (preg_match('/@return\s+\S+\s+(.*?)(@|\*\/)/s', $docBlock, $matches))
- {
- $value = $matches[1];
- $value = preg_replace('/\s?\*\s/m', '', $value);
- $value = preg_replace('/\s{2,}/', ' ', $value);
- $returnDesc = trim($value);
- }
- }
-
- // Get param types and description
- if (preg_match_all('/@param\s+([^\s]+)/m', $docBlock, $matches)) {
- $paramTypesTmp = $matches[1];
- if (preg_match_all('/@param\s+\S+\s+(\$^\S+)\s+(.*?)(@|\*\/)/s', $docBlock, $matches))
- {
- $paramDesc = $matches[2];
- foreach ($paramDesc as $key => $value) {
- $value = preg_replace('/\s?\*\s/m', '', $value);
- $value = preg_replace('/\s{2,}/', ' ', $value);
- $paramDesc[$key] = trim($value);
- }
- }
- }
- } else {
- $helpText = $function->getName();
- $return = 'void';
- }
-
- // Set method description
- $this->setDescription($helpText);
-
- // Get all param types as arrays
- if (!isset($paramTypesTmp) && (0 < $paramCount)) {
- $paramTypesTmp = array_fill(0, $paramCount, 'mixed');
- } elseif (!isset($paramTypesTmp)) {
- $paramTypesTmp = array();
- } elseif (count($paramTypesTmp) < $paramCount) {
- $start = $paramCount - count($paramTypesTmp);
- for ($i = $start; $i < $paramCount; ++$i) {
- $paramTypesTmp[$i] = 'mixed';
- }
- }
-
- // Get all param descriptions as arrays
- if (!isset($paramDesc) && (0 < $paramCount)) {
- $paramDesc = array_fill(0, $paramCount, '');
- } elseif (!isset($paramDesc)) {
- $paramDesc = array();
- } elseif (count($paramDesc) < $paramCount) {
- $start = $paramCount - count($paramDesc);
- for ($i = $start; $i < $paramCount; ++$i) {
- $paramDesc[$i] = '';
- }
- }
-
-
- $paramTypes = array();
- foreach ($paramTypesTmp as $i => $param) {
- $tmp = explode('|', $param);
- if ($parameters[$i]->isOptional()) {
- array_unshift($tmp, null);
- }
- $paramTypes[] = $tmp;
- }
-
- $this->_buildSignatures($return, $returnDesc, $paramTypes, $paramDesc);
- }
-
- public function __call($method, $args)
- {
- if (method_exists($this->_reflection, $method)) {
- return call_user_func_array(array($this->_reflection, $method), $args);
- }
-
- throw new IPF_Exception('Invalid reflection method ("' .$method. '")');
- }
-
- public function __get($key)
- {
- if (isset($this->_config[$key])) {
- return $this->_config[$key];
- }
-
- return null;
- }
-
- public function __set($key, $value)
- {
- $this->_config[$key] = $value;
- }
-
- public function setNamespace($namespace)
- {
- if (empty($namespace)) {
- $this->_namespace = '';
- return;
- }
-
- if (!is_string($namespace) || !preg_match('/[a-z0-9_\.]+/i', $namespace)) {
- throw new IPF_Exception('Invalid namespace');
- }
-
- $this->_namespace = $namespace;
- }
-
- public function getNamespace()
- {
- return $this->_namespace;
- }
-
- public function setDescription($string)
- {
- if (!is_string($string)) {
- throw new IPF_Exception('Invalid description');
- }
-
- $this->_description = $string;
- }
-
- public function getDescription()
- {
- return $this->_description;
- }
-
- public function getPrototypes()
- {
- return $this->_prototypes;
- }
-
- public function getInvokeArguments()
- {
- return $this->_argv;
- }
-
- public function __wakeup()
- {
- if ($this->_reflection instanceof ReflectionMethod) {
- $class = new ReflectionClass($this->_class);
- $this->_reflection = new ReflectionMethod($class->newInstance(), $this->getName());
- } else {
- $this->_reflection = new ReflectionFunction($this->getName());
- }
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Method extends IPF_Server_Reflection_Function_Abstract
-{
- protected $_class;
- protected $_classReflection;
-
- public function __construct(IPF_Server_Reflection_Class $class, ReflectionMethod $r, $namespace = null, $argv = array())
- {
- $this->_classReflection = $class;
- $this->_reflection = $r;
-
- $classNamespace = $class->getNamespace();
-
- // Determine namespace
- if (!empty($namespace)) {
- $this->setNamespace($namespace);
- } elseif (!empty($classNamespace)) {
- $this->setNamespace($classNamespace);
- }
-
- // Determine arguments
- if (is_array($argv)) {
- $this->_argv = $argv;
- }
-
- // If method call, need to store some info on the class
- $this->_class = $class->getName();
-
- // Perform some introspection
- $this->_reflect();
- }
-
- public function getDeclaringClass()
- {
- return $this->_classReflection;
- }
-
- public function __wakeup()
- {
- $this->_classReflection = new IPF_Server_Reflection_Class(new ReflectionClass($this->_class), $this->getNamespace(), $this->getInvokeArguments());
- $this->_reflection = new ReflectionMethod($this->_classReflection->getName(), $this->getName());
- }
-
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Node
-{
- protected $_value = null;
- protected $_children = array();
- protected $_parent = null;
-
- public function __construct($value, IPF_Server_Reflection_Node $parent = null)
- {
- $this->_value = $value;
- if (null !== $parent) {
- $this->setParent($parent, true);
- }
-
- return $this;
- }
-
- public function setParent(IPF_Server_Reflection_Node $node, $new = false)
- {
- $this->_parent = $node;
-
- if ($new) {
- $node->attachChild($this);
- return;
- }
- }
-
- public function createChild($value)
- {
- $child = new self($value, $this);
-
- return $child;
- }
-
- public function attachChild(IPF_Server_Reflection_Node $node)
- {
- $this->_children[] = $node;
-
- if ($node->getParent() !== $this) {
- $node->setParent($this);
- }
- }
-
- public function getChildren()
- {
- return $this->_children;
- }
-
- public function hasChildren()
- {
- return count($this->_children) > 0;
- }
-
- public function getParent()
- {
- return $this->_parent;
- }
-
- public function getValue()
- {
- return $this->_value;
- }
-
- public function setValue($value)
- {
- $this->_value = $value;
- }
-
- public function getEndPoints()
- {
- $endPoints = array();
- if (!$this->hasChildren()) {
- return $endPoints;
- }
-
- foreach ($this->_children as $child) {
- $value = $child->getValue();
-
- if (null === $value) {
- $endPoints[] = $this;
- } elseif ((null !== $value)
- && $child->hasChildren())
- {
- $childEndPoints = $child->getEndPoints();
- if (!empty($childEndPoints)) {
- $endPoints = array_merge($endPoints, $childEndPoints);
- }
- } elseif ((null !== $value) && !$child->hasChildren()) {
- $endPoints[] = $child;
- }
- }
-
- return $endPoints;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Parameter
-{
- protected $_reflection;
- protected $_position;
- protected $_type;
- protected $_description;
-
- public function __construct(ReflectionParameter $r, $type = 'mixed', $description = '')
- {
- $this->_reflection = $r;
- $this->setType($type);
- $this->setDescription($description);
- }
-
- public function __call($method, $args)
- {
- if (method_exists($this->_reflection, $method)) {
- return call_user_func_array(array($this->_reflection, $method), $args);
- }
- throw new IPF_Exception('Invalid reflection method');
- }
-
- public function getType()
- {
- return $this->_type;
- }
-
- public function setType($type)
- {
- if (!is_string($type) && (null !== $type)) {
- throw new IPF_Exception('Invalid parameter type');
- }
- $this->_type = $type;
- }
-
- public function getDescription()
- {
- return $this->_description;
- }
-
- public function setDescription($description)
- {
- if (!is_string($description) && (null !== $description)) {
- throw new IPF_Exception('Invalid parameter description');
- }
- $this->_description = $description;
- }
-
- public function setPosition($index)
- {
- $this->_position = (int) $index;
- }
-
- public function getPosition()
- {
- return $this->_position;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_Prototype
-{
- public function __construct(IPF_Server_Reflection_ReturnValue $return, $params = null)
- {
- $this->_return = $return;
-
- if (!is_array($params) && (null !== $params)) {
- throw new IPF_Exception('Invalid parameters');
- }
-
- if (is_array($params)) {
- foreach ($params as $param) {
- if (!$param instanceof IPF_Server_Reflection_Parameter) {
- throw new IPF_Exception('One or more params are invalid');
- }
- }
- }
-
- $this->_params = $params;
- }
-
- public function getReturnType()
- {
- return $this->_return->getType();
- }
-
- public function getReturnValue()
- {
- return $this->_return;
- }
-
- public function getParameters()
- {
- return $this->_params;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_Server_Reflection_ReturnValue
-{
- protected $_type;
- protected $_description;
-
- public function __construct($type = 'mixed', $description = '')
- {
- $this->setType($type);
- $this->setDescription($description);
- }
-
- public function getType()
- {
- return $this->_type;
- }
-
- public function setType($type)
- {
- if (!is_string($type) && (null !== $type)) {
- throw new IPF_Exception('Invalid parameter type');
- }
- $this->_type = $type;
- }
-
- public function getDescription()
- {
- return $this->_description;
- }
-
- public function setDescription($description)
- {
- if (!is_string($description) && (null !== $description)) {
- throw new IPF_Exception('Invalid parameter description');
- }
- $this->_description = $description;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Fault
-{
- protected $_code;
- protected $_encoding = 'UTF-8';
- protected $_message;
-
- protected $_internal = array(
- 404 => 'Unknown Error',
-
- // 610 - 619 reflection errors
- 610 => 'Invalid method class',
- 611 => 'Unable to attach function or callback; not callable',
- 612 => 'Unable to load array; not an array',
- 613 => 'One or more method records are corrupt or otherwise unusable',
-
- // 620 - 629 dispatch errors
- 620 => 'Method does not exist',
- 621 => 'Error instantiating class to invoke method',
- 622 => 'Method missing implementation',
- 623 => 'Calling parameters do not match signature',
-
- // 630 - 639 request errors
- 630 => 'Unable to read request',
- 631 => 'Failed to parse request',
- 632 => 'Invalid request, no method passed; request must contain a \'methodName\' tag',
- 633 => 'Param must contain a value',
- 634 => 'Invalid method name',
- 635 => 'Invalid XML provided to request',
- 636 => 'Error creating xmlrpc value',
-
- // 640 - 649 system.* errors
- 640 => 'Method does not exist',
-
- // 650 - 659 response errors
- 650 => 'Invalid XML provided for response',
- 651 => 'Failed to parse response',
- 652 => 'Invalid response',
- 653 => 'Invalid XMLRPC value in response',
- );
-
- public function __construct($code = 404, $message = '')
- {
- $this->setCode($code);
- $code = $this->getCode();
-
- if (empty($message) && isset($this->_internal[$code])) {
- $message = $this->_internal[$code];
- } elseif (empty($message)) {
- $message = 'Unknown error';
- }
- $this->setMessage($message);
- }
-
- public function setCode($code)
- {
- $this->_code = (int) $code;
- return $this;
- }
-
- public function getCode()
- {
- return $this->_code;
- }
-
- public function setMessage($message)
- {
- $this->_message = (string) $message;
- return $this;
- }
-
- public function getMessage()
- {
- return $this->_message;
- }
-
- public function setEncoding($encoding)
- {
- $this->_encoding = $encoding;
- return $this;
- }
-
- public function getEncoding()
- {
- return $this->_encoding;
- }
-
- public function loadXml($fault)
- {
- if (!is_string($fault)) {
- throw new IPF_Exception('Invalid XML provided to fault');
- }
-
- try {
- $xml = @new SimpleXMLElement($fault);
- } catch (Exception $e) {
- // Not valid XML
- throw new IPF_Exception('Failed to parse XML fault: ' . $e->getMessage(), 500);
- }
-
- // Check for fault
- if (!$xml->fault) {
- // Not a fault
- return false;
- }
-
- if (!$xml->fault->value->struct) {
- // not a proper fault
- throw new IPF_Exception('Invalid fault structure', 500);
- }
-
- $structXml = $xml->fault->value->asXML();
- $structXml = preg_replace('/<\?xml version=.*?\?>/i', '', $structXml);
- $struct = IPF_XmlRpc_Value::getXmlRpcValue(trim($structXml), IPF_XmlRpc_Value::XML_STRING);
- $struct = $struct->getValue();
-
- if (isset($struct['faultCode'])) {
- $code = $struct['faultCode'];
- }
- if (isset($struct['faultString'])) {
- $message = $struct['faultString'];
- }
-
- if (empty($code) && empty($message)) {
- throw new IPF_Exception('Fault code and string required');
- }
-
- if (empty($code)) {
- $code = '404';
- }
-
- if (empty($message)) {
- if (isset($this->_internal[$code])) {
- $message = $this->_internal[$code];
- } else {
- $message = 'Unknown Error';
- }
- }
-
- $this->setCode($code);
- $this->setMessage($message);
-
- return true;
- }
-
- public static function isFault($xml)
- {
- $fault = new self();
- try {
- $isFault = $fault->loadXml($xml);
- } catch (IPF_Exception $e) {
- $isFault = false;
- }
-
- return $isFault;
- }
-
- public function saveXML()
- {
- // Create fault value
- $faultStruct = array(
- 'faultCode' => $this->getCode(),
- 'faultString' => $this->getMessage()
- );
- $value = IPF_XmlRpc_Value::getXmlRpcValue($faultStruct);
- $valueDOM = new DOMDocument('1.0', $this->getEncoding());
- $valueDOM->loadXML($value->saveXML());
-
- // Build response XML
- $dom = new DOMDocument('1.0', 'ISO-8859-1');
- $r = $dom->appendChild($dom->createElement('methodResponse'));
- $f = $r->appendChild($dom->createElement('fault'));
- $f->appendChild($dom->importNode($valueDOM->documentElement, 1));
-
- return $dom->saveXML();
- }
-
- public function __toString()
- {
- return $this->saveXML();
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Request
-{
- protected $_encoding = 'UTF-8';
- protected $_method;
- protected $_xml;
- protected $_params = array();
- protected $_fault = null;
- protected $_types = array();
- protected $_xmlRpcParams = array();
-
- public function __construct($method = null, $params = null)
- {
- if ($method !== null) {
- $this->setMethod($method);
- }
-
- if ($params !== null) {
- $this->setParams($params);
- }
- }
-
- public function setEncoding($encoding)
- {
- $this->_encoding = $encoding;
- return $this;
- }
-
- public function getEncoding()
- {
- return $this->_encoding;
- }
-
- public function setMethod($method)
- {
- if (!is_string($method) || !preg_match('/^[a-z0-9_.:\/]+$/i', $method)) {
- $this->_fault = new IPF_XmlRpc_Fault(634, 'Invalid method name ("' . $method . '")');
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- $this->_method = $method;
- return true;
- }
-
- public function getMethod()
- {
- return $this->_method;
- }
-
- public function addParam($value, $type = null)
- {
- $this->_params[] = $value;
- if (null === $type) {
- // Detect type if not provided explicitly
- if ($value instanceof IPF_XmlRpc_Value) {
- $type = $value->getType();
- } else {
- $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($value);
- $type = $xmlRpcValue->getType();
- }
- }
- $this->_types[] = $type;
- $this->_xmlRpcParams[] = array('value' => $value, 'type' => $type);
- }
-
- public function setParams()
- {
- $argc = func_num_args();
- $argv = func_get_args();
- if (0 == $argc) {
- return;
- }
-
- if ((1 == $argc) && is_array($argv[0])) {
- $params = array();
- $types = array();
- $wellFormed = true;
- foreach ($argv[0] as $arg) {
- if (!is_array($arg) || !isset($arg['value'])) {
- $wellFormed = false;
- break;
- }
- $params[] = $arg['value'];
-
- if (!isset($arg['type'])) {
- $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg['value']);
- $arg['type'] = $xmlRpcValue->getType();
- }
- $types[] = $arg['type'];
- }
- if ($wellFormed) {
- $this->_xmlRpcParams = $argv[0];
- $this->_params = $params;
- $this->_types = $types;
- } else {
- $this->_params = $argv[0];
- $this->_types = array();
- $xmlRpcParams = array();
- foreach ($argv[0] as $arg) {
- if ($arg instanceof IPF_XmlRpc_Value) {
- $type = $arg->getType();
- } else {
- $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg);
- $type = $xmlRpcValue->getType();
- }
- $xmlRpcParams[] = array('value' => $arg, 'type' => $type);
- $this->_types[] = $type;
- }
- $this->_xmlRpcParams = $xmlRpcParams;
- }
- return;
- }
-
- $this->_params = $argv;
- $this->_types = array();
- $xmlRpcParams = array();
- foreach ($argv as $arg) {
- if ($arg instanceof IPF_XmlRpc_Value) {
- $type = $arg->getType();
- } else {
- $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg);
- $type = $xmlRpcValue->getType();
- }
- $xmlRpcParams[] = array('value' => $arg, 'type' => $type);
- $this->_types[] = $type;
- }
- $this->_xmlRpcParams = $xmlRpcParams;
- }
-
- public function getParams()
- {
- return $this->_params;
- }
-
- public function getTypes()
- {
- return $this->_types;
- }
-
- public function loadXml($request)
- {
- if (!is_string($request)) {
- $this->_fault = new IPF_XmlRpc_Fault(635);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- try {
- $xml = @new SimpleXMLElement($request);
- } catch (Exception $e) {
- // Not valid XML
- $this->_fault = new IPF_XmlRpc_Fault(631);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- // Check for method name
- if (empty($xml->methodName)) {
- // Missing method name
- $this->_fault = new IPF_XmlRpc_Fault(632);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- $this->_method = (string) $xml->methodName;
-
- // Check for parameters
- if (!empty($xml->params)) {
- $types = array();
- $argv = array();
- foreach ($xml->params->children() as $param) {
- if (! $param->value instanceof SimpleXMLElement) {
- $this->_fault = new IPF_XmlRpc_Fault(633);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- try {
- $param = IPF_XmlRpc_Value::getXmlRpcValue($param->value, IPF_XmlRpc_Value::XML_STRING);
- $types[] = $param->getType();
- $argv[] = $param->getValue();
- } catch (Exception $e) {
- $this->_fault = new IPF_XmlRpc_Fault(636);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
- }
-
- $this->_types = $types;
- $this->_params = $argv;
- }
-
- $this->_xml = $request;
-
- return true;
- }
-
- public function isFault()
- {
- return $this->_fault instanceof IPF_XmlRpc_Fault;
- }
-
- public function getFault()
- {
- return $this->_fault;
- }
-
- protected function _getXmlRpcParams()
- {
- $params = array();
- if (is_array($this->_xmlRpcParams)) {
- foreach ($this->_xmlRpcParams as $param) {
- $value = $param['value'];
- $type = isset($param['type']) ? $param['type'] : IPF_XmlRpc_Value::AUTO_DETECT_TYPE;
-
- if (!$value instanceof IPF_XmlRpc_Value) {
- $value = IPF_XmlRpc_Value::getXmlRpcValue($value, $type);
- }
- $params[] = $value;
- }
- }
-
- return $params;
- }
-
- public function saveXML()
- {
- $args = $this->_getXmlRpcParams();
- $method = $this->getMethod();
-
- $dom = new DOMDocument('1.0', $this->getEncoding());
- $mCall = $dom->appendChild($dom->createElement('methodCall'));
- $mName = $mCall->appendChild($dom->createElement('methodName', $method));
-
- if (is_array($args) && count($args)) {
- $params = $mCall->appendChild($dom->createElement('params'));
-
- foreach ($args as $arg) {
- /* @var $arg IPF_XmlRpc_Value */
- $argDOM = new DOMDocument('1.0', $this->getEncoding());
- $argDOM->loadXML($arg->saveXML());
-
- $param = $params->appendChild($dom->createElement('param'));
- $param->appendChild($dom->importNode($argDOM->documentElement, 1));
- }
- }
-
- return $dom->saveXML();
- }
-
- public function __toString()
- {
- return $this->saveXML();
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Request_Http extends IPF_XmlRpc_Request
-{
- protected $_headers;
- protected $_xml;
- public function __construct()
- {
- $fh = fopen('php://input', 'r');
- if (!$fh) {
- $this->_fault = new IPF_Exception(630);
- return;
- }
-
- $xml = '';
- while (!feof($fh)) {
- $xml .= fgets($fh);
- }
- fclose($fh);
-
- $this->_xml = $xml;
-
- $this->loadXml($xml);
- }
-
- public function getRawRequest()
- {
- return $this->_xml;
- }
-
- public function getHeaders()
- {
- if (null === $this->_headers) {
- $this->_headers = array();
- foreach ($_SERVER as $key => $value) {
- if ('HTTP_' == substr($key, 0, 5)) {
- $header = str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($key, 5)))));
- $this->_headers[$header] = $value;
- }
- }
- }
-
- return $this->_headers;
- }
-
- public function getFullRequest()
- {
- $request = '';
- foreach ($this->getHeaders() as $key => $value) {
- $request .= $key . ': ' . $value . "\n";
- }
-
- $request .= $this->_xml;
-
- return $request;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Request_Stdin extends IPF_XmlRpc_Request
-{
- protected $_xml;
-
- public function __construct()
- {
- $fh = fopen('php://stdin', 'r');
- if (!$fh) {
- $this->_fault = new IPF_XmlRpc_Fault(630);
- return;
- }
-
- $xml = '';
- while (!feof($fh)) {
- $xml .= fgets($fh);
- }
- fclose($fh);
-
- $this->_xml = $xml;
-
- $this->loadXml($xml);
- }
-
- public function getRawRequest()
- {
- return $this->_xml;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Response
-{
- protected $_return;
- protected $_type;
- protected $_encoding = 'UTF-8';
- protected $_fault = null;
-
- public function __construct($return = null, $type = null)
- {
- $this->setReturnValue($return, $type);
- }
-
- public function setEncoding($encoding)
- {
- $this->_encoding = $encoding;
- return $this;
- }
-
- public function getEncoding()
- {
- return $this->_encoding;
- }
-
- public function setReturnValue($value, $type = null)
- {
- $this->_return = $value;
- $this->_type = (string) $type;
- }
-
- public function getReturnValue()
- {
- return $this->_return;
- }
-
- protected function _getXmlRpcReturn()
- {
- return IPF_XmlRpc_Value::getXmlRpcValue($this->_return);
- }
-
- public function isFault()
- {
- return $this->_fault instanceof IPF_XmlRpc_Fault;
- }
-
- public function getFault()
- {
- return $this->_fault;
- }
-
- public function loadXml($response)
- {
- if (!is_string($response)) {
- $this->_fault = new IPF_XmlRpc_Fault(650);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- try {
- $xml = @new SimpleXMLElement($response);
- } catch (Exception $e) {
- // Not valid XML
- $this->_fault = new IPF_XmlRpc_Fault(651);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- if (!empty($xml->fault)) {
- // fault response
- $this->_fault = new IPF_XmlRpc_Fault();
- $this->_fault->setEncoding($this->getEncoding());
- $this->_fault->loadXml($response);
- return false;
- }
-
- if (empty($xml->params)) {
- // Invalid response
- $this->_fault = new IPF_XmlRpc_Fault(652);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- try {
- if (!isset($xml->params) || !isset($xml->params->param) || !isset($xml->params->param->value)) {
- throw new IPF_Exception('Missing XML-RPC value in XML');
- }
- $valueXml = $xml->params->param->value->asXML();
- $valueXml = preg_replace('/<\?xml version=.*?\?>/i', '', $valueXml);
- $value = IPF_XmlRpc_Value::getXmlRpcValue(trim($valueXml), IPF_XmlRpc_Value::XML_STRING);
- } catch (IPF_Exception $e) {
- $this->_fault = new IPF_XmlRpc_Fault(653);
- $this->_fault->setEncoding($this->getEncoding());
- return false;
- }
-
- $this->setReturnValue($value->getValue());
- return true;
- }
-
- public function saveXML()
- {
- $value = $this->_getXmlRpcReturn();
- $valueDOM = new DOMDocument('1.0', $this->getEncoding());
- $valueDOM->loadXML($value->saveXML());
-
- $dom = new DOMDocument('1.0', $this->getEncoding());
- $response = $dom->appendChild($dom->createElement('methodResponse'));
- $params = $response->appendChild($dom->createElement('params'));
- $param = $params->appendChild($dom->createElement('param'));
-
- $param->appendChild($dom->importNode($valueDOM->documentElement, true));
-
- return $dom->saveXML();
- }
-
- public function __toString()
- {
- return $this->saveXML();
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Response_Http extends IPF_XmlRpc_Response
-{
- public function __toString()
- {
- if (!headers_sent()) {
- header('Content-Type: text/xml; charset=' . strtolower($this->getEncoding()));
- }
- return parent::__toString();
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Server
-{
- protected $_encoding = 'UTF-8';
- protected $_methods = array();
- protected $_request = null;
- protected $_responseClass = 'IPF_XmlRpc_Response_Http';
-
- protected $_table = array();
-
- protected $_typeMap = array(
- 'i4' => 'i4',
- 'int' => 'int',
- 'integer' => 'int',
- 'double' => 'double',
- 'float' => 'double',
- 'real' => 'double',
- 'boolean' => 'boolean',
- 'bool' => 'boolean',
- 'true' => 'boolean',
- 'false' => 'boolean',
- 'string' => 'string',
- 'str' => 'string',
- 'base64' => 'base64',
- 'dateTime.iso8601' => 'dateTime.iso8601',
- 'date' => 'dateTime.iso8601',
- 'time' => 'dateTime.iso8601',
- 'time' => 'dateTime.iso8601',
- 'array' => 'array',
- 'struct' => 'struct',
- 'null' => 'nil',
- 'nil' => 'nil',
- 'void' => 'void',
- 'mixed' => 'struct'
- );
-
- public function __construct()
- {
- // Setup system.* methods
- $system = array(
- 'listMethods',
- 'methodHelp',
- 'methodSignature',
- 'multicall'
- );
-
- $class = IPF_Server_Reflection::reflectClass($this);
- foreach ($system as $method) {
- $reflection = new IPF_Server_Reflection_Method($class, new ReflectionMethod($this, $method), 'system');
- $reflection->system = true;
- $this->_methods[] = $reflection;
- }
-
- $this->_buildDispatchTable();
- }
-
- protected function _fixTypes(IPF_Server_Reflection_Function_Abstract $method)
- {
- foreach ($method->getPrototypes() as $prototype) {
- foreach ($prototype->getParameters() as $param) {
- $pType = $param->getType();
- if (isset($this->_typeMap[$pType])) {
- $param->setType($this->_typeMap[$pType]);
- } else {
- $param->setType('void');
- }
- }
- }
- }
-
- protected function _buildDispatchTable()
- {
- $table = array();
- foreach ($this->_methods as $dispatchable) {
- if ($dispatchable instanceof IPF_Server_Reflection_Function_Abstract) {
- // function/method call
- $ns = $dispatchable->getNamespace();
- $name = $dispatchable->getName();
- $name = empty($ns) ? $name : $ns . '.' . $name;
-
- if (isset($table[$name])) {
- throw new IPF_Exception('Duplicate method registered: ' . $name);
- }
- $table[$name] = $dispatchable;
- $this->_fixTypes($dispatchable);
-
- continue;
- }
-
- if ($dispatchable instanceof IPF_Server_Reflection_Class) {
- foreach ($dispatchable->getMethods() as $method) {
- $ns = $method->getNamespace();
- $name = $method->getName();
- $name = empty($ns) ? $name : $ns . '.' . $name;
-
- if (isset($table[$name])) {
- throw new IPF_Exception('Duplicate method registered: ' . $name);
- }
- $table[$name] = $method;
- $this->_fixTypes($method);
- continue;
- }
- }
- }
-
- $this->_table = $table;
- }
-
- public function setEncoding($encoding)
- {
- $this->_encoding = $encoding;
- return $this;
- }
-
- public function getEncoding()
- {
- return $this->_encoding;
- }
-
- public function addFunction($function, $namespace = '')
- {
- if (!is_string($function) && !is_array($function)) {
- throw new IPF_Exception('Unable to attach function; invalid', 611);
- }
-
- $argv = null;
- if (2 < func_num_args()) {
- $argv = func_get_args();
- $argv = array_slice($argv, 2);
- }
-
- $function = (array) $function;
- foreach ($function as $func) {
- if (!is_string($func) || !function_exists($func)) {
- throw new IPF_Exception('Unable to attach function; invalid', 611);
- }
- $this->_methods[] = IPF_Server_Reflection::reflectFunction($func, $argv, $namespace);
- }
-
- $this->_buildDispatchTable();
- }
-
- public function loadFunctions($array)
- {
- if (!is_array($array)) {
- throw new IPF_Exception('Unable to load array; not an array', 612);
- }
-
- foreach ($array as $key => $value) {
- if (!$value instanceof IPF_Server_Reflection_Function_Abstract
- && !$value instanceof IPF_Server_Reflection_Class)
- {
- throw new IPF_Exception('One or more method records are corrupt or otherwise unusable', 613);
- }
-
- if ($value->system) {
- unset($array[$key]);
- }
- }
-
- foreach ($array as $dispatchable) {
- $this->_methods[] = $dispatchable;
- }
-
- $this->_buildDispatchTable();
- }
-
- public function setPersistence($class = null)
- {
- }
-
- public function setClass($class, $namespace = '', $argv = null)
- {
- if (is_string($class) && !class_exists($class)) {
- if (!class_exists($class)) {
- throw new IPF_Exception('Invalid method class', 610);
- }
- }
-
- $argv = null;
- if (3 < func_num_args()) {
- $argv = func_get_args();
- $argv = array_slice($argv, 3);
- }
-
- $this->_methods[] = IPF_Reflection::reflectClass($class, $argv, $namespace);
- $this->_buildDispatchTable();
- }
-
- public function setRequest($request)
- {
- if (is_string($request) && class_exists($request)) {
- $request = new $request();
- if (!$request instanceof IPF_XmlRpc_Request) {
- throw new IPF_Exception('Invalid request class');
- }
- $request->setEncoding($this->getEncoding());
- } elseif (!$request instanceof IPF_XmlRpc_Request) {
- throw new IPF_Exception('Invalid request object');
- }
-
- $this->_request = $request;
- return $this;
- }
-
- public function getRequest()
- {
- return $this->_request;
- }
-
- public function fault($fault, $code = 404)
- {
- if (!$fault instanceof Exception) {
- $fault = (string) $fault;
- $fault = new IPF_Exception($fault, $code);
- }
- return IPF_XmlRpc_Server_Fault::getInstance($fault);
- }
-
- protected function _handle(IPF_XmlRpc_Request $request)
- {
- $method = $request->getMethod();
-
- // Check for valid method
- if (!isset($this->_table[$method])) {
- throw new IPF_Exception('Method "' . $method . '" does not exist', 620);
- }
-
- $info = $this->_table[$method];
- $params = $request->getParams();
- $argv = $info->getInvokeArguments();
- if (0 < count($argv)) {
- $params = array_merge($params, $argv);
- }
-
- // Check calling parameters against signatures
- $matched = false;
- $sigCalled = $request->getTypes();
-
- $sigLength = count($sigCalled);
- $paramsLen = count($params);
- if ($sigLength < $paramsLen) {
- for ($i = $sigLength; $i < $paramsLen; ++$i) {
- $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($params[$i]);
- $sigCalled[] = $xmlRpcValue->getType();
- }
- }
-
- $signatures = $info->getPrototypes();
- foreach ($signatures as $signature) {
- $sigParams = $signature->getParameters();
- $tmpParams = array();
- foreach ($sigParams as $param) {
- $tmpParams[] = $param->getType();
- }
- if ($sigCalled === $tmpParams) {
- $matched = true;
- break;
- }
- }
- if (!$matched) {
- throw new IPF_Exception('Calling parameters do not match signature', 623);
- }
-
- if ($info instanceof IPF_Server_Reflection_Function) {
- $func = $info->getName();
- $return = call_user_func_array($func, $params);
- } elseif (($info instanceof IPF_Server_Reflection_Method) && $info->system) {
- // System methods
- $return = $info->invokeArgs($this, $params);
- } elseif ($info instanceof IPF_Server_Reflection_Method) {
- // Get class
- $class = $info->getDeclaringClass()->getName();
-
- if ('static' == $info->isStatic()) {
- // for some reason, invokeArgs() does not work the same as
- // invoke(), and expects the first argument to be an object.
- // So, using a callback if the method is static.
- $return = call_user_func_array(array($class, $info->getName()), $params);
- } else {
- // Object methods
- try {
- $object = $info->getDeclaringClass()->newInstance();
- } catch (Exception $e) {
- throw new IPF_Exception('Error instantiating class ' . $class . ' to invoke method ' . $info->getName(), 621);
- }
-
- $return = $info->invokeArgs($object, $params);
- }
- } else {
- throw new IPF_Exception('Method missing implementation ' . get_class($info), 622);
- }
-
- $response = new ReflectionClass($this->_responseClass);
- return $response->newInstance($return);
- }
-
- public function handle(IPF_XmlRpc_Request $request = null)
- {
- // Get request
- if ((null === $request) && (null === ($request = $this->getRequest()))) {
- $request = new IPF_XmlRpc_Request_Http();
- $request->setEncoding($this->getEncoding());
- }
-
- $this->setRequest($request);
-
- if ($request->isFault()) {
- $response = $request->getFault();
- } else {
- try {
- $response = $this->_handle($request);
- } catch (Exception $e) {
- $response = $this->fault($e);
- }
- }
-
- // Set output encoding
- $response->setEncoding($this->getEncoding());
-
- return $response;
- }
-
- public function setResponseClass($class)
- {
- if (class_exists($class)) {
- $reflection = new ReflectionClass($class);
- if ($reflection->isSubclassOf(new ReflectionClass('IPF_XmlRpc_Response'))) {
- $this->_responseClass = $class;
- return true;
- }
- }
-
- return false;
- }
-
- public function getFunctions()
- {
- $return = array();
- foreach ($this->_methods as $method) {
- if ($method instanceof IPF_Server_Reflection_Class
- && ($method->system))
- {
- continue;
- }
-
- $return[] = $method;
- }
-
- return $return;
- }
-
- public function listMethods()
- {
- return array_keys($this->_table);
- }
-
- public function methodHelp($method)
- {
- if (!isset($this->_table[$method])) {
- throw new IPF_Exception('Method "' . $method . '"does not exist', 640);
- }
-
- return $this->_table[$method]->getDescription();
- }
-
- public function methodSignature($method)
- {
- if (!isset($this->_table[$method])) {
- throw new IPF_Exception('Method "' . $method . '"does not exist', 640);
- }
- $prototypes = $this->_table[$method]->getPrototypes();
-
- $signatures = array();
- foreach ($prototypes as $prototype) {
- $signature = array($prototype->getReturnType());
- foreach ($prototype->getParameters() as $parameter) {
- $signature[] = $parameter->getType();
- }
- $signatures[] = $signature;
- }
-
- return $signatures;
- }
-
- public function multicall($methods)
- {
- $responses = array();
- foreach ($methods as $method) {
- $fault = false;
- if (!is_array($method)) {
- $fault = $this->fault('system.multicall expects each method to be a struct', 601);
- } elseif (!isset($method['methodName'])) {
- $fault = $this->fault('Missing methodName', 602);
- } elseif (!isset($method['params'])) {
- $fault = $this->fault('Missing params', 603);
- } elseif (!is_array($method['params'])) {
- $fault = $this->fault('Params must be an array', 604);
- } else {
- if ('system.multicall' == $method['methodName']) {
- // don't allow recursive calls to multicall
- $fault = $this->fault('Recursive system.multicall forbidden', 605);
- }
- }
-
- if (!$fault) {
- try {
- $request = new IPF_XmlRpc_Request();
- $request->setMethod($method['methodName']);
- $request->setParams($method['params']);
- $response = $this->_handle($request);
- $responses[] = $response->getReturnValue();
- } catch (Exception $e) {
- $fault = $this->fault($e);
- }
- }
-
- if ($fault) {
- $responses[] = array(
- 'faultCode' => $fault->getCode(),
- 'faultString' => $fault->getMessage()
- );
- }
- }
- return $responses;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Server_Cache
-{
- public static function save($filename, IPF_XmlRpc_Server $server)
- {
- if (!is_string($filename)
- || (!file_exists($filename) && !is_writable(dirname($filename))))
- {
- return false;
- }
-
- // Remove system.* methods
- $methods = $server->getFunctions();
- foreach ($methods as $name => $method) {
- if ($method->system) {
- unset($methods[$name]);
- }
- }
-
- // Store
- if (0 === @file_put_contents($filename, serialize($methods))) {
- return false;
- }
-
- return true;
- }
-
- public static function get($filename, IPF_XmlRpc_Server $server)
- {
- if (!is_string($filename)
- || !file_exists($filename)
- || !is_readable($filename))
- {
- return false;
- }
-
- if (false === ($dispatch = @file_get_contents($filename))) {
- return false;
- }
-
- if (false === ($dispatchArray = @unserialize($dispatch))) {
- return false;
- }
-
- $server->loadFunctions($dispatchArray);
-
- return true;
- }
-
- public static function delete($filename)
- {
- if (is_string($filename) && file_exists($filename)) {
- unlink($filename);
- return true;
- }
-
- return false;
- }
-}
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Server_Fault extends IPF_XmlRpc_Fault
-{
- protected $_exception;
- protected static $_faultExceptionClasses = array('IPF_Exception' => true);
- protected static $_observers = array();
-
- public function __construct(Exception $e)
- {
- $this->_exception = $e;
- $code = 404;
- $message = 'Unknown error';
- $exceptionClass = get_class($e);
-
- foreach (array_keys(self::$_faultExceptionClasses) as $class) {
- if ($e instanceof $class) {
- $code = $e->getCode();
- $message = $e->getMessage();
- break;
- }
- }
-
- parent::__construct($code, $message);
-
- // Notify exception observers, if present
- if (!empty(self::$_observers)) {
- foreach (array_keys(self::$_observers) as $observer) {
- call_user_func(array($observer, 'observe'), $this);
- }
- }
- }
-
- public static function getInstance(Exception $e)
- {
- return new self($e);
- }
-
- public static function attachFaultException($classes)
- {
- if (!is_array($classes)) {
- $classes = (array) $classes;
- }
-
- foreach ($classes as $class) {
- if (is_string($class) && class_exists($class)) {
- self::$_faultExceptionClasses[$class] = true;
- }
- }
- }
-
- public static function detachFaultException($classes)
- {
- if (!is_array($classes)) {
- $classes = (array) $classes;
- }
-
- foreach ($classes as $class) {
- if (is_string($class) && isset(self::$_faultExceptionClasses[$class])) {
- unset(self::$_faultExceptionClasses[$class]);
- }
- }
- }
-
- public static function attachObserver($class)
- {
- if (!is_string($class)
- || !class_exists($class)
- || !is_callable(array($class, 'observe')))
- {
- return false;
- }
-
- if (!isset(self::$_observers[$class])) {
- self::$_observers[$class] = true;
- }
-
- return true;
- }
-
- public static function detachObserver($class)
- {
- if (!isset(self::$_observers[$class])) {
- return false;
- }
-
- unset(self::$_observers[$class]);
- return true;
- }
-
- public function getException()
- {
- return $this->_exception;
- }
-}
+++ /dev/null
-<?php
-
-abstract class IPF_XmlRpc_Value
-{
- protected $_value;
- protected $_type;
- protected $_as_xml;
- protected $_as_dom;
-
- const AUTO_DETECT_TYPE = 'auto_detect';
- const XML_STRING = 'xml';
-
- const XMLRPC_TYPE_I4 = 'i4';
- const XMLRPC_TYPE_INTEGER = 'int';
- const XMLRPC_TYPE_DOUBLE = 'double';
- const XMLRPC_TYPE_BOOLEAN = 'boolean';
- const XMLRPC_TYPE_STRING = 'string';
- const XMLRPC_TYPE_DATETIME = 'dateTime.iso8601';
- const XMLRPC_TYPE_BASE64 = 'base64';
- const XMLRPC_TYPE_ARRAY = 'array';
- const XMLRPC_TYPE_STRUCT = 'struct';
- const XMLRPC_TYPE_NIL = 'nil';
-
- public function getType()
- {
- return $this->_type;
- }
-
- abstract public function getValue();
- abstract public function saveXML();
-
- public function getAsDOM()
- {
- if (!$this->_as_dom) {
- $doc = new DOMDocument('1.0');
- $doc->loadXML($this->saveXML());
- $this->_as_dom = $doc->documentElement;
- }
-
- return $this->_as_dom;
- }
-
- protected function _stripXmlDeclaration(DOMDocument $dom)
- {
- return preg_replace('/<\?xml version="1.0"( encoding="[^\"]*")?\?>\n/u', '', $dom->saveXML());
- }
-
- public static function getXmlRpcValue($value, $type = self::AUTO_DETECT_TYPE)
- {
- switch ($type) {
- case self::AUTO_DETECT_TYPE:
- // Auto detect the XML-RPC native type from the PHP type of $value
- return self::_phpVarToNativeXmlRpc($value);
-
- case self::XML_STRING:
- // Parse the XML string given in $value and get the XML-RPC value in it
- return self::_xmlStringToNativeXmlRpc($value);
-
- case self::XMLRPC_TYPE_I4:
- // fall through to the next case
- case self::XMLRPC_TYPE_INTEGER:
- return new IPF_XmlRpc_Value_Integer($value);
-
- case self::XMLRPC_TYPE_DOUBLE:
- return new IPF_XmlRpc_Value_Double($value);
-
- case self::XMLRPC_TYPE_BOOLEAN:
- return new IPF_XmlRpc_Value_Boolean($value);
-
- case self::XMLRPC_TYPE_STRING:
- return new IPF_XmlRpc_Value_String($value);
-
- case self::XMLRPC_TYPE_BASE64:
- return new IPF_XmlRpc_Value_Base64($value);
-
- case self::XMLRPC_TYPE_NIL:
- return new IPF_XmlRpc_Value_Nil();
-
- case self::XMLRPC_TYPE_DATETIME:
- return new IPF_XmlRpc_Value_DateTime($value);
-
- case self::XMLRPC_TYPE_ARRAY:
- return new IPF_XmlRpc_Value_Array($value);
-
- case self::XMLRPC_TYPE_STRUCT:
- return new IPF_XmlRpc_Value_Struct($value);
-
- default:
- throw new IPF_Exception('Given type is not a '. __CLASS__ .' constant');
- }
- }
-
- private static function _phpVarToNativeXmlRpc($value)
- {
- switch (gettype($value)) {
- case 'object':
- // Check to see if it's an XmlRpc value
- if ($value instanceof IPF_XmlRpc_Value) {
- return $value;
- }
-
- // Otherwise, we convert the object into a struct
- $value = get_object_vars($value);
- // Break intentionally omitted
- case 'array':
- // Default native type for a PHP array (a simple numeric array) is 'array'
- $obj = 'IPF_XmlRpc_Value_Array';
-
- // Determine if this is an associative array
- if (!empty($value) && is_array($value) && (array_keys($value) !== range(0, count($value) - 1))) {
- $obj = 'IPF_XmlRpc_Value_Struct';
- }
- return new $obj($value);
-
- case 'integer':
- return new IPF_XmlRpc_Value_Integer($value);
-
- case 'double':
- return new IPF_XmlRpc_Value_Double($value);
-
- case 'boolean':
- return new IPF_XmlRpc_Value_Boolean($value);
-
- case 'NULL':
- case 'null':
- return new IPF_XmlRpc_Value_Nil();
-
- case 'string':
- // Fall through to the next case
- default:
- // If type isn't identified (or identified as string), it treated as string
- return new IPF_XmlRpc_Value_String($value);
- }
- }
-
- private static function _xmlStringToNativeXmlRpc($simple_xml)
- {
- if (!$simple_xml instanceof SimpleXMLElement) {
- try {
- $simple_xml = @new SimpleXMLElement($simple_xml);
- } catch (Exception $e) {
- // The given string is not a valid XML
- throw new IPF_Exception('Failed to create XML-RPC value from XML string: '.$e->getMessage(),$e->getCode());
- }
- }
-
- // Get the key (tag name) and value from the simple xml object and convert the value to an XML-RPC native value
- list($type, $value) = each($simple_xml);
- if (!$type) { // If no type was specified, the default is string
- $type = self::XMLRPC_TYPE_STRING;
- }
-
- switch ($type) {
- // All valid and known XML-RPC native values
- case self::XMLRPC_TYPE_I4:
- // Fall through to the next case
- case self::XMLRPC_TYPE_INTEGER:
- $xmlrpc_val = new IPF_XmlRpc_Value_Integer($value);
- break;
- case self::XMLRPC_TYPE_DOUBLE:
- $xmlrpc_val = new IPF_XmlRpc_Value_Double($value);
- break;
- case self::XMLRPC_TYPE_BOOLEAN:
- $xmlrpc_val = new IPF_XmlRpc_Value_Boolean($value);
- break;
- case self::XMLRPC_TYPE_STRING:
- $xmlrpc_val = new IPF_XmlRpc_Value_String($value);
- break;
- case self::XMLRPC_TYPE_DATETIME: // The value should already be in a iso8601 format
- $xmlrpc_val = new IPF_XmlRpc_Value_DateTime($value);
- break;
- case self::XMLRPC_TYPE_BASE64: // The value should already be base64 encoded
- $xmlrpc_val = new IPF_XmlRpc_Value_Base64($value ,true);
- break;
- case self::XMLRPC_TYPE_NIL: // The value should always be NULL
- $xmlrpc_val = new IPF_XmlRpc_Value_Nil();
- break;
- case self::XMLRPC_TYPE_ARRAY:
- // If the XML is valid, $value must be an SimpleXML element and contain the <data> tag
- if (!$value instanceof SimpleXMLElement) {
- throw new IPF_Exception('XML string is invalid for XML-RPC native '. self::XMLRPC_TYPE_ARRAY .' type');
- }
-
- // PHP 5.2.4 introduced a regression in how empty($xml->value)
- // returns; need to look for the item specifically
- $data = null;
- foreach ($value->children() as $key => $value) {
- if ('data' == $key) {
- $data = $value;
- break;
- }
- }
-
- if (null === $data) {
- throw new IPF_Exception('Invalid XML for XML-RPC native '. self::XMLRPC_TYPE_ARRAY .' type: ARRAY tag must contain DATA tag');
- }
- $values = array();
- // Parse all the elements of the array from the XML string
- // (simple xml element) to IPF_XmlRpc_Value objects
- foreach ($data->value as $element) {
- $values[] = self::_xmlStringToNativeXmlRpc($element);
- }
- $xmlrpc_val = new IPF_XmlRpc_Value_Array($values);
- break;
- case self::XMLRPC_TYPE_STRUCT:
- // If the XML is valid, $value must be an SimpleXML
- if ((!$value instanceof SimpleXMLElement)) {
- throw new IPF_Exception('XML string is invalid for XML-RPC native '. self::XMLRPC_TYPE_STRUCT .' type');
- }
- $values = array();
- // Parse all the memebers of the struct from the XML string
- // (simple xml element) to IPF_XmlRpc_Value objects
- foreach ($value->member as $member) {
- // @todo? If a member doesn't have a <value> tag, we don't add it to the struct
- // Maybe we want to throw an exception here ?
- if ((!$member->value instanceof SimpleXMLElement) || empty($member->value)) {
- continue;
- //throw new IPF_XmlRpc_Value_Exception('Member of the '. self::XMLRPC_TYPE_STRUCT .' XML-RPC native type must contain a VALUE tag');
- }
- $values[(string)$member->name] = self::_xmlStringToNativeXmlRpc($member->value);
- }
- $xmlrpc_val = new IPF_XmlRpc_Value_Struct($values);
- break;
- default:
- throw new IPF_Exception('Value type \''. $type .'\' parsed from the XML string is not a known XML-RPC native type');
- break;
- }
- $xmlrpc_val->_setXML($simple_xml->asXML());
-
- return $xmlrpc_val;
- }
-
- private function _setXML($xml)
- {
- $this->_as_xml = $xml;
- }
-
-}
-
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Array extends IPF_XmlRpc_Value_Collection
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_ARRAY;
- parent::__construct($value);
- }
-
- public function saveXML()
- {
- if (!$this->_as_xml) { // The XML code was not calculated yet
- $dom = new DOMDocument('1.0');
- $value = $dom->appendChild($dom->createElement('value'));
- $array = $value->appendChild($dom->createElement('array'));
- $data = $array->appendChild($dom->createElement('data'));
-
- if (is_array($this->_value)) {
- foreach ($this->_value as $val) {
- /* @var $val IPF_XmlRpc_Value */
- $data->appendChild($dom->importNode($val->getAsDOM(), true));
- }
- }
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Base64 extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value, $already_encoded=false)
- {
- $this->_type = self::XMLRPC_TYPE_BASE64;
-
- $value = (string)$value; // Make sure this value is string
- if (!$already_encoded) {
- $value = base64_encode($value); // We encode it in base64
- }
- $this->_value = $value;
- }
-
- public function getValue()
- {
- return base64_decode($this->_value);
- }
-
- public function saveXML()
- {
- if (! $this->_as_xml) { // The XML was not generated yet
- $dom = new DOMDocument('1.0', 'UTF-8');
- $value = $dom->appendChild($dom->createElement('value'));
- $type = $value->appendChild($dom->createElement($this->_type));
- $type->appendChild($dom->createTextNode($this->_value));
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Boolean extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_BOOLEAN;
- $this->_value = (int)(bool)$value;
- }
-
- public function getValue()
- {
- return (bool)$this->_value;
- }
-
- public function saveXML()
- {
- if (! $this->_as_xml) { // The XML was not generated yet
- $dom = new DOMDocument('1.0', 'UTF-8');
- $value = $dom->appendChild($dom->createElement('value'));
- $type = $value->appendChild($dom->createElement($this->_type));
- $type->appendChild($dom->createTextNode($this->_value));
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
+++ /dev/null
-<?php
-
-abstract class IPF_XmlRpc_Value_Collection extends IPF_XmlRpc_Value
-{
- public function __construct($value)
- {
- $values = (array)$value; // Make sure that the value is an array
- foreach ($values as $key => $value) {
- // If the elements of the given array are not IPF_XmlRpc_Value objects,
- // we need to convert them as such (using auto-detection from PHP value)
- if (!$value instanceof parent) {
- $value = self::getXmlRpcValue($value, self::AUTO_DETECT_TYPE);
- }
- $this->_value[$key] = $value;
- }
- }
-
- public function getValue()
- {
- $values = (array)$this->_value;
- foreach ($values as $key => $value) {
- /* @var $value IPF_XmlRpc_Value */
- if (!$value instanceof parent) {
- throw new IPF_Exception('Values of '. get_class($this) .' type must be IPF_XmlRpc_Value objects');
- }
- $values[$key] = $value->getValue();
- }
- return $values;
- }
-
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_DateTime extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_DATETIME;
-
- // If the value is not numeric, we try to convert it to a timestamp (using the strtotime function)
- if (is_numeric($value)) { // The value is numeric, we make sure it is an integer
- $value = (int)$value;
- } else {
- $value = strtotime($value);
- if ($value === false || $value == -1) { // cannot convert the value to a timestamp
- throw new IPF_Exception('Cannot convert given value \''. $value .'\' to a timestamp');
- }
- }
- $value = date('c', $value); // Convert the timestamp to iso8601 format
-
- // Strip out TZ information and dashes
- $value = preg_replace('/(\+|-)\d{2}:\d{2}$/', '', $value);
- $value = str_replace('-', '', $value);
-
- $this->_value = $value;
- }
-
- public function getValue()
- {
- return $this->_value;
- }
-
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Double extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_DOUBLE;
- $this->_value = sprintf('%f',(float)$value); // Make sure this value is float (double) and without the scientific notation
- }
-
- public function getValue()
- {
- return (float)$this->_value;
- }
-
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Integer extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_INTEGER;
- $this->_value = (int)$value; // Make sure this value is integer
- }
-
- public function getValue()
- {
- return $this->_value;
- }
-
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Nil extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct()
- {
- $this->_type = self::XMLRPC_TYPE_NIL;
- $this->_value = null;
- }
-
- public function getValue()
- {
- return null;
- }
-
- public function saveXML()
- {
- if (! $this->_as_xml) { // The XML was not generated yet
- $dom = new DOMDocument('1.0', 'UTF-8');
- $value = $dom->appendChild($dom->createElement('value'));
- $type = $value->appendChild($dom->createElement($this->_type));
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
+++ /dev/null
-<?php
-
-abstract class IPF_XmlRpc_Value_Scalar extends IPF_XmlRpc_Value
-{
- public function saveXML()
- {
- if (!$this->_as_xml) { // The XML code was not calculated yet
- $dom = new DOMDocument('1.0');
- $value = $dom->appendChild($dom->createElement('value'));
- $type = $value->appendChild($dom->createElement($this->_type));
- $type->appendChild($dom->createTextNode($this->getValue()));
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_String extends IPF_XmlRpc_Value_Scalar
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_STRING;
-
- // Make sure this value is string and all XML characters are encoded
- $this->_value = $this->_xml_entities($value);
- }
-
- public function getValue()
- {
- return html_entity_decode($this->_value, ENT_QUOTES, 'UTF-8');
- }
-
- private function _xml_entities($str)
- {
- return htmlentities($str, ENT_QUOTES, 'UTF-8');
- }
-
-}
-
+++ /dev/null
-<?php
-
-class IPF_XmlRpc_Value_Struct extends IPF_XmlRpc_Value_Collection
-{
- public function __construct($value)
- {
- $this->_type = self::XMLRPC_TYPE_STRUCT;
- parent::__construct($value);
- }
-
- public function saveXML()
- {
- if (!$this->_as_xml) { // The XML code was not calculated yet
- $dom = new DOMDocument('1.0');
- $value = $dom->appendChild($dom->createElement('value'));
- $struct = $value->appendChild($dom->createElement('struct'));
-
- if (is_array($this->_value)) {
- foreach ($this->_value as $name => $val) {
- /* @var $val IPF_XmlRpc_Value */
- $member = $struct->appendChild($dom->createElement('member'));
- $member->appendChild($dom->createElement('name', $name));
- $member->appendChild($dom->importNode($val->getAsDOM(), 1));
- }
- }
-
- $this->_as_dom = $value;
- $this->_as_xml = $this->_stripXmlDeclaration($dom);
- }
-
- return $this->_as_xml;
- }
-}
-
--- /dev/null
+<?php
+
+abstract class IPF_Server_Abstract implements IPF_Server_Interface
+{
+ protected static $magic_methods = array(
+ '__construct',
+ '__destruct',
+ '__get',
+ '__set',
+ '__call',
+ '__sleep',
+ '__wakeup',
+ '__isset',
+ '__unset',
+ '__tostring',
+ '__clone',
+ '__set_state',
+ );
+
+ public static function lowerCase(&$value, &$key)
+ {
+ return $value = strtolower($value);
+ }
+}
--- /dev/null
+<?php
+
+interface IPF_Server_Interface
+{
+ public function addFunction($function, $namespace = '');
+ public function setClass($class, $namespace = '', $argv = null);
+ public function fault($fault = null, $code = 404);
+ public function handle($request = false);
+ public function getFunctions();
+ public function loadFunctions($definition);
+ public function setPersistence($mode);
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection
+{
+ public static function reflectClass($class, $argv = false, $namespace = '')
+ {
+ if (is_object($class)) {
+ $reflection = new ReflectionObject($class);
+ } elseif (class_exists($class)) {
+ $reflection = new ReflectionClass($class);
+ } else {
+ throw new IPF_Exception('Invalid class or object passed to attachClass()');
+ }
+
+ if ($argv && !is_array($argv)) {
+ throw new IPF_Exception('Invalid argv argument passed to reflectClass');
+ }
+ return new IPF_Server_Reflection_Class($reflection, $namespace, $argv);
+ }
+
+ public static function reflectFunction($function, $argv = false, $namespace = '')
+ {
+ if (!is_string($function) || !function_exists($function)) {
+ throw new IPF_Exception('Invalid function "' . $function . '" passed to reflectFunction');
+ }
+ if ($argv && !is_array($argv)) {
+ throw new IPF_Exception('Invalid argv argument passed to reflectClass');
+ }
+ return new IPF_Server_Reflection_Function(new ReflectionFunction($function), $namespace, $argv);
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Class
+{
+ protected $_config = array();
+ protected $_methods = array();
+ protected $_namespace = null;
+ protected $_reflection;
+ public function __construct(ReflectionClass $reflection, $namespace = null, $argv = false)
+ {
+ $this->_reflection = $reflection;
+ $this->setNamespace($namespace);
+
+ foreach ($reflection->getMethods() as $method) {
+ // Don't aggregate magic methods
+ if ('__' == substr($method->getName(), 0, 2)) {
+ continue;
+ }
+
+ if ($method->isPublic()) {
+ // Get signatures and description
+ $this->_methods[] = new IPF_Server_Reflection_Method($this, $method, $this->getNamespace(), $argv);
+ }
+ }
+ }
+
+ public function __call($method, $args)
+ {
+ if (method_exists($this->_reflection, $method)) {
+ return call_user_func_array(array($this->_reflection, $method), $args);
+ }
+ throw new IPF_Exception('Invalid reflection method');
+ }
+
+ public function __get($key)
+ {
+ if (isset($this->_config[$key])) {
+ return $this->_config[$key];
+ }
+
+ return null;
+ }
+
+ public function __set($key, $value)
+ {
+ $this->_config[$key] = $value;
+ }
+
+ public function getMethods()
+ {
+ return $this->_methods;
+ }
+
+ public function getNamespace()
+ {
+ return $this->_namespace;
+ }
+
+ public function setNamespace($namespace)
+ {
+ if (empty($namespace)) {
+ $this->_namespace = '';
+ return;
+ }
+
+ if (!is_string($namespace) || !preg_match('/[a-z0-9_\.]+/i', $namespace)) {
+ throw new IPF_Exception('Invalid namespace');
+ }
+
+ $this->_namespace = $namespace;
+ }
+
+ public function __wakeup()
+ {
+ $this->_reflection = new ReflectionClass($this->getName());
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Function extends IPF_Server_Reflection_Function_Abstract{
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Function_Abstract
+{
+ protected $_reflection;
+ protected $_argv = array();
+ protected $_config = array();
+ protected $_class;
+ protected $_description = '';
+ protected $_namespace;
+
+ protected $_prototypes = array();
+
+ private $_return;
+ private $_returnDesc;
+ private $_paramDesc;
+ private $_sigParams;
+ private $_sigParamsDepth;
+
+ public function __construct(Reflector $r, $namespace = null, $argv = array())
+ {
+ // In PHP 5.1.x, ReflectionMethod extends ReflectionFunction. In 5.2.x,
+ // both extend ReflectionFunctionAbstract. So, we can't do normal type
+ // hinting in the prototype, but instead need to do some explicit
+ // testing here.
+ if ((!$r instanceof ReflectionFunction)
+ && (!$r instanceof ReflectionMethod)) {
+ throw new IPF_Exception('Invalid reflection class');
+ }
+ $this->_reflection = $r;
+
+ // Determine namespace
+ if (null !== $namespace){
+ $this->setNamespace($namespace);
+ }
+
+ // Determine arguments
+ if (is_array($argv)) {
+ $this->_argv = $argv;
+ }
+
+ // If method call, need to store some info on the class
+ if ($r instanceof ReflectionMethod) {
+ $this->_class = $r->getDeclaringClass()->getName();
+ }
+
+ // Perform some introspection
+ $this->_reflect();
+ }
+
+ protected function _addTree(IPF_Server_Reflection_Node $parent, $level = 0)
+ {
+ if ($level >= $this->_sigParamsDepth) {
+ return;
+ }
+
+ foreach ($this->_sigParams[$level] as $value) {
+ $node = new IPF_Server_Reflection_Node($value, $parent);
+ if ((null !== $value) && ($this->_sigParamsDepth > $level + 1)) {
+ $this->_addTree($node, $level + 1);
+ }
+ }
+ }
+
+ protected function _buildTree()
+ {
+ $returnTree = array();
+ foreach ((array) $this->_return as $value) {
+ $node = new IPF_Server_Reflection_Node($value);
+ $this->_addTree($node);
+ $returnTree[] = $node;
+ }
+
+ return $returnTree;
+ }
+
+ protected function _buildSignatures($return, $returnDesc, $paramTypes, $paramDesc)
+ {
+ $this->_return = $return;
+ $this->_returnDesc = $returnDesc;
+ $this->_paramDesc = $paramDesc;
+ $this->_sigParams = $paramTypes;
+ $this->_sigParamsDepth = count($paramTypes);
+ $signatureTrees = $this->_buildTree();
+ $signatures = array();
+
+ $endPoints = array();
+ foreach ($signatureTrees as $root) {
+ $tmp = $root->getEndPoints();
+ if (empty($tmp)) {
+ $endPoints = array_merge($endPoints, array($root));
+ } else {
+ $endPoints = array_merge($endPoints, $tmp);
+ }
+ }
+
+ foreach ($endPoints as $node) {
+ if (!$node instanceof IPF_Server_Reflection_Node) {
+ continue;
+ }
+
+ $signature = array();
+ do {
+ array_unshift($signature, $node->getValue());
+ $node = $node->getParent();
+ } while ($node instanceof IPF_Server_Reflection_Node);
+
+ $signatures[] = $signature;
+ }
+
+ // Build prototypes
+ $params = $this->_reflection->getParameters();
+ foreach ($signatures as $signature) {
+ $return = new IPF_Server_Reflection_ReturnValue(array_shift($signature), $this->_returnDesc);
+ $tmp = array();
+ foreach ($signature as $key => $type) {
+ $param = new IPF_Server_Reflection_Parameter($params[$key], $type, $this->_paramDesc[$key]);
+ $param->setPosition($key);
+ $tmp[] = $param;
+ }
+
+ $this->_prototypes[] = new IPF_Server_Reflection_Prototype($return, $tmp);
+ }
+ }
+
+ protected function _reflect()
+ {
+ $function = $this->_reflection;
+ $helpText = '';
+ $signatures = array();
+ $returnDesc = '';
+ $paramCount = $function->getNumberOfParameters();
+ $paramCountRequired = $function->getNumberOfRequiredParameters();
+ $parameters = $function->getParameters();
+ $docBlock = $function->getDocComment();
+
+ if (!empty($docBlock)) {
+ // Get help text
+ if (preg_match(':/\*\*\s*\r?\n\s*\*\s(.*?)\r?\n\s*\*(\s@|/):s', $docBlock, $matches))
+ {
+ $helpText = $matches[1];
+ $helpText = preg_replace('/(^\s*\*\s)/m', '', $helpText);
+ $helpText = preg_replace('/\r?\n\s*\*\s*(\r?\n)*/s', "\n", $helpText);
+ $helpText = trim($helpText);
+ }
+
+ // Get return type(s) and description
+ $return = 'void';
+ if (preg_match('/@return\s+(\S+)/', $docBlock, $matches)) {
+ $return = explode('|', $matches[1]);
+ if (preg_match('/@return\s+\S+\s+(.*?)(@|\*\/)/s', $docBlock, $matches))
+ {
+ $value = $matches[1];
+ $value = preg_replace('/\s?\*\s/m', '', $value);
+ $value = preg_replace('/\s{2,}/', ' ', $value);
+ $returnDesc = trim($value);
+ }
+ }
+
+ // Get param types and description
+ if (preg_match_all('/@param\s+([^\s]+)/m', $docBlock, $matches)) {
+ $paramTypesTmp = $matches[1];
+ if (preg_match_all('/@param\s+\S+\s+(\$^\S+)\s+(.*?)(@|\*\/)/s', $docBlock, $matches))
+ {
+ $paramDesc = $matches[2];
+ foreach ($paramDesc as $key => $value) {
+ $value = preg_replace('/\s?\*\s/m', '', $value);
+ $value = preg_replace('/\s{2,}/', ' ', $value);
+ $paramDesc[$key] = trim($value);
+ }
+ }
+ }
+ } else {
+ $helpText = $function->getName();
+ $return = 'void';
+ }
+
+ // Set method description
+ $this->setDescription($helpText);
+
+ // Get all param types as arrays
+ if (!isset($paramTypesTmp) && (0 < $paramCount)) {
+ $paramTypesTmp = array_fill(0, $paramCount, 'mixed');
+ } elseif (!isset($paramTypesTmp)) {
+ $paramTypesTmp = array();
+ } elseif (count($paramTypesTmp) < $paramCount) {
+ $start = $paramCount - count($paramTypesTmp);
+ for ($i = $start; $i < $paramCount; ++$i) {
+ $paramTypesTmp[$i] = 'mixed';
+ }
+ }
+
+ // Get all param descriptions as arrays
+ if (!isset($paramDesc) && (0 < $paramCount)) {
+ $paramDesc = array_fill(0, $paramCount, '');
+ } elseif (!isset($paramDesc)) {
+ $paramDesc = array();
+ } elseif (count($paramDesc) < $paramCount) {
+ $start = $paramCount - count($paramDesc);
+ for ($i = $start; $i < $paramCount; ++$i) {
+ $paramDesc[$i] = '';
+ }
+ }
+
+
+ $paramTypes = array();
+ foreach ($paramTypesTmp as $i => $param) {
+ $tmp = explode('|', $param);
+ if ($parameters[$i]->isOptional()) {
+ array_unshift($tmp, null);
+ }
+ $paramTypes[] = $tmp;
+ }
+
+ $this->_buildSignatures($return, $returnDesc, $paramTypes, $paramDesc);
+ }
+
+ public function __call($method, $args)
+ {
+ if (method_exists($this->_reflection, $method)) {
+ return call_user_func_array(array($this->_reflection, $method), $args);
+ }
+
+ throw new IPF_Exception('Invalid reflection method ("' .$method. '")');
+ }
+
+ public function __get($key)
+ {
+ if (isset($this->_config[$key])) {
+ return $this->_config[$key];
+ }
+
+ return null;
+ }
+
+ public function __set($key, $value)
+ {
+ $this->_config[$key] = $value;
+ }
+
+ public function setNamespace($namespace)
+ {
+ if (empty($namespace)) {
+ $this->_namespace = '';
+ return;
+ }
+
+ if (!is_string($namespace) || !preg_match('/[a-z0-9_\.]+/i', $namespace)) {
+ throw new IPF_Exception('Invalid namespace');
+ }
+
+ $this->_namespace = $namespace;
+ }
+
+ public function getNamespace()
+ {
+ return $this->_namespace;
+ }
+
+ public function setDescription($string)
+ {
+ if (!is_string($string)) {
+ throw new IPF_Exception('Invalid description');
+ }
+
+ $this->_description = $string;
+ }
+
+ public function getDescription()
+ {
+ return $this->_description;
+ }
+
+ public function getPrototypes()
+ {
+ return $this->_prototypes;
+ }
+
+ public function getInvokeArguments()
+ {
+ return $this->_argv;
+ }
+
+ public function __wakeup()
+ {
+ if ($this->_reflection instanceof ReflectionMethod) {
+ $class = new ReflectionClass($this->_class);
+ $this->_reflection = new ReflectionMethod($class->newInstance(), $this->getName());
+ } else {
+ $this->_reflection = new ReflectionFunction($this->getName());
+ }
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Method extends IPF_Server_Reflection_Function_Abstract
+{
+ protected $_class;
+ protected $_classReflection;
+
+ public function __construct(IPF_Server_Reflection_Class $class, ReflectionMethod $r, $namespace = null, $argv = array())
+ {
+ $this->_classReflection = $class;
+ $this->_reflection = $r;
+
+ $classNamespace = $class->getNamespace();
+
+ // Determine namespace
+ if (!empty($namespace)) {
+ $this->setNamespace($namespace);
+ } elseif (!empty($classNamespace)) {
+ $this->setNamespace($classNamespace);
+ }
+
+ // Determine arguments
+ if (is_array($argv)) {
+ $this->_argv = $argv;
+ }
+
+ // If method call, need to store some info on the class
+ $this->_class = $class->getName();
+
+ // Perform some introspection
+ $this->_reflect();
+ }
+
+ public function getDeclaringClass()
+ {
+ return $this->_classReflection;
+ }
+
+ public function __wakeup()
+ {
+ $this->_classReflection = new IPF_Server_Reflection_Class(new ReflectionClass($this->_class), $this->getNamespace(), $this->getInvokeArguments());
+ $this->_reflection = new ReflectionMethod($this->_classReflection->getName(), $this->getName());
+ }
+
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Node
+{
+ protected $_value = null;
+ protected $_children = array();
+ protected $_parent = null;
+
+ public function __construct($value, IPF_Server_Reflection_Node $parent = null)
+ {
+ $this->_value = $value;
+ if (null !== $parent) {
+ $this->setParent($parent, true);
+ }
+
+ return $this;
+ }
+
+ public function setParent(IPF_Server_Reflection_Node $node, $new = false)
+ {
+ $this->_parent = $node;
+
+ if ($new) {
+ $node->attachChild($this);
+ return;
+ }
+ }
+
+ public function createChild($value)
+ {
+ $child = new self($value, $this);
+
+ return $child;
+ }
+
+ public function attachChild(IPF_Server_Reflection_Node $node)
+ {
+ $this->_children[] = $node;
+
+ if ($node->getParent() !== $this) {
+ $node->setParent($this);
+ }
+ }
+
+ public function getChildren()
+ {
+ return $this->_children;
+ }
+
+ public function hasChildren()
+ {
+ return count($this->_children) > 0;
+ }
+
+ public function getParent()
+ {
+ return $this->_parent;
+ }
+
+ public function getValue()
+ {
+ return $this->_value;
+ }
+
+ public function setValue($value)
+ {
+ $this->_value = $value;
+ }
+
+ public function getEndPoints()
+ {
+ $endPoints = array();
+ if (!$this->hasChildren()) {
+ return $endPoints;
+ }
+
+ foreach ($this->_children as $child) {
+ $value = $child->getValue();
+
+ if (null === $value) {
+ $endPoints[] = $this;
+ } elseif ((null !== $value)
+ && $child->hasChildren())
+ {
+ $childEndPoints = $child->getEndPoints();
+ if (!empty($childEndPoints)) {
+ $endPoints = array_merge($endPoints, $childEndPoints);
+ }
+ } elseif ((null !== $value) && !$child->hasChildren()) {
+ $endPoints[] = $child;
+ }
+ }
+
+ return $endPoints;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Parameter
+{
+ protected $_reflection;
+ protected $_position;
+ protected $_type;
+ protected $_description;
+
+ public function __construct(ReflectionParameter $r, $type = 'mixed', $description = '')
+ {
+ $this->_reflection = $r;
+ $this->setType($type);
+ $this->setDescription($description);
+ }
+
+ public function __call($method, $args)
+ {
+ if (method_exists($this->_reflection, $method)) {
+ return call_user_func_array(array($this->_reflection, $method), $args);
+ }
+ throw new IPF_Exception('Invalid reflection method');
+ }
+
+ public function getType()
+ {
+ return $this->_type;
+ }
+
+ public function setType($type)
+ {
+ if (!is_string($type) && (null !== $type)) {
+ throw new IPF_Exception('Invalid parameter type');
+ }
+ $this->_type = $type;
+ }
+
+ public function getDescription()
+ {
+ return $this->_description;
+ }
+
+ public function setDescription($description)
+ {
+ if (!is_string($description) && (null !== $description)) {
+ throw new IPF_Exception('Invalid parameter description');
+ }
+ $this->_description = $description;
+ }
+
+ public function setPosition($index)
+ {
+ $this->_position = (int) $index;
+ }
+
+ public function getPosition()
+ {
+ return $this->_position;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_Prototype
+{
+ public function __construct(IPF_Server_Reflection_ReturnValue $return, $params = null)
+ {
+ $this->_return = $return;
+
+ if (!is_array($params) && (null !== $params)) {
+ throw new IPF_Exception('Invalid parameters');
+ }
+
+ if (is_array($params)) {
+ foreach ($params as $param) {
+ if (!$param instanceof IPF_Server_Reflection_Parameter) {
+ throw new IPF_Exception('One or more params are invalid');
+ }
+ }
+ }
+
+ $this->_params = $params;
+ }
+
+ public function getReturnType()
+ {
+ return $this->_return->getType();
+ }
+
+ public function getReturnValue()
+ {
+ return $this->_return;
+ }
+
+ public function getParameters()
+ {
+ return $this->_params;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_Server_Reflection_ReturnValue
+{
+ protected $_type;
+ protected $_description;
+
+ public function __construct($type = 'mixed', $description = '')
+ {
+ $this->setType($type);
+ $this->setDescription($description);
+ }
+
+ public function getType()
+ {
+ return $this->_type;
+ }
+
+ public function setType($type)
+ {
+ if (!is_string($type) && (null !== $type)) {
+ throw new IPF_Exception('Invalid parameter type');
+ }
+ $this->_type = $type;
+ }
+
+ public function getDescription()
+ {
+ return $this->_description;
+ }
+
+ public function setDescription($description)
+ {
+ if (!is_string($description) && (null !== $description)) {
+ throw new IPF_Exception('Invalid parameter description');
+ }
+ $this->_description = $description;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Fault
+{
+ protected $_code;
+ protected $_encoding = 'UTF-8';
+ protected $_message;
+
+ protected $_internal = array(
+ 404 => 'Unknown Error',
+
+ // 610 - 619 reflection errors
+ 610 => 'Invalid method class',
+ 611 => 'Unable to attach function or callback; not callable',
+ 612 => 'Unable to load array; not an array',
+ 613 => 'One or more method records are corrupt or otherwise unusable',
+
+ // 620 - 629 dispatch errors
+ 620 => 'Method does not exist',
+ 621 => 'Error instantiating class to invoke method',
+ 622 => 'Method missing implementation',
+ 623 => 'Calling parameters do not match signature',
+
+ // 630 - 639 request errors
+ 630 => 'Unable to read request',
+ 631 => 'Failed to parse request',
+ 632 => 'Invalid request, no method passed; request must contain a \'methodName\' tag',
+ 633 => 'Param must contain a value',
+ 634 => 'Invalid method name',
+ 635 => 'Invalid XML provided to request',
+ 636 => 'Error creating xmlrpc value',
+
+ // 640 - 649 system.* errors
+ 640 => 'Method does not exist',
+
+ // 650 - 659 response errors
+ 650 => 'Invalid XML provided for response',
+ 651 => 'Failed to parse response',
+ 652 => 'Invalid response',
+ 653 => 'Invalid XMLRPC value in response',
+ );
+
+ public function __construct($code = 404, $message = '')
+ {
+ $this->setCode($code);
+ $code = $this->getCode();
+
+ if (empty($message) && isset($this->_internal[$code])) {
+ $message = $this->_internal[$code];
+ } elseif (empty($message)) {
+ $message = 'Unknown error';
+ }
+ $this->setMessage($message);
+ }
+
+ public function setCode($code)
+ {
+ $this->_code = (int) $code;
+ return $this;
+ }
+
+ public function getCode()
+ {
+ return $this->_code;
+ }
+
+ public function setMessage($message)
+ {
+ $this->_message = (string) $message;
+ return $this;
+ }
+
+ public function getMessage()
+ {
+ return $this->_message;
+ }
+
+ public function setEncoding($encoding)
+ {
+ $this->_encoding = $encoding;
+ return $this;
+ }
+
+ public function getEncoding()
+ {
+ return $this->_encoding;
+ }
+
+ public function loadXml($fault)
+ {
+ if (!is_string($fault)) {
+ throw new IPF_Exception('Invalid XML provided to fault');
+ }
+
+ try {
+ $xml = @new SimpleXMLElement($fault);
+ } catch (Exception $e) {
+ // Not valid XML
+ throw new IPF_Exception('Failed to parse XML fault: ' . $e->getMessage(), 500);
+ }
+
+ // Check for fault
+ if (!$xml->fault) {
+ // Not a fault
+ return false;
+ }
+
+ if (!$xml->fault->value->struct) {
+ // not a proper fault
+ throw new IPF_Exception('Invalid fault structure', 500);
+ }
+
+ $structXml = $xml->fault->value->asXML();
+ $structXml = preg_replace('/<\?xml version=.*?\?>/i', '', $structXml);
+ $struct = IPF_XmlRpc_Value::getXmlRpcValue(trim($structXml), IPF_XmlRpc_Value::XML_STRING);
+ $struct = $struct->getValue();
+
+ if (isset($struct['faultCode'])) {
+ $code = $struct['faultCode'];
+ }
+ if (isset($struct['faultString'])) {
+ $message = $struct['faultString'];
+ }
+
+ if (empty($code) && empty($message)) {
+ throw new IPF_Exception('Fault code and string required');
+ }
+
+ if (empty($code)) {
+ $code = '404';
+ }
+
+ if (empty($message)) {
+ if (isset($this->_internal[$code])) {
+ $message = $this->_internal[$code];
+ } else {
+ $message = 'Unknown Error';
+ }
+ }
+
+ $this->setCode($code);
+ $this->setMessage($message);
+
+ return true;
+ }
+
+ public static function isFault($xml)
+ {
+ $fault = new self();
+ try {
+ $isFault = $fault->loadXml($xml);
+ } catch (IPF_Exception $e) {
+ $isFault = false;
+ }
+
+ return $isFault;
+ }
+
+ public function saveXML()
+ {
+ // Create fault value
+ $faultStruct = array(
+ 'faultCode' => $this->getCode(),
+ 'faultString' => $this->getMessage()
+ );
+ $value = IPF_XmlRpc_Value::getXmlRpcValue($faultStruct);
+ $valueDOM = new DOMDocument('1.0', $this->getEncoding());
+ $valueDOM->loadXML($value->saveXML());
+
+ // Build response XML
+ $dom = new DOMDocument('1.0', 'ISO-8859-1');
+ $r = $dom->appendChild($dom->createElement('methodResponse'));
+ $f = $r->appendChild($dom->createElement('fault'));
+ $f->appendChild($dom->importNode($valueDOM->documentElement, 1));
+
+ return $dom->saveXML();
+ }
+
+ public function __toString()
+ {
+ return $this->saveXML();
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Request
+{
+ protected $_encoding = 'UTF-8';
+ protected $_method;
+ protected $_xml;
+ protected $_params = array();
+ protected $_fault = null;
+ protected $_types = array();
+ protected $_xmlRpcParams = array();
+
+ public function __construct($method = null, $params = null)
+ {
+ if ($method !== null) {
+ $this->setMethod($method);
+ }
+
+ if ($params !== null) {
+ $this->setParams($params);
+ }
+ }
+
+ public function setEncoding($encoding)
+ {
+ $this->_encoding = $encoding;
+ return $this;
+ }
+
+ public function getEncoding()
+ {
+ return $this->_encoding;
+ }
+
+ public function setMethod($method)
+ {
+ if (!is_string($method) || !preg_match('/^[a-z0-9_.:\/]+$/i', $method)) {
+ $this->_fault = new IPF_XmlRpc_Fault(634, 'Invalid method name ("' . $method . '")');
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ $this->_method = $method;
+ return true;
+ }
+
+ public function getMethod()
+ {
+ return $this->_method;
+ }
+
+ public function addParam($value, $type = null)
+ {
+ $this->_params[] = $value;
+ if (null === $type) {
+ // Detect type if not provided explicitly
+ if ($value instanceof IPF_XmlRpc_Value) {
+ $type = $value->getType();
+ } else {
+ $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($value);
+ $type = $xmlRpcValue->getType();
+ }
+ }
+ $this->_types[] = $type;
+ $this->_xmlRpcParams[] = array('value' => $value, 'type' => $type);
+ }
+
+ public function setParams()
+ {
+ $argc = func_num_args();
+ $argv = func_get_args();
+ if (0 == $argc) {
+ return;
+ }
+
+ if ((1 == $argc) && is_array($argv[0])) {
+ $params = array();
+ $types = array();
+ $wellFormed = true;
+ foreach ($argv[0] as $arg) {
+ if (!is_array($arg) || !isset($arg['value'])) {
+ $wellFormed = false;
+ break;
+ }
+ $params[] = $arg['value'];
+
+ if (!isset($arg['type'])) {
+ $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg['value']);
+ $arg['type'] = $xmlRpcValue->getType();
+ }
+ $types[] = $arg['type'];
+ }
+ if ($wellFormed) {
+ $this->_xmlRpcParams = $argv[0];
+ $this->_params = $params;
+ $this->_types = $types;
+ } else {
+ $this->_params = $argv[0];
+ $this->_types = array();
+ $xmlRpcParams = array();
+ foreach ($argv[0] as $arg) {
+ if ($arg instanceof IPF_XmlRpc_Value) {
+ $type = $arg->getType();
+ } else {
+ $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg);
+ $type = $xmlRpcValue->getType();
+ }
+ $xmlRpcParams[] = array('value' => $arg, 'type' => $type);
+ $this->_types[] = $type;
+ }
+ $this->_xmlRpcParams = $xmlRpcParams;
+ }
+ return;
+ }
+
+ $this->_params = $argv;
+ $this->_types = array();
+ $xmlRpcParams = array();
+ foreach ($argv as $arg) {
+ if ($arg instanceof IPF_XmlRpc_Value) {
+ $type = $arg->getType();
+ } else {
+ $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($arg);
+ $type = $xmlRpcValue->getType();
+ }
+ $xmlRpcParams[] = array('value' => $arg, 'type' => $type);
+ $this->_types[] = $type;
+ }
+ $this->_xmlRpcParams = $xmlRpcParams;
+ }
+
+ public function getParams()
+ {
+ return $this->_params;
+ }
+
+ public function getTypes()
+ {
+ return $this->_types;
+ }
+
+ public function loadXml($request)
+ {
+ if (!is_string($request)) {
+ $this->_fault = new IPF_XmlRpc_Fault(635);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ try {
+ $xml = @new SimpleXMLElement($request);
+ } catch (Exception $e) {
+ // Not valid XML
+ $this->_fault = new IPF_XmlRpc_Fault(631);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ // Check for method name
+ if (empty($xml->methodName)) {
+ // Missing method name
+ $this->_fault = new IPF_XmlRpc_Fault(632);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ $this->_method = (string) $xml->methodName;
+
+ // Check for parameters
+ if (!empty($xml->params)) {
+ $types = array();
+ $argv = array();
+ foreach ($xml->params->children() as $param) {
+ if (! $param->value instanceof SimpleXMLElement) {
+ $this->_fault = new IPF_XmlRpc_Fault(633);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ try {
+ $param = IPF_XmlRpc_Value::getXmlRpcValue($param->value, IPF_XmlRpc_Value::XML_STRING);
+ $types[] = $param->getType();
+ $argv[] = $param->getValue();
+ } catch (Exception $e) {
+ $this->_fault = new IPF_XmlRpc_Fault(636);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+ }
+
+ $this->_types = $types;
+ $this->_params = $argv;
+ }
+
+ $this->_xml = $request;
+
+ return true;
+ }
+
+ public function isFault()
+ {
+ return $this->_fault instanceof IPF_XmlRpc_Fault;
+ }
+
+ public function getFault()
+ {
+ return $this->_fault;
+ }
+
+ protected function _getXmlRpcParams()
+ {
+ $params = array();
+ if (is_array($this->_xmlRpcParams)) {
+ foreach ($this->_xmlRpcParams as $param) {
+ $value = $param['value'];
+ $type = isset($param['type']) ? $param['type'] : IPF_XmlRpc_Value::AUTO_DETECT_TYPE;
+
+ if (!$value instanceof IPF_XmlRpc_Value) {
+ $value = IPF_XmlRpc_Value::getXmlRpcValue($value, $type);
+ }
+ $params[] = $value;
+ }
+ }
+
+ return $params;
+ }
+
+ public function saveXML()
+ {
+ $args = $this->_getXmlRpcParams();
+ $method = $this->getMethod();
+
+ $dom = new DOMDocument('1.0', $this->getEncoding());
+ $mCall = $dom->appendChild($dom->createElement('methodCall'));
+ $mName = $mCall->appendChild($dom->createElement('methodName', $method));
+
+ if (is_array($args) && count($args)) {
+ $params = $mCall->appendChild($dom->createElement('params'));
+
+ foreach ($args as $arg) {
+ /* @var $arg IPF_XmlRpc_Value */
+ $argDOM = new DOMDocument('1.0', $this->getEncoding());
+ $argDOM->loadXML($arg->saveXML());
+
+ $param = $params->appendChild($dom->createElement('param'));
+ $param->appendChild($dom->importNode($argDOM->documentElement, 1));
+ }
+ }
+
+ return $dom->saveXML();
+ }
+
+ public function __toString()
+ {
+ return $this->saveXML();
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Request_Http extends IPF_XmlRpc_Request
+{
+ protected $_headers;
+ protected $_xml;
+ public function __construct()
+ {
+ $fh = fopen('php://input', 'r');
+ if (!$fh) {
+ $this->_fault = new IPF_Exception(630);
+ return;
+ }
+
+ $xml = '';
+ while (!feof($fh)) {
+ $xml .= fgets($fh);
+ }
+ fclose($fh);
+
+ $this->_xml = $xml;
+
+ $this->loadXml($xml);
+ }
+
+ public function getRawRequest()
+ {
+ return $this->_xml;
+ }
+
+ public function getHeaders()
+ {
+ if (null === $this->_headers) {
+ $this->_headers = array();
+ foreach ($_SERVER as $key => $value) {
+ if ('HTTP_' == substr($key, 0, 5)) {
+ $header = str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($key, 5)))));
+ $this->_headers[$header] = $value;
+ }
+ }
+ }
+
+ return $this->_headers;
+ }
+
+ public function getFullRequest()
+ {
+ $request = '';
+ foreach ($this->getHeaders() as $key => $value) {
+ $request .= $key . ': ' . $value . "\n";
+ }
+
+ $request .= $this->_xml;
+
+ return $request;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Request_Stdin extends IPF_XmlRpc_Request
+{
+ protected $_xml;
+
+ public function __construct()
+ {
+ $fh = fopen('php://stdin', 'r');
+ if (!$fh) {
+ $this->_fault = new IPF_XmlRpc_Fault(630);
+ return;
+ }
+
+ $xml = '';
+ while (!feof($fh)) {
+ $xml .= fgets($fh);
+ }
+ fclose($fh);
+
+ $this->_xml = $xml;
+
+ $this->loadXml($xml);
+ }
+
+ public function getRawRequest()
+ {
+ return $this->_xml;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Response
+{
+ protected $_return;
+ protected $_type;
+ protected $_encoding = 'UTF-8';
+ protected $_fault = null;
+
+ public function __construct($return = null, $type = null)
+ {
+ $this->setReturnValue($return, $type);
+ }
+
+ public function setEncoding($encoding)
+ {
+ $this->_encoding = $encoding;
+ return $this;
+ }
+
+ public function getEncoding()
+ {
+ return $this->_encoding;
+ }
+
+ public function setReturnValue($value, $type = null)
+ {
+ $this->_return = $value;
+ $this->_type = (string) $type;
+ }
+
+ public function getReturnValue()
+ {
+ return $this->_return;
+ }
+
+ protected function _getXmlRpcReturn()
+ {
+ return IPF_XmlRpc_Value::getXmlRpcValue($this->_return);
+ }
+
+ public function isFault()
+ {
+ return $this->_fault instanceof IPF_XmlRpc_Fault;
+ }
+
+ public function getFault()
+ {
+ return $this->_fault;
+ }
+
+ public function loadXml($response)
+ {
+ if (!is_string($response)) {
+ $this->_fault = new IPF_XmlRpc_Fault(650);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ try {
+ $xml = @new SimpleXMLElement($response);
+ } catch (Exception $e) {
+ // Not valid XML
+ $this->_fault = new IPF_XmlRpc_Fault(651);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ if (!empty($xml->fault)) {
+ // fault response
+ $this->_fault = new IPF_XmlRpc_Fault();
+ $this->_fault->setEncoding($this->getEncoding());
+ $this->_fault->loadXml($response);
+ return false;
+ }
+
+ if (empty($xml->params)) {
+ // Invalid response
+ $this->_fault = new IPF_XmlRpc_Fault(652);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ try {
+ if (!isset($xml->params) || !isset($xml->params->param) || !isset($xml->params->param->value)) {
+ throw new IPF_Exception('Missing XML-RPC value in XML');
+ }
+ $valueXml = $xml->params->param->value->asXML();
+ $valueXml = preg_replace('/<\?xml version=.*?\?>/i', '', $valueXml);
+ $value = IPF_XmlRpc_Value::getXmlRpcValue(trim($valueXml), IPF_XmlRpc_Value::XML_STRING);
+ } catch (IPF_Exception $e) {
+ $this->_fault = new IPF_XmlRpc_Fault(653);
+ $this->_fault->setEncoding($this->getEncoding());
+ return false;
+ }
+
+ $this->setReturnValue($value->getValue());
+ return true;
+ }
+
+ public function saveXML()
+ {
+ $value = $this->_getXmlRpcReturn();
+ $valueDOM = new DOMDocument('1.0', $this->getEncoding());
+ $valueDOM->loadXML($value->saveXML());
+
+ $dom = new DOMDocument('1.0', $this->getEncoding());
+ $response = $dom->appendChild($dom->createElement('methodResponse'));
+ $params = $response->appendChild($dom->createElement('params'));
+ $param = $params->appendChild($dom->createElement('param'));
+
+ $param->appendChild($dom->importNode($valueDOM->documentElement, true));
+
+ return $dom->saveXML();
+ }
+
+ public function __toString()
+ {
+ return $this->saveXML();
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Response_Http extends IPF_XmlRpc_Response
+{
+ public function __toString()
+ {
+ if (!headers_sent()) {
+ header('Content-Type: text/xml; charset=' . strtolower($this->getEncoding()));
+ }
+ return parent::__toString();
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Server
+{
+ protected $_encoding = 'UTF-8';
+ protected $_methods = array();
+ protected $_request = null;
+ protected $_responseClass = 'IPF_XmlRpc_Response_Http';
+
+ protected $_table = array();
+
+ protected $_typeMap = array(
+ 'i4' => 'i4',
+ 'int' => 'int',
+ 'integer' => 'int',
+ 'double' => 'double',
+ 'float' => 'double',
+ 'real' => 'double',
+ 'boolean' => 'boolean',
+ 'bool' => 'boolean',
+ 'true' => 'boolean',
+ 'false' => 'boolean',
+ 'string' => 'string',
+ 'str' => 'string',
+ 'base64' => 'base64',
+ 'dateTime.iso8601' => 'dateTime.iso8601',
+ 'date' => 'dateTime.iso8601',
+ 'time' => 'dateTime.iso8601',
+ 'time' => 'dateTime.iso8601',
+ 'array' => 'array',
+ 'struct' => 'struct',
+ 'null' => 'nil',
+ 'nil' => 'nil',
+ 'void' => 'void',
+ 'mixed' => 'struct'
+ );
+
+ public function __construct()
+ {
+ // Setup system.* methods
+ $system = array(
+ 'listMethods',
+ 'methodHelp',
+ 'methodSignature',
+ 'multicall'
+ );
+
+ $class = IPF_Server_Reflection::reflectClass($this);
+ foreach ($system as $method) {
+ $reflection = new IPF_Server_Reflection_Method($class, new ReflectionMethod($this, $method), 'system');
+ $reflection->system = true;
+ $this->_methods[] = $reflection;
+ }
+
+ $this->_buildDispatchTable();
+ }
+
+ protected function _fixTypes(IPF_Server_Reflection_Function_Abstract $method)
+ {
+ foreach ($method->getPrototypes() as $prototype) {
+ foreach ($prototype->getParameters() as $param) {
+ $pType = $param->getType();
+ if (isset($this->_typeMap[$pType])) {
+ $param->setType($this->_typeMap[$pType]);
+ } else {
+ $param->setType('void');
+ }
+ }
+ }
+ }
+
+ protected function _buildDispatchTable()
+ {
+ $table = array();
+ foreach ($this->_methods as $dispatchable) {
+ if ($dispatchable instanceof IPF_Server_Reflection_Function_Abstract) {
+ // function/method call
+ $ns = $dispatchable->getNamespace();
+ $name = $dispatchable->getName();
+ $name = empty($ns) ? $name : $ns . '.' . $name;
+
+ if (isset($table[$name])) {
+ throw new IPF_Exception('Duplicate method registered: ' . $name);
+ }
+ $table[$name] = $dispatchable;
+ $this->_fixTypes($dispatchable);
+
+ continue;
+ }
+
+ if ($dispatchable instanceof IPF_Server_Reflection_Class) {
+ foreach ($dispatchable->getMethods() as $method) {
+ $ns = $method->getNamespace();
+ $name = $method->getName();
+ $name = empty($ns) ? $name : $ns . '.' . $name;
+
+ if (isset($table[$name])) {
+ throw new IPF_Exception('Duplicate method registered: ' . $name);
+ }
+ $table[$name] = $method;
+ $this->_fixTypes($method);
+ continue;
+ }
+ }
+ }
+
+ $this->_table = $table;
+ }
+
+ public function setEncoding($encoding)
+ {
+ $this->_encoding = $encoding;
+ return $this;
+ }
+
+ public function getEncoding()
+ {
+ return $this->_encoding;
+ }
+
+ public function addFunction($function, $namespace = '')
+ {
+ if (!is_string($function) && !is_array($function)) {
+ throw new IPF_Exception('Unable to attach function; invalid', 611);
+ }
+
+ $argv = null;
+ if (2 < func_num_args()) {
+ $argv = func_get_args();
+ $argv = array_slice($argv, 2);
+ }
+
+ $function = (array) $function;
+ foreach ($function as $func) {
+ if (!is_string($func) || !function_exists($func)) {
+ throw new IPF_Exception('Unable to attach function; invalid', 611);
+ }
+ $this->_methods[] = IPF_Server_Reflection::reflectFunction($func, $argv, $namespace);
+ }
+
+ $this->_buildDispatchTable();
+ }
+
+ public function loadFunctions($array)
+ {
+ if (!is_array($array)) {
+ throw new IPF_Exception('Unable to load array; not an array', 612);
+ }
+
+ foreach ($array as $key => $value) {
+ if (!$value instanceof IPF_Server_Reflection_Function_Abstract
+ && !$value instanceof IPF_Server_Reflection_Class)
+ {
+ throw new IPF_Exception('One or more method records are corrupt or otherwise unusable', 613);
+ }
+
+ if ($value->system) {
+ unset($array[$key]);
+ }
+ }
+
+ foreach ($array as $dispatchable) {
+ $this->_methods[] = $dispatchable;
+ }
+
+ $this->_buildDispatchTable();
+ }
+
+ public function setPersistence($class = null)
+ {
+ }
+
+ public function setClass($class, $namespace = '', $argv = null)
+ {
+ if (is_string($class) && !class_exists($class)) {
+ if (!class_exists($class)) {
+ throw new IPF_Exception('Invalid method class', 610);
+ }
+ }
+
+ $argv = null;
+ if (3 < func_num_args()) {
+ $argv = func_get_args();
+ $argv = array_slice($argv, 3);
+ }
+
+ $this->_methods[] = IPF_Reflection::reflectClass($class, $argv, $namespace);
+ $this->_buildDispatchTable();
+ }
+
+ public function setRequest($request)
+ {
+ if (is_string($request) && class_exists($request)) {
+ $request = new $request();
+ if (!$request instanceof IPF_XmlRpc_Request) {
+ throw new IPF_Exception('Invalid request class');
+ }
+ $request->setEncoding($this->getEncoding());
+ } elseif (!$request instanceof IPF_XmlRpc_Request) {
+ throw new IPF_Exception('Invalid request object');
+ }
+
+ $this->_request = $request;
+ return $this;
+ }
+
+ public function getRequest()
+ {
+ return $this->_request;
+ }
+
+ public function fault($fault, $code = 404)
+ {
+ if (!$fault instanceof Exception) {
+ $fault = (string) $fault;
+ $fault = new IPF_Exception($fault, $code);
+ }
+ return IPF_XmlRpc_Server_Fault::getInstance($fault);
+ }
+
+ protected function _handle(IPF_XmlRpc_Request $request)
+ {
+ $method = $request->getMethod();
+
+ // Check for valid method
+ if (!isset($this->_table[$method])) {
+ throw new IPF_Exception('Method "' . $method . '" does not exist', 620);
+ }
+
+ $info = $this->_table[$method];
+ $params = $request->getParams();
+ $argv = $info->getInvokeArguments();
+ if (0 < count($argv)) {
+ $params = array_merge($params, $argv);
+ }
+
+ // Check calling parameters against signatures
+ $matched = false;
+ $sigCalled = $request->getTypes();
+
+ $sigLength = count($sigCalled);
+ $paramsLen = count($params);
+ if ($sigLength < $paramsLen) {
+ for ($i = $sigLength; $i < $paramsLen; ++$i) {
+ $xmlRpcValue = IPF_XmlRpc_Value::getXmlRpcValue($params[$i]);
+ $sigCalled[] = $xmlRpcValue->getType();
+ }
+ }
+
+ $signatures = $info->getPrototypes();
+ foreach ($signatures as $signature) {
+ $sigParams = $signature->getParameters();
+ $tmpParams = array();
+ foreach ($sigParams as $param) {
+ $tmpParams[] = $param->getType();
+ }
+ if ($sigCalled === $tmpParams) {
+ $matched = true;
+ break;
+ }
+ }
+ if (!$matched) {
+ throw new IPF_Exception('Calling parameters do not match signature', 623);
+ }
+
+ if ($info instanceof IPF_Server_Reflection_Function) {
+ $func = $info->getName();
+ $return = call_user_func_array($func, $params);
+ } elseif (($info instanceof IPF_Server_Reflection_Method) && $info->system) {
+ // System methods
+ $return = $info->invokeArgs($this, $params);
+ } elseif ($info instanceof IPF_Server_Reflection_Method) {
+ // Get class
+ $class = $info->getDeclaringClass()->getName();
+
+ if ('static' == $info->isStatic()) {
+ // for some reason, invokeArgs() does not work the same as
+ // invoke(), and expects the first argument to be an object.
+ // So, using a callback if the method is static.
+ $return = call_user_func_array(array($class, $info->getName()), $params);
+ } else {
+ // Object methods
+ try {
+ $object = $info->getDeclaringClass()->newInstance();
+ } catch (Exception $e) {
+ throw new IPF_Exception('Error instantiating class ' . $class . ' to invoke method ' . $info->getName(), 621);
+ }
+
+ $return = $info->invokeArgs($object, $params);
+ }
+ } else {
+ throw new IPF_Exception('Method missing implementation ' . get_class($info), 622);
+ }
+
+ $response = new ReflectionClass($this->_responseClass);
+ return $response->newInstance($return);
+ }
+
+ public function handle(IPF_XmlRpc_Request $request = null)
+ {
+ // Get request
+ if ((null === $request) && (null === ($request = $this->getRequest()))) {
+ $request = new IPF_XmlRpc_Request_Http();
+ $request->setEncoding($this->getEncoding());
+ }
+
+ $this->setRequest($request);
+
+ if ($request->isFault()) {
+ $response = $request->getFault();
+ } else {
+ try {
+ $response = $this->_handle($request);
+ } catch (Exception $e) {
+ $response = $this->fault($e);
+ }
+ }
+
+ // Set output encoding
+ $response->setEncoding($this->getEncoding());
+
+ return $response;
+ }
+
+ public function setResponseClass($class)
+ {
+ if (class_exists($class)) {
+ $reflection = new ReflectionClass($class);
+ if ($reflection->isSubclassOf(new ReflectionClass('IPF_XmlRpc_Response'))) {
+ $this->_responseClass = $class;
+ return true;
+ }
+ }
+
+ return false;
+ }
+
+ public function getFunctions()
+ {
+ $return = array();
+ foreach ($this->_methods as $method) {
+ if ($method instanceof IPF_Server_Reflection_Class
+ && ($method->system))
+ {
+ continue;
+ }
+
+ $return[] = $method;
+ }
+
+ return $return;
+ }
+
+ public function listMethods()
+ {
+ return array_keys($this->_table);
+ }
+
+ public function methodHelp($method)
+ {
+ if (!isset($this->_table[$method])) {
+ throw new IPF_Exception('Method "' . $method . '"does not exist', 640);
+ }
+
+ return $this->_table[$method]->getDescription();
+ }
+
+ public function methodSignature($method)
+ {
+ if (!isset($this->_table[$method])) {
+ throw new IPF_Exception('Method "' . $method . '"does not exist', 640);
+ }
+ $prototypes = $this->_table[$method]->getPrototypes();
+
+ $signatures = array();
+ foreach ($prototypes as $prototype) {
+ $signature = array($prototype->getReturnType());
+ foreach ($prototype->getParameters() as $parameter) {
+ $signature[] = $parameter->getType();
+ }
+ $signatures[] = $signature;
+ }
+
+ return $signatures;
+ }
+
+ public function multicall($methods)
+ {
+ $responses = array();
+ foreach ($methods as $method) {
+ $fault = false;
+ if (!is_array($method)) {
+ $fault = $this->fault('system.multicall expects each method to be a struct', 601);
+ } elseif (!isset($method['methodName'])) {
+ $fault = $this->fault('Missing methodName', 602);
+ } elseif (!isset($method['params'])) {
+ $fault = $this->fault('Missing params', 603);
+ } elseif (!is_array($method['params'])) {
+ $fault = $this->fault('Params must be an array', 604);
+ } else {
+ if ('system.multicall' == $method['methodName']) {
+ // don't allow recursive calls to multicall
+ $fault = $this->fault('Recursive system.multicall forbidden', 605);
+ }
+ }
+
+ if (!$fault) {
+ try {
+ $request = new IPF_XmlRpc_Request();
+ $request->setMethod($method['methodName']);
+ $request->setParams($method['params']);
+ $response = $this->_handle($request);
+ $responses[] = $response->getReturnValue();
+ } catch (Exception $e) {
+ $fault = $this->fault($e);
+ }
+ }
+
+ if ($fault) {
+ $responses[] = array(
+ 'faultCode' => $fault->getCode(),
+ 'faultString' => $fault->getMessage()
+ );
+ }
+ }
+ return $responses;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Server_Cache
+{
+ public static function save($filename, IPF_XmlRpc_Server $server)
+ {
+ if (!is_string($filename)
+ || (!file_exists($filename) && !is_writable(dirname($filename))))
+ {
+ return false;
+ }
+
+ // Remove system.* methods
+ $methods = $server->getFunctions();
+ foreach ($methods as $name => $method) {
+ if ($method->system) {
+ unset($methods[$name]);
+ }
+ }
+
+ // Store
+ if (0 === @file_put_contents($filename, serialize($methods))) {
+ return false;
+ }
+
+ return true;
+ }
+
+ public static function get($filename, IPF_XmlRpc_Server $server)
+ {
+ if (!is_string($filename)
+ || !file_exists($filename)
+ || !is_readable($filename))
+ {
+ return false;
+ }
+
+ if (false === ($dispatch = @file_get_contents($filename))) {
+ return false;
+ }
+
+ if (false === ($dispatchArray = @unserialize($dispatch))) {
+ return false;
+ }
+
+ $server->loadFunctions($dispatchArray);
+
+ return true;
+ }
+
+ public static function delete($filename)
+ {
+ if (is_string($filename) && file_exists($filename)) {
+ unlink($filename);
+ return true;
+ }
+
+ return false;
+ }
+}
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Server_Fault extends IPF_XmlRpc_Fault
+{
+ protected $_exception;
+ protected static $_faultExceptionClasses = array('IPF_Exception' => true);
+ protected static $_observers = array();
+
+ public function __construct(Exception $e)
+ {
+ $this->_exception = $e;
+ $code = 404;
+ $message = 'Unknown error';
+ $exceptionClass = get_class($e);
+
+ foreach (array_keys(self::$_faultExceptionClasses) as $class) {
+ if ($e instanceof $class) {
+ $code = $e->getCode();
+ $message = $e->getMessage();
+ break;
+ }
+ }
+
+ parent::__construct($code, $message);
+
+ // Notify exception observers, if present
+ if (!empty(self::$_observers)) {
+ foreach (array_keys(self::$_observers) as $observer) {
+ call_user_func(array($observer, 'observe'), $this);
+ }
+ }
+ }
+
+ public static function getInstance(Exception $e)
+ {
+ return new self($e);
+ }
+
+ public static function attachFaultException($classes)
+ {
+ if (!is_array($classes)) {
+ $classes = (array) $classes;
+ }
+
+ foreach ($classes as $class) {
+ if (is_string($class) && class_exists($class)) {
+ self::$_faultExceptionClasses[$class] = true;
+ }
+ }
+ }
+
+ public static function detachFaultException($classes)
+ {
+ if (!is_array($classes)) {
+ $classes = (array) $classes;
+ }
+
+ foreach ($classes as $class) {
+ if (is_string($class) && isset(self::$_faultExceptionClasses[$class])) {
+ unset(self::$_faultExceptionClasses[$class]);
+ }
+ }
+ }
+
+ public static function attachObserver($class)
+ {
+ if (!is_string($class)
+ || !class_exists($class)
+ || !is_callable(array($class, 'observe')))
+ {
+ return false;
+ }
+
+ if (!isset(self::$_observers[$class])) {
+ self::$_observers[$class] = true;
+ }
+
+ return true;
+ }
+
+ public static function detachObserver($class)
+ {
+ if (!isset(self::$_observers[$class])) {
+ return false;
+ }
+
+ unset(self::$_observers[$class]);
+ return true;
+ }
+
+ public function getException()
+ {
+ return $this->_exception;
+ }
+}
--- /dev/null
+<?php
+
+abstract class IPF_XmlRpc_Value
+{
+ protected $_value;
+ protected $_type;
+ protected $_as_xml;
+ protected $_as_dom;
+
+ const AUTO_DETECT_TYPE = 'auto_detect';
+ const XML_STRING = 'xml';
+
+ const XMLRPC_TYPE_I4 = 'i4';
+ const XMLRPC_TYPE_INTEGER = 'int';
+ const XMLRPC_TYPE_DOUBLE = 'double';
+ const XMLRPC_TYPE_BOOLEAN = 'boolean';
+ const XMLRPC_TYPE_STRING = 'string';
+ const XMLRPC_TYPE_DATETIME = 'dateTime.iso8601';
+ const XMLRPC_TYPE_BASE64 = 'base64';
+ const XMLRPC_TYPE_ARRAY = 'array';
+ const XMLRPC_TYPE_STRUCT = 'struct';
+ const XMLRPC_TYPE_NIL = 'nil';
+
+ public function getType()
+ {
+ return $this->_type;
+ }
+
+ abstract public function getValue();
+ abstract public function saveXML();
+
+ public function getAsDOM()
+ {
+ if (!$this->_as_dom) {
+ $doc = new DOMDocument('1.0');
+ $doc->loadXML($this->saveXML());
+ $this->_as_dom = $doc->documentElement;
+ }
+
+ return $this->_as_dom;
+ }
+
+ protected function _stripXmlDeclaration(DOMDocument $dom)
+ {
+ return preg_replace('/<\?xml version="1.0"( encoding="[^\"]*")?\?>\n/u', '', $dom->saveXML());
+ }
+
+ public static function getXmlRpcValue($value, $type = self::AUTO_DETECT_TYPE)
+ {
+ switch ($type) {
+ case self::AUTO_DETECT_TYPE:
+ // Auto detect the XML-RPC native type from the PHP type of $value
+ return self::_phpVarToNativeXmlRpc($value);
+
+ case self::XML_STRING:
+ // Parse the XML string given in $value and get the XML-RPC value in it
+ return self::_xmlStringToNativeXmlRpc($value);
+
+ case self::XMLRPC_TYPE_I4:
+ // fall through to the next case
+ case self::XMLRPC_TYPE_INTEGER:
+ return new IPF_XmlRpc_Value_Integer($value);
+
+ case self::XMLRPC_TYPE_DOUBLE:
+ return new IPF_XmlRpc_Value_Double($value);
+
+ case self::XMLRPC_TYPE_BOOLEAN:
+ return new IPF_XmlRpc_Value_Boolean($value);
+
+ case self::XMLRPC_TYPE_STRING:
+ return new IPF_XmlRpc_Value_String($value);
+
+ case self::XMLRPC_TYPE_BASE64:
+ return new IPF_XmlRpc_Value_Base64($value);
+
+ case self::XMLRPC_TYPE_NIL:
+ return new IPF_XmlRpc_Value_Nil();
+
+ case self::XMLRPC_TYPE_DATETIME:
+ return new IPF_XmlRpc_Value_DateTime($value);
+
+ case self::XMLRPC_TYPE_ARRAY:
+ return new IPF_XmlRpc_Value_Array($value);
+
+ case self::XMLRPC_TYPE_STRUCT:
+ return new IPF_XmlRpc_Value_Struct($value);
+
+ default:
+ throw new IPF_Exception('Given type is not a '. __CLASS__ .' constant');
+ }
+ }
+
+ private static function _phpVarToNativeXmlRpc($value)
+ {
+ switch (gettype($value)) {
+ case 'object':
+ // Check to see if it's an XmlRpc value
+ if ($value instanceof IPF_XmlRpc_Value) {
+ return $value;
+ }
+
+ // Otherwise, we convert the object into a struct
+ $value = get_object_vars($value);
+ // Break intentionally omitted
+ case 'array':
+ // Default native type for a PHP array (a simple numeric array) is 'array'
+ $obj = 'IPF_XmlRpc_Value_Array';
+
+ // Determine if this is an associative array
+ if (!empty($value) && is_array($value) && (array_keys($value) !== range(0, count($value) - 1))) {
+ $obj = 'IPF_XmlRpc_Value_Struct';
+ }
+ return new $obj($value);
+
+ case 'integer':
+ return new IPF_XmlRpc_Value_Integer($value);
+
+ case 'double':
+ return new IPF_XmlRpc_Value_Double($value);
+
+ case 'boolean':
+ return new IPF_XmlRpc_Value_Boolean($value);
+
+ case 'NULL':
+ case 'null':
+ return new IPF_XmlRpc_Value_Nil();
+
+ case 'string':
+ // Fall through to the next case
+ default:
+ // If type isn't identified (or identified as string), it treated as string
+ return new IPF_XmlRpc_Value_String($value);
+ }
+ }
+
+ private static function _xmlStringToNativeXmlRpc($simple_xml)
+ {
+ if (!$simple_xml instanceof SimpleXMLElement) {
+ try {
+ $simple_xml = @new SimpleXMLElement($simple_xml);
+ } catch (Exception $e) {
+ // The given string is not a valid XML
+ throw new IPF_Exception('Failed to create XML-RPC value from XML string: '.$e->getMessage(),$e->getCode());
+ }
+ }
+
+ // Get the key (tag name) and value from the simple xml object and convert the value to an XML-RPC native value
+ list($type, $value) = each($simple_xml);
+ if (!$type) { // If no type was specified, the default is string
+ $type = self::XMLRPC_TYPE_STRING;
+ }
+
+ switch ($type) {
+ // All valid and known XML-RPC native values
+ case self::XMLRPC_TYPE_I4:
+ // Fall through to the next case
+ case self::XMLRPC_TYPE_INTEGER:
+ $xmlrpc_val = new IPF_XmlRpc_Value_Integer($value);
+ break;
+ case self::XMLRPC_TYPE_DOUBLE:
+ $xmlrpc_val = new IPF_XmlRpc_Value_Double($value);
+ break;
+ case self::XMLRPC_TYPE_BOOLEAN:
+ $xmlrpc_val = new IPF_XmlRpc_Value_Boolean($value);
+ break;
+ case self::XMLRPC_TYPE_STRING:
+ $xmlrpc_val = new IPF_XmlRpc_Value_String($value);
+ break;
+ case self::XMLRPC_TYPE_DATETIME: // The value should already be in a iso8601 format
+ $xmlrpc_val = new IPF_XmlRpc_Value_DateTime($value);
+ break;
+ case self::XMLRPC_TYPE_BASE64: // The value should already be base64 encoded
+ $xmlrpc_val = new IPF_XmlRpc_Value_Base64($value ,true);
+ break;
+ case self::XMLRPC_TYPE_NIL: // The value should always be NULL
+ $xmlrpc_val = new IPF_XmlRpc_Value_Nil();
+ break;
+ case self::XMLRPC_TYPE_ARRAY:
+ // If the XML is valid, $value must be an SimpleXML element and contain the <data> tag
+ if (!$value instanceof SimpleXMLElement) {
+ throw new IPF_Exception('XML string is invalid for XML-RPC native '. self::XMLRPC_TYPE_ARRAY .' type');
+ }
+
+ // PHP 5.2.4 introduced a regression in how empty($xml->value)
+ // returns; need to look for the item specifically
+ $data = null;
+ foreach ($value->children() as $key => $value) {
+ if ('data' == $key) {
+ $data = $value;
+ break;
+ }
+ }
+
+ if (null === $data) {
+ throw new IPF_Exception('Invalid XML for XML-RPC native '. self::XMLRPC_TYPE_ARRAY .' type: ARRAY tag must contain DATA tag');
+ }
+ $values = array();
+ // Parse all the elements of the array from the XML string
+ // (simple xml element) to IPF_XmlRpc_Value objects
+ foreach ($data->value as $element) {
+ $values[] = self::_xmlStringToNativeXmlRpc($element);
+ }
+ $xmlrpc_val = new IPF_XmlRpc_Value_Array($values);
+ break;
+ case self::XMLRPC_TYPE_STRUCT:
+ // If the XML is valid, $value must be an SimpleXML
+ if ((!$value instanceof SimpleXMLElement)) {
+ throw new IPF_Exception('XML string is invalid for XML-RPC native '. self::XMLRPC_TYPE_STRUCT .' type');
+ }
+ $values = array();
+ // Parse all the memebers of the struct from the XML string
+ // (simple xml element) to IPF_XmlRpc_Value objects
+ foreach ($value->member as $member) {
+ // @todo? If a member doesn't have a <value> tag, we don't add it to the struct
+ // Maybe we want to throw an exception here ?
+ if ((!$member->value instanceof SimpleXMLElement) || empty($member->value)) {
+ continue;
+ //throw new IPF_XmlRpc_Value_Exception('Member of the '. self::XMLRPC_TYPE_STRUCT .' XML-RPC native type must contain a VALUE tag');
+ }
+ $values[(string)$member->name] = self::_xmlStringToNativeXmlRpc($member->value);
+ }
+ $xmlrpc_val = new IPF_XmlRpc_Value_Struct($values);
+ break;
+ default:
+ throw new IPF_Exception('Value type \''. $type .'\' parsed from the XML string is not a known XML-RPC native type');
+ break;
+ }
+ $xmlrpc_val->_setXML($simple_xml->asXML());
+
+ return $xmlrpc_val;
+ }
+
+ private function _setXML($xml)
+ {
+ $this->_as_xml = $xml;
+ }
+
+}
+
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Array extends IPF_XmlRpc_Value_Collection
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_ARRAY;
+ parent::__construct($value);
+ }
+
+ public function saveXML()
+ {
+ if (!$this->_as_xml) { // The XML code was not calculated yet
+ $dom = new DOMDocument('1.0');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $array = $value->appendChild($dom->createElement('array'));
+ $data = $array->appendChild($dom->createElement('data'));
+
+ if (is_array($this->_value)) {
+ foreach ($this->_value as $val) {
+ /* @var $val IPF_XmlRpc_Value */
+ $data->appendChild($dom->importNode($val->getAsDOM(), true));
+ }
+ }
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Base64 extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value, $already_encoded=false)
+ {
+ $this->_type = self::XMLRPC_TYPE_BASE64;
+
+ $value = (string)$value; // Make sure this value is string
+ if (!$already_encoded) {
+ $value = base64_encode($value); // We encode it in base64
+ }
+ $this->_value = $value;
+ }
+
+ public function getValue()
+ {
+ return base64_decode($this->_value);
+ }
+
+ public function saveXML()
+ {
+ if (! $this->_as_xml) { // The XML was not generated yet
+ $dom = new DOMDocument('1.0', 'UTF-8');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $type = $value->appendChild($dom->createElement($this->_type));
+ $type->appendChild($dom->createTextNode($this->_value));
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Boolean extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_BOOLEAN;
+ $this->_value = (int)(bool)$value;
+ }
+
+ public function getValue()
+ {
+ return (bool)$this->_value;
+ }
+
+ public function saveXML()
+ {
+ if (! $this->_as_xml) { // The XML was not generated yet
+ $dom = new DOMDocument('1.0', 'UTF-8');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $type = $value->appendChild($dom->createElement($this->_type));
+ $type->appendChild($dom->createTextNode($this->_value));
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
--- /dev/null
+<?php
+
+abstract class IPF_XmlRpc_Value_Collection extends IPF_XmlRpc_Value
+{
+ public function __construct($value)
+ {
+ $values = (array)$value; // Make sure that the value is an array
+ foreach ($values as $key => $value) {
+ // If the elements of the given array are not IPF_XmlRpc_Value objects,
+ // we need to convert them as such (using auto-detection from PHP value)
+ if (!$value instanceof parent) {
+ $value = self::getXmlRpcValue($value, self::AUTO_DETECT_TYPE);
+ }
+ $this->_value[$key] = $value;
+ }
+ }
+
+ public function getValue()
+ {
+ $values = (array)$this->_value;
+ foreach ($values as $key => $value) {
+ /* @var $value IPF_XmlRpc_Value */
+ if (!$value instanceof parent) {
+ throw new IPF_Exception('Values of '. get_class($this) .' type must be IPF_XmlRpc_Value objects');
+ }
+ $values[$key] = $value->getValue();
+ }
+ return $values;
+ }
+
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_DateTime extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_DATETIME;
+
+ // If the value is not numeric, we try to convert it to a timestamp (using the strtotime function)
+ if (is_numeric($value)) { // The value is numeric, we make sure it is an integer
+ $value = (int)$value;
+ } else {
+ $value = strtotime($value);
+ if ($value === false || $value == -1) { // cannot convert the value to a timestamp
+ throw new IPF_Exception('Cannot convert given value \''. $value .'\' to a timestamp');
+ }
+ }
+ $value = date('c', $value); // Convert the timestamp to iso8601 format
+
+ // Strip out TZ information and dashes
+ $value = preg_replace('/(\+|-)\d{2}:\d{2}$/', '', $value);
+ $value = str_replace('-', '', $value);
+
+ $this->_value = $value;
+ }
+
+ public function getValue()
+ {
+ return $this->_value;
+ }
+
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Double extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_DOUBLE;
+ $this->_value = sprintf('%f',(float)$value); // Make sure this value is float (double) and without the scientific notation
+ }
+
+ public function getValue()
+ {
+ return (float)$this->_value;
+ }
+
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Integer extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_INTEGER;
+ $this->_value = (int)$value; // Make sure this value is integer
+ }
+
+ public function getValue()
+ {
+ return $this->_value;
+ }
+
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Nil extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct()
+ {
+ $this->_type = self::XMLRPC_TYPE_NIL;
+ $this->_value = null;
+ }
+
+ public function getValue()
+ {
+ return null;
+ }
+
+ public function saveXML()
+ {
+ if (! $this->_as_xml) { // The XML was not generated yet
+ $dom = new DOMDocument('1.0', 'UTF-8');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $type = $value->appendChild($dom->createElement($this->_type));
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
--- /dev/null
+<?php
+
+abstract class IPF_XmlRpc_Value_Scalar extends IPF_XmlRpc_Value
+{
+ public function saveXML()
+ {
+ if (!$this->_as_xml) { // The XML code was not calculated yet
+ $dom = new DOMDocument('1.0');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $type = $value->appendChild($dom->createElement($this->_type));
+ $type->appendChild($dom->createTextNode($this->getValue()));
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_String extends IPF_XmlRpc_Value_Scalar
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_STRING;
+
+ // Make sure this value is string and all XML characters are encoded
+ $this->_value = $this->_xml_entities($value);
+ }
+
+ public function getValue()
+ {
+ return html_entity_decode($this->_value, ENT_QUOTES, 'UTF-8');
+ }
+
+ private function _xml_entities($str)
+ {
+ return htmlentities($str, ENT_QUOTES, 'UTF-8');
+ }
+
+}
+
--- /dev/null
+<?php
+
+class IPF_XmlRpc_Value_Struct extends IPF_XmlRpc_Value_Collection
+{
+ public function __construct($value)
+ {
+ $this->_type = self::XMLRPC_TYPE_STRUCT;
+ parent::__construct($value);
+ }
+
+ public function saveXML()
+ {
+ if (!$this->_as_xml) { // The XML code was not calculated yet
+ $dom = new DOMDocument('1.0');
+ $value = $dom->appendChild($dom->createElement('value'));
+ $struct = $value->appendChild($dom->createElement('struct'));
+
+ if (is_array($this->_value)) {
+ foreach ($this->_value as $name => $val) {
+ /* @var $val IPF_XmlRpc_Value */
+ $member = $struct->appendChild($dom->createElement('member'));
+ $member->appendChild($dom->createElement('name', $name));
+ $member->appendChild($dom->importNode($val->getAsDOM(), 1));
+ }
+ }
+
+ $this->_as_dom = $value;
+ $this->_as_xml = $this->_stripXmlDeclaration($dom);
+ }
+
+ return $this->_as_xml;
+ }
+}
+
projects / ipf-xmlrpc.git / commitdiff