'is_string', 'optional' => 'is_bool', 'default' => null, 'description' => 'is_string', ); /** * Service params * @var array */ protected $params = array(); /** * Mapping of parameter types to JSON-RPC types * @var array */ protected $paramMap = array( 'any' => 'any', 'arr' => 'array', 'array' => 'array', 'assoc' => 'object', 'bool' => 'boolean', 'boolean' => 'boolean', 'dbl' => 'float', 'double' => 'float', 'false' => 'boolean', 'float' => 'float', 'hash' => 'object', 'integer' => 'integer', 'int' => 'integer', 'mixed' => 'any', 'nil' => 'null', 'null' => 'null', 'object' => 'object', 'string' => 'string', 'str' => 'string', 'struct' => 'object', 'true' => 'boolean', 'void' => 'null', ); /** * Allowed transport types * @var array */ protected $transportTypes = array( 'POST', ); /** * Constructor * * @param string|array $spec * @throws InvalidArgumentException if no name provided */ public function __construct($spec) { if (is_string($spec)) { $this->setName($spec); } elseif (is_array($spec)) { $this->setOptions($spec); } if (null == $this->getName()) { throw new InvalidArgumentException('SMD service description requires a name; none provided'); } } /** * Set object state * * @param array $options * @return Service */ public function setOptions(array $options) { $methods = get_class_methods($this); foreach ($options as $key => $value) { if ('options' == strtolower($key)) { continue; } $method = 'set' . ucfirst($key); if (in_array($method, $methods)) { $this->$method($value); } } return $this; } /** * Set service name * * @param string $name * @return Service * @throws InvalidArgumentException */ public function setName($name) { $name = (string) $name; if (!preg_match($this->nameRegex, $name)) { throw new InvalidArgumentException("Invalid name '{$name} provided for service; must follow PHP method naming conventions"); } $this->name = $name; return $this; } /** * Retrieve name * * @return string */ public function getName() { return $this->name; } /** * Set Transport * * Currently limited to POST * * @param string $transport * @throws InvalidArgumentException * @return Service */ public function setTransport($transport) { if (!in_array($transport, $this->transportTypes)) { throw new InvalidArgumentException("Invalid transport '{$transport}'; please select one of (" . implode(', ', $this->transportTypes) . ')'); } $this->transport = $transport; return $this; } /** * Get transport * * @return string */ public function getTransport() { return $this->transport; } /** * Set service target * * @param string $target * @return Service */ public function setTarget($target) { $this->target = (string) $target; return $this; } /** * Get service target * * @return string */ public function getTarget() { return $this->target; } /** * Set envelope type * * @param string $envelopeType * @throws InvalidArgumentException * @return Service */ public function setEnvelope($envelopeType) { if (!in_array($envelopeType, $this->envelopeTypes)) { throw new InvalidArgumentException("Invalid envelope type '{$envelopeType}'; please specify one of (" . implode(', ', $this->envelopeTypes) . ')'); } $this->envelope = $envelopeType; return $this; } /** * Get envelope type * * @return string */ public function getEnvelope() { return $this->envelope; } /** * Add a parameter to the service * * @param string|array $type * @param array $options * @param int|null $order * @throws InvalidArgumentException * @return Service */ public function addParam($type, array $options = array(), $order = null) { if (is_string($type)) { $type = $this->_validateParamType($type); } elseif (is_array($type)) { foreach ($type as $key => $paramType) { $type[$key] = $this->_validateParamType($paramType); } } else { throw new InvalidArgumentException('Invalid param type provided'); } $paramOptions = array( 'type' => $type, ); foreach ($options as $key => $value) { if (in_array($key, array_keys($this->paramOptionTypes))) { if (null !== ($callback = $this->paramOptionTypes[$key])) { if (!$callback($value)) { continue; } } $paramOptions[$key] = $value; } } $this->params[] = array( 'param' => $paramOptions, 'order' => $order, ); return $this; } /** * Add params * * Each param should be an array, and should include the key 'type'. * * @param array $params * @return Service */ public function addParams(array $params) { ksort($params); foreach ($params as $options) { if (!is_array($options)) { continue; } if (!array_key_exists('type', $options)) { continue; } $type = $options['type']; $order = (array_key_exists('order', $options)) ? $options['order'] : null; $this->addParam($type, $options, $order); } return $this; } /** * Overwrite all parameters * * @param array $params * @return Service */ public function setParams(array $params) { $this->params = array(); return $this->addParams($params); } /** * Get all parameters * * Returns all params in specified order. * * @return array */ public function getParams() { $params = array(); $index = 0; foreach ($this->params as $param) { if (null === $param['order']) { if (array_search($index, array_keys($params), true)) { ++$index; } $params[$index] = $param['param']; ++$index; } else { $params[$param['order']] = $param['param']; } } ksort($params); return $params; } /** * Set return type * * @param string|array $type * @throws InvalidArgumentException * @return Service */ public function setReturn($type) { if (is_string($type)) { $type = $this->_validateParamType($type, true); } elseif (is_array($type)) { foreach ($type as $key => $returnType) { $type[$key] = $this->_validateParamType($returnType, true); } } else { throw new InvalidArgumentException("Invalid param type provided ('" . gettype($type) . "')"); } $this->return = $type; return $this; } /** * Get return type * * @return string|array */ public function getReturn() { return $this->return; } /** * Cast service description to array * * @return array */ public function toArray() { $envelope = $this->getEnvelope(); $target = $this->getTarget(); $transport = $this->getTransport(); $parameters = $this->getParams(); $returns = $this->getReturn(); $name = $this->getName(); if (empty($target)) { return compact('envelope', 'transport', 'name', 'parameters', 'returns'); } return compact('envelope', 'target', 'transport', 'name', 'parameters', 'returns'); } /** * Return JSON encoding of service * * @return string */ public function toJson() { $service = array($this->getName() => $this->toArray()); return \Zend\Json\Json::encode($service); } /** * Cast to string * * @return string */ public function __toString() { return $this->toJson(); } /** * Validate parameter type * * @param string $type * @param bool $isReturn * @return string * @throws InvalidArgumentException */ protected function _validateParamType($type, $isReturn = false) { if (!is_string($type)) { throw new InvalidArgumentException("Invalid param type provided ('{$type}')"); } if (!array_key_exists($type, $this->paramMap)) { $type = 'object'; } $paramType = $this->paramMap[$type]; if (!$isReturn && ('null' == $paramType)) { throw new InvalidArgumentException("Invalid param type provided ('{$type}')"); } return $paramType; } }