tidal / PEIP

src/Base/ReflectionClassBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -32,7 +32,7 @@ 
      * @param string $className name of the class to return ReflectionClass for 

      * @return ReflectionClass the ReflectionClass instance for given class

      */    

-    protected static function getReflectionClass($className){

+    protected static function getReflectionClass($className) {

         return array_key_exists($className, self::$reflectionClasses) 

             ? self::$reflectionClasses[$className] 

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

@@ -47,7 +47,7 @@ 
      * @param string $className name of the class to return ReflectionClass for 

      * @return ReflectionClass the ReflectionClass instance for given class

      */     

-    public static function getInstance($className){

+    public static function getInstance($className) {

         return self::getReflectionClass($className);

     }

 

src/Base/FlyAdapter.php

Spacing +4 added lines, -4 removed lines

@@ -30,7 +30,7 @@ 
      * @param $methodMap 

      * @return 

      */

-    public function __construct(ArrayAccess $methodMap){        

+    public function __construct(ArrayAccess $methodMap) {        

         $this->methodMap = $methodMap;  

     }

     

@@ -40,7 +40,7 @@ 
      * @param $subject 

      * @return 

      */

-    public function setSubject($subject){

+    public function setSubject($subject) {

         $this->subject = $subject;

         return $this;

     }

@@ -52,8 +52,8 @@ 
      * @param $arguments 

      * @return 

      */

-    public function __call($method, $arguments){

-        if(array_key_exists($method, $this->methodMap)){

+    public function __call($method, $arguments) {

+        if (array_key_exists($method, $this->methodMap)) {

             return call_user_func_array(array($this->subject, $this->methodMap[$method]), $arguments);

         }

     }

src/Base/Sealer.php

Spacing +3 added lines, -3 removed lines

@@ -38,7 +38,7 @@ 
      * @param ObjectStorage $store an instane of ObjectStorage to act as the internal object-store

      * @return 

      */

-    public function __construct(\SplObjectStorage $store = NULL){

+    public function __construct(\SplObjectStorage $store = NULL) {

         $this->store = (bool)$store ? $store : new ObjectStorage;    

     }   

       

@@ -53,7 +53,7 @@ 
      * @param object $box an object to act as the 'box'  

      * @return object the 'box' for the sealed value

      */

-    public function seal($value, $box = false){

+    public function seal($value, $box = false) {

         $box = (bool)$box ? $box : new \stdClass;

         $this->store[$box] = $value;        

         return $box;

@@ -66,7 +66,7 @@ 
      * @param object $box the box-object to return the value for. 

      * @return 

      */

-    public function unseal($box){

+    public function unseal($box) {

         return $this->store[$box];

     }

 }

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

         }