tidal / PEIP

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;

     }   

     

Unused Use Statements +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
  * @implements \PEIP\INF\Base\Container, \PEIP\INF\Message\Message, \PEIP\INF\Base\Buildable

  */

 

-use PEIP\Util\Test;

+use PEIP\Util\Test;
 use PEIP\Base\GenericBuilder;

 

 class GenericMessage 

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

     }

 }

Unused Use Statements +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
  *

  * @author timo

  */

-use PEIP\Context\XMLContext;

+use PEIP\Context\XMLContext;
 use PEIP\Plugins\BasePlugin;

 

 class ServiceProvider extends \PEIP\Service\ServiceContainer  {

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

     }

     

src/ABS/Splitter/MessageSplitter.php

Spacing +6 added lines, -6 removed lines

@@ -35,9 +35,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);    

         }   

     }           

@@ -49,13 +49,13 @@ 
      * @param \PEIP\INF\Message\Message $message message to split 

      * @return 

      */

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

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

         $res = $this->split($message);      

-        if(is_array($res)){

-            foreach($res as $msg){ 

+        if (is_array($res)) {

+            foreach ($res as $msg) { 

                 $this->replyMessage($msg);

             }

-        }else{

+        }else {

             $this->replyMessage($res);

         }

     }

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/ABS/Router/Router.php

Spacing +8 added lines, -8 removed lines

@@ -34,7 +34,7 @@ 
         EVENT_PRE_RESOLVE = 'pre_resolve',

         EVENT_POST_RESOLVE = 'post_resolve',

         EVENT_ERR_RESOLVE = 'err_resolve',

-        HEADER_CHANNEL  = 'CHANNEL',

+        HEADER_CHANNEL = 'CHANNEL',

         HEADER_CHANNEL_NAME = 'CHANNEL_NAME',

         HEADER_CHANNEL_RESOLVER = 'HEADER_CHANNEL_RESOLVER';

 

@@ -48,7 +48,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input channel for the router 

      * @return 

      */

-    public function __construct(\PEIP\INF\Channel\Channel_Resolver $channelResolver, \PEIP\INF\Channel\Channel $inputChannel){

+    public function __construct(\PEIP\INF\Channel\Channel_Resolver $channelResolver, \PEIP\INF\Channel\Channel $inputChannel) {

         $this->channelResolver = $channelResolver;

         $this->setInputChannel($inputChannel);  

     }               

@@ -60,7 +60,7 @@ 
      * @param \PEIP\INF\Channel\Channel_Resolver $channelResolver the channel resolver for the router

      * @return 

      */

-    public function setChannelResolver(\PEIP\INF\Channel\Channel_Resolver $channelResolver){

+    public function setChannelResolver(\PEIP\INF\Channel\Channel_Resolver $channelResolver) {

         $this->doFireEvent(self::EVENT_CHANNEL_RESOLVER_SET, array(self::HEADER_CHANNEL_RESOLVER=>$channelResolver));

         $this->channelResolver = $channelResolver;

         $this->doFireEvent(self::EVENT_CHANNEL_RESOLVER_SET, array(self::HEADER_CHANNEL_RESOLVER=>$channelResolver));

@@ -73,9 +73,9 @@ 
      * @param \PEIP\INF\Message\Message $message the message to reply with

      * @return 

      */

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

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

         $channels = (array)$this->selectChannels($message);

-        foreach($channels as $channel){

+        foreach ($channels as $channel) {

             $this->setOutputChannel($this->resolveChannel($channel));

             $this->replyMessage($message); 

         }

@@ -90,12 +90,12 @@ 
      * @param mixed $channel channel-name or instance of \PEIP\INF\Channel\Channel 

      * @return 

      */

-    protected function resolveChannel($channel){

+    protected function resolveChannel($channel) {

         $this->doFireEvent(self::EVENT_PRE_RESOLVE, array(self::HEADER_CHANNEL=>$channel));

-        if(!($channel instanceof \PEIP\INF\Channel\Channel)){

+        if (!($channel instanceof \PEIP\INF\Channel\Channel)) {

             $channelName = $channel;

             $channel = $this->channelResolver->resolveChannelName($channelName);

-            if(!$channel){

+            if (!$channel) {

                 $this->doFireEvent(self::EVENT_ERR_RESOLVE, array(self::HEADER_CHANNEL_NAME=>$channelName));

                 throw new \RuntimeException('Could not resolve Channel : '.$channelName);

             }

src/Message/CommandMessage.php

Spacing +5 added lines, -5 removed lines

@@ -35,8 +35,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');

         }

         

@@ -49,10 +49,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

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

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

             return $object; 

-        }else{

+        } else{

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

         }

     }