tidal / PEIP

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

src/ABS/Command/Command.php

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
      * @access public
      * @return 
      */
-    public function __invoke(){
+    public function __invoke() {
         return $this->execute();
     }
    
@@ -51,7 +51,7 @@ 
      * @access public
      * @return 
      */
-    public function execute(){
+    public function execute() {
         return call_user_func_array($this->callable, $this->getParameters());
     }   
         

src/ABS/Service/ServiceActivator.php

Spacing +6 added lines, -6 removed lines

@@ -38,12 +38,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to handle/reply for
      * @return 
      */
-    public function doReply(\PEIP\INF\Message\Message $message){
+    public function doReply(\PEIP\INF\Message\Message $message) {
         $res = $this->callService($message);
         $out = (bool)$message->hasHeader('REPLY_CHANNEL') 
             ? $message->getHeader('REPLY_CHANNEL') 
             : $this->outputChannel;    
-        if($out){
+        if ($out) {
             $this->replyMessage($res, $res);    
         }
     }  
@@ -56,12 +56,12 @@ 
      * @param \PEIP\INF\Message\Message $message message to call the service with it�s content/payload
      * @return mixed result of calling the registered service callable with message content/payload
      */
-    protected function callService(\PEIP\INF\Message\Message $message){
+    protected function callService(\PEIP\INF\Message\Message $message) {
         $res = NULL;
-        if(is_callable($this->serviceCallable)){
+        if (is_callable($this->serviceCallable)) {
             $res = call_user_func($this->serviceCallable, $message->getContent());
-        }else{
-            if(is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')){
+        }else {
+            if (is_object($this->serviceCallable) && method_exists($this->serviceCallable, 'handle')) {
                 $res = $this->serviceCallable->handle($message->getContent());
             }
         }    

src/ABS/Handler/ReplyProducingMessageHandler.php

Spacing +17 added lines, -17 removed lines

@@ -42,7 +42,7 @@ 
      * @param \PEIP\INF\Channel\Channel $outputChannel the output-channel
      * @return \PEIP\ABS\Handler\MessageHandler $this;
      */
-    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
+    public function setOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {
         $this->doSetOutputChannel($outputChannel);
         return $this;
     }   
@@ -54,7 +54,7 @@ 
      * @param \PEIP\INF\Channel\Channel $inputChannel the output-channel to connect the handler to
      * @return 
      */
-    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel){
+    protected function doSetOutputChannel(\PEIP\INF\Channel\Channel $outputChannel) {
         $this->outputChannel = $outputChannel;
     }
        
@@ -64,7 +64,7 @@ 
      * @access public
      * @return \PEIP\INF\Channel\Channel output-channel for this handler
      */
-    public function getOutputChannel(){
+    public function getOutputChannel() {
         return $this->outputChannel;
     }
 
@@ -78,7 +78,7 @@ 
      * @param \PEIP\INF\Message\Message $message the message to resolve output-channel for
      * @return \PEIP\INF\Channel\Channel the output-channel for the message
      */    
-    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message){
+    protected function doGetOutputChannel(\PEIP\INF\Message\Message $message) {
         $replyChannel = $this->resolveReplyChannel($message);
         return $replyChannel ? $replyChannel : $this->getOutputChannel();       
     }
@@ -92,9 +92,9 @@ 
      * @param \PEIP\INF\Message\Message $message 
      * @return \PEIP\INF\Channel\Channel the reply-channel if found
      */     
-    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message){
-        foreach($this->replyChannelHeaders as $header){
-            if($message->hasHeader($header)){
+    protected function resolveReplyChannel(\PEIP\INF\Message\Message $message) {
+        foreach ($this->replyChannelHeaders as $header) {
+            if ($message->hasHeader($header)) {
                 return $message->getHeader($header);
             }
         }
@@ -111,7 +111,7 @@ 
      * @access protected
      * @param mixed $content \PEIP\INF\Message\Message or content/payload for new message 
      */
-    protected function replyMessage($content){
+    protected function replyMessage($content) {
         $message = $this->ensureMessage($content);      
         $this->doGetOutputChannel($message)->send($message);      
     }
@@ -125,7 +125,7 @@ 
      * @param mixed $message \PEIP\INF\Message\Message or content/payload for new message
      * @return \PEIP\INF\Message\Message
      */
-    protected function ensureMessage($message){
+    protected function ensureMessage($message) {
         return ($message instanceof \PEIP\INF\Message\Message) ? $message : $this->buildMessage($message);   
     }
        
@@ -138,7 +138,7 @@ 
      * @return \PEIP\INF\Message\Message
      * @see MessageBuilder
      */
-    protected function buildMessage($content){
+    protected function buildMessage($content) {
         return $this->getMessageBuilder()->setContent($content)->build();   
     }   
        
@@ -149,7 +149,7 @@ 
      * @access protected
      * @return MessageBuilder builder for the registered 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);
@@ -162,7 +162,7 @@ 
      * @param string $messageClass name of the message-class to create reply-messages from. 
      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
      */
-    public function setMessageClass($messageClass){
+    public function setMessageClass($messageClass) {
         $this->messageClass = $messageClass;
         return $this;
     }
@@ -173,7 +173,7 @@ 
      * @access public
      * @return string name of the message-class to create reply-messages from. 
      */
-    public function getMessageClass(){
+    public function getMessageClass() {
         return $this->messageClass;
     }       
 
@@ -184,7 +184,7 @@ 
      * @param string $headerName name of a message-header to look for a reply-channel
      * @return void
      */
-    public function addReplyChannelHeader($headerName){
+    public function addReplyChannelHeader($headerName) {
         $this->replyChannelHeaders[] = $headerName;
     }
     
@@ -195,7 +195,7 @@ 
      * @param array $headerNames array of message-header names to look for a reply-channel
      * @return PEIP\ABS\Handler\ReplyProducingMessageHandler $this
      */
-    public function setReplyChannelHeaders(array $headerNames){
+    public function setReplyChannelHeaders(array $headerNames) {
         $this->replyChannelHeaders = $headerNames;
         return $this;
     } 
@@ -206,7 +206,7 @@ 
      * @access public
      * @return array array of message-header names to look for a reply-channel
      */
-    public function getReplyChannelHeaders(){
+    public function getReplyChannelHeaders() {
         return $this->replyChannelHeaders;
     }
          
@@ -220,7 +220,7 @@ 
      * @param \PEIP\INF\Message\Message $message 
      * @return 
      */
-    protected function doHandle(\PEIP\INF\Message\Message $message){
+    protected function doHandle(\PEIP\INF\Message\Message $message) {
         return $this->doReply($message);
     }