tidal / PEIP

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

Spacing +4 added lines, -4 removed lines

@@ -37,9 +37,9 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the outputs-channel 

      * @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->setInputChannel($inputChannel);

-        if(is_object($outputChannel)){

+        if (is_object($outputChannel)) {

             $this->setOutputChannel($outputChannel);    

         }   

     }           

@@ -51,7 +51,7 @@ 
      * @param \PEIP\INF\Message\Message $message message to transform content 

      * @return 

      */

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

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

         $this->replyMessage($this->transform($message));

     }

   

@@ -62,7 +62,7 @@ 
      * @param \PEIP\INF\Message\Message $message 

      * @return mixed result of transforming the message 

      */

-    public function transform(\PEIP\INF\Message\Message $message){

+    public function transform(\PEIP\INF\Message\Message $message) {

         return $this->doTransform($message);

     }

 

src/ABS/Transformer/ContentTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param \PEIP\INF\Message\Message $message 

      * @return mixed result of transforming the message payload/content 

      */

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

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

         return $this->transformContent($message->getContent());    

     }

 

src/ABS/Channel/PollableChannel.php

Indentation +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
  */

 

 

- class PollableChannel     

+    class PollableChannel     

     extends \PEIP\ABS\Channel\Channel

     implements \PEIP\INF\Channel\PollableChannel {

 

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

             }

         }

Braces +2 added lines, -2 removed lines

@@ -48,11 +48,11 @@
         $message = NULL;

         if($timeout == 0){

             $message = $this->getMessage(); 

-        }elseif($timeout < 0){

+        } elseif($timeout < 0){

             while(!$message = $this->getMessage()){

                                 

             }

-        }else{

+        } else{

             $time = time() + $timeout;

             while(($time > time()) && !$message = $this->getMessage()){

                 

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

Spacing +2 added lines, -2 removed lines

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

      * @return 

      */

-    public function __invoke(){

+    public function __invoke() {

         return $this->execute();

     }

    

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

      * @return 

      */

-    public function execute(){

+    public function execute() {

         return call_user_func_array($this->callable, $this->getParameters());

     }   

         

src/ABS/Context/ContextPlugin.php

Indentation +12 added lines, -12 removed lines

@@ -47,18 +47,18 @@
         }   

     }

 

-     /**

-     * Builds and modifies an arbitrary service/object instance from a config-obect.

-     *

-     * @see XMLContext::doBuild

-     * @see XMLContext::modifyService

-     * @implements \PEIP\INF\Context\Context

-     * @access public

-     * @param object $config configuration object to build a service instance from.

-     * @param array $arguments arguments for the service constructor

-     * @param string $defaultClass class to create instance for if none is set in config

-     * @return object build and modified srvice instance

-     */

+        /**

+         * Builds and modifies an arbitrary service/object instance from a config-obect.

+         *

+         * @see XMLContext::doBuild

+         * @see XMLContext::modifyService

+         * @implements \PEIP\INF\Context\Context

+         * @access public

+         * @param object $config configuration object to build a service instance from.

+         * @param array $arguments arguments for the service constructor

+         * @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){

         return ServiceFactory::buildAndModify($config, $arguments, $defaultClass);

     }

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

Spacing +4 added lines, -4 removed lines

@@ -37,7 +37,7 @@ 
      * @param $connection 

      * @return 

      */

-    public function setConnection($connection){

+    public function setConnection($connection) {

         $this->connection = $connection;

     }

     

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

      * @return 

      */

-    public function execute(){

+    public function execute() {

         return $this->send();   

     }

 

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

      * @return 

      */

-    public function send(){

+    public function send() {

         return $this->connection->sendRequest($this);

     }

     

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

      * @return 

      */

-    public function getRequestData(){

+    public function getRequestData() {

         return $this->doGetRequestData();   

     }

     

src/ABS/Request/Connection.php

Spacing +1 added lines, -1 removed lines

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

      * @return 

      */

-    public function sendRequest(\PEIP\ABS\Request\Request $request){

+    public function sendRequest(\PEIP\ABS\Request\Request $request) {

         return $this->doSendRequest($request);

     }