tidal / PEIP

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

         }

     }

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/Plugins/BasePlugin.php

Spacing +22 added lines, -22 removed lines

@@ -46,7 +46,7 @@ 
      * @param object $config configuration object for the pollable channel.

      * @return \PEIP\INF\Channel\Channel the created pollable channel instance

      */

-    public function createChannel($config){

+    public function createChannel($config) {

         return $this->doCreateChannel($config, 'PollableChannel');

     }

 

@@ -58,7 +58,7 @@ 
      * @param object $config configuration object for the subscribable channel.

      * @return \PEIP\INF\Channel\Channel the created subscribable channel instance

      */

-    public function createSubscribableChannel($config){

+    public function createSubscribableChannel($config) {

         return $this->doCreateChannel($config, 'PublishSubscribeChannel');

     }

 

@@ -71,9 +71,9 @@ 
      * @param $additionalArguments additional arguments for the channel constructor (without first arg = id)

      * @return \PEIP\INF\Channel\Channel the created channel instance

      */

-    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()){

+    public function doCreateChannel($config, $defaultChannelClass, array $additionalArguments = array()) {

         $id = (string)$config['id'];

-        if($id != ''){

+        if ($id != '') {

             array_unshift($additionalArguments, $id);

             $channel = $this->buildAndModify($config, $additionalArguments, $defaultChannelClass);

             //$this->channelRegistry->register($channel);

@@ -91,7 +91,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.

      * @return object the gateway instance

      */

-    public function createGateway($config, $defaultClass = false){

+    public function createGateway($config, $defaultClass = false) {

         $args = array(

             $this->getRequestChannel($config),

             $this->getReplyChannel($config)

@@ -115,7 +115,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.

      * @return object the router instance

      */

-    public function createRouter($config, $defaultClass = false){

+    public function createRouter($config, $defaultClass = false) {

         $resolver = $config['channel_resolver'] ? (string)$config['channel_resolver'] : $this->channelRegistry;

         return $this->buildAndModify($config, array(

             $resolver,

@@ -132,7 +132,7 @@ 
      * @param object $config configuration object for the splitter.

      * @return object the splitter instance

      */

-    public function createSplitter($config){

+    public function createSplitter($config) {

         return $this->createReplyMessageHandler($config);

     }

 

@@ -145,7 +145,7 @@ 
      * @param object $config configuration object for the transformer.

      * @return object the transformer instance

      */

-    public function createTransformer($config){

+    public function createTransformer($config) {

         return $this->createReplyMessageHandler($config);

     }

 

@@ -158,7 +158,7 @@ 
      * @param object $config configuration object for the aggregator.

      * @return object the aggregator instance

      */

-    public function createAggregator($config){

+    public function createAggregator($config) {

         return $this->createReplyMessageHandler($config);

     }

 

@@ -171,7 +171,7 @@ 
      * @param object $config configuration object for the wiretap.

      * @return object the wiretap instance

      */

-    public function createWiretap($config){

+    public function createWiretap($config) {

         return $this->createReplyMessageHandler($config, 'Wiretap');

     }

 

@@ -184,7 +184,7 @@ 
      * @param string $defaultClass the class to use if none is set in config.

      * @return object the reply-message-handler instance

      */

-    public function createReplyMessageHandler($config, $defaultClass = false){

+    public function createReplyMessageHandler($config, $defaultClass = false) {

         return $this->buildAndModify($config, $this->getReplyHandlerArguments($config), $defaultClass);

     }

 

@@ -197,12 +197,12 @@ 
      * @param string $defaultClass the class to use if none is set in config.

      * @return object the service-activator instance

      */

-    public function createServiceActivator($config, $defaultClass = false){

+    public function createServiceActivator($config, $defaultClass = false) {

         $method = (string)$config['method'];

         $service = $this->context->getServiceProvider()->provideService((string)$config['ref']);

-        if($method && $service){

+        if ($method && $service) {

             $args = $this->getReplyHandlerArguments($config);

-            array_unshift($args,array(

+            array_unshift($args, array(

                 $service,

                 $method

             ));

@@ -219,12 +219,12 @@ 
      * @param object $config configuration object to create arguments from.

      * @return mixed build arguments

      */

-    protected function getReplyHandlerArguments($config){

+    protected function getReplyHandlerArguments($config) {

         $args = array(

             $this->doGetChannel('input', $config),

             $this->doGetChannel('output', $config)

         );

-        if($args[0] == NULL){

+        if ($args[0] == NULL) {

             throw new \RuntimeException('Could not receive input channel.');

         }

         return $args;

@@ -239,7 +239,7 @@ 
      * @param object $config configuration object to return request-channel from.

      * @return \PEIP\INF\Channel\Channel request-channel

      */

-    protected function getRequestChannel($config){

+    protected function getRequestChannel($config) {

         return $this->doGetChannel('request', $config);

     }

 

@@ -252,7 +252,7 @@ 
      * @param object $config configuration object to return reply-channel from.

      * @return \PEIP\INF\Channel\Channel reply-channel

      */

-    protected function getReplyChannel($config){

+    protected function getReplyChannel($config) {

         return $this->doGetChannel('reply', $config);

     }

 

@@ -265,15 +265,15 @@ 
      * @param object $config configuration object to return channel from.

      * @return \PEIP\INF\Channel\Channel reply-channel

      */

-    public function doGetChannel($type, $config){

+    public function doGetChannel($type, $config) {

         $channelName = $config[$type."_channel"]

             ? $config[$type."_channel"]

             : $config["default_".$type."_channel"];

         return $this->context->getServiceProvider()->provideService(trim((string)$channelName));

-        $channel =  $this->services[trim((string)$channelName)];

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

+        $channel = $this->services[trim((string)$channelName)];

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

             return $channel;

-        }else{

+        }else {

             return NULL;

         }

     }

src/Autoload/AutoloadPaths.php

Spacing +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
 

     // please, dont�t edit these lines manually

     // use Autoload::make() instead

-    public static $paths = array (

+    public static $paths = array(

   'PEIP\ABS\Aggregator\MessageBarrierHandler' => '/ABS/aggregator/PEIP\ABS\Aggregator\MessageBarrierHandler.php',

   'PEIP\ABS\Router\Router' => '/ABS/router/PEIP\ABS\Router\Router.php',

   'PEIP\ABS\Dispatcher\MapDispatcher' => '/ABS/dispatcher/PEIP\ABS\Dispatcher\MapDispatcher.php',

src/Autoload/Autoload.php

Spacing +13 added lines, -13 removed lines

@@ -33,7 +33,7 @@ 
      * 

      * @access protected

      */ 

-    protected function __construct(){

+    protected function __construct() {

         $this->init();

         require_once(dirname(__FILE__).'/AutoloadPaths.php');

         $this->setClassPaths(AutoloadPaths::$paths);

@@ -46,8 +46,8 @@ 
      * @static

      * @return Autoload

      */     

-    static public function getInstance(){ 

-        if (!isset(self::$instance)){

+    static public function getInstance() { 

+        if (!isset(self::$instance)) {

             self::$instance = new Autoload();

         }

         return self::$instance;

@@ -58,7 +58,7 @@ 
      * @access protected

      * @return Autoload

      */

-    protected static function doGetInstance(){

+    protected static function doGetInstance() {

         return self::$instance = new Autoload();   

     }       

  

@@ -69,8 +69,8 @@ 
      * @param string directoy to scan

      * @return void

      */ 

-    public function scanDirectory($dir){

-        if(is_dir($dir)){ 

+    public function scanDirectory($dir) {

+        if (is_dir($dir)) { 

             $this->addClassPaths($this->findPaths(NULL, new RecursiveDirectoryIterator($dir)));

         }

     } 

@@ -82,7 +82,7 @@ 
      * @static

      * @return void

      */ 

-    public static function make(){

+    public static function make() {

         $baseDir = self::getBaseDirectory();

         $iterator = new RecursiveDirectoryIterator($baseDir);

         $paths = self::findPaths($baseDir, $iterator);

@@ -102,12 +102,12 @@ 
      * @param array $paths the array to store the class/path associations in.

      * @return Autoload

      */ 

-    protected static function findPaths($baseDir, RecursiveDirectoryIterator $iterator, array $paths = array()){

+    protected static function findPaths($baseDir, RecursiveDirectoryIterator $iterator, array $paths = array()) {

         $iterator->rewind();

-        while($iterator->valid()){

-            if($iterator->isDir() && !$iterator->isDot()){

+        while ($iterator->valid()) {

+            if ($iterator->isDir() && !$iterator->isDot()) {

                 $paths = self::findPaths($baseDir, $iterator->getChildren(), $paths);

-            }elseif($iterator->isFile() && strrchr($iterator->getFilename(), '.') == '.php'){

+            }elseif ($iterator->isFile() && strrchr($iterator->getFilename(), '.') == '.php') {

                 $class = $iterator->getBasename('.php');

                 $paths[$class] = str_replace($baseDir, '', $iterator->getPathName());                       

             }

@@ -124,8 +124,8 @@ 
      * @param string $class the class to load

      * @return path to the class-file 

      */     

-    public function autoload($class){ 

-        if(!$this->getClassPath($class)){

+    public function autoload($class) { 

+        if (!$this->getClassPath($class)) {

             $this->scanDirectory(realpath(dirname(__FILE__).'/../extensions')); 

         }

         parent::autoload($class);

src/Autoload/SimpleAutoload.php

Spacing +17 added lines, -17 removed lines

@@ -33,7 +33,7 @@ 
      * 

      * @access protected

      */             

-    protected function __construct(){

+    protected function __construct() {

         $this->init();

     }   

 

@@ -43,10 +43,10 @@ 
      * 

      * @access protected

      */     

-    protected function init(){

+    protected function init() {

         $this->baseDir = self::getBaseDirectory();

         ini_set('unserialize_callback_func', 'spl_autoload_call');

-        if (false === spl_autoload_register(array($this, 'autoload'))){

+        if (false === spl_autoload_register(array($this, 'autoload'))) {

             throw new \RuntimeException(sprintf('Unable to register %s::autoload as an autoloading method.', get_class($this)));

         }   

     }

@@ -58,7 +58,7 @@ 
      * @access protected

      * @return string the base directory

      */     

-    protected static function getBaseDirectory(){

+    protected static function getBaseDirectory() {

         return str_replace(DIRECTORY_SEPARATOR, '/', realpath(dirname(__FILE__).DIRECTORY_SEPARATOR.'..'));     

     }

         

@@ -69,8 +69,8 @@ 
      * @static

      * @return SimpleAutoload

      */     

-    static public function getInstance(){

-        if (!isset(self::$instance)){

+    static public function getInstance() {

+        if (!isset(self::$instance)) {

             self::$instance = new SimpleAutoload();

         }

         return self::$instance;

@@ -83,8 +83,8 @@ 
      * @access protected

      * @return SimpleAutoload

      */ 

-    protected static function doGetInstance(){

-        return self::$instance = new SimpleAutoload();;   

+    protected static function doGetInstance() {

+        return self::$instance = new SimpleAutoload(); ;   

     }

         

     /**

@@ -95,7 +95,7 @@ 
      * @param string $path the path to the class-file  

      * @return void

      */     

-    public function setClassPath($class, $path){

+    public function setClassPath($class, $path) {

         $this->classPaths[$class] = $path;

     }

 

@@ -106,7 +106,7 @@ 
      * @param array $classPaths class-paths as key(class)/value(path) pairs array

      * @return void

      */     

-    public function setClassPaths(array $classPaths){

+    public function setClassPaths(array $classPaths) {

         $this->classPaths = $classPaths;    

     }   

 

@@ -117,7 +117,7 @@ 
      * @param array $classPaths class-paths as key(class)/value(path) pairs array

      * @return void

      */     

-    public function addClassPaths(array $classPaths){

+    public function addClassPaths(array $classPaths) {

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

     }   

     

@@ -129,12 +129,12 @@ 
      * @param string $class the class name

      * @return path to the class-file 

      */     

-    public function getClassPath($class){

-        if (!isset($this->classPaths[$class])){

+    public function getClassPath($class) {

+        if (!isset($this->classPaths[$class])) {

             return null;

         }

         $file = $this->classPaths[$class];

-        if(!is_file($file)){

+        if (!is_file($file)) {

             $file = $this->baseDir.DIRECTORY_SEPARATOR.$file;

         }       

         return $file;

@@ -147,13 +147,13 @@ 
      * @param string $class the class to load

      * @return path to the class-file 

      */     

-    public function autoload($class){

+    public function autoload($class) {

         $path = str_replace('PEIP\\', '', $class);

 	$path = $this->baseDir.'/'.str_replace('\\', '/', $path).'.php'; 

 	//$path = $this->getClassPath($class);

-        if (is_file($path)){

+        if (is_file($path)) {

             require $path;

-                if(class_exists($class) || interface_exists($class)){

+                if (class_exists($class) || interface_exists($class)) {

                     return true;

                 }

             }

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

         }

     }

src/Message/MessageBuilder.php

Spacing +13 added lines, -13 removed lines

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

      * @param string $messageClass the message-class to build instances for 

      */

-    public function __construct($messageClass = '\PEIP\Message\GenericMessage'){

+    public function __construct($messageClass = '\PEIP\Message\GenericMessage') {

         $this->messageClass = $messageClass;

         $this->factory = DedicatedFactory::getfromCallable(array($messageClass, 'build'));    

     }

@@ -51,7 +51,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this

      */

-    public function copyHeaders(array $headers){

+    public function copyHeaders(array $headers) {

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

         return $this;       

     }

@@ -63,7 +63,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this

      */

-    public function copyHeadersIfAbsent(array $headers){

+    public function copyHeadersIfAbsent(array $headers) {

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

         return $this;   

     }

@@ -75,7 +75,7 @@ 
      * @param string $headerName the name of the header

      * @return MessageBuilder $this

      */

-    public function removeHeader($headerName){

+    public function removeHeader($headerName) {

         unset($this->headers[$headerName]);

         return $this;

     }

@@ -88,7 +88,7 @@ 
      * @param mixed $headerValue the value for the header

      * @return MessageBuilder $this 

      */

-    public function setHeader($headerName, $headerValue){

+    public function setHeader($headerName, $headerValue) {

         $this->headers[$headerName] = $headerValue;

         return $this;   

     }

@@ -100,7 +100,7 @@ 
      * @param array $headers the headers to set

      * @return MessageBuilder $this 

      */

-    public function setHeaders(array $headers){

+    public function setHeaders(array $headers) {

         $this->headers = $headers;

         return $this;   

     }

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

      * @return array the headers for the message to build 

      */

-    public function getHeaders(){

+    public function getHeaders() {

         return $this->headers;

     }  

         

@@ -122,7 +122,7 @@ 
      * @param $arguments 

      * @return 

      */

-    public function build(array $headers = array()){

+    public function build(array $headers = array()) {

         $this->copyHeaders($headers);

         return GenericBuilder::getInstance($this->messageClass)

             ->build(array($this->payload, new \ArrayObject($this->headers)));        

@@ -135,7 +135,7 @@ 
      * @param mixed $payload payload for the message to build 

      * @return MessageBuilder $this 

      */

-    public function setContent($payload){

+    public function setContent($payload) {

         $this->payload = $payload;

         return $this;

     }

@@ -148,7 +148,7 @@ 
      * @param string $messageClass the message class to build from the builder 

      * @return MessageBuilder new instance of MessageBuilder 

      */    

-    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage'){

+    public static function getInstance($messageClass = '\PEIP\Message\GenericMessage') {

         return new  MessageBuilder($messageClass);

     }

   

@@ -160,7 +160,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to get class to build from the builder 

      * @return MessageBuilder new instance of MessageBuilder 

      */      

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

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

         return new MessageBuilder(get_class($message));

     }

    

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

      * @param string $messageClass the message-class to build new instances for

      */

-    public function setMessageClass($messageClass){

+    public function setMessageClass($messageClass) {

         $this->messageClass = $messageClass;

     }

  

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

      * @return string the message-class to build new instances for

      */

-    public function getMessageClass(){

+    public function getMessageClass() {

         return $this->messageClass;

     }         

 }
\ No newline at end of file

src/Message/CallableMessageHandler.php

Spacing +11 added lines, -11 removed lines

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

      * @return 

      */

-    public function __construct($callable){

+    public function __construct($callable) {

         $this->callable = $callable;    

         $this->examineCallabe();

     }

@@ -45,22 +45,22 @@ 
      * @access protected

      * @return 

      */

-    protected function examineCallabe(){

-        if(is_callable($this->callable)){        

-            if(is_array($this->callable)){

-                list($class, $method) =  $this->callable;

+    protected function examineCallabe() {

+        if (is_callable($this->callable)) {        

+            if (is_array($this->callable)) {

+                list($class, $method) = $this->callable;

                 $static = !is_object($class);

                 $class = is_object($class) ? get_class($class) : (string)$class;

                 $reflectionClass = new \ReflectionClass($class);

                 $reflectionFunc = $reflectionClass->getMethod($method);

-                if($static && !$reflectionFunc->isStatic()){

+                if ($static && !$reflectionFunc->isStatic()) {

                     throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not an Callable: Method "'.$method.'" of class '.$class.' is not static.');                  

                 }

-            }else{

+            }else {

                 $reflectionFunc = new \ReflectionFunction($this->callable);  

             }

             $this->requiredParameters = $reflectionFunc->getNumberOfRequiredParameters();

-        }else{

+        }else {

             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::__construct is not a Callable');

         }   

     }   

@@ -73,14 +73,14 @@ 
      * @param $sent 

      * @return 

      */

-    public function handle($message, $channel = false, $sent = false){

-        if(!is_object($message)){

+    public function handle($message, $channel = false, $sent = false) {

+        if (!is_object($message)) {

             throw new \InvalidArgumentException('Argument 1 passed to CallableMessageHandler::handle is not a Object');       

         }   

         try {

             return call_user_func_array($this->callable, array($message, $channel, $sent));

         }

-        catch(\Exception $e){

+        catch (\Exception $e) {

             throw new \RuntimeException('Unable to call Callable: '.$e->getMessage());

         }   

     }