tidal / PEIP

src/Pipe/Pipe.php

Spacing +18 added lines, -18 removed lines

@@ -63,7 +63,7 @@ 
      * @param $name 

      * @return 

      */

-    public function setName($name){

+    public function setName($name) {

         $this->name = $name;

     }

     

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

      * @return 

      */

-    public function getName(){

+    public function getName() {

         return $this->name;

     }

 

@@ -83,7 +83,7 @@ 
      * @param $timeout 

      * @return 

      */

-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){

+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {

         return $this->handle($message);

     }

 

@@ -93,7 +93,7 @@ 
      * @param $message 

      * @return 

      */

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

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

         $this->doFireEvent(self::EVENT_PRE_PUBLISH, array(self::HEADER_MESSAGE=>$message));

         $this->getMessageDispatcher()->notify($message);

         $this->doFireEvent(self::EVENT_POST_PUBLISH, array(self::HEADER_MESSAGE=>$message));

@@ -106,11 +106,11 @@ 
      * @param $content 

      * @return 

      */

-    protected function replyMessage($message){

-        if(\PEIP\Util\Test::assertMessage($message)){

-            if($this->getOutputChannel()){

+    protected function replyMessage($message) {

+        if (\PEIP\Util\Test::assertMessage($message)) {

+            if ($this->getOutputChannel()) {

                 $this->getOutputChannel()->send($message);

-            }else{

+            }else {

                 $this->doSend($message);

             }

         }

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

      * @return 

      */

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

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

         $this->replyMessage($message);

     }

 

@@ -132,7 +132,7 @@ 
      * @param $handler 

      * @return 

      */

-    public function subscribe($handler){

+    public function subscribe($handler) {

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->connect($handler);

         $this->doFireEvent(self::EVENT_SUBSCRIBE, array(self::HEADER_SUBSCRIBER=>$handler));

@@ -144,7 +144,7 @@ 
      * @param $handler e

      * @return 

      */

-    public function unsubscribe($handler){

+    public function unsubscribe($handler) {

         Test::ensureHandler($handler);

         $this->getMessageDispatcher()->disconnect($handler);

         $this->doFireEvent(

@@ -162,9 +162,9 @@ 
      * @param $transferListeners 

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

             }   

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

      * @return 

      */

-    public function getMessageDispatcher(){

+    public function getMessageDispatcher() {

         $defaultDispatcher = self::DEFAULT_CLASS_MESSAGE_DISPATCHER;

         return isset($this->dispatcher) ? $this->dispatcher : $this->dispatcher = new $defaultDispatcher;

     }   

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

      * @return 

      */

-    protected function registerCommand($commandName, $callable){

+    protected function registerCommand($commandName, $callable) {

         $this->commands[$commandName] = $callable;  

     }

     

@@ -200,10 +200,10 @@ 
      * @param $cmdMessage 

      * @return 

      */

-    public function command(\PEIP\INF\Message\Message $cmdMessage){

+    public function command(\PEIP\INF\Message\Message $cmdMessage) {

         $this->doFireEvent(self::EVENT_PRE_COMMAND, array(self::HEADER_MESSAGE=>$cmdMessage));

         $commandName = trim((string)$cmdMessage->getHeader('COMMAND'));

-        if($commandName != '' && array_key_exists($commandName, $this->commands)){

+        if ($commandName != '' && array_key_exists($commandName, $this->commands)) {

             call_user_func($this->commands[$commandName], $cmdMessage->getContent());   

         }

         $this->doFireEvent(self::EVENT_POST_COMMAND, array(self::HEADER_MESSAGE=>$cmdMessage));

src/Pipe/EventPipe.php

Spacing +13 added lines, -13 removed lines

@@ -29,7 +29,7 @@ 
     protected 

         $eventName; 

        

-    public function connectChannel(\PEIP\INF\Channel\Channel $inputChannel){

+    public function connectChannel(\PEIP\INF\Channel\Channel $inputChannel) {

         $this->inputChannel = $inputChannel;

         

     }

@@ -44,7 +44,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the input-channel to listen for events. 

      * @return 

      */

-    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){        

+    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {        

         $this->connectChannel($inputChannel);            

     }     

   

@@ -60,9 +60,9 @@ 
      * @access protected

      * @param \PEIP\INF\Message\Message $message the message to reply with

      */

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

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

         $headerMessage = $message->getHeader('MESSAGE');

-        if($headerMessage instanceof \PEIP\INF\Message\Message){

+        if ($headerMessage instanceof \PEIP\INF\Message\Message) {

             return $this->replyMessage($headerMessage);

         }

     }

@@ -75,7 +75,7 @@ 
      * @param \PEIP\INF\Event\Connectable $connectable the connectable to listen to

      * @return 

      */

-    public function listen(\PEIP\INF\Event\Connectable $connectable){

+    public function listen(\PEIP\INF\Event\Connectable $connectable) {

         return $this->doListen($this->eventName, $connectable);     

     }

        

@@ -87,7 +87,7 @@ 
      * @param \PEIP\INF\Event\Connectable $connectable the connectable to unlisten  

      * @return 

      */

-    public function unlisten(\PEIP\INF\Event\Connectable $connectable){

+    public function unlisten(\PEIP\INF\Event\Connectable $connectable) {

         return $this->doUnlisten($this->eventName, $connectable);       

     }

      

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

      * @return array array of \PEIP\INF\Event\Connectable instances

      */

-    public function getConnected(){

+    public function getConnected() {

         return $this->doGetConnected();

     }

        

@@ -108,7 +108,7 @@ 
      * @param \PEIP\INF\Channel\Channel $channel \PEIP\INF\Channel\Channel instance to disconnect from

      * @return 

      */

-    public function disconnectChannel(\PEIP\INF\Channel\Channel $channel){

+    public function disconnectChannel(\PEIP\INF\Channel\Channel $channel) {

         $this->disconnectInputChannel();        

         $this->inputChannel = $channel;         

         $this->connectInputChannel();       

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

      * @return 

      */

-    protected function connectInputChannel(){

-        if($this->inputChannel && $this->eventName){

+    protected function connectInputChannel() {

+        if ($this->inputChannel && $this->eventName) {

             $this->inputChannel->connect($this->eventName, $this);

         }   

     }

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

      * @return 

      */

-    protected function disconnectInputChannel(){

-        if($this->inputChannel && $this->eventName){

+    protected function disconnectInputChannel() {

+        if ($this->inputChannel && $this->eventName) {

             $this->inputChannel->disconnect($this->eventName, $this);

         }       

     }

@@ -147,7 +147,7 @@ 
      * @param $eventName 

      * @return 

      */

-    public function setEventName($eventName){

+    public function setEventName($eventName) {

         $this->disconnectInputChannel();

         $this->eventName = $eventName;

         $this->connectInputChannel();

src/Pipe/SimpleEventPipe.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      * @param $outputChannel 

      * @return 

      */

-    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel){

+    public function __construct($eventName, \PEIP\INF\Channel\Channel $inputChannel, \PEIP\INF\Channel\Channel $outputChannel) {

         $this->setEventName($eventName);

         $this->setInputChannel($inputChannel);

         $this->setOutputChannel($outputChannel);        

src/Pipe/FixedEventPipe.php

Spacing +6 added lines, -6 removed lines

@@ -31,10 +31,10 @@ 
      * @param $inputChannel 

      * @return 

      */

-    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel){        

-        if(isset($this->eventName)){

+    public function setInputChannel(\PEIP\INF\Channel\Channel $inputChannel) {        

+        if (isset($this->eventName)) {

             $this->connectChannel($inputChannel);   

-        }else{

+        }else {

             $this->inputChannel = $inputChannel;    

         }               

     }       

@@ -45,10 +45,10 @@ 
      * @param $eventName 

      * @return 

      */

-    public function setEventName($eventName){

-        if(!isset($this->eventName)){

+    public function setEventName($eventName) {

+        if (!isset($this->eventName)) {

             $this->eventName = $eventName;

-            if($this->inputChannel){

+            if ($this->inputChannel) {

                 $this->inputChannel->connect($this->eventName, $this);

             }   

         }

src/Pipe/CommandPipe.php

Spacing +1 added lines, -1 removed lines

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

      * @return 

      */

-    protected function replyMessage($content){

+    protected function replyMessage($content) {

         $message = $this->ensureMessage($content);      

         $this->getOutputChannel()->command($message);       

     }

src/Gateway/SimpleMessagingGateway.php

Spacing +15 added lines, -15 removed lines

@@ -43,9 +43,9 @@ 
      * @param \PEIP\INF\Channel\PollableChannel $replyChannel The default channel to receive requests from the gateway

      * @param array $defaultHeaders The default headers to apply to request messages 

      */

-    public function __construct(\PEIP\INF\Channel\Channel $requestChannel, \PEIP\INF\Channel\Channel $replyChannel = NULL, array $defaultHeaders = array()){

+    public function __construct(\PEIP\INF\Channel\Channel $requestChannel, \PEIP\INF\Channel\Channel $replyChannel = NULL, array $defaultHeaders = array()) {

         $this->setRequestChannel($requestChannel);

-        if($replyChannel){

+        if ($replyChannel) {

             $this->setReplyChannel($replyChannel);

         }     

         $this->defaultHeaders = $defaultHeaders;

@@ -59,7 +59,7 @@ 
      * @param \PEIP\INF\Channel\Channel $replyChannel The default channel to receive requests from the gateway

      * @return 

      */

-    public function setRequestChannel(\PEIP\INF\Channel\Channel $requestChannel){

+    public function setRequestChannel(\PEIP\INF\Channel\Channel $requestChannel) {

         $this->requestChannel = $requestChannel;

     }

   

@@ -70,8 +70,8 @@ 
      * @param \PEIP\INF\Channel\PollableChannel $replyChannel The default channel to receive requests from the gateway

      * @return 

      */

-    public function setReplyChannel(\PEIP\INF\Channel\Channel $replyChannel){

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

+    public function setReplyChannel(\PEIP\INF\Channel\Channel $replyChannel) {

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

             throw new \InvalidArgumentException('reply channel must be instance of \PEIP\INF\Channel\PollableChannel.');

         }       

         $this->replyChannel = $replyChannel;

@@ -84,7 +84,7 @@ 
      * @param mixed $content the content/payload for the message to send 

      * @return 

      */

-    public function send($content){

+    public function send($content) {

         return $this->requestChannel->send($this->buildMessage($content));

     }

    

@@ -94,12 +94,12 @@ 
      * @access public

      * @return mixed content/payload of the received message

      */

-    public function receive(){

-        if(!isset($this->replyChannel)){

+    public function receive() {

+        if (!isset($this->replyChannel)) {

             throw new \LogicException('No replyChannel set.');

         }       

         $message = $this->replyChannel->receive();

-        if($message){

+        if ($message) {

             return $message->getContent();

         }

         return NULL;

@@ -112,12 +112,12 @@ 
      * @param mixed $content the content/payload for the message to send 

      * @return mixed content/payload of the received message

      */

-    public function sendAndReceive($content){

+    public function sendAndReceive($content) {

         $this->send($content);

         try {

             $res = $this->receive();

         }

-        catch(\Exception $e){

+        catch (\Exception $e) {

             return NULL;

         }

         return $res;

@@ -130,7 +130,7 @@ 
      * @param mixed $content the content/payload for the message to send 

      * @return \PEIP\INF\Message\Message the built message

      */

-    protected function buildMessage($content){

+    protected function buildMessage($content) {

         return $this->getMessageBuilder()->setContent($content)->build();   

     }   

       

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

      * @return MessageBuilder message builder instance for the registerd message class

      */

-    protected function getMessageBuilder(){

+    protected function getMessageBuilder() {

         return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())

             ? $this->messageBuilder

             : $this->messageBuilder = MessageBuilder::getInstance($this->messageClass)->setHeaders($this->defaultHeaders);

@@ -153,7 +153,7 @@ 
      * @param   string $messageClass message class to create instances from

      * @return 

      */

-    public function setMessageClass($messageClass){

+    public function setMessageClass($messageClass) {

         $this->messageClass = $messageClass;

     }

     

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

      * @return string message class to create instances from

      */

-    public function getMessageClass(){

+    public function getMessageClass() {

         return $this->messageClass;

     }   

 

src/Util/Reflection.php

Spacing +3 added lines, -3 removed lines

@@ -30,9 +30,9 @@ 
      * @return array array with interface/class info for the class

      */

 

-    public static function getImplementedClassesAndInterfaces($class, $store = true){

+    public static function getImplementedClassesAndInterfaces($class, $store = true) {

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

-        if(isset(self::$classInfo[$class])){

+        if (isset(self::$classInfo[$class])) {

             return self::$classInfo[$class];

         }

         $cls = ReflectionPool::getInstance($class);

@@ -40,7 +40,7 @@ 
         $classInfo = (array)$cls->getInterfaceNames();

         $classInfo[] = $cls->getName();

         // get names of parent-classes

-        while($cls = $cls->getParentClass()){

+        while ($cls = $cls->getParentClass()) {

             $classInfo[] = $cls->getName();

         }

         

src/Util/Test.php

Spacing +28 added lines, -28 removed lines

@@ -15,11 +15,11 @@ 
 class Test {
 
 
-    public static function assertClassHasConstructor($className){
-        return (boolean) ReflectionPool::getInstance($className)->getConstructor();
+    public static function assertClassHasConstructor($className) {
+        return (boolean)ReflectionPool::getInstance($className)->getConstructor();
     }
 
-    public static function assertRequiredConstructorParameters($className, $parameters){
+    public static function assertRequiredConstructorParameters($className, $parameters) {
             return (boolean)
                 !self::assertClassHasConstructor($className) ||
                 count($parameters) >= ReflectionPool::getInstance($className)
@@ -27,55 +27,55 @@ 
                     ->getNumberOfRequiredParameters();
     }
 
-    public static function assertInstanceOf($className, $object){
-        return (boolean) ReflectionPool::getInstance($className)
+    public static function assertInstanceOf($className, $object) {
+        return (boolean)ReflectionPool::getInstance($className)
             ->isInstance($object);
     }
 
-    public static function assertClassOrInterfaceExists($className){
-        return (boolean) class_exists($className) || interface_exists($className);
+    public static function assertClassOrInterfaceExists($className) {
+        return (boolean)class_exists($className) || interface_exists($className);
     }
 
-    public static function assertImplements($className, $interfaceName){
+    public static function assertImplements($className, $interfaceName) {
         $className = is_object($className) ? get_class($className) : $className;
         $res = false;
         try { 
             class_exists($className);
-            $res =  ReflectionPool::getInstance($className)
+            $res = ReflectionPool::getInstance($className)
                 ->implementsInterface($interfaceName);            
-        }  catch (\Exception $e){
+        } catch (\Exception $e) {
             $res = false; 
         }
-        return $res;;
+        return $res; ;
     }
 
-    public static function assertMessage($message){
+    public static function assertMessage($message) {
         return self::assertImplements($message, '\PEIP\INF\Message\Message');
     }
 
-    public static function assertEvent($event){
+    public static function assertEvent($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event');
     }
 
-    public static function assertEventSubject($event){
+    public static function assertEventSubject($event) {
         return self::assertImplements($event, '\PEIP\INF\Event\Event')
             && $event->getSubject();
     }
 
-    public static function assertEventObjectSubject($event){
+    public static function assertEventObjectSubject($event) {
         return self::assertEventSubject($event)
             && is_object($event->getSubject());
     }
-    public static function assertArrayAccess($var){
-        return (boolean) is_array($var) || $var instanceof \ArrayAccess;
+    public static function assertArrayAccess($var) {
+        return (boolean)is_array($var) || $var instanceof \ArrayAccess;
     }
 
-    public static function assertHandler($var){
-        return (boolean) is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
+    public static function assertHandler($var) {
+        return (boolean)is_callable($var) || $var instanceof \PEIP\INF\Handler\Handler;
     }
 
-    public static function castType($var, $type){
-        switch($type){
+    public static function castType($var, $type) {
+        switch ($type) {
             case 'string':
                 $var = (string)$var;
                 break;
@@ -99,8 +99,8 @@ 
         return $var;
     }
 
-    public static function ensureArrayAccess($var){
-        if(!Test::assertArrayAccess($var)){
+    public static function ensureArrayAccess($var) {
+        if (!Test::assertArrayAccess($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an array nor an instance of ArrayAccess'
             );
@@ -109,8 +109,8 @@ 
     }
 
 
-    public static function ensureHandler($var){
-        if(!Test::assertHandler($var)){
+    public static function ensureHandler($var) {
+        if (!Test::assertHandler($var)) {
             throw new \InvalidArgumentException(
                 'Value is not an callable nor an instance of \PEIP\INF\Handler\Handler'
             );
@@ -118,8 +118,8 @@ 
         return $var;
     }
 
-    public static function ensureImplements($className, $interfaceName){
-        if(!Test::assertImplements($className, $interfaceName)){
+    public static function ensureImplements($className, $interfaceName) {
+        if (!Test::assertImplements($className, $interfaceName)) {
             throw new \InvalidArgumentException(
                 'Class "'.$className.'" is not an instanceof "'.$interfaceName.'"'
             );
@@ -127,7 +127,7 @@ 
         return $className;
     }
 
-    public static function assertMethod($className, $methodname){
+    public static function assertMethod($className, $methodname) {
         return ReflectionPool::getInstance($className)->hasMethod($methodname);
     }
 

src/Util/ReflectionPool.php

Spacing +2 added lines, -2 removed lines

@@ -22,11 +22,11 @@
      * @param $argument

      * @return ReflectionClass

      */

-    public  static function getInstance($argument){

+    public  static function getInstance($argument) {

 

         $className = is_object($argument)

             ? get_class($argument)

-            : (string) $argument;

+            : (string)$argument;

         return isset(self::$instances[$className])

             ? self::$instances[$className]

             : self::$instances[$className] = new \ReflectionClass($className);