tidal / PEIP

src/Plugins/BasePlugin.php

Doc Comments +2 added lines, -1 removed lines

@@ -213,7 +213,7 @@ 
      *
      * @access protected
      * @param object $config configuration object to create arguments from.
-     * @return mixed build arguments
+     * @return \PEIP\INF\Channel\Channel[] build arguments
      */
     protected function getReplyHandlerArguments($config){
         $args = array(
@@ -259,6 +259,7 @@ 
      * @access protected
      * @param string the configuration type ofthe channel (e.g.: 'reply', 'request')
      * @param object $config configuration object to return channel from.
+     * @param string $type
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
     public function doGetChannel($type, $config){

Spacing +19 added lines, -19 removed lines

@@ -42,7 +42,7 @@ 
      * @param object $config configuration object for the pollable channel.
      * @return \PEIP\INF\Channel\Channel the created pollable channel instance
      */
-    public function createChannel($config){
+    public function createChannel($config) {
         return $this->doCreateChannel($config, '\PEIP\Channel\PollableChannel');
     }
 
@@ -54,7 +54,7 @@ 
      * @param object $config configuration object for the subscribable channel.
      * @return \PEIP\INF\Channel\Channel the created subscribable channel instance
      */
-    public function createSubscribableChannel($config){
+    public function createSubscribableChannel($config) {
         return $this->doCreateChannel($config, '\PEIP\Channel\PublishSubscribeChannel');
     }
 
@@ -67,9 +67,9 @@ 
      * @param $additionalArguments additional arguments for the channel constructor (without first arg = id)
      * @return \PEIP\INF\Channel\Channel the created channel instance
      */
-    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()){
+    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()) {
         $id = (string)$config['id'];
-        if($id != ''){
+        if ($id != '') {
             array_unshift($additionalArguments, $id);
             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);
             //$this->channelRegistry->register($channel);
@@ -87,7 +87,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the gateway instance
      */
-    public function createGateway($config, $defaultClass = false){
+    public function createGateway($config, $defaultClass = false) {
         $args = array(
             $this->getRequestChannel($config),
             $this->getReplyChannel($config)
@@ -111,7 +111,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the router instance
      */
-    public function createRouter($config, $defaultClass = false){
+    public function createRouter($config, $defaultClass = false) {
         $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;
         return $this->buildAndModify($config, array(
             $resolver,
@@ -128,7 +128,7 @@ 
      * @param object $config configuration object for the splitter.
      * @return object the splitter instance
      */
-    public function createSplitter($config){
+    public function createSplitter($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -141,7 +141,7 @@ 
      * @param object $config configuration object for the transformer.
      * @return object the transformer instance
      */
-    public function createTransformer($config){
+    public function createTransformer($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -154,7 +154,7 @@ 
      * @param object $config configuration object for the aggregator.
      * @return object the aggregator instance
      */
-    public function createAggregator($config){
+    public function createAggregator($config) {
         return $this->createReplyMessageHandler($config);
     }
 
@@ -167,7 +167,7 @@ 
      * @param object $config configuration object for the wiretap.
      * @return object the wiretap instance
      */
-    public function createWiretap($config){
+    public function createWiretap($config) {
         return $this->createReplyMessageHandler($config, '\PEIP\Listener\Wiretap');
     }
 
@@ -180,7 +180,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the reply-message-handler instance
      */
-    public function createReplyMessageHandler($config, $defaultClass = false){
+    public function createReplyMessageHandler($config, $defaultClass = false) {
         return $this->buildAndModify($config, $this->getReplyHandlerArguments($config), $defaultClass);
     }
 
@@ -193,12 +193,12 @@ 
      * @param string $defaultClass the class to use if none is set in config.
      * @return object the service-activator instance
      */
-    public function createServiceActivator($config, $defaultClass = false){
+    public function createServiceActivator($config, $defaultClass = false) {
         $method = (string)$config['method'];
         $service = $this->context->getServiceProvider()->provideService((string)$config['ref']);
-        if($method && $service){
+        if ($method && $service) {
             $args = $this->getReplyHandlerArguments($config);
-            array_unshift($args,array(
+            array_unshift($args, array(
                 $service,
                 $method
             ));
@@ -215,12 +215,12 @@ 
      * @param object $config configuration object to create arguments from.
      * @return mixed build arguments
      */
-    protected function getReplyHandlerArguments($config){
+    protected function getReplyHandlerArguments($config) {
         $args = array(
             $this->doGetChannel('input', $config),
             $this->doGetChannel('output', $config)
         );
-        if($args[0] == NULL){
+        if ($args[0] == NULL) {
             throw new \RuntimeException('Could not receive input channel.');
         }
         return $args;
@@ -235,7 +235,7 @@ 
      * @param object $config configuration object to return request-channel from.
      * @return \PEIP\INF\Channel\Channel request-channel
      */
-    protected function getRequestChannel($config){
+    protected function getRequestChannel($config) {
         return $this->doGetChannel('request', $config);
     }
 
@@ -248,7 +248,7 @@ 
      * @param object $config configuration object to return reply-channel from.
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    protected function getReplyChannel($config){
+    protected function getReplyChannel($config) {
         return $this->doGetChannel('reply', $config);
     }
 
@@ -261,7 +261,7 @@ 
      * @param object $config configuration object to return channel from.
      * @return \PEIP\INF\Channel\Channel reply-channel
      */
-    public function doGetChannel($type, $config){
+    public function doGetChannel($type, $config) {
         $channelName = isset($config[$type."_channel"])
             ? $config[$type."_channel"]
             : $config["default_".$type."_channel"];

src/Translator/XMLArrayTranslator.php

Spacing +10 added lines, -10 removed lines

@@ -22,42 +22,42 @@ 
 
 class XMLArrayTranslator {
 
-    public static function translate($content){
+    public static function translate($content) {
         try {
             $node = simplexml_load_string($content);
             // fix for hhvm
-            if(!($node instanceof \SimpleXMLElement)){
+            if (!($node instanceof \SimpleXMLElement)) {
                 throw new \Exception('loading XML failed');  
             }
             
         }
-        catch(\Exception $e){
+        catch (\Exception $e) {
             return false;
         }     
         
         return self::doTranslate($node);
     }
 
-    protected static function doTranslate(\SimpleXMLElement $node){
+    protected static function doTranslate(\SimpleXMLElement $node) {
         
         $array = array();
         $array['type'] = $node['type']
             ? (string)$node['type']
             : (string)$node->getName();
         $value = (string)$node;
-        if($value != ''){
+        if ($value != '') {
             $array['value'] = $value;
         }
 
-        foreach($node->attributes() as $name=>$value){
+        foreach ($node->attributes() as $name=>$value) {
             $array[$name] = (string)$value;
         }
-        foreach($node->children() as $nr=>$child){
+        foreach ($node->children() as $nr=>$child) {
             $name = $child->getName();
             $res = self::doTranslate($child);
 
-            if(isset($array[$name])){
-                if(is_string($array[$name])){
+            if (isset($array[$name])) {
+                if (is_string($array[$name])) {
                     $array[$name] = array(
                         array(
                             'type'=>$name,
@@ -65,7 +65,7 @@ 
                         )
                     );
                 }
-            }else{
+            }else {
                 $array[$name] = array();
             }
             $array[$name][] = $res;

Braces +2 added lines, -3 removed lines

@@ -30,8 +30,7 @@ 
                 throw new \Exception('loading XML failed');  
             }
             
-        }
-        catch(\Exception $e){
+        } catch(\Exception $e){
             return false;
         }     
         
@@ -65,7 +64,7 @@ 
                         )
                     );
                 }
-            }else{
+            } else{
                 $array[$name] = array();
             }
             $array[$name][] = $res;

src/Context/XMLContextReader.php

Spacing +4 added lines, -4 removed lines

@@ -19,21 +19,21 @@
     protected $config;
 
 
-    public function __construct($config){ 
+    public function __construct($config) { 
         $this->config = ($config);       
     }
 
-    public function read(){      
+    public function read() {      
         $iterator = new \SimpleXMLIterator($this->config);
         $iterator->rewind();
-        while($iterator->valid()){
+        while ($iterator->valid()) {
             
             $arrayNode = XMLArrayTranslator::translate($iterator->current()->asXML()); 
             $this->doFireEvent('read_node', array('NODE'=>$arrayNode));            
             $iterator->next();
         }
         
-        foreach($iterator as $xmlNode){  
+        foreach ($iterator as $xmlNode) {  
 
         }
         $this->config = array();

src/Message/GenericMessage.php

Indentation +5 added lines, -5 removed lines

@@ -76,11 +76,11 @@
     }
 
         /**
-     * returns all headers of the message
-     * 
-     * @access public
-     * @return ArrayAccess ArrayAccess object of headers
-     */
+         * returns all headers of the message
+         * 
+         * @access public
+         * @return ArrayAccess ArrayAccess object of headers
+         */
     public function getHeaders(){
         return (array) $this->headers;
     }

Spacing +15 added lines, -15 removed lines

@@ -41,7 +41,7 @@ 
      * @param mixed $content The content/payload of the message 
      * @param array|ArrayAccess $headers headers as key/value pairs
      */
-    public function __construct($content, $headers = array()){
+    public function __construct($content, $headers = array()) {
         $this->doSetContent($content);
         $this->doSetHeaders($headers);          
     }
@@ -53,7 +53,7 @@ 
      * @access public
      * @return
      */
-    public function getContent(){
+    public function getContent() {
         return $this->content;
     }
 
@@ -63,13 +63,13 @@ 
      * @access protected
      * @param mixed $content The content/payload of the message 
      */
-    protected function doSetContent($content){
+    protected function doSetContent($content) {
         $this->content = Test::castType($content, self::CONTENT_CAST_TYPE);
     }
 
-    protected function doSetHeaders($headers){
+    protected function doSetHeaders($headers) {
         $headers = Test::ensureArrayAccess($headers);
-        if(is_array($headers)){
+        if (is_array($headers)) {
             $headers = new \ArrayObject($headers);
         }
         $this->headers = $headers;
@@ -81,8 +81,8 @@ 
      * @access public
      * @return ArrayAccess ArrayAccess object of headers
      */
-    public function getHeaders(){
-        return (array) $this->headers;
+    public function getHeaders() {
+        return (array)$this->headers;
     }
   
     /**
@@ -92,7 +92,7 @@ 
      * @param string $name the name of the header  
      * @return mixed the value of the header
      */
-    public function getHeader($name){
+    public function getHeader($name) {
         $name = (string)$name;
         return isset($this->headers[$name]) ? $this->headers[$name] : NULL;
     }
@@ -105,8 +105,8 @@ 
      * @param string $name the name of the header
      * @return boolean wether the header has been successfully  set
      */
-    public function addHeader($name, $value){
-        if(!$this->hasHeader($name)){
+    public function addHeader($name, $value) {
+        if (!$this->hasHeader($name)) {
             $this->headers[$name] = $value;
             return true;
         }
@@ -120,7 +120,7 @@ 
      * @param string $name the name of the header
      * @return boolean wether the header is set
      */
-    public function hasHeader($name){
+    public function hasHeader($name) {
         return isset($this->headers[$name]);
     }
 
@@ -130,16 +130,16 @@ 
      * @access public
      * @return string  content/payload of the message
      */
-    public function __toString(){
+    public function __toString() {
         $res = false;
         try {
             $res = (string)$this->getContent();
         }
-        catch(\Exception $e){           
+        catch (\Exception $e) {           
             try {
                 $res = get_class($this->getContent());
             }
-            catch(\Exception $e){
+            catch (\Exception $e) {
                 return "";
             }
         }     
@@ -157,7 +157,7 @@ 
      * @param array $arguments argumends for the constructor
      * @return GenericMessage new class instance
      */    
-    public static function build(array $arguments = array()){
+    public static function build(array $arguments = array()) {
         return GenericBuilder::getInstance(__CLASS__)->build($arguments);
     }     
 } 
\ No newline at end of file

Braces +2 added lines, -4 removed lines

@@ -134,12 +134,10 @@
         $res = false;
         try {
             $res = (string)$this->getContent();
-        }
-        catch(\Exception $e){           
+        } catch(\Exception $e){           
             try {
                 $res = get_class($this->getContent());
-            }
-            catch(\Exception $e){
+            } catch(\Exception $e){
                 return "";
             }
         }     

src/Message/MessageBuilder.php

Spacing +13 added lines, -13 removed lines

@@ -39,7 +39,7 @@ 
      * @access public
      * @param string $messageClass the message-class to build instances for 
      */
-    public function __construct($messageClass = '\PEIP\Message\GenericMessage'){
+    public function __construct($messageClass = '\PEIP\Message\GenericMessage') {
         $this->messageClass = $messageClass;
         $this->factory = DedicatedFactory::getfromCallable(array($messageClass, 'build'));    
     }
@@ -51,7 +51,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this
      */
-    public function copyHeaders(array $headers){
+    public function copyHeaders(array $headers) {
         $this->headers = array_merge($this->headers, $headers);
         return $this;       
     }
@@ -63,7 +63,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this
      */
-    public function copyHeadersIfAbsent(array $headers){
+    public function copyHeadersIfAbsent(array $headers) {
         $this->headers = array_merge($headers, $this->headers);
         return $this;   
     }
@@ -75,7 +75,7 @@ 
      * @param string $headerName the name of the header
      * @return MessageBuilder $this
      */
-    public function removeHeader($headerName){
+    public function removeHeader($headerName) {
         unset($this->headers[$headerName]);
         return $this;
     }
@@ -88,7 +88,7 @@ 
      * @param mixed $headerValue the value for the header
      * @return MessageBuilder $this 
      */
-    public function setHeader($headerName, $headerValue){
+    public function setHeader($headerName, $headerValue) {
         $this->headers[$headerName] = $headerValue;
         return $this;   
     }
@@ -100,7 +100,7 @@ 
      * @param array $headers the headers to set
      * @return MessageBuilder $this 
      */
-    public function setHeaders(array $headers){
+    public function setHeaders(array $headers) {
         $this->headers = $headers;
         return $this;   
     }
@@ -111,7 +111,7 @@ 
      * @access public
      * @return array the headers for the message to build 
      */
-    public function getHeaders(){
+    public function getHeaders() {
         return $this->headers;
     }  
         
@@ -122,7 +122,7 @@ 
      * @param $arguments 
      * @return 
      */
-    public function build(array $headers = array()){
+    public function build(array $headers = array()) {
         $this->copyHeaders($headers);
         return GenericBuilder::getInstance($this->messageClass)
             ->build(array($this->payload, new \ArrayObject($this->headers)));        
@@ -135,7 +135,7 @@ 
      * @param mixed $payload payload for the message to build 
      * @return MessageBuilder $this 
      */
-    public function setContent($payload){
+    public function setContent($payload) {
         $this->payload = $payload;
         return $this;
     }
@@ -148,7 +148,7 @@ 
      * @param string $messageClass the message class to build from the builder 
      * @return MessageBuilder new instance of MessageBuilder 
      */    
-    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage'){
+    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage') {
         return new  MessageBuilder($messageClass);
     }
   
@@ -160,7 +160,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to get class to build from the builder 
      * @return MessageBuilder new instance of MessageBuilder 
      */      
-    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message){
+    public static function getInstanceFromMessage(\PEIP\INF\Message\Message $message) {
         return new MessageBuilder(get_class($message));
     }
    
@@ -170,7 +170,7 @@ 
      * @access public
      * @param string $messageClass the message-class to build new instances for
      */
-    public function setMessageClass($messageClass){
+    public function setMessageClass($messageClass) {
         $this->messageClass = $messageClass;
     }
  
@@ -180,7 +180,7 @@ 
      * @access public
      * @return string the message-class to build new instances for
      */
-    public function getMessageClass(){
+    public function getMessageClass() {
         return $this->messageClass;
     }         
 }
\ No newline at end of file

src/Message/CommandMessage.php

Spacing +5 added lines, -5 removed lines

@@ -37,8 +37,8 @@ 
      * @param $headers 
      * @return 
      */
-    public function __construct($content, ArrayAccess $headers = NULL){
-        if(!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)){
+    public function __construct($content, ArrayAccess $headers = NULL) {
+        if (!($content instanceof \PEIP\INF\Command\Command) && !is_callable($content)) {
             throw new \BadArgumentException('Argument 1 for CommandMessage::__construct must be callable or implment \PEIP\INF\Command\Command');
         }
         
@@ -51,10 +51,10 @@ 
      * @access public
      * @return 
      */
-    public function execute(){
-        if(is_callable($this->getContent())){
+    public function execute() {
+        if (is_callable($this->getContent())) {
             return call_user_func($this->getContent());
-        }else{
+        }else {
             return $this->getContent()->execute();
         }
     }

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     public function execute(){
         if(is_callable($this->getContent())){
             return call_user_func($this->getContent());
-        }else{
+        } else{
             return $this->getContent()->execute();
         }
     }

src/Message/CallableMessageHandler.php

Spacing +11 added lines, -11 removed lines

@@ -35,7 +35,7 @@ 
      * @param $callable 
      * @return 
      */
-    public function __construct($callable){
+    public function __construct($callable) {
         $this->callable = $callable;    
         $this->examineCallabe();
     }
@@ -45,22 +45,22 @@ 
      * @access protected
      * @return 
      */
-    protected function examineCallabe(){
-        if(is_callable($this->callable)){        
-            if(is_array($this->callable)){
-                list($class, $method) =  $this->callable;
+    protected function examineCallabe() {
+        if (is_callable($this->callable)) {        
+            if (is_array($this->callable)) {
+                list($class, $method) = $this->callable;
                 $static = !is_object($class);
                 $class = is_object($class) ? get_class($class) : (string)$class;
                 $reflectionClass = new \ReflectionClass($class);
                 $reflectionFunc = $reflectionClass->getMethod($method);
-                if($static && !$reflectionFunc->isStatic()){
+                if ($static && !$reflectionFunc->isStatic()) {
                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  
                 }
-            }else{
+            }else {
                 $reflectionFunc = new \ReflectionFunction($this->callable);  
             }
             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();
-        }else{
+        }else {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');
         }   
     }   
@@ -73,14 +73,14 @@ 
      * @param $sent 
      * @return 
      */
-    public function handle($message, $channel = false, $sent = false){
-        if(!is_object($message)){
+    public function handle($message, $channel = false, $sent = false) {
+        if (!is_object($message)) {
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::handle is not a Object');       
         }   
         try {
             return call_user_func_array($this->callable, array($message, $channel, $sent));
         }
-        catch(\Exception $e){
+        catch (\Exception $e) {
             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());
         }   
     }   

Braces +3 added lines, -4 removed lines

@@ -56,11 +56,11 @@ 
                 if($static && !$reflectionFunc->isStatic()){
                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  
                 }
-            }else{
+            } else{
                 $reflectionFunc = new \ReflectionFunction($this->callable);  
             }
             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();
-        }else{
+        } else{
             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');
         }   
     }   
@@ -79,8 +79,7 @@ 
         }   
         try {
             return call_user_func_array($this->callable, array($message, $channel, $sent));
-        }
-        catch(\Exception $e){
+        } catch(\Exception $e){
             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());
         }   
     }   

src/Message/ErrorMessage.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
      * @param $headers 
      * @return 
      */
-    public function __construct(\Exception $payload, array $headers = array()){
+    public function __construct(\Exception $payload, array $headers = array()) {
         $this->payload = $payload;
         $this->headers = $headers;
     }

src/Data/InternalStoreAbstract.php

Spacing +7 added lines, -7 removed lines

@@ -32,7 +32,7 @@ 
      * @param $key 
      * @return 
      */
-    protected function hasInternalValue($key){
+    protected function hasInternalValue($key) {
         return array_key_exists($key, $this->internalValues);
     }   
     
@@ -42,7 +42,7 @@ 
      * @param $key 
      * @return 
      */
-    protected function getInternalValue($key){
+    protected function getInternalValue($key) {
         return array_key_exists($key, $this->internalValues) ? $this->internalValues[$key] : NULL;
     }
     
@@ -52,7 +52,7 @@ 
      * @param $key 
      * @return 
      */
-    protected function deleteInternalValue($key){
+    protected function deleteInternalValue($key) {
         unset($this->internalValues[$key]);
     }   
 
@@ -63,7 +63,7 @@ 
      * @param $value 
      * @return 
      */
-    protected function setInternalValue($key, $value){
+    protected function setInternalValue($key, $value) {
         $this->internalValues[$key] = $value;
     }
     
@@ -80,7 +80,7 @@ 
      * @param $internalValues 
      * @return 
      */
-    protected function setInternalValues(array $internalValues){
+    protected function setInternalValues(array $internalValues) {
         $this->internalValues = $internalValues;        
     }
 
@@ -95,7 +95,7 @@ 
      * @access protected
      * @return 
      */
-    protected function getInternalValues(){
+    protected function getInternalValues() {
         return $this->internalValues;
     }
 
@@ -104,7 +104,7 @@ 
      * @access protected
      * @return 
      */
-    protected function addInternalValues(){
+    protected function addInternalValues() {
         array_merge($this->internalValues, $internalValues);
     }