tidal / PEIP

src/ABS/Pipe/EventPipe.php

Spacing +5 added lines, -5 removed lines

@@ -38,8 +38,8 @@ 
      * @param string $eventName name of the event to listen to 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to listen to 
      */
-    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doListen($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->connect($eventName, $this);
             $this->connections[spl_object_hash($connectable)] = $connectable;   
         }   
@@ -52,8 +52,8 @@ 
      * @param string $eventName name of the event to unlisten 
      * @param \PEIP\INF\Event\Connectable $connectable instance of \PEIP\INF\Event\Connectable to unlisten to 
      */
-    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable){
-        if(!$connectable->hasListener($eventName, $this)){
+    protected function doUnlisten($eventName, \PEIP\INF\Event\Connectable $connectable) {
+        if (!$connectable->hasListener($eventName, $this)) {
             $connectable->disconnect($eventName, $this);
             unset($this->connections[spl_object_hash($connectable)]);   
         }   
@@ -65,7 +65,7 @@ 
      * @access public
      * @return array array of \PEIP\INF\Event\Connectable instances
      */
-    public function doGetConnected(){
+    public function doGetConnected() {
         return array_values($this->connections);
     }
     

src/ABS/Base/Connectable.php

Spacing +15 added lines, -15 removed lines

@@ -17,7 +17,7 @@ 
  * @subpackage base 
  */
 
-abstract class Connectable  implements \PEIP\INF\Event\Connectable{
+abstract class Connectable  implements \PEIP\INF\Event\Connectable {
 
     const
         DEFAULT_CLASS_MESSAGE_DISPATCHER = '\PEIP\Dispatcher\Dispatcher',
@@ -42,7 +42,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function connect($name, $listener){
+    public function connect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->connect($name, $this, $listener);
         $this->doFireEvent(
@@ -61,7 +61,7 @@ 
      * @param Callable|PEIP\INF\Handler\Handler $listener
      * @return
      */
-    public function disconnect($name, $listener){
+    public function disconnect($name, $listener) {
         \PEIP\Util\Test::ensureHandler($listener);
         $this->getEventDispatcher()->disconnect($name, $this, $listener);
         $this->doFireEvent(
@@ -82,7 +82,7 @@ 
      * @param $name
      * @return
      */
-    public function hasListeners($name){
+    public function hasListeners($name) {
         return $this->getEventDispatcher()->hasListeners($name, $this);
     }
 
@@ -92,7 +92,7 @@ 
      * @param $name
      * @return
      */
-    public function getListeners($name){
+    public function getListeners($name) {
         return $this->getEventDispatcher()->getListeners($name, $this);
     }
 
@@ -102,7 +102,7 @@ 
      * @param $callable
      * @return
      */
-    public function disconnectAll($name){
+    public function disconnectAll($name) {
         $this->getEventDispatcher()->disconnectAll($name, $this);
     }
 
@@ -112,11 +112,11 @@ 
      * @param $transferListners
      * @return
      */
-    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true){
-        if($transferListners){
-            foreach($this->getEventDispatcher()->getEventNames($this) as $name){
-                if($this->getEventDispatcher()->hasListeners($name, $this)){
-                    foreach($this->getEventDispatcher()->getListeners($name, $this) as $listener){
+    public function setEventDispatcher(\PEIP\Dispatcher\ObjectEventDispatcher $dispatcher, $transferListners = true) {
+        if ($transferListners) {
+            foreach ($this->getEventDispatcher()->getEventNames($this) as $name) {
+                if ($this->getEventDispatcher()->hasListeners($name, $this)) {
+                    foreach ($this->getEventDispatcher()->getListeners($name, $this) as $listener) {
                         $dispatcher->connect($name, $this, $listener);
                     }
                 }
@@ -131,11 +131,11 @@ 
      * @access public
      * @return
      */
-    public function getEventDispatcher(){
+    public function getEventDispatcher() {
         return $this->eventDispatcher ? $this->eventDispatcher : $this->eventDispatcher = self::getSharedEventDispatcher();
     }
 
-    protected static function getSharedEventDispatcher(){
+    protected static function getSharedEventDispatcher() {
         $defaultDispatcher = self::DEFAULT_CLASS_EVENT_DISPATCHER;
         return self::$sharedEventDispatcher ? self::$sharedEventDispatcher : self::$sharedEventDispatcher = new $defaultDispatcher;
     }
@@ -148,12 +148,12 @@ 
      * @param $eventClass
      * @return
      */
-    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false){
+    protected function doFireEvent($name, array $headers = array(), $eventClass = '', $type = false) {
         $eventClass = trim($eventClass) == '' ? static::DEFAULT_EVENT_CLASS : $eventClass;
         return $this->getEventDispatcher()->buildAndNotify($name, $this, $headers, $eventClass, $type);
     }
 
-    protected static function getDefaultEventClass(){
+    protected static function getDefaultEventClass() {
         return self::DEFAULT_EVENT_CLASS;
     }
 }

src/ABS/Base/MutableContainer.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
      * @access public
      * @return mixed content
      */
-    public function getContent(){
+    public function getContent() {
         return parent::getContent();
     } 
 }
\ No newline at end of file

src/ABS/Base/Container.php

Spacing +2 added lines, -2 removed lines

@@ -22,7 +22,7 @@ 
 
 
 abstract class Container 
-    implements \PEIP\INF\Base\Container{
+    implements \PEIP\INF\Base\Container {
 
     protected $content;
        
@@ -33,7 +33,7 @@ 
      * @access public
      * @return 
      */
-    public function getContent(){
+    public function getContent() {
         return $this->content;
     }
     

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

Spacing +4 added lines, -4 removed lines

@@ -37,9 +37,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);    
         }   
     }           
@@ -51,7 +51,7 @@ 
      * @param \PEIP\INF\Message\Message $message message to transform content 
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){     
+    public function doReply(\PEIP\INF\Message\Message $message) {     
         $this->replyMessage($this->transform($message));
     }
   
@@ -62,7 +62,7 @@ 
      * @param \PEIP\INF\Message\Message $message 
      * @return mixed result of transforming the message 
      */
-    public function transform(\PEIP\INF\Message\Message $message){
+    public function transform(\PEIP\INF\Message\Message $message) {
         return $this->doTransform($message);
     }
 

src/ABS/Transformer/ContentTransformer.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
      * @param \PEIP\INF\Message\Message $message 
      * @return mixed result of transforming the message payload/content 
      */
-    protected function doTransform(\PEIP\INF\Message\Message $message){
+    protected function doTransform(\PEIP\INF\Message\Message $message) {
         return $this->transformContent($message->getContent());    
     }