tidal / PEIP

src/Service/ServiceProvider.php

Spacing +4 added lines, -4 removed lines

@@ -69,7 +69,7 @@ 
          * @param string $nodeName the name of the node
          * @param callable $callable a callable which creates instances for node-name
          */
-    public function registerNodeBuilder($nodeName, $callable){
+    public function registerNodeBuilder($nodeName, $callable) {
         $this->nodeBuilders[$nodeName] = $callable;
     }
     /**
@@ -82,16 +82,16 @@ 
      * @see XMLContext::includeContext
      * @access protected
      */
-    protected function initNodeBuilders(){
+    protected function initNodeBuilders() {
         $builders = array(
             'service' => 'initService'
         );
-        foreach($builders as $nodeName => $method){
+        foreach ($builders as $nodeName => $method) {
             $this->registerNodeBuilder($nodeName, array($this, $method));
         }
     }
 
-    public function addConfig($config){ 
+    public function addConfig($config) { 
         $this->doFireEvent(
             self::EVENT_BEFORE_ADD_CONFIG,
             array(

Braces +5 added lines, -5 removed lines

@@ -117,7 +117,7 @@ 
 
         if ($this->hasService($key)) {
             $service = $this->getService($key);
-        }else {
+        } else {
             $service = $this->createService($key);
         }
 
@@ -149,11 +149,11 @@ 
                 ));
 
                 return $node;                
-            }else {
+            } else {
                 $errorMessage = 'COULD NOT BUILD NODE FOR KEY: '.$key;
             }
 
-        }else {
+        } else {
             $errorMessage = 'NO CONFIG FOR KEY: '.$key;
         }
         $this->doFireEvent(self::EVENT_CREATE_SERVICE_ERROR, array(
@@ -197,10 +197,10 @@ 
                     self::HEADER_NODE => $nodeInstance
                 ));
                 return $nodeInstance;
-            }else {
+            } else {
                 $errorMessage = 'BUILDER RETURNED NO OBJECT FOR NODE-TYPE: '.$nodeName;
             }
-        }else {
+        } else {
             $errorMessage = 'NO BUILDER FOUND FOR NODE-TYPE: '.$nodeName;
         }
 

src/Service/HeaderServiceActivator.php

Spacing +4 added lines, -4 removed lines

@@ -38,12 +38,12 @@
          * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload
          * @return mixed result of calling the registered service callable with message content/payload
          */
-    protected function callService(\PEIP\INF\Message\Message $message){
+    protected function callService(\PEIP\INF\Message\Message $message) {
         $res = NULL; 
-        if(is_callable($this->serviceCallable)){
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func($this->serviceCallable, $message->getHeader($this->headerName));
-        }else{
-            if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }else {
+            if (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
                 $res = $this->serviceCallable->handle($message->getHeader($this->headerName));
             }
         }

src/Service/SplittingServiceActivator.php

Braces +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
     public function callService(\PEIP\INF\Message\Message $message) {
         if (is_callable($this->serviceCallable)) {
             $res = call_user_func_array($this->serviceCallable, $message->getContent());
-        }elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
+        } elseif (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
             $res = call_user_func_array(array($this->serviceCallable, 'handle'), $message->getContent());               
         }
         return $res;

src/Factory/ServiceFactory.php

Braces +3 added lines, -3 removed lines

@@ -51,7 +51,7 @@ 
                 $constructor = isset($config["constructor"]) ? (string)$config["constructor"] : "";

                 if ($constructor != '' && Test::assertMethod($cls, $constructor)) {

                     $service = call_user_func_array(array($cls, $constructor), $arguments);

-                }else {

+                } else {

                     $service = self::build($cls, $arguments);

                 }

             } catch (\Exception $e) {

@@ -97,7 +97,7 @@ 
                 if ($entry->getName() == 'value') {

                     if ($entry['key']) {

                         $arg[(string)$entry['key']] = (string)$entry;

-                    }else {

+                    } else {

                         $arg[] = (string)$entry;

                     }

                 } elseif ($entry->getName() == 'service') {

@@ -129,7 +129,7 @@ 
     public static function buildAndModify(array $config, $arguments, $defaultClass = "") {

         if ((isset($config["class"]) && "" != (string)$config["class"]) || $defaultClass !== "") {

              $service = ServiceFactory::doBuild($config, $arguments, $defaultClass);

-        }else {

+        } else {

             throw new \RuntimeException('Could not create Service. no class or reference given.');

         }

         if (isset($config["ref_property"])) {

src/Pipe/Pipe.php

Braces +1 added lines, -1 removed lines

@@ -108,7 +108,7 @@
         //if(\PEIP\Util\Test::assertMessage($message)){
             if ($this->getOutputChannel()) { 
                 $this->getOutputChannel()->send($message);
-            }else { 
+            } else { 
                 $this->doSend($message);
             }
         //}

src/ABS/Dispatcher/Dispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -58,9 +58,9 @@
      * @param mixed $subject subject to notify the listeners of 
      * @return \PEIP\INF\Handler\Handler listener that returned a boolean true value
      */     
-    protected static function doNotifyUntil(array $listeners, $subject){
-        foreach ($listeners as $listener){
-            if (self::doNotifyOne($listener, $subject)){
+    protected static function doNotifyUntil(array $listeners, $subject) {
+        foreach ($listeners as $listener) {
+            if (self::doNotifyOne($listener, $subject)) {
             return $listener;
             }
         }

Braces +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
     protected function doSend(\PEIP\INF\Message\Message $message) {
         if ($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()) {
             $this->queue->insert($message, $message->getHeader($this->priorityHeader));
-        }else {
+        } else {
             throw new \Exception('Not implemented yet.');
         }            
     }       

src/ABS/Dispatcher/MapDispatcher.php

Spacing +6 added lines, -6 removed lines

@@ -44,9 +44,9 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return 
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         Test::ensureHandler($listener);
-        if (!$this->hasListeners($name)){
+        if (!$this->hasListeners($name)) {
             $this->listeners[$name] = array();
         }
         $this->listeners[$name][] = $listener;
@@ -61,13 +61,13 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener listener to connect
      * @return 
      */
-    public function disconnect($name, $listener){
-        if (!$this->hasListeners($name)){
+    public function disconnect($name, $listener) {
+        if (!$this->hasListeners($name)) {
             return false;
         }
         $res = false;
-        foreach ($this->listeners[$name] as $i => $callable){
-            if ($listener === $callable){
+        foreach ($this->listeners[$name] as $i => $callable) {
+            if ($listener === $callable) {
             unset($this->listeners[$name][$i]);
             $res = true;
             }

src/ABS/Context/ContextPlugin.php

Spacing +1 added lines, -1 removed lines

@@ -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/Handler/MessageHandler.php

Spacing +7 added lines, -7 removed lines

@@ -42,7 +42,7 @@ 
      * @param object $message the message to handle
      * @return 
      */
-    public function handle($message){
+    public function handle($message) {
             $this->doHandle($this->getMessageFromObject($message));      
     }
    
@@ -73,24 +73,24 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel to connect the handler to
      * @return 
      */
-    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel){
+    protected function doSetInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {
         $this->inputChannel = $inputChannel;    
-        if($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel){
+        if ($this->inputChannel instanceof \PEIP\INF\Channel\SubscribableChannel) {
                 $this->inputChannel->subscribe($this);
-        } else{          
+        }else {          
             $this->unwrapEvents = true;
             $this->inputChannel->connect('postSend', $this);
         }  
     }
   
-    protected function getMessageFromObject($object){ 
+    protected function getMessageFromObject($object) { 
         $content = $object->getContent();
-        if($this->unwrapEvents
+        if ($this->unwrapEvents
             && $object instanceof \PEIP\INF\Event\Event
             && $object->getName() == 'postSend'
             && $object->hasHeader(Pipe::HEADER_MESSAGE)
             && $content instanceof \PEIP\INF\Channel\PollableChannel
-            ){
+            ) {
             $object = $content->receive();
         }
         if (!($object instanceof \PEIP\INF\Message\Message)) {