tidal / PEIP

src/Channel/ChannelAdapter.php

Spacing +6 added lines, -6 removed lines

@@ -9,22 +9,22 @@
     protected $channel;

     protected $handler;

 

-    public function __construct(\PEIP\ABS\Handler\MessageHandler $handler,  $channel){

+    public function __construct(\PEIP\ABS\Handler\MessageHandler $handler, $channel) {

         $this->channel = $channel;

         $this->handler = $handler;

     }

 

-    protected function getMessage($object){

-        if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

+    protected function getMessage($object) {

+        if ($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel) {

             return $object; 

-        }else{

+        }else {

             return $object->getContent()->receive();

         }

     }

 

-    public function handle($object){

+    public function handle($object) {

         $message = $this->getMessage($object);

-                if(!is_object($message)){ 

+                if (!is_object($message)) { 

                     throw new \Exception('Could not get Message from Channel');

                 }               

                 $this->handler->handle($message);

Braces +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     protected function getMessage($object){

         if($this->channel instanceof \PEIP\INF\Channel\SubscribableChannel){

             return $object; 

-        }else{

+        } else{

             return $object->getContent()->receive();

         }

     }

src/Command/Command.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param $params 

      * @return 

      */

-    public function __construct($callable, array $params = array()){

+    public function __construct($callable, array $params = array()) {

         $this->callable = $callable;

         $this->setParameters($params);

     }

src/Data/Store.php

Spacing +7 added lines, -7 removed lines

@@ -34,7 +34,7 @@ 
      * @param mixed $value the value to store

      * @return 

      */

-    public function setValue($key, $value){

+    public function setValue($key, $value) {

         return $this->offsetSet($key, $value);

     }

     

@@ -45,7 +45,7 @@ 
      * @param mixed $key the key to return value for 

      * @return mixed the value for the given key

      */

-    public function getValue($key){

+    public function getValue($key) {

         return $this->offsetGet($key, $value);

     }

   

@@ -56,7 +56,7 @@ 
      * @param mixed $key the key to unset value for 

      * @return 

      */

-    public function deleteValue($key){

+    public function deleteValue($key) {

         return $this->offsetUnset($key);

     }

       

@@ -67,7 +67,7 @@ 
      * @param mixed $key the key to look for a value

      * @return boolean wether a value is stored for the key

      */

-    public function hasValue($key){

+    public function hasValue($key) {

         return $this->offsetExists($key);

     }   

 

@@ -78,7 +78,7 @@ 
      * @param array $values key/value pairs to store

      * @return 

      */

-    public function setValues(array $values){

+    public function setValues(array $values) {

         $this->values = $values;        

     }

 

@@ -88,7 +88,7 @@ 
      * @access public

      * @return array stored key/value pairs

      */

-    public function getValues(){

+    public function getValues() {

         return $this->values;

     }

    

@@ -100,7 +100,7 @@ 
      * @param $values 

      * @return 

      */

-    public function addValues(array $values){

+    public function addValues(array $values) {

         array_merge($this->values, $values);

     }   

 }
\ No newline at end of file

src/Data/ParameterHolderCollection.php

Indentation +11 added lines, -11 removed lines

@@ -74,7 +74,7 @@ 
      */

     public function setParameters($namespace, array $parameters){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

   

   

     /**

@@ -85,7 +85,7 @@ 
      */

     public function addParameters($namespace, array $parameters){

         $this->getParameterHolderOrCreate($namespace)->addParameters($parameters);

-   }

+    }

   

   

     /**

@@ -102,7 +102,7 @@ 
      */

     public function getParameters($namespace){

         $this->getParameterHolderOrCreate($namespace)->getParameters();

-   }

+    }

   

   

     /**

@@ -113,7 +113,7 @@ 
      */

     public function getParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->getParameter($name);

-   }

+    }

   

   

     /**

@@ -125,7 +125,7 @@ 
      */

     public function setParameter($namespace, $name, $value){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

   

   

     /**

@@ -136,7 +136,7 @@ 
      */

     public function hasParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->hasParameter($name);

-   }

+    }

 

   

     /**

@@ -147,7 +147,7 @@ 
      */

     public function deleteParameter($namespace, $name){

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

-   }

+    }

 

   

     /**

@@ -166,7 +166,7 @@ 
      */

     public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder){

     $this->stores[$namespace] = $holder;

-  } 

+    } 

 

   

     /**

@@ -183,7 +183,7 @@ 
      */

     public function getParameterHolder($namespace){

     return $this->stores[$namespace];

-  }

+    }

 

   

     /**

@@ -200,7 +200,7 @@ 
      */

     public function hasParameterHolder($namespace){

     return array_key_exists($namespace, $this->stores);

-  }

+    }

 

   

     /**

@@ -217,7 +217,7 @@ 
      */

     public function deleteParameterHolder($namespace){

     unset($this->stores[$namespace]);

-  } 

+    } 

     

     

 

Spacing +16 added lines, -16 removed lines

@@ -35,7 +35,7 @@ 
      * @param $factory 

      * @return 

      */

-    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory){

+    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory) {

         $this->factory = $factory;

     }

 

@@ -45,12 +45,12 @@ 
      * @param $namespace 

      * @return 

      */

-    protected function getParameterHolderOrCreate($namespace){

-        if(!$this->hasParameterHolder($namespace)){

+    protected function getParameterHolderOrCreate($namespace) {

+        if (!$this->hasParameterHolder($namespace)) {

             $store = $this->factory->build();

-            if($store instanceof \PEIP\INF\Data\ParameterHolder){

+            if ($store instanceof \PEIP\INF\Data\ParameterHolder) {

                 $this->stores[$namespace] = $store;

-            }else{

+            }else {

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\ParameterHolder from factory.');

             }

         }

@@ -72,7 +72,7 @@ 
      * @param $value 

      * @return 

      */

-    public function setParameters($namespace, array $parameters){

+    public function setParameters($namespace, array $parameters) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

   

@@ -83,7 +83,7 @@ 
      * @param $parameters 

      * @return 

      */

-    public function addParameters($namespace, array $parameters){

+    public function addParameters($namespace, array $parameters) {

         $this->getParameterHolderOrCreate($namespace)->addParameters($parameters);

    }

   

@@ -100,7 +100,7 @@ 
      * @param $name 

      * @return 

      */

-    public function getParameters($namespace){

+    public function getParameters($namespace) {

         $this->getParameterHolderOrCreate($namespace)->getParameters();

    }

   

@@ -111,7 +111,7 @@ 
      * @param $name 

      * @return 

      */

-    public function getParameter($namespace, $name){

+    public function getParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->getParameter($name);

    }

   

@@ -123,7 +123,7 @@ 
      * @param $value 

      * @return 

      */

-    public function setParameter($namespace, $name, $value){

+    public function setParameter($namespace, $name, $value) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

   

@@ -134,7 +134,7 @@ 
      * @param $name 

      * @return 

      */

-    public function hasParameter($namespace, $name){

+    public function hasParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->hasParameter($name);

    }

 

@@ -145,7 +145,7 @@ 
      * @param $name 

      * @return 

      */

-    public function deleteParameter($namespace, $name){

+    public function deleteParameter($namespace, $name) {

         $this->getParameterHolderOrCreate($namespace)->setParameters($parameters);

    }

 

@@ -164,7 +164,7 @@ 
      * @param $holder 

      * @return 

      */

-    public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder){

+    public function setParameterHolder($namespace, \PEIP\INF\Data\ParameterHolder $holder) {

     $this->stores[$namespace] = $holder;

   } 

 

@@ -181,7 +181,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function getParameterHolder($namespace){

+    public function getParameterHolder($namespace) {

     return $this->stores[$namespace];

   }

 

@@ -198,7 +198,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function hasParameterHolder($namespace){

+    public function hasParameterHolder($namespace) {

     return array_key_exists($namespace, $this->stores);

   }

 

@@ -215,7 +215,7 @@ 
      * @param $namespace 

      * @return 

      */

-    public function deleteParameterHolder($namespace){

+    public function deleteParameterHolder($namespace) {

     unset($this->stores[$namespace]);

   } 

     

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
             $store = $this->factory->build();

             if($store instanceof \PEIP\INF\Data\Store){

                 $this->setPrivateValue($namespace, $store);

-            }else{

+            } else{

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');

             }

         }

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[$offset]);

     }   

 

@@ -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);

     }   

     

src/Data/ParameterCollection.php

Spacing +4 added lines, -4 removed lines

@@ -32,7 +32,7 @@ 
      * @param $offset 

      * @return 

      */

-    public function offsetExists($offset){

+    public function offsetExists($offset) {

         return $this->hasParameter($offset);

     }   

     

@@ -42,7 +42,7 @@ 
      * @param $offset 

      * @return 

      */

-    public function offsetGet($offset){

+    public function offsetGet($offset) {

         return $this->getParameter($offset);

     }

     

@@ -52,7 +52,7 @@ 
      * @param $name 

      * @return 

      */

-    public function offsetUnset($name){

+    public function offsetUnset($name) {

         $this->deleteParameter($name);

     }   

 

@@ -63,7 +63,7 @@ 
      * @param $name 

      * @return 

      */

-    public function offsetSet($offset, $name){

+    public function offsetSet($offset, $name) {

         $this->setParameter($offeset, $name);

     }

     

src/Data/ParameterHolder.php

Spacing +8 added lines, -8 removed lines

@@ -34,7 +34,7 @@ 
      * @param string $key name of parameter

      * @return boolean wether parameter is set

      */

-    public function hasParameter($key){

+    public function hasParameter($key) {

         return array_key_exists($key, $this->parameters);

     }   

         

@@ -45,7 +45,7 @@ 
      * @param string $key name of parameter 

      * @return 

      */

-    public function getParameter($key){

+    public function getParameter($key) {

         return array_key_exists($key, $this->parameters) ? $this->parameters[$key] : NULL;

     }

         

@@ -56,7 +56,7 @@ 
      * @param string $key name of parameter 

      * @return 

      */

-    public function deleteParameter($key){

+    public function deleteParameter($key) {

         unset($this->parameters[$key]);

     }   

    

@@ -68,7 +68,7 @@ 
      * @param string $value value to set for the parameter 

      * @return 

      */

-    public function setParameter($key, $value){

+    public function setParameter($key, $value) {

         $this->parameters[$key] = $value;

     }

     

@@ -79,7 +79,7 @@ 
      * @param array $parameters parameters as key/value pairs 

      * @return 

      */

-    public function setParameters(array $parameters){

+    public function setParameters(array $parameters) {

         $this->parameters = $parameters;        

     }

    

@@ -89,7 +89,7 @@ 
      * @access public

      * @return array $parameters parameters as key/value pairs

      */

-    public function getParameters(){

+    public function getParameters() {

         return $this->parameters;

     }

    

@@ -101,7 +101,7 @@ 
      * @param array $parameters parameters as key/value pairs 

      * @return 

      */

-    public function addParameters(array $parameters){

+    public function addParameters(array $parameters) {

         $this->parameters = array_merge($this->parameters, $parameters);

         array_unique($this->parameters);

     }   

@@ -114,7 +114,7 @@ 
      * @param array $parameters parameters as key/value pairs 

      * @return 

      */

-    public function addParametersIfNot(array $parameters){

+    public function addParametersIfNot(array $parameters) {

         $this->parameters = array_merge($parameters, $this->parameters);

         array_unique($this->parameters);

     }   

src/Data/StoreCollection.php

Spacing +17 added lines, -17 removed lines

@@ -24,7 +24,7 @@ 
 

 class StoreCollection 

     extends \PEIP\Data\InternalStoreAbstract 

-    implements \PEIP\INF\Data\StoreCollection{

+    implements \PEIP\INF\Data\StoreCollection {

 

     protected 

         $factory,

@@ -37,7 +37,7 @@ 
      * @param \PEIP\INF\Factory\DedicatedFactory $factory a factory instance to create new stores

      * @return 

      */

-    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory){

+    public function __construct(\PEIP\INF\Factory\DedicatedFactory $factory) {

         $this->factory = $factory;

     }

  

@@ -49,12 +49,12 @@ 
      * @param string $namespace the namespace to get the store for

      * @return \PEIP\INF\Data\Store a store for given namespace

      */

-    protected function getStoreOrCreate($namespace){

-        if(!$this->hasPrivateValue($namespace)){

+    protected function getStoreOrCreate($namespace) {

+        if (!$this->hasPrivateValue($namespace)) {

             $store = $this->factory->build();

-            if($store instanceof \PEIP\INF\Data\Store){

+            if ($store instanceof \PEIP\INF\Data\Store) {

                 $this->setPrivateValue($namespace, $store);

-            }else{

+            }else {

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');

             }

         }

@@ -69,7 +69,7 @@ 
      * @param array $values key/value pairs to store

      * @return 

      */

-    public function setValues($namespace, array $values){

+    public function setValues($namespace, array $values) {

         $this->getStoreOrCreate($namespace)->setValues($values);

     }

   

@@ -82,7 +82,7 @@ 
      * @param $values 

      * @return 

      */

-    public function addValues($namespace, array $values){

+    public function addValues($namespace, array $values) {

         $this->getStoreOrCreate($namespace)->addValues($values);

     }

     

@@ -93,7 +93,7 @@ 
      * @param string $namespace the namspace to return values for  

      * @return array stored key/value pairs

      */

-    public function getValues($namespace){

+    public function getValues($namespace) {

         $this->getStoreOrCreate($namespace)->getValues();

     }

   

@@ -105,7 +105,7 @@ 
      * @param string $key the key to return value for 

      * @return mixed value for the given key on the given namespace

      */

-    public function getValue($namespace, $key){

+    public function getValue($namespace, $key) {

         $this->getStoreOrCreate($namespace)->getValue($key);

     }

    

@@ -118,7 +118,7 @@ 
      * @param mixed $value the value to store 

      * @return 

      */

-    public function setValue($namespace, $key, $value){

+    public function setValue($namespace, $key, $value) {

         $this->getStoreOrCreate($namespace)->setValues($values);

     }

   

@@ -130,7 +130,7 @@ 
      * @param string $key the key to look for a value 

      * @return 

      */

-    public function hasValue($namespace, $key){

+    public function hasValue($namespace, $key) {

         $this->getStoreOrCreate($namespace)->hasValue($key);

     }

 

@@ -142,7 +142,7 @@ 
      * @param string $key the key to remove the value from

      * @return 

      */

-    public function deleteValue($namespace, $key){

+    public function deleteValue($namespace, $key) {

         $this->getStoreOrCreate($namespace)->setValues($values);

     }

 

@@ -154,7 +154,7 @@ 
      * @param \PEIP\INF\Data\Store $store the store instance to register for the namespace

      * @return 

      */

-    public function setStore($namespace, \PEIP\INF\Data\Store $store){

+    public function setStore($namespace, \PEIP\INF\Data\Store $store) {

         $this->setInternalValue($namespace, $store);    

     } 

 

@@ -165,7 +165,7 @@ 
      * @param string $namespace the namespace to return the store for 

      * @return \PEIP\INF\Data\Store store instance for given namespace (if set)

      */

-    public function getStore($namespace){

+    public function getStore($namespace) {

         $this->getInternalValue($namespace);

     }

  

@@ -176,7 +176,7 @@ 
      * @param string $namespace the namespace to check for a store instance 

      * @return boolean wether a store has been registered for the given namespace

      */

-    public function hasStore($namespace){

+    public function hasStore($namespace) {

         return $this->hasInternalValue($namespace);

     }

  

@@ -187,7 +187,7 @@ 
      * @param string $namespace the namespace to ungegister the store for 

      * @return 

      */

-    public function deleteStore($namespace){

+    public function deleteStore($namespace) {

         return $this->deleteInternalValue($namespace);

     }    

 

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
             $store = $this->factory->build();

             if($store instanceof \PEIP\INF\Data\Store){

                 $this->setPrivateValue($namespace, $store);

-            }else{

+            } else{

                 throw new \Exception('Could not build Instance of \PEIP\INF\Data\Store from factory.');

             }

         }

src/Listener/Wiretap.php

Spacing +3 added lines, -3 removed lines

@@ -33,10 +33,10 @@ 
      * @param $outputChannel 

      * @return 

      */

-    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL){

+    public function __construct(\PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel = NULL) {

         $this->setEventName('preSend');

         $this->setInputChannel($inputChannel);

-        if(is_object($outputChannel)){

+        if (is_object($outputChannel)) {

             $this->setOutputChannel($outputChannel);

         }           

     }           

@@ -47,7 +47,7 @@ 
      * @param $message 

      * @return 

      */

-    protected function doReply(\PEIP\INF\Message\Message $message){

+    protected function doReply(\PEIP\INF\Message\Message $message) {

         $this->replyMessage($message->getHeader('MESSAGE'));

     }