tidal / PEIP

src/Channel/MessageChannel.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
      * @access public
      * @return 
      */
-    public function getName(){
+    public function getName() {
     
     }
 
@@ -40,7 +40,7 @@ 
      * @param $timeout 
      * @return 
      */
-    public function send(\PEIP\INF\Message\Message $message, $timeout = -1){
+    public function send(\PEIP\INF\Message\Message $message, $timeout = -1) {
         
     }
 

src/Pipe/Pipe.php

Spacing +17 added lines, -17 removed lines

@@ -60,7 +60,7 @@ 
      * @param $name 
      * @return 
      */
-    public function setName($name){
+    public function setName($name) {
         $this->name = $name;
     }
     
@@ -69,7 +69,7 @@ 
      * @access public
      * @return 
      */
-    public function getName(){
+    public function getName() {
         return $this->name;
     }
 
@@ -80,7 +80,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);
     }
 
@@ -90,7 +90,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));
@@ -103,12 +103,12 @@ 
      * @param $content 
      * @return 
      */
-    protected function replyMessage($message){ 
+    protected function replyMessage($message) { 
         $message = $this->ensureMessage($message);
         //if(\PEIP\Util\Test::assertMessage($message)){
-            if($this->getOutputChannel()){ 
+            if ($this->getOutputChannel()) { 
                 $this->getOutputChannel()->send($message);
-            }else{ 
+            }else { 
                 $this->doSend($message);
             }
         //}
@@ -120,7 +120,7 @@ 
      * @param $message 
      * @return 
      */
-    protected function doReply(\PEIP\INF\Message\Message $message){
+    protected function doReply(\PEIP\INF\Message\Message $message) {
         $this->replyMessage($message);
     }
 
@@ -130,7 +130,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));
@@ -142,7 +142,7 @@ 
      * @param $handler e
      * @return 
      */
-    public function unsubscribe($handler){
+    public function unsubscribe($handler) {
         Test::ensureHandler($handler);
         $this->getMessageDispatcher()->disconnect($handler);
         $this->doFireEvent(
@@ -160,9 +160,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);       
             }   
@@ -176,7 +176,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;
     }   
@@ -188,7 +188,7 @@ 
      * @param $callable 
      * @return 
      */
-    protected function registerCommand($commandName, $callable){
+    protected function registerCommand($commandName, $callable) {
         $this->commands[$commandName] = $callable;  
     }
     
@@ -198,10 +198,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/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/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/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/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/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/Base/VisitableArray.php

Spacing +4 added lines, -4 removed lines

@@ -24,7 +24,7 @@ 
 
 class VisitableArray 
     extends \RecursiveArrayIterator 
-    implements \PEIP\INF\Base\Visitable{
+    implements \PEIP\INF\Base\Visitable {
 
 
     
@@ -33,9 +33,9 @@ 
      * @param $visitor 
      * @return 
      */
-    public function acceptVisitor(\PEIP\INF\Base\Visitor $visitor){
-        if($this->hasChildren()){
-            foreach($this->getChildren as $child){
+    public function acceptVisitor(\PEIP\INF\Base\Visitor $visitor) {
+        if ($this->hasChildren()) {
+            foreach ($this->getChildren as $child) {
                 $child->acceptVisitor($visitor);
             }
         }

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