tidal / PEIP

src/Data/ArrayAccess.php

Spacing +4 added lines, -4 removed lines

@@ -32,7 +32,7 @@ 
      * @param mixed $offset the offset  
      * @return 
      */
-    public function offsetExists($offset){
+    public function offsetExists($offset) {
         return array_key_exists($name, $this->values);
     }   
        
@@ -43,7 +43,7 @@ 
      * @param mixed $offset the offset 
      * @return 
      */
-    public function offsetGet($offset){
+    public function offsetGet($offset) {
         return array_key_exists($name, $this->values) ? $this->values[$offset] : NULL;
     }
      
@@ -54,7 +54,7 @@ 
      * @param mixed $offset the offset 
      * @return 
      */
-    public function offsetUnset($offset){
+    public function offsetUnset($offset) {
         unset($this->values[$offset]);
     }   
   
@@ -66,7 +66,7 @@ 
      * @param mixed $value value for the offset 
      * @return 
      */
-    public function offsetSet($offset, $value){
+    public function offsetSet($offset, $value) {
         $this->values[$offset] = $value;
     }
 

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/ParameterHolderCollection.php

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]);
   } 
     

src/ABS/Context/ContextPlugin.php

Spacing +3 added lines, -3 removed lines

@@ -40,9 +40,9 @@ 
      * @param \PEIP\INF\Context\Context $context context instance to register the plugin with
      * @return 
      */
-    public function init(\PEIP\INF\Context\Context $context){
+    public function init(\PEIP\INF\Context\Context $context) {
         $this->context = $context;
-        foreach($this->builders as $node=>$method){
+        foreach ($this->builders as $node=>$method) {
             $context->registerNodeBuilder($node, array($this, $method));        
         }   
     }
@@ -59,7 +59,7 @@ 
      * @param string $defaultClass class to create instance for if none is set in config
      * @return object build and modified srvice instance
      */
-    public function buildAndModify($config, $arguments, $defaultClass = false){
+    public function buildAndModify($config, $arguments, $defaultClass = false) {
         return ServiceFactory::buildAndModify($config, $arguments, $defaultClass);
     }
 }

src/ABS/Channel/SubscribableChannel.php

Spacing +7 added lines, -7 removed lines

@@ -29,7 +29,7 @@ 
 
 abstract class SubscribableChannel 
     extends \PEIP\ABS\Channel\Channel
-    implements \PEIP\INF\Channel\SubscribableChannel{
+    implements \PEIP\INF\Channel\SubscribableChannel {
 
     protected $messageDispatcher;   
        
@@ -41,7 +41,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to subscribe
      * @return 
      */
-    public function subscribe($handler){ 
+    public function subscribe($handler) { 
         Test::ensureHandler($handler);
         $this->getMessageDispatcher()->connect($handler);
         $this->doFireEvent('subscribe', array('SUBSCRIBER'=>$handler));
@@ -55,7 +55,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler  $handler the listener to unsubscribe
      * @return 
      */
-    public function unsubscribe($handler){
+    public function unsubscribe($handler) {
         Test::ensureHandler($handler);
         $this->getMessageDispatcher()->disconnect($handler);
         $this->doFireEvent('unsubscribe', array('SUBSCRIBER'=>$handler));       
@@ -69,9 +69,9 @@ 
      * @param boolean $transferListeners wether to transfer listeners of old dispatcher (if set) to new one. default: true 
      * @return 
      */
-    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true){
-        if(isset($this->dispatcher) && $transferListeners){
-            foreach($this->dispatcher->getListeners() as $listener){
+    public function setMessageDispatcher(\PEIP\INF\Dispatcher\Dispatcher $dispatcher, $transferListeners = true) {
+        if (isset($this->dispatcher) && $transferListeners) {
+            foreach ($this->dispatcher->getListeners() as $listener) {
                 $dispatcher->connect($listener);
                 $this->dispatcher->disconnect($listener);       
             }   
@@ -85,7 +85,7 @@ 
      * @access public
      * @return 
      */
-    public function getMessageDispatcher(){
+    public function getMessageDispatcher() {
         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new Dispatcher;
     }   
     

src/ABS/Channel/PollableChannel.php

Spacing +12 added lines, -12 removed lines

@@ -34,7 +34,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doSend(\PEIP\INF\Message\Message $message){
+    protected function doSend(\PEIP\INF\Message\Message $message) {
         $this->messages[] = $message;        
     }
     
@@ -44,17 +44,17 @@ 
      * @param $timeout 
      * @return 
      */
-    public function receive($timeout = -1){
+    public function receive($timeout = -1) {
         $message = NULL;
-        if($timeout == 0){
+        if ($timeout == 0) {
             $message = $this->getMessage(); 
-        }elseif($timeout < 0){
-            while(!$message = $this->getMessage()){
+        }elseif ($timeout < 0) {
+            while (!$message = $this->getMessage()) {
                                 
             }
-        }else{
+        }else {
             $time = time() + $timeout;
-            while(($time > time()) && !$message = $this->getMessage()){
+            while (($time > time()) && !$message = $this->getMessage()) {
                 
             }       
         }
@@ -66,7 +66,7 @@ 
      * @access protected
      * @return 
      */
-    protected function getMessage(){
+    protected function getMessage() {
         return array_shift($this->messages);
     }
     
@@ -75,7 +75,7 @@ 
      * @access public
      * @return 
      */
-    public function clear(){
+    public function clear() {
         $this->messages = array();
     }
     
@@ -85,9 +85,9 @@ 
      * @param $selector 
      * @return 
      */
-    public function purge(\PEIP\INF\Selector\MessageSelector $selector){
-        foreach($this->messages as $key=>$message){
-            if(!$selector->acceptMessage($message)){
+    public function purge(\PEIP\INF\Selector\MessageSelector $selector) {
+        foreach ($this->messages as $key=>$message) {
+            if (!$selector->acceptMessage($message)) {
                 unset($this->messages[$key]);   
             }
         }

src/ABS/Channel/Channel.php

Spacing +3 added lines, -3 removed lines

@@ -34,7 +34,7 @@ 
      * @param $name
      * @return
      */
-    public function __construct($name){
+    public function __construct($name) {
         $this->name = $name;
     }
 
@@ -42,7 +42,7 @@ 
      * @access public
      * @return string the channel�s name
      */
-    public function getName(){
+    public function getName() {
         return $this->name;
     }
 
@@ -52,7 +52,7 @@ 
      * @param integer $timeout
      * @return
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         $this->doFireEvent('preSend', array('MESSAGE'=>$message));
         $sent = $this->doSend($message);
         $this->doFireEvent('postSend', array(

src/ABS/Pipe/EventPipe.php

Spacing +5 added lines, -5 removed lines

@@ -38,8 +38,8 @@ 
      * @param string $eventName name of the event to listen to 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 
      */
-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->connect($eventName, $this);
             $this->connections[spl_object_hash($connectable)] = $connectable;   
         }   
@@ -52,8 +52,8 @@ 
      * @param string $eventName name of the event to unlisten 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 
      */
-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->disconnect($eventName, $this);
             unset($this->connections[spl_object_hash($connectable)]);   
         }   
@@ -65,7 +65,7 @@ 
      * @access public
      * @return array array of \PEIP\INF\Event\Connectable instances
      */
-    public function doGetConnected(){
+    public function doGetConnected() {
         return array_values($this->connections);
     }
     

src/ABS/Base/Connectable.php

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 
  */
 
-abstract class Connectable  implements \PEIP\INF\Event\Connectable{
+abstract class Connectable  implements \PEIP\INF\Event\Connectable {
 
     const
         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',
@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->connect($name, $this, $listener);
         $this->doFireEvent(
@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function disconnect($name, $listener){
+    public function disconnect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->disconnect($name, $this, $listener);
         $this->doFireEvent(
@@ -82,7 +82,7 @@ 
      * @param $name
      * @return
      */
-    public function hasListeners($name){
+    public function hasListeners($name) {
         return $this->getEventDispatcher()->hasListeners($name, $this);
     }
 
@@ -92,7 +92,7 @@ 
      * @param $name
      * @return
      */
-    public function getListeners($name){
+    public function getListeners($name) {
         return $this->getEventDispatcher()->getListeners($name, $this);
     }
 
@@ -102,7 +102,7 @@ 
      * @param $callable
      * @return
      */
-    public function disconnectAll($name){
+    public function disconnectAll($name) {
         $this->getEventDispatcher()->disconnectAll($name, $this);
     }
 
@@ -112,11 +112,11 @@ 
      * @param $transferListners
      * @return
      */
-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){
-        if($transferListners){
-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){
-                if($this->getEventDispatcher()->hasListeners($name, $this)){
-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){
+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {
+        if ($transferListners) {
+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {
+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {
+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {
                         $dispatcher->connect($name, $this, $listener);
                     }
                 }
@@ -131,11 +131,11 @@ 
      * @access public
      * @return
      */
-    public function getEventDispatcher(){
+    public function getEventDispatcher() {
         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();
     }
 
-    protected static function getSharedEventDispatcher(){
+    protected static function getSharedEventDispatcher() {
         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;
         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;
     }
@@ -148,12 +148,12 @@ 
      * @param $eventClass
      * @return
      */
-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){
+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {
         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;
         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);
     }
 
-    protected static function getDefaultEventClass(){
+    protected static function getDefaultEventClass() {
         return self::DEFAULT_EVENT_CLASS;
     }
 }